Stufe 2a: Der Bestand wird gelesen, nicht mehr nur verwaltet

Dateinamen erkennen, Verzeichnisse durchlaufen, abgleichen, blättern. Noch
ohne TMDB — die Titel kommen vorerst aus den Dateinamen, und genau daran
entscheidet sich später, ob die Metadatenquelle etwas findet.

**Der Dateiname ist die Stelle, an der Medienserver in der Praxis scheitern.**
Was auf der Platte liegt, heisst nicht „Der Fall", sondern
`Notruf.Hafenkante.S01E01.German.1080p.WEB-DL.x264-GRP.mkv`. Das Verfahren
schneidet ab dem ersten Technik-Merkmal ab, statt einzelne Tags
herauszulösen: Letzteres klingt gründlicher, lässt aber bei jedem unbekannten
Tag Bruchstücke stehen — und unbekannte Tags gibt es immer.

Drei Fälle, an denen sich die Regeln entscheiden, alle geprüft:

- **„Blade Runner 2049" behält seine Zahl.** Eine Jahreszahl muss plausibel
  sein; was weit in der Zukunft liegt, gehört zum Titel. Ohne diese Grenze
  hiesse der Film „Blade Runner", erschienen 2049, und keine Metadatenquelle
  fände ihn so.
- **„S.W.A.T." behält seine Punkte.** Trennpunkte werden nur dort zu
  Leerzeichen, wo sonst keine sind — stehen welche im Namen, hat jemand von
  Hand benannt, und seine Punkte sind gewollt. (Der Schlusspunkt fiel erst
  einem Test auf.)
- **Ohne Folgennummer wird nichts geraten.** Eine erfundene Staffel 1 landete
  unter einer Serie, zu der die Datei nicht gehört.

**`@eaDir` ist der Grund, warum der Walker von Hand absteigt.** Synologys
Vorschauablage enthält eine Kopie *jeder* Datei; mit
`SearchOption.AllDirectories` — der bequemen Fassung — stünde jeder Film
zweimal in der Mediathek, zur Hälfte als unbrauchbare Kopie. Äste beschneiden
kann nur, wer selbst absteigt. Ein gesperrter Unterordner bricht den Lauf
nicht ab, sondern wird vermerkt.

**Die Datei zeigt auf den Titel, nicht umgekehrt.** Sieht herumgedreht aus und
ist Absicht: ein Film liegt oft als 4K *und* als 1080p vor. Trüge der Film den
Verweis auf seine eine Datei, wäre die zweite Fassung ein Umbau am
Datenmodell — so ist sie eine Zeile mehr. Geprüft.

**Der Scan läuft im Hintergrund**, nicht in der Anfrage: ein Bestand mit
40 000 Titeln braucht Minuten, und eine so lange offene Anfrage läuft hinter
jedem Reverse Proxy ins Zeitlimit. Einer je Bibliothek, sonst löschen sich
zwei Läufe gegenseitig die Einträge. Aufgeräumt wird über den Zeitstempel des
Laufs — billiger, als sich alle gesehenen Pfade zu merken.

Zweimal scannen ergibt dasselbe wie einmal. Das ist der Fehler, den man sonst
erst nach Wochen bemerkt, wenn jeder Film fünfmal dasteht.

131 Tests grün (88 Kern, 43 Schnittstelle).

Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>
This commit is contained in:
Scarriffle
2026-10-03 13:56:25 +02:00
co-authored by Claude Opus 5
parent 156c740330
commit 78b7e3bcb8
17 changed files with 2290 additions and 0 deletions
+87
View File
@@ -0,0 +1,87 @@
using System.Collections.Concurrent;
using Halo.Data;
namespace Halo.Api;
public sealed record ScanState(
string Status,
DateTimeOffset StartedAt,
DateTimeOffset? FinishedAt,
ScanReport? Report,
string? Error);
/// <summary>Lässt Scans im Hintergrund laufen und weiss, wie weit sie sind.</summary>
///
/// <remarks>
/// <para>
/// <b>Nicht in der Anfrage.</b> Ein Bestand mit 40 000 Titeln braucht Minuten;
/// eine HTTP-Anfrage, die so lange offen steht, läuft hinter jedem Reverse
/// Proxy ins Zeitlimit — und der Anwender sieht einen Fehler, während der Scan
/// in Wahrheit tadellos weiterläuft.
/// </para>
/// <para>
/// <b>Einer je Bibliothek, nicht mehr.</b> Zwei gleichzeitige Läufe über
/// dasselbe Verzeichnis würden sich beim Aufräumen gegenseitig die Einträge
/// löschen: der eine schreibt seine Startzeit, der andere hält sie für alt.
/// </para>
/// <para>
/// Der Zustand liegt im Arbeitsspeicher und nicht in der Datenbank. Ein
/// Neustart bricht den Scan ohnehin ab, und ein „läuft" aus einem früheren
/// Leben wäre dann eine Lüge, die niemand mehr aufräumt.
/// </para>
/// </remarks>
public sealed class ScanCoordinator(
IServiceScopeFactory scopes,
TimeProvider clock,
ILogger<ScanCoordinator> log)
{
private readonly ConcurrentDictionary<Guid, ScanState> _zustand = new();
public ScanState? State(Guid libraryId) => _zustand.GetValueOrDefault(libraryId);
public bool IsRunning(Guid libraryId) => State(libraryId)?.Status == "running";
/// <summary>Startet einen Lauf — oder sagt, dass schon einer läuft.</summary>
public bool TryStart(Guid libraryId)
{
var start = new ScanState("running", clock.GetUtcNow(), null, null, null);
var vorher = _zustand.AddOrUpdate(
libraryId,
start,
(_, alt) => alt.Status == "running" ? alt : start);
// Lief schon einer, steht hier dessen Zustand und nicht unserer.
if (!ReferenceEquals(vorher, start)) return false;
_ = Task.Run(() => Laufen(libraryId));
return true;
}
private async Task Laufen(Guid libraryId)
{
try
{
using var bereich = scopes.CreateScope();
var scanner = bereich.ServiceProvider.GetRequiredService<LibraryScanner>();
var bericht = await scanner.ScanAsync(libraryId);
_zustand[libraryId] = _zustand[libraryId] with
{
Status = "finished",
FinishedAt = clock.GetUtcNow(),
Report = bericht,
};
}
catch (Exception fehler)
{
log.LogError(fehler, "Scan der Bibliothek {Kennung} ist gescheitert.", libraryId);
_zustand[libraryId] = _zustand[libraryId] with
{
Status = "failed",
FinishedAt = clock.GetUtcNow(),
Error = fehler.Message,
};
}
}
}