fixup! core: services: recoder_extractor: Add first version

Author: patrickelectric

core/services/recorder_extractor/main.py

@@ -72,7 +72,6 @@ def resolve_recording(filename: str) -> Path:
 def parse_duration_ns(discover_output: str) -> int:
     duration_ns = 0
     for line in discover_output.splitlines():
-        line = line.decode("utf-8", "ignore")
         # Example: Duration: 0:00:12.345678000
         if "Duration:" not in line:
             continue
@@ -107,6 +106,8 @@ async def build_thumbnail_bytes(path: Path) -> bytes:
         text=False,
     )
     stdout, stderr = await discover_proc.communicate()
+    stdout = stdout.decode("utf-8", "ignore")
+    stderr = stderr.decode("utf-8", "ignore")
     if discover_proc.returncode != 0:
         logger.error(f"gst-discoverer-1.0 failed for {path}: {stderr.strip()}")
         raise HTTPException(
@@ -145,16 +146,17 @@ async def build_thumbnail_bytes(path: Path) -> bytes:
         stderr=asyncio.subprocess.PIPE,
         text=False,
     )
-    out_bytes, err_bytes = await play_proc.communicate()
-    if play_proc.returncode != 0 or not out_bytes:
-        stderr = err_bytes.decode("utf-8", "ignore")
+    stdout, stderr = await play_proc.communicate()
+    stdout = stdout.decode("utf-8", "ignore")
+    stderr = stderr.decode("utf-8", "ignore")
+    if play_proc.returncode != 0 or not stdout:
         logger.error(f"gst-play-1.0 failed for {path} (code={play_proc.returncode}): {stderr}")
         raise HTTPException(
             status_code=status.HTTP_500_INTERNAL_SERVER_ERROR,
             detail="Failed to generate thumbnail.",
         )
 
-    return out_bytes
+    return stdout
 
 
 async def extract_mcap_recordings() -> None:
@@ -190,12 +192,14 @@ async def extract_mcap_recordings() -> None:
                         text=False,
                     )
                     stdout, stderr = await process.communicate()
+                    stdout = stdout.decode("utf-8", "ignore")
+                    stderr = stderr.decode("utf-8", "ignore")
                 if process.returncode != 0:
                     logger.error(
-                        f"MCAP extract failed for {mcap_path} (code={process.returncode}): {stderr.decode('utf-8', 'ignore')}",
+                        f"MCAP extract failed for {mcap_path} (code={process.returncode}): {stderr}",
                     )
                 else:
-                    logger.info(f"MCAP extract completed for {mcap_path}: {stdout.decode('utf-8', 'ignore').strip()}")
+                    logger.info(f"MCAP extract completed for {mcap_path}: {stdout.strip()}")
         except Exception as exception:
             logger.exception(f"MCAP extraction loop failed: {exception}")