Skip to content

Commit cb0fc80

Browse files
committed
fix: remove live status recheck
1 parent fb3971b commit cb0fc80

File tree

1 file changed

+6
-11
lines changed

1 file changed

+6
-11
lines changed

app/core/recording/stream_manager.py

Lines changed: 6 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -149,8 +149,8 @@ def is_flv_preferred_platform(self):
149149

150150
def _select_source_url(self, stream_info: StreamData):
151151
if (
152-
self.user_config.get("default_live_source") != "HLS"
153-
and self.is_flv_preferred_platform
152+
self.user_config.get("default_live_source") != "HLS"
153+
and self.is_flv_preferred_platform
154154
):
155155
codec = utils.get_query_params(stream_info.flv_url, "codec")
156156
if codec and codec[0] == 'h265':
@@ -369,12 +369,10 @@ async def start_ffmpeg(
369369
self.recording.update({"display_title": display_title})
370370
self.app.page.run_task(self.app.record_card_manager.update_card, self.recording)
371371
self.app.page.pubsub.send_others_on_topic("update", self.recording)
372-
if self.app.recording_enabled and process in self.app.process_manager.ffmpeg_processes:
373-
await asyncio.sleep(15)
374-
self.app.page.run_task(self.app.record_manager.check_if_live, self.recording)
375-
else:
372+
if not self.app.recording_enabled:
376373
self.recording.status_info = RecordingStatus.NOT_RECORDING_SPACE
377374
self.app.page.run_task(self.stop_recording_notify)
375+
378376
except Exception as e:
379377
logger.debug(f"Failed to update UI: {e}")
380378

@@ -660,12 +658,10 @@ async def start_direct_download(
660658
self.recording.update({"display_title": display_title})
661659
await self.app.record_card_manager.update_card(self.recording)
662660
self.app.page.pubsub.send_others_on_topic("update", self.recording)
663-
if self.app.recording_enabled:
664-
await asyncio.sleep(15)
665-
self.app.page.run_task(self.app.record_manager.check_if_live, self.recording)
666-
else:
661+
if not self.app.recording_enabled:
667662
self.recording.status_info = RecordingStatus.NOT_RECORDING_SPACE
668663
self.app.page.run_task(self.stop_recording_notify)
664+
669665
except Exception as e:
670666
logger.debug(f"Failed to update UI: {e}")
671667

@@ -741,4 +737,3 @@ async def end_message_push(self):
741737
msg_title = msg_title or self._["status_notify"]
742738

743739
self.app.page.run_task(msg_manager.push_messages, msg_title, push_content)
744-

0 commit comments

Comments
 (0)