Fix HLS crash

Author: Arrowar

StreamingCommunity/Lib/DASH/segments.py

@@ -480,7 +480,7 @@ def _display_error_summary(self) -> None:
         total_segments = len(self.selected_representation.get('segment_urls', []))
         failed_indices = [i for i in range(total_segments) if i not in self.downloaded_segments]
 
-        console.print(f" [cyan]Max retries: [red]{getattr(self, 'info_maxRetry', 0)} [white]| "
+        console.log(f"[cyan]Max retries: [red]{getattr(self, 'info_maxRetry', 0)} [white]| "
             f"[cyan]Total retries: [red]{getattr(self, 'info_nRetry', 0)} [white]| "
             f"[cyan]Failed segments: [red]{getattr(self, 'info_nFailed', 0)} [white]| "
             f"[cyan]Failed indices: [red]{failed_indices}")

StreamingCommunity/Lib/FFmpeg/util.py

@@ -166,6 +166,7 @@ def is_png_format_or_codec(file_info):
     format_name = file_info.get('format_name')
     codec_names = file_info.get('codec_names', [])
 
+    console.log(f"[cyan]FFMPEG detect format: [green]{format_name}[cyan], codec: [green]{codec_names}")
     return format_name == 'png_pipe' or 'png' in codec_names
 
 

StreamingCommunity/Lib/HLS/segments.py

@@ -165,7 +165,8 @@ def get_type_stream(self, segments) -> str:
         elif self.is_stream_aac:
             return "aac"
         else:
-            return None
+            console.log("[yellow]Warning: Unable to determine stream type.")
+            return "ts"  # Default to ts
 
     def get_info(self) -> None:
         """
@@ -275,7 +276,7 @@ async def _download_single_segment(self, client: httpx.AsyncClient, ts_url: str,
 
                 except Exception:
                     if attempt + 1 == max_retry:
-                        console.print(f" -- [red]Final retry failed for segment: {index}")
+                        console.print(f" -- [red]Failed request for segment: {index}")
                         return index, False, max_retry, 0
 
                     sleep_time = 0.5 + attempt * 0.5 if attempt < 2 else min(3.0, 1.02 ** attempt)
@@ -437,9 +438,6 @@ async def download_segments_async(self, description: str, type: str):
             finally:
                 self._cleanup_resources(temp_dir, progress_bar)
 
-            if not self.download_interrupted:
-                self._verify_download_completion()
-
             return self._generate_results(type)
 
         else:
@@ -524,13 +522,6 @@ def _generate_results(self, stream_type: str, output_path: str = None) -> Dict:
             'output_path': output_path if output_path else self.final_output_path
         }
 
-    def _verify_download_completion(self) -> None:
-        """Validate final download integrity."""
-        total = len(self.segments)
-        if len(self.downloaded_segments) / total < 0.999:
-            missing = sorted(set(range(total)) - self.downloaded_segments)
-            raise RuntimeError(f"Download incomplete ({len(self.downloaded_segments)/total:.1%}). Missing segments: {missing}")
-        
     def _cleanup_resources(self, temp_dir: str, progress_bar: tqdm) -> None:
         """Ensure resource cleanup and final reporting."""
         progress_bar.close()
@@ -550,7 +541,7 @@ def _cleanup_resources(self, temp_dir: str, progress_bar: tqdm) -> None:
 
     def _display_error_summary(self) -> None:
         """Generate final error report."""
-        console.print(f" [cyan]Max retries: [red]{self.info_maxRetry} [white] | "
+        console.log(f"[cyan]Max retries: [red]{self.info_maxRetry} [white] | "
             f"[cyan]Total retries: [red]{self.info_nRetry} [white] | "
             f"[cyan]Failed segments: [red]{self.info_nFailed}")