feat: supports continuous monitoring when live broadcast ends

.eslintrc.cjs

@@ -8,6 +8,7 @@ module.exports = {
   ],
   rules: {
     '@typescript-eslint/explicit-function-return-type': 'off',
-    'typescript-eslint/no-explicit-any': 'off'
+    'typescript-eslint/no-explicit-any': 'off',
+    '@typescript-eslint/no-explicit-any': 'off',
   }
 }

package.json

@@ -44,6 +44,7 @@
     "i18next": "^23.11.5",
     "localforage": "^1.10.0",
     "lucide-react": "^0.383.0",
+    "mitt": "^3.0.1",
     "react-hook-form": "^7.51.5",
     "react-i18next": "^14.1.2",
     "react-use": "^17.5.0",

src/const.ts

@@ -18,3 +18,6 @@ export const USER_CLOSE_WINDOW = 'USER_CLOSE_WINDOW'
 export const FORCE_CLOSE_WINDOW = 'FORCE_CLOSE_WINDOW'
 
 export const RECORD_DUMMY_PROCESS = { kill: () => {} }
+
+
+export const RECORD_END_NOT_USER_STOP = 'RECORD_END_NOT_USER_STOP'

src/renderer/src/components/StreamConfigList/StreamConfigList.tsx

@@ -6,6 +6,8 @@ import Dialog from '@/components/Dialog'
 import StreamConfigCard from './components/StreamConfigCard'
 
 import { SUCCESS_CODE, FFMPEG_ERROR_CODE, errorCodeToI18nMessage } from '../../../../code'
+import emitter from '@/lib/bus'
+import { RECORD_END_NOT_USER_STOP } from '../../../../const'
 
 import { useStreamConfigStore } from '@/store/useStreamConfigStore'
 import { useFfmpegProgressInfoStore } from '@/store/useFfmpegProgressInfoStore'
@@ -52,6 +54,7 @@ export default function StreamConfigList() {
       // FFMPEG_ERROR_CODE.USER_KILL_PROCESS stop by user
       const isStopByUser = code === FFMPEG_ERROR_CODE.USER_KILL_PROCESS
       const isStopByStreamEnd = code === SUCCESS_CODE
+      let stopWithLineError = false
 
       if (streamConfig.status === StreamStatus.RECORDING) {
         await updateStreamConfig(
@@ -81,6 +84,7 @@ export default function StreamConfigList() {
           // if not stop by user and still can get live urls
           // mean the stream can no be record, hint change the stream line
           message = 'error.stop_record.current_line_error'
+          stopWithLineError = true
         } else {
           // mean the stream is not live
           // start monitor the stream
@@ -101,6 +105,12 @@ export default function StreamConfigList() {
         { ...streamConfig, status: StreamStatus.NOT_STARTED },
         streamConfig.title
       )
+
+      if (isStopByUser || stopWithLineError) {
+        return
+      }
+
+      emitter.emit(RECORD_END_NOT_USER_STOP, streamConfig.title)
     })
 
     window.api.onUserCloseWindow(() => {

src/renderer/src/components/StreamConfigList/components/OperationBar.tsx

@@ -1,4 +1,4 @@
-import { useRef, useState } from 'react'
+import { useEffect, useRef, useState } from 'react'
 import { useTranslation } from 'react-i18next'
 
 import UseThemeIcon from '@/components/UseThemeIcon'
@@ -20,6 +20,8 @@ import StreamConfigSheet from '@renderer/components/StreamConfigSheet'
 
 import { useToast } from '@renderer/hooks/useToast'
 import { CRAWLER_ERROR_CODE, SUCCESS_CODE, errorCodeToI18nMessage } from '../../../../../code'
+import { RECORD_END_NOT_USER_STOP } from '../../../../../const'
+import emitter from '@/lib/bus'
 
 interface OperationBarProps {
   streamConfig: IStreamConfig
@@ -91,7 +93,7 @@ export default function OperationBar(props: OperationBarProps) {
     )
     toast({
       title: streamConfig.title,
-      description: errMessage,
+      description: t(errMessage),
       variant: 'destructive'
     })
   }
@@ -105,6 +107,22 @@ export default function OperationBar(props: OperationBarProps) {
     clearTimeout(timer.current)
   }
 
+  useEffect(() => {
+    const handleRecordEndNotUserStop = async (title: string) => {
+      if (title !== streamConfig.title) return
+      if (timer.current) {
+        clearTimeout(timer.current)
+      }
+      timer.current = setTimeout(() => {
+        handlePlayClick()
+      }, 2000)
+    }
+    emitter.on(RECORD_END_NOT_USER_STOP, handleRecordEndNotUserStop as any)
+    return () => {
+      emitter.off(RECORD_END_NOT_USER_STOP, handleRecordEndNotUserStop as any)
+    }
+  }, [streamConfig, timer])
+
   return (
     <>
       <div className="flex absolute right-0 gap-2">

src/renderer/src/lib/bus.ts

@@ -0,0 +1,5 @@
+import mitt from 'mitt'
+
+const emitter = mitt()
+
+export default emitter

src/renderer/src/locales/locales.js

@@ -82,7 +82,10 @@ export default {
           forbidden: 'Request was denied, try using or changing the proxy',
           invalid_proxy: 'Proxy address is invalid, please check the proxy address',
           not_support: 'This streaming platform is not supported',
-          invalid_url: 'Stream URL is invalid'
+          invalid_url: 'Stream URL is invalid',
+          cookie_expired: 'Cookie has expired, please re-enter the cookie',
+          cookie_is_required:
+            'Current streaming platform requires a cookie, please enter the cookie'
         },
         stop_record: {
           current_line_error: 'Stop recording (current line error, try using another line)',
@@ -174,7 +177,9 @@ export default {
           forbidden: '请求被拒绝，尝试使用或者更换代理',
           invalid_proxy: '代理地址不合法， 请检查代理地址',
           not_support: '当前不支持该直播平台',
-          invalid_url: '直播间地址不合法'
+          invalid_url: '直播间地址不合法',
+          cookie_expired: 'Cookie已过期，请重新填写',
+          cookie_is_required: '当前直播平台需要Cookie，请填写Cookie'
         },
         stop_record: {
           current_line_error: '停止录制(当前线路错误，尝试使用其他线路)',

tsconfig.web.json

@@ -6,7 +6,8 @@
     "src/renderer/src/**/*.tsx",
     "src/preload/*.d.ts",
     "./type.d.ts",
-    "./src/code.ts"
+    "./src/code.ts",
+    "./src/const.ts"
   ],
   "compilerOptions": {
     "composite": true,