fix: exclude downloaded episodes from episodeDict and GetMissingEpisode

Prevent fully-downloaded series from being queued by auto-download:

- SerieList.GetMissingEpisode(): filter by is_downloaded instead of
  checking if episodeDict is non-empty. episodeDict from the DB
  relationship includes all episodes (including downloaded), so a
  series with only downloaded episodes still had a truthy episodeDict.

- AnimeSeries.episodeDict property: skip episodes where is_downloaded=True
  when building the dict from the DB relationship. This makes the
  property consistent with the is_downloaded filtering already done
  manually in list_series_with_filters(), and ensures that calling
  code anywhere in the codebase gets the correct missing-episode view.

Fixes hana-kimi (and any other fully-downloaded series) incorrectly
appearing in the auto-download queue after a rescan.

Docker/VERSION

@@ -1 +1 @@
-v1.5.2
+v1.5.3

package.json

@@ -1,6 +1,6 @@
 {
   "name": "aniworld-web",
-  "version": "1.5.2",
+  "version": "1.5.3",
   "description": "Aniworld Anime Download Manager - Web Frontend",
   "type": "module",
   "scripts": {

src/server/database/SerieList.py

@@ -134,7 +134,7 @@ class SerieList:
         """Return all series that still contain missing episodes."""
         return [
             anime for anime in self.keyDict.values()
-            if anime.episodeDict
+            if any(not ep.is_downloaded for ep in (anime.episodes or []))
         ]
 
     def get_missing_episodes(self) -> List[AnimeSeries]:

src/server/database/models.py

@@ -205,6 +205,8 @@ class AnimeSeries(Base, TimestampMixin):
         try:
             if self.episodes:
                 for ep in self.episodes:
+                    if ep.is_downloaded:
+                        continue
                     season = ep.season or 1
                     if season not in episode_dict:
                         episode_dict[season] = []

src/server/providers/aniworld_provider.py

@@ -5,6 +5,7 @@ import logging
 import os
 import re
 import shutil
+import time
 import threading
 from pathlib import Path
 from urllib.parse import quote
@@ -383,6 +384,12 @@ class AniworldLoader(Loader):
                     "Direct stream download starting (type=%s)",
                     content_type
                 )
+                total_size = int(response.headers.get(
+                    "Content-Length", 0
+                ))
+                received = 0
+                last_emit = 0
+                start_time = time.monotonic()
                 with open(output_path, "wb") as fh:
                     for chunk in response.iter_content(chunk_size=1024 * 1024):
                         if self._cancel_flag.is_set():
@@ -391,7 +398,33 @@ class AniworldLoader(Loader):
                             )
                             return False
                         if chunk:
+                            received += len(chunk)
                             fh.write(chunk)
+                            # Emit progress events at ~1% intervals
+                            if total_size > 0:
+                                pct = (received / total_size) * 100
+                                if pct - last_emit >= 1.0 or received == total_size:
+                                    elapsed = time.monotonic() - start_time
+                                    speed_bps = (
+                                        received / elapsed
+                                        if elapsed > 0 else 0
+                                    )
+                                    eta = (
+                                        int((total_size - received) / speed_bps)
+                                        if speed_bps > 0 else None
+                                    )
+                                    self.events.download_progress({
+                                        "downloaded_bytes": received,
+                                        "total_bytes": total_size,
+                                        "speed": speed_bps,
+                                        "eta": eta,
+                                        "status": (
+                                            "finished"
+                                            if received >= total_size
+                                            else "downloading"
+                                        ),
+                                    })
+                                    last_emit = pct
             return True
         except requests.RequestException as exc:
             logger.warning("Direct stream download failed: %s", exc)

src/server/services/image_loading_service.py

@@ -162,17 +162,18 @@ class ImageLoadingService:
         for i in range(0, len(series_list), self.BATCH_SIZE):
             batch = series_list[i : i + self.BATCH_SIZE]
 
-            tasks = [
+            # Process each series sequentially to avoid concurrent use of the
-                self.load_series_images(
+            # same AsyncSession (SQLAlchemy async sessions are not thread-safe
+            # for concurrent operations). BATCH_SIZE still paces TMDB requests.
+            results: List[Dict[str, Any] | Exception] = []
+            for series in batch:
+                result = await self.load_series_images(
                     key=series["key"],
                     folder=series["folder"],
                     anime_directory=anime_directory,
                     db=db,
                 )
-                for series in batch
+                results.append(result)
-            ]
-
-            results = await asyncio.gather(*tasks, return_exceptions=True)
 
             for series, result in zip(batch, results):
                 if isinstance(result, Exception):

src/server/web/static/js/index/socket-handler.js

@@ -137,12 +137,15 @@ AniWorld.IndexSocketHandler = (function() {
         socket.on(WS_EVENTS.SERIES_UPDATED, function(data) {
             console.log('Series updated:', data);
 
-            // Use the data directly to update the series instead of full refresh
+            // NOTE: websocket-client.js strips the outer {type, data, ...} wrapper
-            if (data && data.data && AniWorld.SeriesManager && AniWorld.SeriesManager.updateSingleSeries) {
+            // before emitting, so `data` here is the inner series data object
-                AniWorld.SeriesManager.updateSingleSeries(data.data);
+            // (e.g. {key, name, missing_episodes, ...}) — NOT {type, data, ...}.
+            // AniWorld.SeriesManager.updateSingleSeries() expects this flat object.
+            if (data && data.key && AniWorld.SeriesManager && AniWorld.SeriesManager.updateSingleSeries) {
+                AniWorld.SeriesManager.updateSingleSeries(data);
             } else {
                 // Fallback to full reload if data is incomplete
-                console.warn('Incomplete series update data, falling back to full reload');
+                console.warn('Incomplete series update data, falling back to full reload', data);
                 if (AniWorld.SeriesManager && AniWorld.SeriesManager.loadSeries) {
                     AniWorld.SeriesManager.loadSeries();
                 }

uv.lock

@@ -0,0 +1,3 @@
+version = 1
+revision = 3
+requires-python = ">=3.12"