Detect and track existing Plex scans from activities

- Updated api_pending_scans to check Plex activities for running scans
- Automatically adds scans that aren't already tracked in PENDING_SCANS
- Uses activity subtitle (item name) for better display names
- Now shows scans that were started outside the web UI
- Matches activities to library sections by librarySectionID

Author: devinvee

media_watcher_service.py

@@ -69,7 +69,7 @@ def check_scan_status(scan_id: str) -> str:
     # Get current activities from Plex
     from plex_utils import get_plex_activities, is_plex_scanning
     activities = get_plex_activities()
-    
+
     # Check if there are any scanning activities
     has_scanning_activity = len(activities) > 0
 
@@ -84,20 +84,23 @@ def check_scan_status(scan_id: str) -> str:
                 # Activities might have librarySectionID in context
                 context = activity.get('context', {})
                 if isinstance(context, dict):
-                    act_section_id = context.get('librarySectionID') or context.get('sectionID')
+                    act_section_id = context.get(
+                        'librarySectionID') or context.get('sectionID')
                     if act_section_id and str(act_section_id) == str(section_id):
                         section_scanning = True
-                        logger.info(f"Found scanning activity for section {section_id}")
+                        logger.info(
+                            f"Found scanning activity for section {section_id}")
                         break
-            
+
             # Also check using the section's refreshing attribute
             if not section_scanning:
                 section_scanning = is_plex_scanning(section_id)
-            
+
             if not section_scanning:
                 # No scanning activity found, check timeout
                 scan_timestamp = datetime.fromisoformat(scan_info["timestamp"])
-                time_since_scan = (datetime.now() - scan_timestamp).total_seconds()
+                time_since_scan = (
+                    datetime.now() - scan_timestamp).total_seconds()
                 # If no activity and it's been more than 2 minutes, assume completed
                 if time_since_scan > 120:
                     scan_info["status"] = "completed"
@@ -133,8 +136,10 @@ def check_scan_status(scan_id: str) -> str:
                 section_id = int(library_key)
                 is_scanning = is_plex_scanning(section_id)
                 if not is_scanning:
-                    scan_timestamp = datetime.fromisoformat(scan_info["timestamp"])
-                    time_since_scan = (datetime.now() - scan_timestamp).total_seconds()
+                    scan_timestamp = datetime.fromisoformat(
+                        scan_info["timestamp"])
+                    time_since_scan = (
+                        datetime.now() - scan_timestamp).total_seconds()
                     if time_since_scan > 120:  # 2 minutes
                         scan_info["status"] = "completed"
                         scan_info["completed_at"] = datetime.now().isoformat()
@@ -1093,8 +1098,66 @@ def api_plex_item_scan():
 
 @app.route('/api/plex/pending-scans', methods=['GET'])
 def api_pending_scans():
-    """Gets the list of pending scans."""
+    """Gets the list of pending scans, including currently running scans from Plex."""
     try:
+        # First, check Plex activities for any currently running scans
+        from plex_utils import get_plex_activities, get_plex_client
+        activities = get_plex_activities()
+        
+        # Track which section IDs we've already seen in PENDING_SCANS
+        tracked_sections = set()
+        for scan_info in PENDING_SCANS.values():
+            library_key = scan_info.get("library_key")
+            if library_key:
+                tracked_sections.add(str(library_key))
+        
+        # Add any running scans from activities that aren't already tracked
+        plex = get_plex_client()
+        for activity in activities:
+            context = activity.get('context', {})
+            library_section_id = context.get('librarySectionID')
+            
+            if library_section_id and str(library_section_id) not in tracked_sections:
+                # This is a scan we haven't tracked yet, add it
+                try:
+                    # Get library name
+                    library_name = f"Library {library_section_id}"
+                    if plex:
+                        try:
+                            section = plex.library.sectionByID(int(library_section_id))
+                            if section:
+                                library_name = section.title
+                        except:
+                            pass
+                    
+                    # Get activity details for better naming
+                    activity_title = activity.get('title', '')
+                    activity_subtitle = activity.get('subtitle', '')
+                    
+                    # Use subtitle if available (often contains item name like "Carmen Sandiego (2015)")
+                    display_name = library_name
+                    if activity_subtitle:
+                        display_name = f"{library_name}: {activity_subtitle}"
+                    elif activity_title:
+                        display_name = f"{library_name}: {activity_title}"
+                    
+                    # Create a scan ID for this activity
+                    activity_key = activity.get('key', '')
+                    scan_id = f"activity_{library_section_id}_{activity_key[:8] if activity_key else uuid.uuid4().hex[:8]}"
+                    
+                    # Only add if we don't already have this scan_id
+                    if scan_id not in PENDING_SCANS:
+                        add_pending_scan(
+                            "library",
+                            scan_id,
+                            display_name,
+                            library_key=str(library_section_id)
+                        )
+                        tracked_sections.add(str(library_section_id))
+                        logger.info(f"Added untracked scan from activities: {display_name} (section {library_section_id})")
+                except Exception as e:
+                    logger.warning(f"Error adding scan from activity: {e}")
+        
         # Update status for all pending scans
         for scan_id in list(PENDING_SCANS.keys()):
             scan_info = PENDING_SCANS[scan_id]