@@ -719,7 +735,8 @@ CONFIG_HTML = r"""
},
jellyfinSyncRunning: false,
jellyfinSyncJobId: null,
- watchlistReconcileRunning: false
+ watchlistReconcileRunning: false,
+ watchlistImportRunning: false
};
const $ = (id) => document.getElementById(id);
@@ -765,6 +782,15 @@ CONFIG_HTML = r"""
$("watchlistReconcileStatus").textContent = text || "No watchlist filesystem sync run yet.";
}
+ function setWatchlistBackupStatus(text) {
+ $("watchlistBackupStatus").textContent = text || "No watchlist backup action run yet.";
+ }
+
+ function setWatchlistImportButton(running) {
+ $("importWatchlistBtn").disabled = !!running;
+ $("importWatchlistBtn").textContent = running ? "Importing..." : "Import";
+ }
+
function selectedWebhookEvents() {
return [...document.querySelectorAll(".webhook-event:checked")].map((input) => input.value);
}
@@ -906,6 +932,35 @@ CONFIG_HTML = r"""
}
}
+ function exportWatchlistBackup() {
+ setWatchlistBackupStatus("Preparing watchlist backup download...");
+ window.location.href = "/api/config/watchlist/export";
+ }
+
+ async function importWatchlistBackup(file) {
+ if (!file) return;
+ state.watchlistImportRunning = true;
+ setWatchlistImportButton(true);
+ setWatchlistBackupStatus("Reading backup file...");
+ try {
+ const payload = JSON.parse(await file.text());
+ setWatchlistBackupStatus("Importing backup...");
+ const data = await api("/api/config/watchlist/import", {
+ method: "POST",
+ body: JSON.stringify(payload)
+ });
+ setWatchlistBackupStatus(`${data.imported || 0} watchlist entries imported.`);
+ setNotice(data.message || "Watchlist backup imported.");
+ } catch (error) {
+ setWatchlistBackupStatus("Watchlist backup import failed.");
+ setNotice(error.message);
+ } finally {
+ $("importWatchlistFile").value = "";
+ state.watchlistImportRunning = false;
+ setWatchlistImportButton(false);
+ }
+ }
+
function closePathBrowser() {
state.pathBrowser = {
targetId: "",
@@ -1053,6 +1108,9 @@ CONFIG_HTML = r"""
$("testWebhookBtn").addEventListener("click", testWebhook);
$("runJellyfinSyncBtn").addEventListener("click", runJellyfinSync);
$("reconcileWatchlistDownloadsBtn").addEventListener("click", reconcileWatchlistDownloads);
+ $("exportWatchlistBtn").addEventListener("click", exportWatchlistBackup);
+ $("importWatchlistBtn").addEventListener("click", () => $("importWatchlistFile").click());
+ $("importWatchlistFile").addEventListener("change", (event) => importWatchlistBackup((event.target.files || [])[0]));
$("openChangelogBtn").addEventListener("click", openChangelog);
$("closeChangelogBtn").addEventListener("click", closeChangelog);
$("pathBrowserCloseBtn").addEventListener("click", closePathBrowser);
diff --git a/http_handler.py b/http_handler.py
index 0d65be9..5371677 100644
--- a/http_handler.py
+++ b/http_handler.py
@@ -58,6 +58,7 @@ class HandlerContext:
download_watchlist_item: object
ensure_runtime: object
episode_list: object
+ export_watchlist_backup: object
get_config_snapshot: object
get_jellyfin_sync_status: object
get_watchlist_homepage_summary: object
@@ -65,6 +66,7 @@ class HandlerContext:
get_watchlist_refresh_status: object
http_error: object
index_html: str
+ import_watchlist_backup: object
queue_html: str
reconcile_watchlist_downloaded_files: object
remove_from_watchlist: object
@@ -747,6 +749,12 @@ class Handler(BaseHTTPRequestHandler):
elif parsed.path == "/api/config/jellyfin/sync-status":
Handler._runtime(self)
self.json(Handler._context(self).get_jellyfin_sync_status())
+ elif parsed.path == "/api/config/watchlist/export":
+ Handler._runtime(self)
+ self.json_attachment(
+ Handler._context(self).export_watchlist_backup(),
+ "ani-cli-web-watchlist-backup.json",
+ )
else:
self.error(HTTPStatus.NOT_FOUND, "Not found")
except Exception as exc:
@@ -796,6 +804,9 @@ class Handler(BaseHTTPRequestHandler):
if str(merged.get("download_dir") or "").strip():
Handler.validate_remote_path(self, merged["download_dir"], "download directory")
self.json(Handler._context(self).reconcile_watchlist_downloaded_files(merged))
+ elif parsed.path == "/api/config/watchlist/import":
+ payload = Handler.require_json_object(self, self.body_json())
+ self.json(Handler._context(self).import_watchlist_backup(payload))
elif parsed.path == "/api/config/webhook/test":
payload = Handler.require_json_object(self, self.body_json())
validate_discord_webhook_url(payload.get("discord_webhook_url"))
@@ -1014,6 +1025,19 @@ class Handler(BaseHTTPRequestHandler):
data = json.dumps(payload).encode("utf-8")
self.write_response_bytes(data, status, {"Content-Type": "application/json"})
+ def json_attachment(self, payload, filename, status=HTTPStatus.OK):
+ data = json.dumps(payload, indent=2, sort_keys=True).encode("utf-8")
+ safe_filename = str(filename or "watchlist-backup.json").replace('"', "")
+ self.write_response_bytes(
+ data,
+ status,
+ {
+ "Content-Type": "application/json",
+ "Content-Disposition": f'attachment; filename="{safe_filename}"',
+ "Cache-Control": "no-store",
+ },
+ )
+
def write_response_bytes(self, payload, status, headers):
try:
self.send_response(status)
diff --git a/test_app.py b/test_app.py
index 843cc6e..5a01886 100644
--- a/test_app.py
+++ b/test_app.py
@@ -72,6 +72,12 @@ class DummyHandler:
self.json_payload = payload
self.json_status = status
+ def json_attachment(self, payload, filename, status=HTTPStatus.OK):
+ return APP.Handler.json_attachment(self, payload, filename, status=status)
+
+ def write_response_bytes(self, payload, status, headers):
+ return APP.Handler.write_response_bytes(self, payload, status, headers)
+
def error(self, status, message):
self.error_status = status
self.error_message = message
@@ -2385,6 +2391,92 @@ class WatchlistFilesystemReconcileTests(unittest.TestCase):
self.assertTrue(item["downloaded"])
+class WatchlistBackupTests(unittest.TestCase):
+ def setUp(self):
+ with APP.WATCHLIST._connect() as conn:
+ conn.execute("DELETE FROM watchlist")
+ conn.execute("DELETE FROM watchlist_removals")
+
+ def seed_watchlist_item(self, **overrides):
+ now = APP.now_iso()
+ item = {
+ "show_id": "show-backup-1",
+ "title": "Backup Show",
+ "category": "finished",
+ "downloaded": True,
+ "status": "updated",
+ "status_message": "Ready.",
+ "created_at": now,
+ "updated_at": now,
+ "last_checked": now,
+ "sub_count": 2,
+ "dub_count": 2,
+ "expected_count": 2,
+ "airing_status": "Finished",
+ "sub_latest_episode": "2",
+ "dub_latest_episode": "2",
+ "animeschedule_route": "backup-route",
+ "animeschedule_title": "Backup Schedule",
+ "anidb_aid": "123",
+ "anidb_title": "Backup AniDB",
+ "media_type": "tv",
+ "auto_download_mode": "dub",
+ "auto_download_quality": "best",
+ "auto_download_name": "Backup Show",
+ "auto_download_source_name": "Backup Search",
+ "auto_download_series": "1",
+ "auto_download_offset": None,
+ "downloaded_sub_episodes_json": APP.encode_episode_values(["1"]),
+ "downloaded_dub_episodes_json": APP.encode_episode_values(["1", "2"]),
+ "thumbnail_path": "show-backup-1.jpg",
+ "thumbnail_checked_at": now,
+ }
+ item.update(overrides)
+ with APP.WATCHLIST.lock, APP.WATCHLIST._connect() as conn:
+ APP.WATCHLIST._upsert_conn(conn, item)
+
+ def test_export_watchlist_backup_includes_raw_watchlist_and_removal_rows(self):
+ self.seed_watchlist_item()
+ with APP.WATCHLIST._connect() as conn:
+ conn.execute(
+ "INSERT INTO watchlist_removals (show_id, title, removed_at) VALUES (?, ?, ?)",
+ ("removed-show", "Removed Show", APP.now_iso()),
+ )
+
+ backup = APP.export_watchlist_backup()
+
+ self.assertEqual(backup["format"], "ani-cli-web-watchlist-backup")
+ self.assertEqual(backup["format_version"], 1)
+ self.assertEqual(backup["tables"]["watchlist"]["rows"][0]["show_id"], "show-backup-1")
+ self.assertEqual(backup["tables"]["watchlist"]["rows"][0]["downloaded_dub_episodes_json"], APP.encode_episode_values(["1", "2"]))
+ self.assertEqual(backup["tables"]["watchlist_removals"]["rows"][0]["show_id"], "removed-show")
+
+ def test_import_watchlist_backup_replaces_existing_watchlist_tables(self):
+ self.seed_watchlist_item(show_id="old-show", title="Old Show")
+ backup = APP.export_watchlist_backup()
+ backup["tables"]["watchlist"]["rows"][0]["show_id"] = "new-show"
+ backup["tables"]["watchlist"]["rows"][0]["title"] = "New Show"
+ backup["tables"]["watchlist_removals"]["rows"] = [
+ {"show_id": "removed-new", "title": "Removed New", "removed_at": APP.now_iso()}
+ ]
+
+ result = APP.import_watchlist_backup(backup)
+
+ self.assertEqual(result["imported"], 1)
+ with self.assertRaises(KeyError):
+ APP.WATCHLIST.get("old-show")
+ restored = APP.WATCHLIST.get("new-show")
+ self.assertEqual(restored["title"], "New Show")
+ self.assertEqual(restored["downloaded_dub_episodes"], ["1", "2"])
+ with APP.WATCHLIST._connect() as conn:
+ removal = conn.execute("SELECT title FROM watchlist_removals WHERE show_id = ?", ("removed-new",)).fetchone()
+ self.assertEqual(removal["title"], "Removed New")
+
+ def test_import_watchlist_backup_rejects_unrecognized_format(self):
+ with self.assertRaises(ValueError):
+ APP.import_watchlist_backup({"format": "not-this-app", "format_version": 1, "tables": {}})
+
+
class WatchlistQueuedRefreshRecoveryTests(unittest.TestCase):
def setUp(self):
with APP.WATCHLIST._connect() as conn:
@@ -3762,6 +3854,35 @@ class HandlerRouteTests(unittest.TestCase):
}
)
+ def test_watchlist_export_route_returns_json_attachment(self):
+ handler = DummyHandler("/api/config/watchlist/export")
+ payload = {"format": "ani-cli-web-watchlist-backup", "tables": {"watchlist": {"rows": []}}}
+ handler.handler_context = mock.Mock(
+ ensure_runtime=mock.Mock(),
+ runtime_state=mock.Mock(return_value={}),
+ export_watchlist_backup=mock.Mock(return_value=payload),
+ )
+
+ APP.Handler.do_GET(handler)
+
+ self.assertEqual(handler.response_status, HTTPStatus.OK)
+ headers = dict(handler.response_headers)
+ self.assertEqual(headers.get("Content-Type"), "application/json")
+ self.assertIn("attachment", headers.get("Content-Disposition", ""))
+ self.assertEqual(json.loads(handler.wfile.getvalue().decode("utf-8")), payload)
+
+ def test_watchlist_import_route_returns_import_summary(self):
+ body = b'{"format":"ani-cli-web-watchlist-backup","format_version":1,"tables":{"watchlist":{"rows":[]}}}'
+ handler = DummyHandler("/api/config/watchlist/import", body=body, content_length=len(body))
+ payload = {"message": "Imported 0 watchlist entries from backup.", "imported": 0, "removals": 0}
+ handler.handler_context = mock.Mock(import_watchlist_backup=mock.Mock(return_value=payload))
+
+ APP.Handler.do_POST(handler)
+
+ self.assertEqual(handler.json_status, HTTPStatus.OK)
+ self.assertEqual(handler.json_payload, payload)
+ handler.handler_context.import_watchlist_backup.assert_called_once()
+
def test_generic_handler_exception_skips_traceback_when_debug_disabled(self):
handler = DummyHandler("/api/config")
with mock.patch.object(http_handler, "debug_enabled", return_value=False), mock.patch.object(