Skip to content

Clarify safe Radarr media and sidecar repair #49

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
slashmad merged 1 commit into from
Jul 29, 2026
Merged

Clarify safe Radarr media and sidecar repair #49

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
56 changes: 41 additions & 15 deletions src/stowarr/engine.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -39,6 +39,7 @@
SAFE_RECONCILE_AUDIT_STATUSES = {
"root-mismatch", "missing-library-file", "hardlink-missing",
}
SYNC_HEALTHY_STATUSES = {"in-sync", "packed-media"}
RELEASE_FOLDER_MARKERS = re.compile(
r"(?i)(?:^|[._ -])(?:720p|1080[pi]|2160p|uhd|bluray|blu-ray|web(?:[._ -]?dl)?|"
r"remux|x26[45]|h[._ -]?26[45]|hevc|avc|hdr10p?|dv|dolby[._ -]?vision|"
Expand Down Expand Up @@ -2824,6 +2825,7 @@ def sync_audit(self, app: str) -> dict:
expected_roots: tuple[Path, ...] = ()
expected_category = None
category_repairable = False
media_candidate_count = None
title_candidate_count = sum(
title_matches(candidate.get("title", ""), torrent["name"])
for candidate in items.values()
Expand Down Expand Up @@ -3014,6 +3016,7 @@ def sync_audit(self, app: str) -> dict:
)
and path.is_file()
]
media_candidate_count = len(torrent_videos)
hardlinked = any(
(candidate.stat().st_dev, candidate.stat().st_ino)
== (library_stat.st_dev, library_stat.st_ino)
Expand All @@ -3030,28 +3033,49 @@ def sync_audit(self, app: str) -> dict:
"Radarr manages visible media derived from a packed "
"qBittorrent download; hardlink identity is not applicable"
)
elif len(torrent_videos) == 1:
status = "hardlink-missing"
reason = (
"Radarr media and one same-size qBittorrent video are "
"separate files; content is not hash-verified yet"
)
issues.append({
"code": "PACKED_MEDIA_HARDLINK_NOT_APPLICABLE",
"code": "LIBRARY_HARDLINK_MISSING",
"summary": reason,
"action": (
"Keep the qBittorrent archives intact. No hardlink repair "
"is available; use Diagnose only if the imported media or "
"Radarr association is suspect."
"Build a Reconcile plan. Stowarr will hash-verify the "
"single candidate before replacing the library copy "
"in place with a verified hardlink."
),
})
elif not torrent_videos:
status = "media-file-unmatched"
reason = (
"No selected qBittorrent video has the same size as "
"Radarr's managed movie"
)
issues.append({
"code": "QBITTORRENT_MEDIA_CANDIDATE_MISSING",
"summary": reason,
"action": (
"Force recheck qBittorrent and verify the selected files "
"and Radarr download association. Do not replace the "
"library file until one exact candidate is identified."
),
})
else:
status = "hardlink-missing"
status = "media-file-ambiguous"
reason = (
"Radarr media is not hardlinked to the matched "
"qBittorrent download"
f"{len(torrent_videos)} selected qBittorrent videos have "
"the same size as Radarr's managed movie"
)
issues.append({
"code": "LIBRARY_HARDLINK_MISSING",
"code": "QBITTORRENT_MEDIA_CANDIDATE_AMBIGUOUS",
"summary": reason,
"action": (
"Build a Reconcile plan. Stowarr will require one exact "
"same-content torrent file before replacing the library "
"entry with a verified hardlink."
"Inspect the selected torrent files and use Radarr Manual "
"Import if needed. Stowarr will not choose between multiple "
"same-size candidates automatically."
),
})
else:
Expand All @@ -3069,6 +3093,7 @@ def sync_audit(self, app: str) -> dict:
"expected_roots": [str(root) for root in expected_roots],
"expected_category": expected_category,
"category_repairable": category_repairable,
"media_candidate_count": media_candidate_count,
"title_candidate_count": title_candidate_count,
"status": status,
"reason": reason,
Expand Down Expand Up @@ -3107,13 +3132,14 @@ def sync_audit(self, app: str) -> dict:
row["related_torrents"] = torrent_evidence
for row in rows:
row["safe_plan_candidate"] = safe_sync_candidate(row)
rows.sort(key=lambda row: (row["status"] == "in-sync", row["torrent_name"].casefold()))
row["healthy"] = row["status"] in SYNC_HEALTHY_STATUSES
rows.sort(key=lambda row: (row["healthy"], row["torrent_name"].casefold()))
return {
"app": app,
"scanned": len(rows),
"matched_history": len(history),
"in_sync": sum(row["status"] == "in-sync" for row in rows),
"issues": sum(row["status"] != "in-sync" for row in rows),
"in_sync": sum(row["healthy"] for row in rows),
"issues": sum(not row["healthy"] for row in rows),
"rows": rows,
}

Expand Down Expand Up @@ -3144,7 +3170,7 @@ def safe_sync_plan(self, app: str, progress=None) -> dict:
queued_reconciles = []
manual = []
for row in audit["rows"]:
if row["status"] == "in-sync":
if row.get("healthy") is True or row["status"] in SYNC_HEALTHY_STATUSES:
continue
if (
row["status"] == "category-unconfigured"
Expand Down
Loading
Loading