rescan file on reopen/unapprove so returning to inbox refreshes stream metadata

Single-item "← Back to inbox" (reopen, unapprove) now re-probes the file
via ffprobe and re-upserts media_items + media_streams. Covers cases where
the original scan errored or the file was replaced on disk. Bulk operations
(unsort-all, reopen-all) skip the rescan to avoid hammering ffprobe.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

server/api/review.ts

@@ -2,6 +2,9 @@ import { unlinkSync } from "node:fs";
 import { Hono } from "hono";
 import { getAllConfig, getConfig, getDb } from "../db/index";
 import { log, error as logError } from "../lib/log";
+import { parsePath } from "../services/path-parser";
+import { probeFile } from "../services/probe";
+import { upsertScannedItem } from "../services/rescan";
 import { isOneOf, parseId } from "../lib/validate";
 import { analyzeItem, assignTargetOrder } from "../services/analyzer";
 import { buildCommand, LANG_NAMES } from "../services/ffmpeg";
@@ -1215,6 +1218,26 @@ export function sendToInbox(db: ReturnType<typeof getDb>, itemId: number): void
 	db.prepare("DELETE FROM jobs WHERE item_id = ? AND status IN ('pending', 'done', 'error')").run(itemId);
 }
 
+/** Re-probe a single file and update its media_items + media_streams. */
+async function rescanFile(db: ReturnType<typeof getDb>, itemId: number): Promise<void> {
+	const item = db.prepare("SELECT file_path FROM media_items WHERE id = ?").get(itemId) as
+		| { file_path: string }
+		| undefined;
+	if (!item?.file_path) return;
+	const cfg = getAllConfig();
+	const moviesRoot = cfg.movies_root || "/movies";
+	const tvRoot = cfg.tv_root || "/tv";
+	const parsed = parsePath(item.file_path, moviesRoot, tvRoot);
+	if (!parsed) return;
+	try {
+		const probe = await probeFile(item.file_path);
+		upsertScannedItem(db, item.file_path, parsed, probe);
+	} catch (err) {
+		logError(`Rescan failed for ${item.file_path}:`, err);
+		db.prepare("UPDATE media_items SET scan_status = 'error', scan_error = ? WHERE id = ?").run(String(err), itemId);
+	}
+}
+
 /** Send all items in Review back to inbox. */
 export function unsortAll(db: ReturnType<typeof getDb>): number {
 	const rows = db
@@ -1429,17 +1452,18 @@ app.post("/:id/retry", (c) => {
 // running plan), this handles the post-job states and drops the lingering
 // job row so the pipeline doesn't show leftover history for an item that's
 // about to be re-sorted.
-app.post("/:id/reopen", (c) => {
+app.post("/:id/reopen", async (c) => {
 	const db = getDb();
 	const id = parseId(c.req.param("id"));
 	if (id == null) return c.json({ error: "invalid id" }, 400);
 	const plan = db.prepare("SELECT * FROM review_plans WHERE item_id = ?").get(id) as ReviewPlan | undefined;
 	if (!plan) return c.notFound();
 	sendToInbox(db, id);
+	await rescanFile(db, id);
 	return c.json({ ok: true });
 });
 
-app.post("/:id/unapprove", (c) => {
+app.post("/:id/unapprove", async (c) => {
 	const db = getDb();
 	const id = parseId(c.req.param("id"));
 	if (id == null) return c.json({ error: "invalid id" }, 400);
@@ -1451,6 +1475,7 @@ app.post("/:id/unapprove", (c) => {
 		| undefined;
 	if (job?.status === "running") return c.json({ ok: false, error: "Job is running — cannot send back to inbox" }, 409);
 	sendToInbox(db, id);
+	await rescanFile(db, id);
 	return c.json({ ok: true });
 });