Author SHA1 Message Date
Hermes (Server) 824f6364e2 Baka-Konto-Dialog: Passwort wird jetzt auch getrimmt (wie im Navidrome-Dialog)
Das Passwortfeld im Baka-Konto-Anmelde-Dialog wurde vor dem Absenden und
vor dem Speichern nicht getrimmt — ein durch Autofill eingefügtes
Leerzeichen ließ korrekte Logins scheitern. Gleicher Fix wie bereits in
settings_screen.dart (Commit 3d1e00646a) für denselben Symptom-Typ.
2026-08-29 18:08:19 +02:00
Hermes (Server) e2304b66cd Gestaffelte Enter-Animation für Songlisten (EinblendItem)
Items in song_list.dart und artist_list.dart faden/rutschen beim ersten
Erscheinen gestaffelt statt abrupt ein — angelehnt an HyperOS' fließende
Motion-Sprache. Läuft einmal pro Element, respektiert Reduce-Motion und
deckelt die Verzögerung ab Index 12.
2026-08-29 12:51:04 +02:00
Hermes (Server) 196303145a Manuelle Baka-Anmeldung übernimmt das Passwort jetzt dauerhaft; Auto-Login-Fehler werden geloggt
Nach erfolgreichem manuellem Login im "Baka-Konto"-Dialog wird das neue
Passwort jetzt zusätzlich in NavidromeService persistiert (dafür ergänzt:
öffentlicher serverUrl-Getter) — vorher schrieb der Dialog es nur ins
BakaAuth-Token, nie zurück in die lokale Navidrome-Ablage, aus der
autoAnmelden() sich beim nächsten App-Start bedient. Ohne diesen Fix kam
der Auto-Login-Fehler nach Ablauf des 7-Tage-Tokens garantiert wieder.

Zusätzlich hält BakaAuth.letzterAutoLoginFehler jetzt den Fehlertext des
letzten Auto-Login-Versuchs fest, statt ihn zu verwerfen — bisher war aus
der App nicht diagnostizierbar, woran ein Auto-Login scheiterte.
2026-08-29 12:38:20 +02:00
Hermes (Server) 609ca37ede Auto-Anmeldung: doppelten Login-Request beim App-Start verhindert (Race durch IndexedStack)
Betraf alle drei Nutzer (Dustin, Baka, Tinker), nicht nur einen: IndexedStack
baut Download-Tab und YT-Suche beim App-Start gleichzeitig, beide loesen
unabhaengig voneinander autoAnmelden() aus. Ohne In-Flight-Absicherung gingen
zwei fast-gleichzeitige Login-Requests an denselben Server, von denen einer
abgelehnt wurde - obwohl die Zugangsdaten korrekt waren.

- BakaAuth.autoAnmelden() haengt einen ueberlappenden Aufruf jetzt an den
  bereits laufenden Login-Versuch an, statt einen zweiten Request zu senden.
- Anmelde-Dialog im Download-Tab zeigt den tatsaechlich bekannten
  Navidrome-Benutzernamen statt immer "Baka" vorauszufuellen.
- Navidrome-Dialog in den Einstellungen waehlt den zuletzt bekannten
  Benutzer vor statt immer "Baka".
2026-08-29 11:31:28 +02:00
Hermes (Server)andClaude Sonnet 5 2cabe36a6c Zuletzt zeigt zuletzt Gehörtes statt neu Hinzugefügtes; Herz sitzt jetzt neben dem Songnamen
- MeloDb.watchRecentlyPlayed(): wertet PlaybackHistory statt dateAddedMs aus,
  ein mehrfach gehörter Song erscheint nur einmal, an der Position seines
  jüngsten Abspielens (Subquery mit GROUP BY songId / MAX(playedAtMs)).
- "Zuletzt" (Karte + RecentlyPlayedScreen, vormals RecentlyAddedScreen) in
  my_music_screen.dart nutzt jetzt watchRecentlyPlayed() statt watchRecent().
- Herz im Vollbild-Player: aus der AppBar-actions-Row entfernt, sitzt jetzt
  direkt neben dem Songtitel in _Angaben (now_playing_screen.dart).

Co-Authored-By: Claude Sonnet 5 <noreply@anthropic.com>
Claude-Session: https://claude.ai/code/session_012A2pmbnVNPiHdyf2GW8eLP
2026-08-29 11:24:42 +02:00
Hermes (Server) 90b63c467e Zurück-Geste auf Nicht-Start-Tabs navigiert zu Meine Musik statt die App zu minimieren
Tab-Wechsel in HomeShell laufen nur über setState (IndexedStack +
BottomNavigationBar), nie über Navigator.push — eine System-Zurück-Geste
hatte auf Nicht-Start-Tabs also nie eine Route zum Poppen und minimierte
stattdessen die App. build() jetzt in ein PopScope gewickelt, das bei
_index != 0 zuerst zu Tab 0 zurückspringt.
2026-08-27 15:31:21 +02:00
Hermes (Server) 1b096f5227 Doppelten Scan-Button auf Android entfernen (Musik scannen und Erneut scannen taten dasselbe) 2026-08-27 15:18:36 +02:00
Hermes (Server) 94a48675b1 Song-Tap oeffnet den Vollbild-Player mit grossem Cover 2026-08-27 15:10:33 +02:00
Hermes (Server) 648b22bfa7 AudioSession konfigurieren: Audio-Fokus bleibt beim automatischen Songwechsel erhalten 2026-08-27 14:53:59 +02:00
Hermes (Server)andClaude Sonnet 5 7dbea128e0 Shuffle/Wiederholung: PlaybackState meldet echten Zustand statt immer "aus"
Co-Authored-By: Claude Sonnet 5 <noreply@anthropic.com>
Claude-Session: https://claude.ai/code/session_012A2pmbnVNPiHdyf2GW8eLP
2026-08-27 14:49:32 +02:00
48 changed files with 1555 additions and 2757 deletions
+190 -47
View File
@@ -5,54 +5,197 @@ Format angelehnt an [Keep a Changelog](https://keepachangelog.com/de/1.0.0/).
## [Unreleased]
### 💾❤️ Sync-Ausbau: Favoriten gehen nicht mehr verloren (2026-08-27)
### 🔑 Baka-Konto-Dialog trimmte das Passwort nicht — Autofill-Leerzeichen ließ korrekte Logins scheitern (2026-08-29)
- ❤️ **Der Favoriten-Datenverlust ist behoben.** Bisher hat jedes Gerät beim
Abgleich seine eigene Favoritenliste als Komplett-Ersatz zum Server
geschickt — ein frisch installiertes Handy löschte damit beim allerersten
Abgleich sämtliche Server-Favoriten. Neu wird nur noch **hinzugefügt**:
Was hier Favorit ist und dort fehlt, wird einzeln gemeldet; was dort
Favorit ist und hier fehlt, wird hier gesetzt. Entfernt wird in keiner
Richtung etwas. Der alte Weg (`POST /favorites`) existiert im Code nicht
mehr — der Fehler kann also nicht zurückkommen.
- 💔 **Bewusster Preis:** Ein entferntes Herz wirkt sofort auf diesem Gerät
und (online) auch am Server, ist aber **nicht geräteübergreifend
garantiert**: Hält ein zweites Gerät den Favoriten noch, bringt dessen
nächster Abgleich ihn zurück. Kein Datenverlust ist uns wichtiger als
verlässliches Löschen.
-**Herz antippen meldet sofort.** Wer online ein Herz setzt oder entfernt,
schickt den Wunsch direkt zum Server — eindeutig als „setze auf ja/nein",
nicht als Umschalten. Geht das schief, passiert nichts Schlimmes: der
nächste Abgleich holt es nach.
- 🛡️ **Der Server darf sich nicht mehr missverständlich ausdrücken.** Kommt
auf die Favoriten-Abfrage eine Antwort ohne Favoritenliste, gilt das jetzt
als Fehler und die Favoriten-Runde wird übersprungen — vorher wurde daraus
stillschweigend „keine Favoriten".
- ☁️ **Neu: „Auf den Server laden".** Im Auswahl-Modus von „Meine Musik"
(langes Drücken) lassen sich einzelne Titel markieren und gezielt
hochladen. Titel, die schon oben sind, werden übersprungen; einzelne
Fehlschläge stoppen den Rest nicht. Die Aktion erscheint bewusst nur dort
und nicht bei Favoriten, Wiedergabelisten oder Titellisten.
- ⬇️ **Neu: einzelne Server-Titel offline nehmen.** In der Album- und
Künstler-Ansicht hat jede Zeile jetzt einen Knopf — bisher ging nur „ganzes
Album". Schon geladene Titel lassen sich dort auch wieder entfernen.
*Bekannte Einschränkung:* Ein gerade gehörter Titel liegt danach kurzzeitig
doppelt (Zwischenspeicher + Download), bis der Zwischenspeicher aufräumt.
- 🗂️ **Playlisten werden einseitig am Server gesichert** (kein Rück-Merge,
Umbenennungen propagieren nicht).
- 📰 **Neu: „Willkommen zurück".** War der letzte **erfolgreiche** Abgleich
mehr als 24 Stunden her, zeigt die App danach einmalig, was dazugekommen
und was verschwunden ist. Beim allerersten Start nach einer Neuinstallation
erscheint er absichtlich **nicht**.
- 🔧 **Unter der Haube:** Der Abgleichs-Zeitstempel wird jetzt **vor** dem
Abfragen der Serverliste genommen (sonst fallen Änderungen während des Laufs
durchs Raster); ein hängender Upload (Zeitüberschreitung) reißt nicht mehr
den ganzen Abgleich ab; ausgefallene Teilschritte verschieben die
24-Stunden-Uhr des Berichts nicht mehr.
- 🧪 Neue Tests für die Merge-Regeln, den additiven Abgleich, den Sofort-Push,
den Auswahl-Upload samt Abbrechen und den Bericht. Zwei bestehende Tests
wurden bewusst umgeschrieben, weil sie das alte (fehlerhafte) Verhalten
festschrieben.
- 🐛 **Im "Baka-Konto"-Anmelde-Dialog (`_AnmeldeDialogState._anmelden()` in
`downloads_screen.dart`) wurde der Benutzername vor dem Absenden getrimmt
(`_benutzer.text.trim()`), das Passwort aber nicht** (`_passwort.text`
roh, an beiden Stellen: beim `BakaAuth.anmelden(...)`-Aufruf UND beim
anschließenden `NavidromeService.speichereZugangsdaten(...)`). Ein durch
Autofill/Tastatur-Vorschläge im `obscureText`-Passwortfeld eingefügtes
unsichtbares Leerzeichen landete dadurch im gesendeten UND dauerhaft
gespeicherten Passwort — der Login schlug fehl, obwohl der Nutzer sein
Passwort korrekt kannte.
- 🔧 **Fix:** `_passwort.text.trim()` an beiden Stellen, mit demselben
Kommentar wie beim strukturell identischen, bereits behobenen Fall im
Navidrome-Login-Dialog (`settings_screen.dart`, Commit `3d1e00646ac`) —
das war schon einmal exakt dasselbe Symptom in einem zweiten
Passwort-Dialog. Falls das Muster ein drittes Mal auftaucht: derselbe
Trim-Fix, derselbe Kommentar.
-**Getestet (RED→GREEN):** neuer Widget-Test in `online_screen_test.dart`
gibt im Passwortfeld `'geheim '` (mit Leerzeichen) ein und bestätigt, dass
sowohl der gesendete `POST /auth/login`-Body als auch
`nav.passwort` das getrimmte `'geheim'` enthalten. Volle Suite (605 Tests)
grün, `flutter analyze` ohne Befund.
### ✨ Staggered List-Enter-Animation: Listen faden beim ersten Erscheinen gestaffelt ein (2026-08-29)
-**Teil 1 einer Animations-Serie** (inspiriert von Xiaomis HyperOS-
Design-Sprache — fließende statt abrupte Bewegung): neues Widget
`EinblendItem` (`lib/shared/einblend_item.dart`) blendet ein Listenelement
beim ersten Erscheinen mit Opacity 0→1 und leichtem Versatz (`MeloSpace.sm`
→ 0) ein, Dauer `MeloMotion.normal` (220ms), Kurve `MeloMotion.curve`.
Jedes Element startet um `min(index, 12) × 25ms` versetzt — ab Index 12
ohne zusätzliche Verzögerung, damit lange Listen nicht träge wirken. Läuft
genau einmal je Element-Lebenszeit (nicht bei jedem Rebuild) und
respektiert Reduce-Motion (`MeloMotion.ruhig`): dann erscheint das Element
sofort im Endzustand, ohne Verzögerung oder Bewegung.
- 🔧 Eingebunden in `SongList` (`lib/library/song_list.dart`) und in beide
Listen von `artist_list.dart` (Künstler-Übersicht sowie die Zeilen der
Künstler-Detailseite — Alben, Titel und Zwischenüberschriften). Die
wiederverwendete `SongZeile` selbst bleibt unverändert, damit Suche und
Playlist-Detail (die den Wrapper nicht bekommen sollen) unangetastet
bleiben. `my_music_screen.dart` rendert keine eigene Liste (nur
eingebettete `SortableSongList`/`ArtistListScreen`/`CategoryListScreen`)
— dort war nichts einzubinden.
-**Getestet (RED→GREEN):** neuer Widget-Test
`test/shared/einblend_item_test.dart` prüft Start bei Opacity 0, Ziel bei
1,0 nach `pumpAndSettle()`, sofortigen Endzustand bei
`disableAnimations: true` sowie den Deckel bei Index 12 (Index 50 startet
nicht später als Index 12). Bestehende Tests zu `song_list.dart` liefen
bereits mit `pumpAndSettle()` und blieben unverändert grün. Volle Suite
(604 Tests) grün, `flutter analyze` ohne Befund.
### 🔑 Manuelle Baka-Anmeldung übernahm das neue Passwort nie dauerhaft; Auto-Login-Fehler wurde verworfen (2026-08-29)
- 🐛 **Wer sich nach einer fehlgeschlagenen Auto-Anmeldung manuell im
"Baka-Konto"-Dialog mit dem korrekten (neuen) Passwort anmeldete, bekam
denselben Fehler beim nächsten App-Start (nach Ablauf des 7-Tage-Tokens)
garantiert wieder** — unabhängig vom Server-Zustand. Grund: Navidrome-
und Baka-Konto teilen sich laut Design dieselben Zugangsdaten
(`navidrome_service.dart`), aber der manuelle Anmelde-Dialog
(`_AnmeldeDialogState._anmelden()` in `downloads_screen.dart`) schrieb
das eingegebene Passwort nur ins `BakaAuth`-Token — nie zurück in die
lokale Navidrome-Zugangsdaten-Ablage (`NavidromeService`), aus der
`BakaAuth.autoAnmelden()` sich beim nächsten Start bedient. Der manuelle
Login "half" also nur bis zum nächsten Token-Ablauf.
- 🔧 **Fix:** Nach erfolgreichem manuellem Login persistiert der Dialog die
neuen Zugangsdaten jetzt zusätzlich über
`NavidromeService.speichereZugangsdaten(...)`. Dafür bekam
`NavidromeService` einen fehlenden öffentlichen Getter `serverUrl`.
- 🐛 **`BakaAuth.autoAnmelden()` verwarf den Fehlertext von `anmelden()`
komplett** — aus der App war nicht diagnostizierbar, ob ein Auto-Login
an falschem Passwort, Rate-Limit oder Verbindungsfehler scheiterte.
- 🔧 **Fix:** neues Feld `BakaAuth.letzterAutoLoginFehler` hält den
Fehlertext des letzten Auto-Login-Versuchs fest (zusätzlich per
`debugPrint` geloggt) — die bestehende Race-Condition-Absicherung über
`_laufenderAutoLogin` bleibt unverändert erhalten.
-**Getestet (RED→GREEN):** neuer Widget-Test in `online_screen_test.dart`
bestätigt, dass `nav.passwort`/`nav.benutzer` nach erfolgreichem
manuellem Login den neu eingegebenen Wert zeigen; neuer Unit-Test in
`baka_auth_test.dart` bestätigt, dass `letzterAutoLoginFehler` nach
einem fehlgeschlagenen `autoAnmelden()` den Fehlertext trägt statt
`null` zu bleiben. Volle Suite (601 Tests) grün, `flutter analyze` ohne
Befund.
### 🎧 "Zuletzt" zeigte neu Hinzugefügtes statt zuletzt Gehörtem; Herz saß fern vom Songnamen (2026-08-29)
- 🐛 **Der Schnellzugriff "Zuletzt" auf "Meine Musik" zeigte "zuletzt hinzugefügte" Songs,
nicht "zuletzt gehörte"** — von Tinker gemeldet. Sowohl die Karte als auch der
Vollbild-Screen dahinter nutzten `db.watchRecent()`, das nach `dateAddedMs`
(Hinzufüge-Datum) sortiert, nicht nach dem tatsächlichen Abspielen.
- 🔧 **Fix:** neue Methode `MeloDb.watchRecentlyPlayed()` (`database.dart`) wertet
stattdessen die `PlaybackHistory`-Tabelle aus — eine Subquery ermittelt je Song per
`GROUP BY songId` / `MAX(playedAtMs)` nur den jüngsten Play-Zeitpunkt, damit ein
mehrfach gehörter Song nur einmal erscheint (an der Position seines letzten
Abspielens), zurückverknüpft auf `songs` (ohne getombstonte). "Zuletzt" in
`my_music_screen.dart` (Karte + Vollbild-Screen, `RecentlyAddedScreen` dafür in
`RecentlyPlayedScreen` umbenannt) nutzt jetzt diese Methode.
- 🐛 **Das Favoriten-Herz im Vollbild-Player saß oben in der AppBar**, weit weg vom
Songnamen — ebenfalls von Tinker gemeldet.
- 🔧 **Fix:** `_Herz` aus der AppBar-`actions`-Row entfernt und stattdessen direkt
neben den Titel in `_Angaben` gesetzt (`now_playing_screen.dart`).
-**Getestet:** 3 neue Unit-Tests für `watchRecentlyPlayed()` (RED→GREEN:
Mehrfach-Play erscheint nur einmal an der neuesten Position, mehrere Songs
absteigend sortiert, getombstonter Song mit Historie fehlt) sowie ein neuer
Widget-Test, der bestätigt, dass das Herz nicht mehr in der AppBar, sondern in
derselben Row wie der Songtitel sitzt. `flutter analyze` ohne Befund.
### 🔑 Auto-Anmeldung schlug beim App-Start fehl — betraf ALLE drei Nutzer (2026-08-29)
- 🐛 **Die automatische Baka-Anmeldung klappte beim App-Start oft nicht**
die App fragte dann nach dem "Baka-Konto", obwohl die Zugangsdaten
korrekt waren. Betraf **alle drei Nutzer** (Dustin, Baka, Tinker), nicht
nur einen — von Dustin selbst gemeldet und bei allen drei bestätigt.
Grund: `main.dart` baut die 5 Haupt-Tabs über `IndexedStack` alle sofort
beim ersten Frame, nicht erst beim Umschalten. Der Download-Tab und die
YT-Suche lösen dabei beide unabhängig voneinander denselben Auto-Login
aus (`pruefeServerUser()``BakaAuth.autoAnmelden()`) — praktisch
gleichzeitig, mit denselben Zugangsdaten. `autoAnmelden()` hatte keine
Schutzvorkehrung gegen so einen doppelten Aufruf (der `istAngemeldet`-
Check lief synchron, bevor die erste Anfrage zurückkam), also gingen
zwei fast-gleichzeitige Login-Anfragen an denselben Server raus — der
lehnte vermutlich eine davon ab (Session-/Lock-Konflikt).
- 🔧 **Fix:** `BakaAuth.autoAnmelden()` in `baka_auth.dart` hängt einen
überlappenden Aufruf jetzt an den bereits laufenden Login-Versuch an
(`_laufenderAutoLogin`), statt einen zweiten Request loszuschicken.
- 🔧 **Nebenbei zwei kleine Anmelde-Dialoge korrigiert:** Der Anmelde-
Dialog im Download-Tab (`downloads_screen.dart`) zeigte das
Benutzername-Feld immer mit "Baka" vorausgefüllt, egal wer die App
nutzt — zeigt jetzt den tatsächlich bekannten Navidrome-Benutzernamen
(leer, falls keiner bekannt). Der Navidrome-Dialog in den Einstellungen
(`settings_screen.dart`) wählte unter Baka/Tinker/Dustin immer "Baka"
vor — wählt jetzt den zuletzt bekannten Benutzer vor, falls bekannt.
-**Getestet:** neuer Unit-Test für `autoAnmelden()` (RED→GREEN, zwei
gleichzeitige Aufrufe lösen nur noch einen HTTP-Request aus statt
zwei) sowie ein neuer Widget-Test für die Benutzername-Vorbelegung im
Download-Tab-Dialog (RED→GREEN). Volle Suite grün, `flutter analyze`
ohne Befund.
### ⬅️ Zurück-Geste auf Nicht-Start-Tabs minimierte die App (2026-08-27)
- 🐛 **Auf "Favoriten" (oder einem anderen Tab außer "Meine Musik") tippen und
dann die System-Zurück-Geste nutzen minimierte die App**, statt zur
vorherigen Ansicht zu navigieren. Grund: Tab-Wechsel in `HomeShell`
laufen nur über `setState` (`IndexedStack` + `BottomNavigationBar`), nie
über `Navigator.push` — es lag also nie eine Route auf dem
Navigator-Stack, die eine Zurück-Geste hätte poppen können.
- 🔧 **Fix:** `build()` in `main.dart` in ein `PopScope` gewickelt
(`canPop: _index == 0`), das bei einem Nicht-Start-Tab zuerst zu Tab 0
("Meine Musik") zurückspringt, statt die App zu verlassen.
-**Getestet:** neuer Widget-Test in `home_shell_test.dart` (RED→GREEN,
simuliert die System-Zurück-Geste über `WidgetsApp.didPopRoute()`), volle
Suite (593 Tests) grün, `flutter analyze` ohne Befund.
### 🔄 Doppelten Scan-Button auf Android entfernt (2026-08-27)
- 🐛 **In den Einstellungen gab es auf Android zwei Buttons für dieselbe
Aktion** ("Musik scannen" und "Erneut scannen") — beide riefen dort
denselben geräteweiten MediaStore-Scan auf (`LibraryService.
pickFolderAndScan()` und `.rescan()` sind auf Android identisch, da
Scoped Storage keine Ordnerwahl erlaubt). Nur auf Desktop unterscheiden
sie sich echt (Ordner hinzufügen vs. bekannte Ordner erneut scannen).
- 🔧 **Fix:** Der zweite `ListTile` ("Erneut scannen") wird in
`settings_screen.dart` nur noch angezeigt, wenn `zeigeErneutScannenButton
(Platform.isAndroid)` das zulässt. Die Sichtbarkeits-Entscheidung ist als
pure Funktion in `library_service.dart` ausgelagert (statt direkt
`Platform.isAndroid` in der UI abzufragen), weil sich die echte Plattform
in Flutter-Tests nicht sauber auf "Android" umschalten lässt.
-**Getestet:** 2 neue Unit-Tests für `zeigeErneutScannenButton` (RED→
GREEN), volle Suite (592 Tests) grün, `flutter analyze` ohne Befund.
### 🎧 Song antippen öffnet den Vollbild-Player (2026-08-27)
- 🐛 **Ein Song antippen öffnete früher nur die Wiedergabe, ohne zum
Vollbild-Player mit großem Cover zu wechseln** — man landete weiter auf
der Bibliotheks-/Playlist-/Server-Liste und musste erst den Mini-Player
antippen oder hochwischen, um das große Cover zu sehen. Behoben an den
drei Stellen, an denen ein Song EXPLIZIT zum Abspielen angetippt wird:
Bibliothek (`song_list.dart`), Wiedergabeliste
(`playlist_detail_screen.dart`) und Server-Titel
(`server_titel_screen.dart`, dort auch für die Knöpfe "Abspielen" und
"Zufällig", weil sie über dieselbe zentrale `_spiele`-Methode laufen).
Nutzt dasselbe, im Projekt etablierte Navigationsmuster wie der
Mini-Player (`Navigator.push(MaterialPageRoute(builder: (_) =>
NowPlayingScreen()))`), nach erfolgreicher Wiedergabe und vor einer
eventuellen Offline-Snackbar, damit die Meldung auf dem neuen Screen
sichtbar bleibt.
- ↩️ **Bewusst unverändert:** `queue_screen.dart` (Song innerhalb der
bereits offenen Warteschlange antippen) — dort ist man schon im
Player-Kontext, ein erneutes Aufspringen des Vollbild-Players bei jedem
Sprung wäre aufdringlich.
-**Getestet:** 3 neue Widget-Tests (RED→GREEN, je einer pro Stelle),
volle Suite (590 Tests) grün, `flutter analyze` ohne Befund.
### 📺🔑 YouTube-Tab: Server-User brauchen keine eigene Baka-Anmeldung mehr (2026-08-26)
+88
View File
@@ -0,0 +1,88 @@
# Sync-Ausbau — Kontext-Sicherung (2026-08-27)
Diese Datei ist eine Übergabe für eine neue Session. Sie ersetzt nicht die
Spec/den Plan, sondern sagt: wo stehen wir, was ist als Nächstes dran.
**Wenn diese Datei erledigt ist (Implementierung fertig oder Plan überholt):
löschen, nicht liegen lassen — sie ist kein Dauerdokument.**
## Die zwei maßgeblichen Dokumente
1. **Spec:** `docs/superpowers/specs/2026-08-27-sync-ausbau-design.md`
Status: **Freigegeben, umsetzungsbereit.** Durch ein 5-Reviewer-Panel
(agent-review-panel) geprüft, nachgeschärft, gegengelesen.
2. **Implementierungsplan:** `docs/superpowers/plans/2026-08-27-sync-ausbau.md`
13 Tasks nach TDD (echter Code in jedem Schritt, kein Platzhalter),
geprüft und korrigiert.
Beide sind committed und gepusht auf Branch `fix/p0-vollwertigkeit`
(bis Commit `1940e2b7909`).
## Was das Feature ist (kurz)
Sync-Ausbau der Melo-App: Favoriten-Merge-Fix (Datenverlust-Bug),
gezielter Song-Upload im Auswahl-Modus, Einzel-Song-Offline,
Playlist-Sicherung (einseitig), „Was ist neu"-Bericht. SSE, persistente
Notification und beidseitiger Playlist-Merge sind bewusst spätere Stufen,
nicht Teil dieser Runde.
## Aktueller Stand — was schon passiert ist
1. Bestandsaufnahme (6 parallele Leser über App/Server/Navidrome/Cross-Platform/Melo-v2).
2. Brainstorming + Spec geschrieben, mit Dustin abgestimmt.
3. **agent-review-panel** (5 Reviewer, 2 Debattenrunden, Audit, Verifikation,
Richterurteil): Score 6/10, Verdikt „nachschärfen dann freigeben". Bericht:
`docs/reviews/2026-08-27-sync-ausbau/review_panel_report.md`.
4. Spec nach den 17 Aktionspunkten des Urteils überarbeitet, gegengelesen,
freigegeben.
5. Implementierungsplan geschrieben, geprüft (fand 3 echte
Server-Vertragsfehler in Task 11 — korrigiert), Korrekturrunde committed.
6. **Der einzige echte Blocker ist behoben:** Ein irreversibler Löschpfad in
`melo_cloud.py` (verschwindet eine lokale Datei, wurde sie serverseitig
endgültig gelöscht, erneutes Hochladen reparierte es nicht). Hermes hat
den Fix eingebaut (Datei-Wiederherstellung im Dedup-Zweig von `upload()`),
ich habe ihn end-to-end getestet (eigene Testdatei, Fake-Nutzer, danach
restlos aufgeräumt — Registry vor/nach Test bei 325 Titeln): Upload →
Löschung (Bug reproduziert, Download 404) → erneuter Upload → **beide
Dateien bitgenau wiederhergestellt.** Spec und Plan sind entsprechend
aktualisiert (§ERLEDIGT in der Spec, ENTBLOCKT-Marker im Plan).
## Nächster Schritt
**Implementierungsplan, Task 1: „Reine Merge-Funktionen (`sync_merge.dart`)“**
(Zeile ~104 im Plan). Tasks 19 sind vollständig entblockt und können sofort
starten, in der im Plan festgelegten Reihenfolge (Favoriten-Fix zuerst).
Empfohlener Einstieg für die neue Session: die Skill
`superpowers:subagent-driven-development` (Pflicht-Sub-Skill laut Plankopf)
für die task-weise Umsetzung nutzen, wie schon beim vorherigen Feature
(YouTube-Gast-Zugang) erfolgreich gemacht.
## Was noch offen ist (kein Blocker, aber zu klären)
- **Tasks 1012 (Playlist-Sicherung, Feature 2):** bauen oder streichen?
Heute 0 Playlisten auf dem Server. Plan empfiehlt: vertagen, bis eine
echte Playlist existiert. Steht im Plan unter „Offene Punkte, die vor
bzw. während der Umsetzung an Dustin gehen".
- **Server-Hygiene (an Hermes, eilt nicht):** `_link_user()` im Dedup-Zweig
von `upload()` legt einen dritten Hardlink unter `users/<user>/<sid>.mp3`
an, den `_entferne_datei_wenn_verwaist()` beim Löschen nicht mit abräumt.
Bisher folgenlos, aber seit dem Wiederherstellungs-Fix hinterlässt jeder
Dedup-Upload einen verwaisten Hardlink.
- **App-Seite, bewusst unangetastet:** `markMissing` tombstoned großzügig,
die Lösch-Bremse greift erst ab 109 von 325 Titeln. Der Schaden ist jetzt
reparabel (siehe oben), also kein Blocker mehr — ob die App trotzdem
vorsichtiger werden soll, ist eine eigene, spätere Entscheidung.
## Regeln, die für die neue Session gelten (aus Erfahrung dieser Session)
- Worktree-Lock beachten: `.claude-worktree-lock` im Repo-Root prüfen/setzen/
entfernen (siehe `melo-app-workflow`-Skill).
- `flutter test` im Hintergrund laufen lassen (600+ Tests, mehrere Minuten,
kein kurzer Foreground-Timeout).
- Vor jedem Commit: Qualitäts-Gate (analyze + test) läuft automatisch als
Pre-Commit-Hook — das ist schon eingerichtet, nichts zu tun.
- CHANGELOG.md nach jeder Aufgabe aktualisieren (Projektregel).
- Bei fertigem Arbeitspaket: melden und stoppen, nicht autonom weitermachen
(Dustin startet dann bewusst eine frische Session — siehe
Memory `feedback_melden-und-stoppen`).
+20 -4
View File
@@ -679,9 +679,10 @@ class _YouTubeBereichState extends State<_YouTubeBereich> {
}
Future<void> _anmelden() async {
final nav = context.read<DownloadService>().navidrome;
await showDialog(
context: context,
builder: (_) => const _AnmeldeDialog(),
builder: (_) => _AnmeldeDialog(benutzer: nav.benutzer),
);
}
@@ -869,14 +870,18 @@ class _YouTubeBereichState extends State<_YouTubeBereich> {
/// Fragt Benutzername und Passwort ab und gibt beides zurück.
class _AnmeldeDialog extends StatefulWidget {
const _AnmeldeDialog();
const _AnmeldeDialog({this.benutzer = ''});
/// Bereits bekannter Navidrome-Benutzername (leer, falls keiner bekannt) —
/// vorausgefüllt statt immer "Baka" zu zeigen, egal wer die App nutzt.
final String benutzer;
@override
State<_AnmeldeDialog> createState() => _AnmeldeDialogState();
}
class _AnmeldeDialogState extends State<_AnmeldeDialog> {
final _benutzer = TextEditingController(text: 'Baka');
late final _benutzer = TextEditingController(text: widget.benutzer);
final _passwort = TextEditingController();
bool _sichtbar = false;
bool _verbindet = false;
@@ -895,9 +900,20 @@ class _AnmeldeDialogState extends State<_AnmeldeDialog> {
_fehler = null;
});
final auth = context.read<BakaAuth>();
final fehler = await auth.anmelden(_benutzer.text.trim(), _passwort.text);
// Randständige Leerzeichen entfernen (verdeckte
// Fehlerquelle im obscureText-Feld / bei Autofill).
final passwort = _passwort.text.trim();
final fehler = await auth.anmelden(_benutzer.text.trim(), passwort);
if (!mounted) return;
if (fehler == null) {
// Navidrome- und Baka-Konto teilen sich die Zugangsdaten (siehe
// navidrome_service.dart) — ohne diese Übernahme würde der nächste
// Auto-Login nach Ablauf des Baka-Tokens wieder mit dem alten
// Passwort scheitern.
final nav = context.read<DownloadService>().navidrome;
await nav.speichereZugangsdaten(
nav.serverUrl, _benutzer.text.trim(), passwort);
if (!mounted) return;
Navigator.pop(context);
return;
}
+11 -61
View File
@@ -5,7 +5,7 @@ import 'package:provider/provider.dart';
import '../library/database.dart';
import '../library/song_media.dart';
import '../player/audio_handler.dart';
import '../services/download_service.dart';
import '../player/now_playing_screen.dart';
import '../services/navidrome_service.dart';
import '../shared/cover.dart';
import '../shared/lauf_balken.dart';
@@ -70,45 +70,6 @@ class _ServerTitelScreenState extends State<ServerTitelScreen> {
}
}
/// Nach Laden oder Entfernen ist der Einmal-Schnappschuss [_geladen] veraltet
/// — hier wird er nachgezogen.
Future<void> _aktualisiereGeladen() async {
final geladen = await context.read<MeloDb>().downloadIds();
if (mounted) setState(() => _geladen = geladen);
}
Future<void> _offlineNehmen(SubsonicSong song) async {
final dienst = context.read<DownloadService>();
final messenger = ScaffoldMessenger.of(context);
if (dienst.laeuft) {
messenger.showSnackBar(
const SnackBar(content: Text('Es läuft schon ein Download')),
);
return;
}
final neu = await dienst.ladeEinzelnenTitel(song);
await _aktualisiereGeladen();
if (!mounted) return;
messenger.showSnackBar(SnackBar(
content: Text(neu
? 'Offline: ${song.titel}'
: (dienst.fehler ?? 'War schon heruntergeladen')),
));
}
Future<void> _offlineEntfernen(SubsonicSong song) async {
final dienst = context.read<DownloadService>();
final messenger = ScaffoldMessenger.of(context);
final weg = await dienst.entferne(song.id);
await _aktualisiereGeladen();
if (!mounted) return;
messenger.showSnackBar(SnackBar(
content: Text(weg
? 'Vom Gerät entfernt: ${song.titel}'
: (dienst.fehler ?? 'Ließ sich nicht entfernen')),
));
}
Future<void> _spiele(List<SubsonicSong> songs, int ab) async {
final handler = context.read<MeloAudioHandler>();
final messenger = ScaffoldMessenger.of(context);
@@ -117,6 +78,10 @@ class _ServerTitelScreenState extends State<ServerTitelScreen> {
];
try {
final uebersprungen = await handler.loadPlaylist(items, startIndex: ab);
if (!mounted) return;
Navigator.of(context).push(
MaterialPageRoute(builder: (_) => const NowPlayingScreen()),
);
if (uebersprungen > 0) {
messenger.showSnackBar(
SnackBar(content: Text(offlineHinweis(uebersprungen))),
@@ -170,8 +135,6 @@ class _ServerTitelScreenState extends State<ServerTitelScreen> {
nummer: i,
geladen: _geladen.contains(song.id),
onTap: () => _spiele(songs, i - 1),
onOffline: () => _offlineNehmen(song),
onEntfernen: () => _offlineEntfernen(song),
);
},
),
@@ -272,16 +235,12 @@ class _Zeile extends StatelessWidget {
required this.nummer,
required this.geladen,
required this.onTap,
required this.onOffline,
required this.onEntfernen,
});
final SubsonicSong song;
final int nummer;
final bool geladen;
final VoidCallback onTap;
final VoidCallback onOffline;
final VoidCallback onEntfernen;
static String _dauer(int sekunden) {
final m = (sekunden ~/ 60).toString();
@@ -332,21 +291,12 @@ class _Zeile extends StatelessWidget {
trailing: Row(
mainAxisSize: MainAxisSize.min,
children: [
// Bisher gab es den Lade-Knopf nur je Album — einen einzelnen
// Titel mitzunehmen ging gar nicht.
geladen
? IconButton(
tooltip: 'Vom Gerät entfernen',
icon: const Icon(Icons.download_done,
size: 20, color: MeloTheme.red),
onPressed: onEntfernen,
)
: IconButton(
tooltip: 'Offline nehmen',
icon: const Icon(Icons.download_outlined,
size: 20, color: MeloTheme.text3),
onPressed: onOffline,
),
if (geladen)
const Padding(
padding: EdgeInsets.only(right: MeloSpace.sm),
child: Icon(Icons.download_done,
size: 16, color: MeloTheme.text3),
),
Text(_dauer(song.dauerSekunden),
style: const TextStyle(color: MeloTheme.text3)),
],
+28 -18
View File
@@ -5,6 +5,7 @@ import '../settings/app_settings.dart';
import '../shared/auswahl.dart';
import '../shared/auswahl_leiste.dart';
import '../shared/cover.dart';
import '../shared/einblend_item.dart';
import '../shared/theme.dart';
import '../shared/titel_listen_screen.dart';
import 'category_service.dart';
@@ -44,7 +45,10 @@ class _ArtistListScreenState extends State<ArtistListScreen> {
itemCount: artists.length,
itemBuilder: (context, i) {
final artist = artists[i];
return _KuenstlerZeile(name: artist, songs: grouped[artist]!);
return EinblendItem(
index: i,
child: _KuenstlerZeile(name: artist, songs: grouped[artist]!),
);
},
);
},
@@ -167,25 +171,31 @@ class _KuenstlerScreenState extends State<KuenstlerScreen> {
body: ListView.builder(
itemCount: vorspann + widget.songs.length,
itemBuilder: (context, i) {
if (zeigeAlben) {
if (i == 0) return const _Kopf('Alben');
if (i <= albumListe.length) {
final eintrag = albumListe[i - 1];
return _AlbumZeile(name: eintrag.key, songs: eintrag.value);
Widget zeile() {
if (zeigeAlben) {
if (i == 0) return const _Kopf('Alben');
if (i <= albumListe.length) {
final eintrag = albumListe[i - 1];
return _AlbumZeile(name: eintrag.key, songs: eintrag.value);
}
if (i == albumListe.length + 1) {
return const Divider(height: 1);
}
if (i == albumListe.length + 2) return const _Kopf('Alle Titel');
}
if (i == albumListe.length + 1) return const Divider(height: 1);
if (i == albumListe.length + 2) return const _Kopf('Alle Titel');
final index = i - vorspann;
final song = widget.songs[index];
return SongZeile(
song: song,
warteschlange: widget.songs,
index: index,
auswahlModus: _waehltAus,
ausgewaehlt: _auswahl.contains(song.id),
onAuswahlWechsel: () => _wechsleAuswahl(song.id),
);
}
final index = i - vorspann;
final song = widget.songs[index];
return SongZeile(
song: song,
warteschlange: widget.songs,
index: index,
auswahlModus: _waehltAus,
ausgewaehlt: _auswahl.contains(song.id),
onAuswahlWechsel: () => _wechsleAuswahl(song.id),
);
return EinblendItem(index: i, child: zeile());
},
),
),
+30 -36
View File
@@ -72,10 +72,6 @@ class Playlists extends Table {
IntColumn get updatedAtMs => integer()();
BoolColumn get deleted => boolean().withDefault(const Constant(false))();
/// ID derselben Playlist am Melo-Server, sobald sie einmal gesichert
/// wurde. `null` heißt: nur auf diesem Gerät.
TextColumn get cloudId => text().nullable()();
@override
Set<Column> get primaryKey => {id};
}
@@ -152,7 +148,7 @@ class MeloDb extends _$MeloDb {
MeloDb([QueryExecutor? executor]) : super(executor ?? _open());
@override
int get schemaVersion => 11;
int get schemaVersion => 10;
@override
MigrationStrategy get migration => MigrationStrategy(
@@ -194,9 +190,6 @@ class MeloDb extends _$MeloDb {
if (from < 10) {
await m.createTable(downloads);
}
if (from < 11) {
await m.addColumn(playlists, playlists.cloudId);
}
},
);
@@ -219,6 +212,35 @@ class MeloDb extends _$MeloDb {
.watch();
}
/// Überwacht die zuletzt GEHÖRTEN Songs (nicht getombstonte), aus
/// [PlaybackHistory]. Ein mehrfach gespielter Song erscheint nur einmal —
/// an der Position seines jüngsten Abspielens. Dafür wird pro [songId]
/// zuerst der jüngste `playedAtMs`-Eintrag ermittelt (Subquery mit
/// `GROUP BY`), und darüber zurück auf [songs] verknüpft.
Stream<List<Song>> watchRecentlyPlayed({int limit = 50}) {
final letzterPlay = playbackHistory.playedAtMs.max();
final letztePlaysProSong = selectOnly(playbackHistory)
..addColumns([playbackHistory.songId, letzterPlay])
..groupBy([playbackHistory.songId]);
final subquery = Subquery(letztePlaysProSong, 'letzte_plays');
final letzterPlayRef = subquery.ref(letzterPlay);
final query = select(songs).join([
innerJoin(
subquery,
subquery.ref(playbackHistory.songId).equalsExp(songs.id),
useColumns: false,
),
])
..where(songs.deleted.equals(false))
..orderBy([
OrderingTerm(expression: letzterPlayRef, mode: OrderingMode.desc)
])
..limit(limit);
return query.watch().map((rows) => rows.map((r) => r.readTable(songs)).toList());
}
/// Alle Songs inkl. getombstonte. Intern für ID-Stabilität beim Scan.
Future<List<Song>> allSongs() => select(songs).get();
@@ -291,26 +313,6 @@ class MeloDb extends _$MeloDb {
);
}
Future<Playlist?> playlistById(String id) =>
(select(playlists)..where((p) => p.id.equals(id))).getSingleOrNull();
Future<void> setPlaylistCloudId(String id, String cloudId) async {
await (update(playlists)..where((p) => p.id.equals(id)))
.write(PlaylistsCompanion(cloudId: Value(cloudId)));
}
/// Wie viele Playlisten es hier gibt — **inklusive Grabsteinen**.
///
/// Grundlage der Wiederherstellung: nur eine wirklich leere Tabelle gilt
/// als Neuinstallation. Wer alle Playlisten selbst gelöscht hat, soll sie
/// nicht vom Server zurückbekommen.
Future<int> countPlaylists() async {
final zaehler = playlists.id.count();
final zeile = await (selectOnly(playlists)..addColumns([zaehler]))
.getSingle();
return zeile.read(zaehler) ?? 0;
}
// === PlaylistSongs ===
Stream<List<Song>> watchPlaylistSongs(String playlistId) {
final query = select(songs).join([
@@ -546,14 +548,6 @@ class MeloDb extends _$MeloDb {
.write(SongsCompanion(cloudId: Value(cloudId)));
}
Future<Song?> songByCloudId(String cloudId) async {
final treffer = await (select(songs)
..where((s) => s.cloudId.equals(cloudId))
..limit(1))
.get();
return treffer.isEmpty ? null : treffer.single;
}
/// Titel, die am Server gelöscht wurden, auch auf dem Gerät als gelöscht
/// markieren. Grabstein statt echtem Löschen — sonst legt der nächste Scan
/// sie wieder an.
+4 -81
View File
@@ -1322,17 +1322,6 @@ class $PlaylistsTable extends Playlists
),
defaultValue: const Constant(false),
);
static const VerificationMeta _cloudIdMeta = const VerificationMeta(
'cloudId',
);
@override
late final GeneratedColumn<String> cloudId = GeneratedColumn<String>(
'cloud_id',
aliasedName,
true,
type: DriftSqlType.string,
requiredDuringInsert: false,
);
@override
List<GeneratedColumn> get $columns => [
id,
@@ -1341,7 +1330,6 @@ class $PlaylistsTable extends Playlists
createdAtMs,
updatedAtMs,
deleted,
cloudId,
];
@override
String get aliasedName => _alias ?? actualTableName;
@@ -1405,12 +1393,6 @@ class $PlaylistsTable extends Playlists
deleted.isAcceptableOrUnknown(data['deleted']!, _deletedMeta),
);
}
if (data.containsKey('cloud_id')) {
context.handle(
_cloudIdMeta,
cloudId.isAcceptableOrUnknown(data['cloud_id']!, _cloudIdMeta),
);
}
return context;
}
@@ -1444,10 +1426,6 @@ class $PlaylistsTable extends Playlists
DriftSqlType.bool,
data['${effectivePrefix}deleted'],
)!,
cloudId: attachedDatabase.typeMapping.read(
DriftSqlType.string,
data['${effectivePrefix}cloud_id'],
),
);
}
@@ -1464,10 +1442,6 @@ class Playlist extends DataClass implements Insertable<Playlist> {
final int createdAtMs;
final int updatedAtMs;
final bool deleted;
/// ID derselben Playlist am Melo-Server, sobald sie einmal gesichert
/// wurde. `null` heißt: nur auf diesem Gerät.
final String? cloudId;
const Playlist({
required this.id,
required this.name,
@@ -1475,7 +1449,6 @@ class Playlist extends DataClass implements Insertable<Playlist> {
required this.createdAtMs,
required this.updatedAtMs,
required this.deleted,
this.cloudId,
});
@override
Map<String, Expression> toColumns(bool nullToAbsent) {
@@ -1488,9 +1461,6 @@ class Playlist extends DataClass implements Insertable<Playlist> {
map['created_at_ms'] = Variable<int>(createdAtMs);
map['updated_at_ms'] = Variable<int>(updatedAtMs);
map['deleted'] = Variable<bool>(deleted);
if (!nullToAbsent || cloudId != null) {
map['cloud_id'] = Variable<String>(cloudId);
}
return map;
}
@@ -1504,9 +1474,6 @@ class Playlist extends DataClass implements Insertable<Playlist> {
createdAtMs: Value(createdAtMs),
updatedAtMs: Value(updatedAtMs),
deleted: Value(deleted),
cloudId: cloudId == null && nullToAbsent
? const Value.absent()
: Value(cloudId),
);
}
@@ -1522,7 +1489,6 @@ class Playlist extends DataClass implements Insertable<Playlist> {
createdAtMs: serializer.fromJson<int>(json['createdAtMs']),
updatedAtMs: serializer.fromJson<int>(json['updatedAtMs']),
deleted: serializer.fromJson<bool>(json['deleted']),
cloudId: serializer.fromJson<String?>(json['cloudId']),
);
}
@override
@@ -1535,7 +1501,6 @@ class Playlist extends DataClass implements Insertable<Playlist> {
'createdAtMs': serializer.toJson<int>(createdAtMs),
'updatedAtMs': serializer.toJson<int>(updatedAtMs),
'deleted': serializer.toJson<bool>(deleted),
'cloudId': serializer.toJson<String?>(cloudId),
};
}
@@ -1546,7 +1511,6 @@ class Playlist extends DataClass implements Insertable<Playlist> {
int? createdAtMs,
int? updatedAtMs,
bool? deleted,
Value<String?> cloudId = const Value.absent(),
}) => Playlist(
id: id ?? this.id,
name: name ?? this.name,
@@ -1554,7 +1518,6 @@ class Playlist extends DataClass implements Insertable<Playlist> {
createdAtMs: createdAtMs ?? this.createdAtMs,
updatedAtMs: updatedAtMs ?? this.updatedAtMs,
deleted: deleted ?? this.deleted,
cloudId: cloudId.present ? cloudId.value : this.cloudId,
);
Playlist copyWithCompanion(PlaylistsCompanion data) {
return Playlist(
@@ -1570,7 +1533,6 @@ class Playlist extends DataClass implements Insertable<Playlist> {
? data.updatedAtMs.value
: this.updatedAtMs,
deleted: data.deleted.present ? data.deleted.value : this.deleted,
cloudId: data.cloudId.present ? data.cloudId.value : this.cloudId,
);
}
@@ -1582,22 +1544,14 @@ class Playlist extends DataClass implements Insertable<Playlist> {
..write('description: $description, ')
..write('createdAtMs: $createdAtMs, ')
..write('updatedAtMs: $updatedAtMs, ')
..write('deleted: $deleted, ')
..write('cloudId: $cloudId')
..write('deleted: $deleted')
..write(')'))
.toString();
}
@override
int get hashCode => Object.hash(
id,
name,
description,
createdAtMs,
updatedAtMs,
deleted,
cloudId,
);
int get hashCode =>
Object.hash(id, name, description, createdAtMs, updatedAtMs, deleted);
@override
bool operator ==(Object other) =>
identical(this, other) ||
@@ -1607,8 +1561,7 @@ class Playlist extends DataClass implements Insertable<Playlist> {
other.description == this.description &&
other.createdAtMs == this.createdAtMs &&
other.updatedAtMs == this.updatedAtMs &&
other.deleted == this.deleted &&
other.cloudId == this.cloudId);
other.deleted == this.deleted);
}
class PlaylistsCompanion extends UpdateCompanion<Playlist> {
@@ -1618,7 +1571,6 @@ class PlaylistsCompanion extends UpdateCompanion<Playlist> {
final Value<int> createdAtMs;
final Value<int> updatedAtMs;
final Value<bool> deleted;
final Value<String?> cloudId;
final Value<int> rowid;
const PlaylistsCompanion({
this.id = const Value.absent(),
@@ -1627,7 +1579,6 @@ class PlaylistsCompanion extends UpdateCompanion<Playlist> {
this.createdAtMs = const Value.absent(),
this.updatedAtMs = const Value.absent(),
this.deleted = const Value.absent(),
this.cloudId = const Value.absent(),
this.rowid = const Value.absent(),
});
PlaylistsCompanion.insert({
@@ -1637,7 +1588,6 @@ class PlaylistsCompanion extends UpdateCompanion<Playlist> {
required int createdAtMs,
required int updatedAtMs,
this.deleted = const Value.absent(),
this.cloudId = const Value.absent(),
this.rowid = const Value.absent(),
}) : id = Value(id),
name = Value(name),
@@ -1650,7 +1600,6 @@ class PlaylistsCompanion extends UpdateCompanion<Playlist> {
Expression<int>? createdAtMs,
Expression<int>? updatedAtMs,
Expression<bool>? deleted,
Expression<String>? cloudId,
Expression<int>? rowid,
}) {
return RawValuesInsertable({
@@ -1660,7 +1609,6 @@ class PlaylistsCompanion extends UpdateCompanion<Playlist> {
if (createdAtMs != null) 'created_at_ms': createdAtMs,
if (updatedAtMs != null) 'updated_at_ms': updatedAtMs,
if (deleted != null) 'deleted': deleted,
if (cloudId != null) 'cloud_id': cloudId,
if (rowid != null) 'rowid': rowid,
});
}
@@ -1672,7 +1620,6 @@ class PlaylistsCompanion extends UpdateCompanion<Playlist> {
Value<int>? createdAtMs,
Value<int>? updatedAtMs,
Value<bool>? deleted,
Value<String?>? cloudId,
Value<int>? rowid,
}) {
return PlaylistsCompanion(
@@ -1682,7 +1629,6 @@ class PlaylistsCompanion extends UpdateCompanion<Playlist> {
createdAtMs: createdAtMs ?? this.createdAtMs,
updatedAtMs: updatedAtMs ?? this.updatedAtMs,
deleted: deleted ?? this.deleted,
cloudId: cloudId ?? this.cloudId,
rowid: rowid ?? this.rowid,
);
}
@@ -1708,9 +1654,6 @@ class PlaylistsCompanion extends UpdateCompanion<Playlist> {
if (deleted.present) {
map['deleted'] = Variable<bool>(deleted.value);
}
if (cloudId.present) {
map['cloud_id'] = Variable<String>(cloudId.value);
}
if (rowid.present) {
map['rowid'] = Variable<int>(rowid.value);
}
@@ -1726,7 +1669,6 @@ class PlaylistsCompanion extends UpdateCompanion<Playlist> {
..write('createdAtMs: $createdAtMs, ')
..write('updatedAtMs: $updatedAtMs, ')
..write('deleted: $deleted, ')
..write('cloudId: $cloudId, ')
..write('rowid: $rowid')
..write(')'))
.toString();
@@ -4274,7 +4216,6 @@ typedef $$PlaylistsTableCreateCompanionBuilder =
required int createdAtMs,
required int updatedAtMs,
Value<bool> deleted,
Value<String?> cloudId,
Value<int> rowid,
});
typedef $$PlaylistsTableUpdateCompanionBuilder =
@@ -4285,7 +4226,6 @@ typedef $$PlaylistsTableUpdateCompanionBuilder =
Value<int> createdAtMs,
Value<int> updatedAtMs,
Value<bool> deleted,
Value<String?> cloudId,
Value<int> rowid,
});
@@ -4351,11 +4291,6 @@ class $$PlaylistsTableFilterComposer
builder: (column) => ColumnFilters(column),
);
ColumnFilters<String> get cloudId => $composableBuilder(
column: $table.cloudId,
builder: (column) => ColumnFilters(column),
);
Expression<bool> playlistSongsRefs(
Expression<bool> Function($$PlaylistSongsTableFilterComposer f) f,
) {
@@ -4420,11 +4355,6 @@ class $$PlaylistsTableOrderingComposer
column: $table.deleted,
builder: (column) => ColumnOrderings(column),
);
ColumnOrderings<String> get cloudId => $composableBuilder(
column: $table.cloudId,
builder: (column) => ColumnOrderings(column),
);
}
class $$PlaylistsTableAnnotationComposer
@@ -4460,9 +4390,6 @@ class $$PlaylistsTableAnnotationComposer
GeneratedColumn<bool> get deleted =>
$composableBuilder(column: $table.deleted, builder: (column) => column);
GeneratedColumn<String> get cloudId =>
$composableBuilder(column: $table.cloudId, builder: (column) => column);
Expression<T> playlistSongsRefs<T extends Object>(
Expression<T> Function($$PlaylistSongsTableAnnotationComposer a) f,
) {
@@ -4523,7 +4450,6 @@ class $$PlaylistsTableTableManager
Value<int> createdAtMs = const Value.absent(),
Value<int> updatedAtMs = const Value.absent(),
Value<bool> deleted = const Value.absent(),
Value<String?> cloudId = const Value.absent(),
Value<int> rowid = const Value.absent(),
}) => PlaylistsCompanion(
id: id,
@@ -4532,7 +4458,6 @@ class $$PlaylistsTableTableManager
createdAtMs: createdAtMs,
updatedAtMs: updatedAtMs,
deleted: deleted,
cloudId: cloudId,
rowid: rowid,
),
createCompanionCallback:
@@ -4543,7 +4468,6 @@ class $$PlaylistsTableTableManager
required int createdAtMs,
required int updatedAtMs,
Value<bool> deleted = const Value.absent(),
Value<String?> cloudId = const Value.absent(),
Value<int> rowid = const Value.absent(),
}) => PlaylistsCompanion.insert(
id: id,
@@ -4552,7 +4476,6 @@ class $$PlaylistsTableTableManager
createdAtMs: createdAtMs,
updatedAtMs: updatedAtMs,
deleted: deleted,
cloudId: cloudId,
rowid: rowid,
),
withReferenceMapper: (p0) => p0
+7
View File
@@ -13,6 +13,13 @@ import 'scan_service.dart';
String get addMusicLabel =>
Platform.isAndroid ? 'Musik scannen' : 'Musikordner hinzufügen';
/// Ob der "Erneut scannen"-Button zusätzlich zum [addMusicLabel]-Button
/// angezeigt wird. Auf Android tun [LibraryService.pickFolderAndScan] und
/// [LibraryService.rescan] dasselbe (kompletter MediaStore-Scan) — dort
/// reicht ein Button. Pure Funktion statt direkter [Platform.isAndroid]-
/// Abfrage, damit sie unabhängig von der echten Plattform testbar ist.
bool zeigeErneutScannenButton(bool isAndroid) => !isAndroid;
/// Koordiniert Ordnerwahl und Scans; hält den Scan-Fortschritt für die UI.
/// Android scannt automatisch über MediaStore (Scoped Storage lässt keinen
/// direkten Dateizugriff zu); Desktop scannt vom Nutzer gewählte Ordner.
+9 -10
View File
@@ -120,7 +120,6 @@ class _MyMusicScreenState extends State<MyMusicScreen> {
return SortableSongList(
songs: songs,
storeKey: SortStore.meineMusik,
serverUpload: true,
empty:
lib.scanning ? const SizedBox.shrink() : const _Empty(),
);
@@ -235,17 +234,17 @@ class _QuickAccessRow extends StatelessWidget {
),
if (sektionen.contains(AppSettings.sektionZuletzt))
StreamBuilder<List<Song>>(
stream: db.watchRecent(limit: 50),
stream: db.watchRecentlyPlayed(limit: 50),
builder: (context, snapshot) {
final recent = snapshot.data ?? const <Song>[];
return _QuickCard(
icon: Icons.schedule,
label: 'Zuletzt',
subtitle: 'Neu hinzugefügt',
subtitle: 'Zuletzt gehört',
coverPath: recent.isEmpty ? null : recent.first.coverPath,
onTap: () => Navigator.of(context).push(
MaterialPageRoute(
builder: (_) => const RecentlyAddedScreen()),
builder: (_) => const RecentlyPlayedScreen()),
),
);
},
@@ -364,22 +363,22 @@ class _Empty extends StatelessWidget {
}
}
/// Vollbild-Liste der zuletzt hinzugefügten Songs (Schnellzugriff "Zuletzt").
class RecentlyAddedScreen extends StatelessWidget {
const RecentlyAddedScreen({super.key});
/// Vollbild-Liste der zuletzt gehörten Songs (Schnellzugriff "Zuletzt").
class RecentlyPlayedScreen extends StatelessWidget {
const RecentlyPlayedScreen({super.key});
@override
Widget build(BuildContext context) {
final db = context.read<MeloDb>();
return Scaffold(
appBar: AppBar(title: const Text('Zuletzt hinzugefügt')),
appBar: AppBar(title: const Text('Zuletzt gehört')),
body: StreamBuilder<List<Song>>(
stream: db.watchRecent(limit: 100),
stream: db.watchRecentlyPlayed(limit: 100),
builder: (context, snapshot) {
final songs = snapshot.data ?? const <Song>[];
if (songs.isEmpty) {
return const Center(
child: Text('Noch nichts hinzugefügt',
child: Text('Noch nichts abgespielt',
style: TextStyle(color: MeloTheme.text2)),
);
}
+6 -121
View File
@@ -1,5 +1,4 @@
import 'package:flutter/foundation.dart';
import '../services/melo_cloud_service.dart';
import '../services/navidrome_service.dart';
import 'database.dart';
@@ -7,22 +6,14 @@ import 'database.dart';
/// nach jeder Mutation (für Feedback wie SnackBars — die Listen selbst
/// beobachten UIs direkt über die watch()-Streams von [MeloDb]).
class PlaylistService extends ChangeNotifier {
// `this._cloud` würde den öffentlichen Parameternamen `cloud` zu `_cloud`
// (privat) ändern und die API brechen.
PlaylistService(this.db, {NavidromeService? navidrome, MeloCloudService? cloud})
: _navidrome = navidrome ?? NavidromeService(),
// ignore: prefer_initializing_formals
_cloud = cloud;
PlaylistService(this.db, {NavidromeService? navidrome})
: _navidrome = navidrome ?? NavidromeService();
final MeloDb db;
final NavidromeService _navidrome;
/// Optional: ohne Cloud-Zugang entfällt der Sofort-Push stillschweigend.
final MeloCloudService? _cloud;
Future<String> createPlaylist(String name, {String? description}) async {
final id = await db.createPlaylist(name, description: description);
notifyListeners();
await _sichereNeuePlaylist(id, name);
return id;
}
@@ -31,64 +22,29 @@ class PlaylistService extends ChangeNotifier {
notifyListeners();
}
Future<void> addSongToPlaylist(
String playlistId, String songId, int position) async {
Future<void> addSongToPlaylist(String playlistId, String songId, int position) async {
await db.addSongToPlaylist(playlistId, songId, position);
notifyListeners();
final cloudId = await _cloudIdDerPlaylist(playlistId);
final songCloudId = (await db.songById(songId))?.cloudId;
if (cloudId == null || songCloudId == null) return;
await _still(() =>
_cloud!.fuegePlaylistSongsHinzu(cloudId, [songCloudId]));
}
Future<void> removeSongFromPlaylist(
String playlistId, String songId) async {
final songCloudId = (await db.songById(songId))?.cloudId;
Future<void> removeSongFromPlaylist(String playlistId, String songId) async {
await db.removeSongFromPlaylist(playlistId, songId);
notifyListeners();
final cloudId = await _cloudIdDerPlaylist(playlistId);
if (cloudId == null || songCloudId == null) return;
await _still(() => _cloud!.entfernePlaylistSong(cloudId, songCloudId));
}
Future<void> reorderSong(
String playlistId, String songId, int newPosition) async {
Future<void> reorderSong(String playlistId, String songId, int newPosition) async {
await db.reorderPlaylistSong(playlistId, songId, newPosition);
notifyListeners();
await _sichereReihenfolge(playlistId);
}
Future<void> reorderAll(
String playlistId, List<String> orderedSongIds) async {
Future<void> reorderAll(String playlistId, List<String> orderedSongIds) async {
await db.reorderAllPlaylistSongs(playlistId, orderedSongIds);
notifyListeners();
await _sichereReihenfolge(playlistId);
}
Future<void> toggleFavorite(String songId) async {
await db.toggleFavorite(songId);
notifyListeners();
await _meldeFavorit(songId);
}
/// Meldet den neuen Favoriten-Stand sofort an die Melo-Cloud.
///
/// Deterministisch (`set:true/false`), nicht als Umschalten: ein
/// abweichender Server-Stand darf den Wunsch nicht invertieren. Nur für
/// Titel mit cloudId, und Fehler werden still geschluckt — der nächste
/// Abgleich pusht additiv nach.
Future<void> _meldeFavorit(String songId) async {
final cloud = _cloud;
if (cloud == null || !cloud.istAngemeldet) return;
final cloudId = (await db.songById(songId))?.cloudId;
if (cloudId == null) return;
final gesetzt = await db.watchIsFavorite(songId).first;
try {
await cloud.setzeFavorit(cloudId, gesetzt);
} catch (e) {
debugPrint('Favorit nicht gemeldet: $e');
}
}
/// Lädt alle Favoriten vom Navidrome-Server und importiert sie lokal.
@@ -151,75 +107,4 @@ class PlaylistService extends ChangeNotifier {
return 0;
}
}
/// Führt [aktion] aus und verwirft jeden Fehler.
///
/// Die Sicherung ist einseitig und ohne Rollback: schlägt sie fehl, bleibt
/// der lokale Stand, wie er ist, und die nächste Änderung versucht es
/// erneut.
Future<void> _still(Future<void> Function() aktion) async {
try {
await aktion();
} catch (e) {
debugPrint('Playlist-Sicherung übersprungen: $e');
}
}
Future<String?> _cloudIdDerPlaylist(String playlistId) async {
if (_cloud == null || !_cloud.istAngemeldet) return null;
return (await db.playlistById(playlistId))?.cloudId;
}
Future<void> _sichereNeuePlaylist(String id, String name) async {
final cloud = _cloud;
if (cloud == null || !cloud.istAngemeldet) return;
await _still(() async {
final cloudId = await cloud.legePlaylistAn(name);
await db.setPlaylistCloudId(id, cloudId);
});
}
Future<void> _sichereReihenfolge(String playlistId) async {
final cloudId = await _cloudIdDerPlaylist(playlistId);
if (cloudId == null) return;
final songs = await db.watchPlaylistSongs(playlistId).first;
final ids = [
for (final s in songs)
if (s.cloudId != null) s.cloudId!,
];
if (ids.isEmpty) return;
await _still(() => _cloud!.setzePlaylistReihenfolge(cloudId, ids));
}
/// Holt die Playlisten des Servers **nur** auf ein Gerät ohne eigene:
/// Neuinstallation oder Wiederherstellung.
///
/// Es gibt bewusst keinen Rück-Merge — Umbenennungen und Änderungen eines
/// zweiten Geräts erscheinen hier nicht. Der beidseitige Abgleich ist eine
/// eigene, spätere Spec.
Future<int> stelleWiederHer() async {
final cloud = _cloud;
if (cloud == null || !cloud.istAngemeldet) return 0;
if (await db.countPlaylists() > 0) return 0;
var angelegt = 0;
try {
for (final vomServer in await cloud.playlisten()) {
final id = await db.createPlaylist(vomServer.name);
await db.setPlaylistCloudId(id, vomServer.id);
final songCloudIds = await cloud.playlistSongs(vomServer.id);
var position = 0;
for (final songCloudId in songCloudIds) {
final song = await db.songByCloudId(songCloudId);
if (song == null) continue;
await db.addSongToPlaylist(id, song.id, position++);
}
angelegt++;
}
} catch (e) {
debugPrint('Playlist-Wiederherstellung abgebrochen: $e');
}
notifyListeners();
return angelegt;
}
}
+17 -8
View File
@@ -3,9 +3,11 @@ import 'package:flutter/material.dart';
import 'package:provider/provider.dart';
import '../player/audio_handler.dart';
import '../player/now_playing_screen.dart';
import '../playlists/create_playlist_dialog.dart';
import '../settings/app_settings.dart';
import '../shared/cover.dart';
import '../shared/einblend_item.dart';
import '../shared/favorite_button.dart';
import '../shared/lauf_balken.dart';
import 'category_service.dart';
@@ -93,15 +95,18 @@ class SongList extends StatelessWidget {
controller: controller,
itemExtent: festeHoehe ? songZeilenHoeheFuer(context) : null,
itemCount: songs.length,
itemBuilder: (context, i) => SongZeile(
song: songs[i],
warteschlange: songs,
itemBuilder: (context, i) => EinblendItem(
index: i,
auswahlModus: gewaehlt != null && gewaehlt.isNotEmpty,
ausgewaehlt: gewaehlt?.contains(songs[i].id) ?? false,
onAuswahlWechsel: onAuswahlWechsel == null
? null
: () => onAuswahlWechsel!(songs[i].id),
child: SongZeile(
song: songs[i],
warteschlange: songs,
index: i,
auswahlModus: gewaehlt != null && gewaehlt.isNotEmpty,
ausgewaehlt: gewaehlt?.contains(songs[i].id) ?? false,
onAuswahlWechsel: onAuswahlWechsel == null
? null
: () => onAuswahlWechsel!(songs[i].id),
),
),
);
}
@@ -378,6 +383,10 @@ class SongZeile extends StatelessWidget {
coverOf: (s) => categories.coverFor(s,
groupByCategory: settings.groupCoversByCategory),
);
if (!context.mounted) return;
Navigator.of(context).push(
MaterialPageRoute(builder: (_) => const NowPlayingScreen()),
);
if (uebersprungen > 0) {
messenger.showSnackBar(
SnackBar(content: Text(offlineHinweis(uebersprungen))),
+44 -69
View File
@@ -30,7 +30,6 @@ import 'services/sync_service.dart';
import 'services/yt_download_service.dart';
import 'services/yt_search_service.dart';
import 'settings/app_settings.dart';
import 'shared/sync_bericht_dialog.dart';
import 'shared/theme.dart';
late final MeloAudioHandler _handler;
@@ -52,6 +51,7 @@ Future<void> main() async {
await logger.init();
_db = MeloDb();
_library = LibraryService(_db);
_playlists = PlaylistService(_db);
_offlineMode = OfflineMode();
await _offlineMode.init();
_categories = CategoryService(_db);
@@ -83,12 +83,6 @@ Future<void> main() async {
cloud: MeloCloudService(auth: _bakaAuth),
);
await _sync.laden();
// Erst hier: der Sofort-Push braucht den angemeldeten Cloud-Zugang, und
// _bakaAuth entsteht weiter oben.
_playlists = PlaylistService(
_db,
cloud: MeloCloudService(auth: _bakaAuth),
);
final navidrome = NavidromeService();
await navidrome.ladeGespeicherteZugangsdaten();
_downloads = DownloadService(db: _db, navidrome: navidrome);
@@ -178,7 +172,7 @@ class _HomeShellState extends State<HomeShell> with WidgetsBindingObserver {
WidgetsBinding.instance.addObserver(this);
// Beim Start einmal mit dem Server abgleichen — neue Titel von anderen
// Geräten sind dann sofort da.
unawaited(_gleicheAbUndZeigeBericht());
context.read<SyncService>().automatisch();
unawaited(context.read<LibraryService>().ensureStartupPermissions());
unawaited(_pruefeGeteilteAdresse());
}
@@ -206,41 +200,13 @@ class _HomeShellState extends State<HomeShell> with WidgetsBindingObserver {
// auf dem Gerät wie am Server.
if (state == AppLifecycleState.resumed) {
if (Platform.isAndroid) _autoScan.pruefe();
unawaited(_gleicheAbUndZeigeBericht());
context.read<SyncService>().automatisch();
// Ein zweites Teilen startet die App nicht neu (singleTop), sondern
// bringt sie nur nach vorn — deshalb auch hier nachsehen.
unawaited(_pruefeGeteilteAdresse());
}
}
/// Gleicht ab und zeigt danach höchstens einmal den „Was ist neu"-Bericht.
Future<void> _gleicheAbUndZeigeBericht() async {
final sync = context.read<SyncService>();
final playlists = context.read<PlaylistService>();
await sync.automatisch();
// Nur auf einem Gerät ohne eigene Playlisten, und nur nach einem
// tatsächlich abgeschlossenen Sync-Lauf: läuft parallel schon ein
// echter Sync (z. B. weil ein Berechtigungsdialog während des
// Erststarts einen App-Resume auslöst und diese Methode ein zweites
// Mal anstößt), kehrt automatisch() oben wegen des _laeuft-Guards
// sofort zurück — dann liefe jede songByCloudId-Suche noch ins Leere,
// legte leere Playlisten an, und der countPlaylists()-Riegel würde
// jeden weiteren Versuch für immer blockieren.
if (!sync.laeuft) {
unawaited(playlists.stelleWiederHer());
}
if (!mounted) return;
final bericht = sync.bericht;
if (bericht == null) return;
// Zuerst quittieren: ein zweites Zurückkehren in die App soll denselben
// Bericht nicht erneut zeigen.
sync.berichtGesehen();
await showDialog<void>(
context: context,
builder: (_) => SyncBerichtDialog(bericht: bericht),
);
}
@override
Widget build(BuildContext context) {
final tabs = <Widget>[
@@ -256,39 +222,48 @@ class _HomeShellState extends State<HomeShell> with WidgetsBindingObserver {
const FavoritesScreen(),
const YoutubeSearchScreen(),
];
return Scaffold(
body: Column(
children: [
Expanded(child: IndexedStack(index: _index, children: tabs)),
const MiniPlayer(),
],
),
// Haarlinie darüber: ohne sie geht die Leiste auf schwarzem Grund
// optisch im Inhalt auf und wirkt nicht wie ein Hauptmenü.
bottomNavigationBar: DecoratedBox(
decoration: const BoxDecoration(
border: Border(top: BorderSide(color: MeloTheme.border)),
return PopScope(
// Tab-Wechsel laufen nur über setState, nie über Navigator.push — die
// Zurück-Geste auf einem Nicht-Start-Tab hätte sonst nichts zum
// Poppen und würde die App minimieren statt zu "Meine Musik" zu gehen.
canPop: _index == 0,
onPopInvokedWithResult: (didPop, _) {
if (!didPop) setState(() => _index = 0);
},
child: Scaffold(
body: Column(
children: [
Expanded(child: IndexedStack(index: _index, children: tabs)),
const MiniPlayer(),
],
),
child: BottomNavigationBar(
currentIndex: _index,
onTap: _goTo,
items: const [
BottomNavigationBarItem(
icon: Icon(Icons.headphones), label: 'Meine Musik'),
BottomNavigationBarItem(icon: Icon(Icons.search), label: 'Suchen'),
BottomNavigationBarItem(
icon: Icon(Icons.download_outlined),
activeIcon: Icon(Icons.download),
label: 'Download'),
BottomNavigationBarItem(
icon: Icon(Icons.favorite_border),
activeIcon: Icon(Icons.favorite),
label: 'Favoriten'),
BottomNavigationBarItem(
icon: Icon(Icons.smart_display_outlined),
activeIcon: Icon(Icons.smart_display),
label: 'YT-Suche'),
],
// Haarlinie darüber: ohne sie geht die Leiste auf schwarzem Grund
// optisch im Inhalt auf und wirkt nicht wie ein Hauptmenü.
bottomNavigationBar: DecoratedBox(
decoration: const BoxDecoration(
border: Border(top: BorderSide(color: MeloTheme.border)),
),
child: BottomNavigationBar(
currentIndex: _index,
onTap: _goTo,
items: const [
BottomNavigationBarItem(
icon: Icon(Icons.headphones), label: 'Meine Musik'),
BottomNavigationBarItem(icon: Icon(Icons.search), label: 'Suchen'),
BottomNavigationBarItem(
icon: Icon(Icons.download_outlined),
activeIcon: Icon(Icons.download),
label: 'Download'),
BottomNavigationBarItem(
icon: Icon(Icons.favorite_border),
activeIcon: Icon(Icons.favorite),
label: 'Favoriten'),
BottomNavigationBarItem(
icon: Icon(Icons.smart_display_outlined),
activeIcon: Icon(Icons.smart_display),
label: 'YT-Suche'),
],
),
),
),
);
+19
View File
@@ -130,6 +130,22 @@ int startIndexNachFilter(List<bool> behalten, int startIndex) {
return davor.clamp(0, gesamt - 1);
}
/// Übersetzung des Player-Shuffle-Zustands in den `audio_service`-Wert für
/// `PlaybackState.shuffleMode`. Als reine Funktion ausgelagert, damit sie
/// ohne laufenden `AudioPlayer` testbar ist — `_transformEvent()` läuft bei
/// jedem Player-Event und lässt sich nicht isoliert aufrufen.
AudioServiceShuffleMode toAudioServiceShuffleMode(bool enabled) =>
enabled ? AudioServiceShuffleMode.all : AudioServiceShuffleMode.none;
/// Übersetzung des Player-Loop-Modus in den `audio_service`-Wert für
/// `PlaybackState.repeatMode`. Siehe [toAudioServiceShuffleMode].
AudioServiceRepeatMode toAudioServiceRepeatMode(LoopMode loopMode) =>
switch (loopMode) {
LoopMode.one => AudioServiceRepeatMode.one,
LoopMode.all => AudioServiceRepeatMode.all,
LoopMode.off => AudioServiceRepeatMode.none,
};
/// Im Offline-Modus ist keiner der gewählten Titel ohne Netz abspielbar.
class NichtsOfflineVerfuegbar implements Exception {
const NichtsOfflineVerfuegbar();
@@ -251,6 +267,7 @@ class MeloAudioHandler extends BaseAudioHandler with QueueHandler, SeekHandler {
/// das in den Einstellungen erlaubt hat.
Future<void> _watchHeadphones() async {
final session = await AudioSession.instance;
await session.configure(const AudioSessionConfiguration.music());
session.devicesChangedEventStream.listen((event) {
final added = event.devicesAdded.map((d) => d.type).toSet();
if (shouldAutoPlay(
@@ -633,6 +650,8 @@ class MeloAudioHandler extends BaseAudioHandler with QueueHandler, SeekHandler {
}[_player.processingState] ??
AudioProcessingState.idle,
playing: _player.playing,
shuffleMode: toAudioServiceShuffleMode(_player.shuffleModeEnabled),
repeatMode: toAudioServiceRepeatMode(_player.loopMode),
updatePosition: _player.position,
bufferedPosition: _player.bufferedPosition,
speed: _player.speed,
+25 -23
View File
@@ -49,23 +49,14 @@ class NowPlayingScreen extends StatelessWidget {
// mit der fragte die App den Server nach einem Titel namens
// "https://…" und bekam nie einen Text.
final songId = songIdOf(item) ?? navidromeIdOf(item) ?? '';
return Row(
mainAxisSize: MainAxisSize.min,
children: [
IconButton(
tooltip: songId.isEmpty
? 'Kein Songtext für diesen Titel verfügbar'
: 'Songtext',
icon: const Icon(Icons.lyrics),
onPressed: songId.isEmpty
? null
: () => _showLyrics(context, songId),
),
// Ein Titel der Bibliothek wird lokal favorisiert, einer
// vom Server am Server — beide bekommen dasselbe Herz,
// statt dass eines davon ausgegraut bleibt.
_Herz(item: item),
],
return IconButton(
tooltip: songId.isEmpty
? 'Kein Songtext für diesen Titel verfügbar'
: 'Songtext',
icon: const Icon(Icons.lyrics),
onPressed: songId.isEmpty
? null
: () => _showLyrics(context, songId),
);
},
),
@@ -240,12 +231,23 @@ class _Angaben extends StatelessWidget {
return Column(
mainAxisSize: MainAxisSize.min,
children: [
Text(
item.title,
style: Theme.of(context).textTheme.headlineSmall,
maxLines: 2,
overflow: TextOverflow.ellipsis,
textAlign: TextAlign.center,
Row(
mainAxisAlignment: MainAxisAlignment.center,
children: [
Expanded(
child: Text(
item.title,
style: Theme.of(context).textTheme.headlineSmall,
maxLines: 2,
overflow: TextOverflow.ellipsis,
textAlign: TextAlign.center,
),
),
// Ein Titel der Bibliothek wird lokal favorisiert, einer
// vom Server am Server — beide bekommen dasselbe Herz,
// statt dass eines davon ausgegraut bleibt.
_Herz(item: item),
],
),
const SizedBox(height: MeloSpace.sm),
Text(
@@ -7,6 +7,7 @@ import '../library/database.dart';
import '../library/playlist_service.dart';
import '../library/song_media.dart';
import '../player/audio_handler.dart';
import '../player/now_playing_screen.dart';
import '../settings/app_settings.dart';
import '../shared/cover.dart';
import '../shared/lauf_balken.dart';
@@ -133,6 +134,10 @@ class _Zeile extends StatelessWidget {
coverOf: (s) => categories.coverFor(s,
groupByCategory: settings.groupCoversByCategory),
);
if (!context.mounted) return;
Navigator.of(context).push(
MaterialPageRoute(builder: (_) => const NowPlayingScreen()),
);
if (uebersprungen > 0) {
messenger.showSnackBar(
SnackBar(content: Text(offlineHinweis(uebersprungen))),
+21 -1
View File
@@ -48,6 +48,16 @@ class BakaAuth extends ChangeNotifier {
String? _token;
String _benutzer = '';
/// Laufender Login-Versuch aus [autoAnmelden] — solange er offen ist,
/// hängt sich ein überlappender Aufruf daran statt einen zweiten
/// Request loszuschicken (Race Condition: mehrere Tabs im IndexedStack
/// lösen beim App-Start gleichzeitig autoAnmelden aus).
Future<void>? _laufenderAutoLogin;
/// Fehlertext des letzten automatischen Anmeldeversuchs — für Diagnose,
/// da autoAnmelden() (anders als anmelden()) keinen Rückgabewert hat.
String? letzterAutoLoginFehler;
bool get istAngemeldet => _token != null && _token!.isNotEmpty;
String get benutzer => _benutzer;
@@ -108,7 +118,17 @@ class BakaAuth extends ChangeNotifier {
/// authentifizierten Aufruf ohnehin automatisch.
Future<void> autoAnmelden(String benutzer, String passwort) async {
if (istAngemeldet || benutzer.isEmpty || passwort.isEmpty) return;
await anmelden(benutzer, passwort);
_laufenderAutoLogin ??= _autoAnmeldenIntern(benutzer, passwort)
.whenComplete(() => _laufenderAutoLogin = null);
await _laufenderAutoLogin;
}
Future<void> _autoAnmeldenIntern(String benutzer, String passwort) async {
final fehler = await anmelden(benutzer, passwort);
letzterAutoLoginFehler = fehler;
if (fehler != null) {
debugPrint('Auto-Anmeldung fehlgeschlagen: $fehler');
}
}
Future<void> abmelden() async {
-14
View File
@@ -110,20 +110,6 @@ class DownloadService extends ChangeNotifier {
return neu;
}
/// Nimmt einen einzelnen Server-Titel offline.
///
/// Bewusst über [lade]: das bringt Doppel-Lauf-Schutz, Verbindungsprüfung
/// und Fortschritts-Buchführung mit. Gibt zurück, ob der Titel neu
/// dazugekommen ist.
///
/// **Bekannte Einschränkung:** Liegt der Titel schon im Abspiel-Zwischen-
/// speicher (weil er gerade gehört wurde), wird er trotzdem neu geladen —
/// bis die Verdrängung greift, belegt er doppelten Platz. Der Gegenschutz
/// kostete einen eigenen Cache-Zugang in diesem Dienst; für drei Nutzer ist
/// das der schlechtere Tausch.
Future<bool> ladeEinzelnenTitel(SubsonicSong song) async =>
await lade([song]) > 0;
Future<_Ergebnis> _ladeEinen(SubsonicSong song) async {
try {
// Datei und Buchführung entstehen nacheinander. Bricht die App
+5 -151
View File
@@ -42,14 +42,6 @@ class CloudSong {
);
}
/// Eine Playlist, wie sie der Server kennt. Mehr als Name und ID braucht die
/// einseitige Sicherung nicht.
class CloudPlaylist {
const CloudPlaylist({required this.id, required this.name});
final String id;
final String name;
}
/// Ein Wiedergabe-Ereignis, das zum Server gemeldet wird.
class CloudVerlauf {
const CloudVerlauf({
@@ -122,22 +114,10 @@ class MeloCloudService {
}
/// Liest die Favoriten-IDs aus einer Server-Antwort.
///
/// Ein fehlender `favorites`-Schlüssel ist ein **Fehler, keine leere
/// Menge**: der Router verdrahtet für `GET /favorites` hart HTTP 200, und
/// mehrere Handler desselben Servers melden Fehler im 200er-Körper. Eine
/// fälschlich leere Antwort wäre sonst von einer echten nicht zu
/// unterscheiden — genau wie bei [parseListe] und [parseUpload] wird
/// deshalb geworfen.
@visibleForTesting
static List<String> parseFavoriten(String body) {
final daten = jsonDecode(body) as Map<String, dynamic>;
final fehler = daten['error'] as String?;
if (fehler != null) throw CloudException(fehler);
final liste = daten['favorites'];
if (liste is! List) {
throw CloudException('Antwort ohne Favoritenliste');
}
final liste = daten['favorites'] as List? ?? const [];
return [
for (final j in liste) (j as Map<String, dynamic>)['id'] as String,
];
@@ -284,145 +264,19 @@ class MeloCloudService {
return parseFavoriten(antwort.body);
}
/// Setzt einen einzelnen Favoriten am Server — additiv oder entfernend,
/// aber immer **deterministisch**.
///
/// Bewusst kein Umschalten: hätte der Server einen abweichenden Stand,
/// kehrte ein Toggle den Wunsch des Nutzers um.
Future<void> setzeFavorit(String cloudId, bool gesetzt) async {
/// Ersetzt die Favoriten am Server durch [cloudIds].
Future<void> setzeFavoriten(List<String> cloudIds) async {
_pruefeAnmeldung();
final antwort = await _client
.post(
Uri.parse('$basisUrl/favorites/toggle'),
Uri.parse('$basisUrl/favorites'),
headers: {..._kopf, 'Content-Type': 'application/json'},
body: jsonEncode({'song_id': cloudId, 'set': gesetzt}),
body: jsonEncode({'song_ids': cloudIds}),
)
.timeout(const Duration(seconds: 30));
_pruefeStatus(antwort);
}
/// Der Körper einer Playlisten-Antwort, oder `CloudException`.
///
/// Der Server meldet Fehler im 200er-Körper unter `error`. Ein bloßes
/// `{"status":"not_found"}` **ohne** `error` (so antworten
/// `handle_playlist_remove_song` und `handle_playlist_update_positions`)
/// geht hier bewusst durch: die Sicherung ist einseitig und
/// fire-and-forget, sie verwirft jeden Fehler ohnehin.
Map<String, dynamic> _json(http.Response antwort) {
final daten = jsonDecode(antwort.body) as Map<String, dynamic>;
final fehler = daten['error'] as String?;
if (fehler != null) throw CloudException(fehler);
return daten;
}
/// Legt eine Playlist am Server an und gibt deren ID zurück.
///
/// Die Identität stammt **immer** von hier: `user_playlists.id` ist
/// AUTOINCREMENT und damit stabil. Eine Zuordnung über den Namen gibt es
/// nicht — sie zerbräche beim ersten Umbenennen.
Future<String> legePlaylistAn(String name) async {
_pruefeAnmeldung();
final antwort = await _client
.post(
Uri.parse('$basisUrl/playlists'),
headers: {..._kopf, 'Content-Type': 'application/json'},
body: jsonEncode({'name': name}),
)
.timeout(const Duration(seconds: 30));
_pruefeStatus(antwort);
// handle_playlist_create antwortet {"status":"ok","playlist":{"id":…}} —
// die ID liegt eine Ebene tiefer, nicht auf oberster Ebene.
final playlist = _json(antwort)['playlist'];
if (playlist is! Map<String, dynamic>) {
throw CloudException('Antwort ohne Playlist');
}
return '${playlist['id']}';
}
Future<void> fuegePlaylistSongsHinzu(
String playlistCloudId, List<String> songCloudIds) async {
if (songCloudIds.isEmpty) return;
_pruefeAnmeldung();
final antwort = await _client
.post(
Uri.parse('$basisUrl/playlists/$playlistCloudId/songs'),
headers: {..._kopf, 'Content-Type': 'application/json'},
body: jsonEncode({'song_ids': songCloudIds}),
)
.timeout(const Duration(seconds: 30));
_pruefeStatus(antwort);
_json(antwort);
}
Future<void> entfernePlaylistSong(
String playlistCloudId, String songCloudId) async {
_pruefeAnmeldung();
final antwort = await _client
.delete(
Uri.parse('$basisUrl/playlists/$playlistCloudId/songs/$songCloudId'),
headers: _kopf,
)
.timeout(const Duration(seconds: 30));
_pruefeStatus(antwort);
_json(antwort);
}
/// Schreibt die Reihenfolge einer Playlist am Server fest.
///
/// Der Körper heißt `positions` und trägt Paare aus `id` und `position`:
/// Der Router liest `d.get('positions',[])`, der Handler greift je Eintrag
/// auf beide Schlüssel zu. Eine blanke ID-Liste unter `song_ids` käme als
/// leere Liste an — der Server antwortete stumm `{"status":"ok"}` und
/// änderte nichts.
Future<void> setzePlaylistReihenfolge(
String playlistCloudId, List<String> songCloudIds) async {
_pruefeAnmeldung();
final antwort = await _client
.put(
Uri.parse('$basisUrl/playlists/$playlistCloudId/positions'),
headers: {..._kopf, 'Content-Type': 'application/json'},
body: jsonEncode({
'positions': [
for (var i = 0; i < songCloudIds.length; i++)
{'id': songCloudIds[i], 'position': i},
],
}),
)
.timeout(const Duration(seconds: 30));
_pruefeStatus(antwort);
_json(antwort);
}
Future<List<CloudPlaylist>> playlisten() async {
_pruefeAnmeldung();
final antwort = await _client
.get(Uri.parse('$basisUrl/playlists'), headers: _kopf)
.timeout(const Duration(seconds: 30));
_pruefeStatus(antwort);
final liste = _json(antwort)['playlists'];
if (liste is! List) throw CloudException('Antwort ohne Playlisten');
return [
for (final j in liste)
CloudPlaylist(
id: '${(j as Map<String, dynamic>)['id']}',
name: j['name'] as String? ?? 'Ohne Namen',
),
];
}
Future<List<String>> playlistSongs(String playlistCloudId) async {
_pruefeAnmeldung();
final antwort = await _client
.get(Uri.parse('$basisUrl/playlists/$playlistCloudId'), headers: _kopf)
.timeout(const Duration(seconds: 30));
_pruefeStatus(antwort);
final liste = _json(antwort)['songs'];
if (liste is! List) throw CloudException('Antwort ohne Titel');
return [
for (final j in liste) '${(j as Map<String, dynamic>)['id']}',
];
}
/// Meldet Wiedergaben. Der Server nimmt höchstens 100 je Aufruf an und
/// verwirft Doppelmeldungen desselben Titels innerhalb einer Stunde.
Future<void> meldeVerlauf(List<CloudVerlauf> eintraege) async {
+1
View File
@@ -145,6 +145,7 @@ class NavidromeService {
/// Zugangsdaten.
String get benutzer => _user;
String get passwort => _password;
String get serverUrl => _serverUrl;
/// Dekodiert eine Subsonic-JSON-Antwort und wirft [NavidromeException],
/// wenn der Server `status:"failed"` meldet (z. B. falsches Passwort) —
-65
View File
@@ -1,65 +0,0 @@
/// Die reinen Entscheidungsfunktionen des Abgleichs — ohne Netz, ohne
/// Datenbank, ohne Plattform-Kanäle.
///
/// Sie liegen bewusst außerhalb von `SyncService`: was hier steht, lässt sich
/// mit einer Handvoll Mengen prüfen statt mit einem halben Server.
library;
/// Wie viele Favoriten je Lauf höchstens gepusht werden.
///
/// Der Rest kommt im nächsten Lauf dran. Die Pushes sind idempotent, ein
/// Teilausfall heilt sich dadurch von selbst.
const int maxFavoritenPushes = 200;
/// Die cloudIds, die zum Server gepusht werden müssen: `lokal \ server`.
///
/// [lokaleFavoriten] sind lokale Song-IDs, [cloudIdVon] bildet sie auf ihre
/// cloudId ab. Titel ohne cloudId kennt der Server nicht — sie tauchen in
/// keiner Richtung im Abgleich auf.
List<String> zuPushendeFavoriten({
required Set<String> lokaleFavoriten,
required Map<String, String> cloudIdVon,
required Set<String> amServer,
int deckel = maxFavoritenPushes,
}) {
final offen = <String>[];
for (final songId in lokaleFavoriten) {
final cloudId = cloudIdVon[songId];
if (cloudId == null) continue;
if (amServer.contains(cloudId)) continue;
offen.add(cloudId);
if (offen.length >= deckel) break;
}
return offen;
}
/// Die lokalen Song-IDs, die aus dem Server-Stand als Favorit dazukommen:
/// `server \ lokal`.
///
/// Eine cloudId ohne lokalen Titel (Download fehlgeschlagen, noch nicht
/// geladen) wird **übersprungen, nicht gelöscht**: ein Favorit ohne Song wäre
/// über den Join unsichtbar, würde aber weiter mitgeschleppt.
List<String> lokalZuSetzendeFavoriten({
required Set<String> amServer,
required Map<String, String> songIdVonCloudId,
required Set<String> lokaleFavoriten,
}) {
final offen = <String>[];
for (final cloudId in amServer) {
final songId = songIdVonCloudId[cloudId];
if (songId == null) continue;
if (lokaleFavoriten.contains(songId)) continue;
offen.add(songId);
}
return offen;
}
/// Ob der „Was ist neu"-Bericht fällig ist.
///
/// `null` heißt Neuinstallation, Abmeldung oder gelöschte App-Daten — dann ist
/// er **nicht** fällig, sonst begrüßt ein frisch eingerichtetes Gerät den
/// Nutzer mit „Willkommen zurück! 325 neue Songs". `sollAutoSync` entscheidet
/// bei `null` bewusst umgekehrt und ist hier **kein** Vorbild.
bool berichtFaellig(DateTime? letzterErfolg, DateTime jetzt) =>
letzterErfolg != null &&
jetzt.difference(letzterErfolg) >= const Duration(hours: 24);
+19 -286
View File
@@ -1,4 +1,3 @@
import 'dart:async';
import 'dart:io';
import 'package:drift/drift.dart' show Value;
@@ -10,7 +9,6 @@ import 'package:uuid/uuid.dart';
import '../library/database.dart';
import 'media_store.dart';
import 'melo_cloud_service.dart';
import 'sync_merge.dart';
/// Was beim Abgleich mit welchen Titeln zu tun ist.
///
@@ -122,48 +120,6 @@ const autoSyncAbstand = Duration(minutes: 15);
bool sollAutoSync(DateTime? letzterLauf, DateTime jetzt) =>
letzterLauf == null || jetzt.difference(letzterLauf) >= autoSyncAbstand;
/// Was ein gezielter Upload erledigt hat — Grundlage der Meldung an den
/// Nutzer. Ein einzelner Fehlschlag darf den Erfolg der übrigen nicht
/// verdecken, deshalb steht hier alles nebeneinander.
class UploadErgebnis {
const UploadErgebnis({
this.hochgeladen = 0,
this.schonDa = 0,
this.fehler = const [],
this.abgebrochen = false,
});
final int hochgeladen;
final int schonDa;
final List<String> fehler;
final bool abgebrochen;
String get meldung {
final teile = <String>[];
if (hochgeladen > 0) teile.add('$hochgeladen hochgeladen');
if (schonDa > 0) teile.add('$schonDa waren schon da');
if (fehler.isNotEmpty) teile.add('${fehler.length} fehlgeschlagen');
if (abgebrochen) teile.add('abgebrochen');
return teile.isEmpty ? 'Nichts zu tun' : teile.join(', ');
}
}
/// Was seit dem letzten erfolgreichen Abgleich passiert ist — der Inhalt des
/// „Willkommen zurück"-Dialogs.
class SyncBericht {
const SyncBericht({
required this.neueSongs,
required this.geloeschte,
required this.favoriten,
});
final int neueSongs;
final int geloeschte;
final int favoriten;
bool get istLeer => neueSongs == 0 && geloeschte == 0 && favoriten == 0;
}
/// Hält Gerät und Server auf demselben Stand: lädt neue Server-Titel herunter,
/// bringt eigene Dateien hoch, zieht Löschungen nach und meldet Favoriten und
/// Wiedergaben. Alle Geräte am selben Konto sehen dadurch dasselbe.
@@ -176,7 +132,6 @@ class SyncService extends ChangeNotifier {
}) : _musikOrdner = musikOrdner ?? _standardMusikOrdner;
static const _letzterLaufKey = 'cloud_sync_letzter_lauf';
static const _letzterErfolgKey = 'cloud_sync_letzter_erfolg';
static const _verlaufStandKey = 'cloud_sync_verlauf_stand';
static const _uuid = Uuid();
@@ -191,9 +146,6 @@ class SyncService extends ChangeNotifier {
String? _fehler;
String? _status;
DateTime? _letzterLauf;
DateTime? _letzterErfolg;
SyncBericht? _bericht;
bool _abbruchGewuenscht = false;
bool get laeuft => _laeuft;
int get erledigt => _erledigt;
@@ -202,23 +154,10 @@ class SyncService extends ChangeNotifier {
String? get status => _status;
DateTime? get letzterLauf => _letzterLauf;
/// Der fällige Bericht, oder `null`. Wird von der Oberfläche genau einmal
/// abgeholt und dann mit [berichtGesehen] quittiert.
SyncBericht? get bericht => _bericht;
void berichtGesehen() {
_bericht = null;
notifyListeners();
}
Future<void> laden() async {
final prefs = await SharedPreferences.getInstance();
final ms = prefs.getInt(_letzterLaufKey);
if (ms != null) _letzterLauf = DateTime.fromMillisecondsSinceEpoch(ms);
final erfolg = prefs.getInt(_letzterErfolgKey);
if (erfolg != null) {
_letzterErfolg = DateTime.fromMillisecondsSinceEpoch(erfolg);
}
notifyListeners();
}
@@ -246,14 +185,6 @@ class SyncService extends ChangeNotifier {
_gesamt = 0;
_melde('Vergleiche mit dem Server …');
// Der Zeitstempel ist der Stand VOR dem Listen: was während des Laufs am
// Server passiert, muss beim nächsten Mal noch drankommen (v2-Lektion,
// Tombstone-Race).
final laufBeginn = DateTime.now();
var vollstaendig = true;
var neueSongs = 0;
var geloeschte = 0;
try {
final amServer = await cloud.liste();
final plan = planeSync(
@@ -273,38 +204,18 @@ class SyncService extends ChangeNotifier {
'$bestand Titeln würden am Server gelöscht. Das sieht nach einem '
'Fehler aus (z. B. Speicherkarte nicht eingehängt) — es wurde '
'nichts gelöscht.';
vollstaendig = false;
}
// Jede Phase für sich: fällt eine aus, laufen die übrigen weiter, und
// der Erfolgs-Zeitstempel bleibt stehen.
geloeschte = plan.lokalLoeschen.length;
await _ziehLoeschungenNach(plan.lokalLoeschen);
if (!bremse && !await _meldeLoeschungen(plan.serverLoeschen)) {
vollstaendig = false;
}
neueSongs = await _ladeHerunter(plan.herunterladen);
if (!await _ladeHoch(plan.hochladen)) vollstaendig = false;
if (!await _gleicheFavoritenAb()) vollstaendig = false;
if (!bremse) await _meldeLoeschungen(plan.serverLoeschen);
await _ladeHerunter(plan.herunterladen);
await _ladeHoch(plan.hochladen);
await _gleicheFavoritenAb();
await _meldeVerlauf();
_letzterLauf = laufBeginn;
_letzterLauf = DateTime.now();
final prefs = await SharedPreferences.getInstance();
await prefs.setInt(_letzterLaufKey, laufBeginn.millisecondsSinceEpoch);
if (vollstaendig) {
// „Erfolgreich" heißt: keine Phase hat einen Fehler geschluckt.
if (berichtFaellig(_letzterErfolg, laufBeginn)) {
_bericht = SyncBericht(
neueSongs: neueSongs,
geloeschte: geloeschte,
favoriten: 0,
);
}
_letzterErfolg = laufBeginn;
await prefs.setInt(
_letzterErfolgKey, laufBeginn.millisecondsSinceEpoch);
}
await prefs.setInt(_letzterLaufKey, _letzterLauf!.millisecondsSinceEpoch);
} on CloudException catch (e) {
_fehler = e.message;
} catch (e) {
@@ -317,104 +228,6 @@ class SyncService extends ChangeNotifier {
}
}
/// Stoppt einen laufenden Auswahl-Upload zwischen zwei Titeln.
///
/// Nach dem Muster von `DownloadService.abbrechen`: wer versehentlich 60
/// statt 6 Titel markiert hat, soll nicht die App killen müssen.
void abbrechen() {
if (_laeuft) _abbruchGewuenscht = true;
}
/// Lädt genau [songs] zum Server — die ausdrückliche Nutzeraktion aus dem
/// Auswahl-Modus.
///
/// Sequenziell, weil der Server jeden Upload komplett im RAM hält. Titel mit
/// cloudId werden übersprungen, Einzelfehler vermerkt und übergangen.
/// Der Sync-Zeitstempel wird bewusst **nicht** geschrieben: ein Upload ist
/// kein Abgleich, und sonst unterdrückte er 15 Minuten den Auto-Sync und
/// verschöbe die 24-h-Uhr des Berichts.
///
/// Den Offline-Modus-Schalter beachtet er nicht — er ist eine ausdrückliche
/// Nutzeraktion.
Future<UploadErgebnis> ladeAusgewaehlteHoch(List<Song> songs) async {
if (_laeuft) {
_fehler = 'Es läuft gerade ein Abgleich — bitte kurz warten';
notifyListeners();
return const UploadErgebnis();
}
if (!cloud.istAngemeldet) {
_fehler = 'Bitte zuerst beim Baka-Konto anmelden';
notifyListeners();
return const UploadErgebnis();
}
_laeuft = true;
_abbruchGewuenscht = false;
_fehler = null;
_erledigt = 0;
_gesamt = songs.length;
notifyListeners();
var hochgeladen = 0;
var schonDa = 0;
final fehler = <String>[];
var abgebrochen = false;
try {
for (final song in songs) {
if (_abbruchGewuenscht) {
abgebrochen = true;
break;
}
if (song.cloudId != null) {
schonDa++;
_erledigt++;
notifyListeners();
continue;
}
final datei = File(song.path);
if (!await datei.exists()) {
fehler.add('${song.title}: Datei nicht gefunden');
_erledigt++;
notifyListeners();
continue;
}
_melde('Sende „${song.title}" …');
try {
final cloudId = await cloud.hochladen(
datei,
dateiname:
'${_sichererDateiname(song.title)}${p.extension(song.path)}',
);
if (cloudId != null) {
await db.setCloudId(song.id, cloudId);
hochgeladen++;
} else {
fehler.add('${song.title}: keine Server-ID erhalten');
}
} on CloudException catch (e) {
fehler.add('${song.title}: ${e.message}');
} on TimeoutException {
fehler.add('${song.title}: Zeitüberschreitung');
}
_erledigt++;
notifyListeners();
}
} finally {
_laeuft = false;
_abbruchGewuenscht = false;
_status = null;
notifyListeners();
}
return UploadErgebnis(
hochgeladen: hochgeladen,
schonDa: schonDa,
fehler: fehler,
abgebrochen: abgebrochen,
);
}
Future<void> _ziehLoeschungenNach(List<Song> songs) async {
if (songs.isEmpty) return;
_melde('Entferne ${songs.length} am Server gelöschte Titel …');
@@ -423,13 +236,7 @@ class SyncService extends ChangeNotifier {
notifyListeners();
}
/// Meldet die hier getombsteten Titel am Server.
///
/// Gibt `false` zurück, sobald eine Meldung geschluckt wurde: der Lauf geht
/// weiter, gilt aber nicht mehr als erfolgreich — sonst rückte der
/// 24-h-Zeitstempel des Berichts vor, obwohl eine Phase ausgefallen ist.
Future<bool> _meldeLoeschungen(List<Song> songs) async {
var vollstaendig = true;
Future<void> _meldeLoeschungen(List<Song> songs) async {
for (final song in songs) {
_melde('Melde Löschung von „${song.title}“ …');
try {
@@ -437,19 +244,14 @@ class SyncService extends ChangeNotifier {
} on CloudException catch (e) {
// Eine abgelehnte Löschung darf den Lauf nicht beenden.
debugPrint('Löschung „${song.title}“ übersprungen: ${e.message}');
vollstaendig = false;
}
_erledigt++;
notifyListeners();
}
return vollstaendig;
}
/// Gibt zurück, wie viele Titel wirklich neu dazugekommen sind — die Zahl
/// im „Was ist neu"-Bericht.
Future<int> _ladeHerunter(List<CloudSong> songs) async {
if (songs.isEmpty) return 0;
var neu = 0;
Future<void> _ladeHerunter(List<CloudSong> songs) async {
if (songs.isEmpty) return;
final ordner = await _musikOrdner();
for (final cloudSong in songs) {
_melde('Lade „${cloudSong.titel}“ …');
@@ -489,21 +291,12 @@ class SyncService extends ChangeNotifier {
cloudId: Value(cloudSong.id),
),
]);
neu++;
_erledigt++;
notifyListeners();
}
return neu;
}
/// Lädt alle Titel ohne cloudId hoch.
///
/// Gibt `false` zurück, sobald ein Upload an einem Fehler oder einer
/// Zeitüberschreitung hängenblieb. Eine **fehlende Datei** zählt bewusst
/// nicht dazu: dort ist nichts schiefgegangen, der Titel ist weg und der
/// nächste Scan tombstoned ihn.
Future<bool> _ladeHoch(List<Song> songs) async {
var vollstaendig = true;
Future<void> _ladeHoch(List<Song> songs) async {
for (final song in songs) {
final datei = File(song.path);
if (!await datei.exists()) {
@@ -516,89 +309,29 @@ class SyncService extends ChangeNotifier {
datei,
dateiname: '${_sichererDateiname(song.title)}${p.extension(song.path)}',
);
if (cloudId != null) {
await db.setCloudId(song.id, cloudId);
} else {
// 200 ohne Server-ID: der Titel ist oben nicht angekommen.
vollstaendig = false;
}
if (cloudId != null) await db.setCloudId(song.id, cloudId);
} on CloudException catch (e) {
// Eine zu große oder abgelehnte Datei darf den Lauf nicht beenden.
debugPrint('Upload „${song.title}“ übersprungen: ${e.message}');
vollstaendig = false;
} on TimeoutException {
// Der 120-s-Timeout (melo_cloud_service.dart:180) wirft
// TimeoutException, nicht CloudException — ohne diesen Zweig riss ein
// einziger hängender Upload den ganzen Lauf ab.
debugPrint('Upload „${song.title}“: Zeitüberschreitung');
vollstaendig = false;
}
_erledigt++;
notifyListeners();
}
return vollstaendig;
}
/// Additiver Favoriten-Abgleich: gleicht in **beide** Richtungen an,
/// entfernt aber in **keiner**.
///
/// Damit ist der alte Datenverlust-Bug strukturell unmöglich: es gibt
/// keinen Codepfad mehr, der den Server-Stand ersetzen könnte. Der Preis
/// ist bekannt und bewusst: ein Ent-Favorisieren propagiert nicht
/// geräteübergreifend — hält ein zweites Gerät den Favoriten noch, bringt
/// dessen nächster Abgleich ihn zurück.
///
/// Gibt `true` zurück, wenn die Phase vollständig durchlief.
Future<bool> _gleicheFavoritenAb() async {
Future<void> _gleicheFavoritenAb() async {
_melde('Gleiche Favoriten ab …');
final Set<String> amServer;
try {
amServer = (await cloud.favoriten()).toSet();
} catch (e) {
// Ohne Server-Stand ist nichts zu tun. Blindes Pushen wäre harmlos,
// aber nutzlos — die Phase wird übersprungen, der Lauf geht weiter.
debugPrint('Favoriten-Abgleich übersprungen: $e');
return false;
}
// Grabsteine bleiben außen vor: favoriteSongIds() liefert auch Favoriten
// getombsteter Titel, und die gehören nicht zurück auf den Server.
final lokal = await db.allSongs();
final cloudIdVon = {
for (final s in lokal)
if (s.cloudId != null && !s.deleted) s.id: s.cloudId!,
if (s.cloudId != null) s.id: s.cloudId!,
};
final songIdVonCloudId = {
for (final s in lokal)
if (s.cloudId != null && !s.deleted) s.cloudId!: s.id,
};
final favoriten = (await db.favoriteSongIds()).toSet();
var vollstaendig = true;
for (final cloudId in zuPushendeFavoriten(
lokaleFavoriten: favoriten,
cloudIdVon: cloudIdVon,
amServer: amServer,
)) {
try {
await cloud.setzeFavorit(cloudId, true);
} catch (e) {
debugPrint('Favorit $cloudId nicht gemeldet: $e');
vollstaendig = false;
}
}
for (final songId in lokalZuSetzendeFavoriten(
amServer: amServer,
songIdVonCloudId: songIdVonCloudId,
lokaleFavoriten: favoriten,
)) {
await db.setFavorite(songId, true);
}
return vollstaendig;
final favoritenIds = await db.favoriteSongIds();
final cloudFavoriten = [
for (final id in favoritenIds)
if (cloudIdVon[id] != null) cloudIdVon[id]!,
];
await cloud.setzeFavoriten(cloudFavoriten);
}
Future<void> _meldeVerlauf() async {
+19 -11
View File
@@ -1,3 +1,5 @@
import 'dart:io';
import 'package:flutter/material.dart';
import 'package:package_info_plus/package_info_plus.dart';
import 'package:provider/provider.dart';
@@ -103,16 +105,17 @@ class _SettingsScreenState extends State<SettingsScreen> {
enabled: !lib.scanning,
onTap: lib.pickFolderAndScan,
),
ListTile(
leading: const Icon(Icons.refresh),
title: const Text('Erneut scannen'),
subtitle: lib.scanning
? Text('Scanne … ${lib.scanDone}'
'${lib.scanTotal > 0 ? ' / ${lib.scanTotal}' : ''}')
: const Text('Bekannte Ordner neu einlesen'),
enabled: !lib.scanning,
onTap: lib.rescan,
),
if (zeigeErneutScannenButton(Platform.isAndroid))
ListTile(
leading: const Icon(Icons.refresh),
title: const Text('Erneut scannen'),
subtitle: lib.scanning
? Text('Scanne … ${lib.scanDone}'
'${lib.scanTotal > 0 ? ' / ${lib.scanTotal}' : ''}')
: const Text('Bekannte Ordner neu einlesen'),
enabled: !lib.scanning,
onTap: lib.rescan,
),
],
),
),
@@ -343,7 +346,12 @@ class _SettingsScreenState extends State<SettingsScreen> {
void _zeigeNavidromeDialog() {
final urlCtrl = TextEditingController(text: 'https://musik.baka-net.de');
final passCtrl = TextEditingController();
String selectedUser = 'Baka';
// Vorauswahl: der zuletzt bekannte Navidrome-Benutzer, falls er einer
// der drei Server-User ist — sonst Fallback "Baka".
const bekannteBenutzer = ['Baka', 'Tinker', 'Dustin'];
String selectedUser = bekannteBenutzer.contains(_navidrome.benutzer)
? _navidrome.benutzer
: 'Baka';
bool verbindet = false;
bool obscure = true;
String? fehler;
-27
View File
@@ -7,7 +7,6 @@ import '../library/playlist_service.dart';
import '../library/song_media.dart';
import '../player/audio_handler.dart';
import '../playlists/create_playlist_dialog.dart';
import '../services/sync_service.dart';
import '../settings/app_settings.dart';
import 'auswahl.dart';
import 'theme.dart';
@@ -23,7 +22,6 @@ class AuswahlLeiste extends StatelessWidget {
required this.onAbbrechen,
required this.onWiedergabeliste,
required this.onWarteschlange,
this.onServerLaden,
});
final int anzahl;
@@ -31,10 +29,6 @@ class AuswahlLeiste extends StatelessWidget {
final VoidCallback onWiedergabeliste;
final VoidCallback onWarteschlange;
/// Nur gesetzt, wo der Upload hingehört („Meine Musik"). Sonst erschiene
/// die Aktion in allen fünf Ansichten, die diese Leiste benutzen.
final VoidCallback? onServerLaden;
@override
Widget build(BuildContext context) {
return Padding(
@@ -55,12 +49,6 @@ class AuswahlLeiste extends StatelessWidget {
style: const TextStyle(fontWeight: FontWeight.w600),
),
),
if (onServerLaden != null)
IconButton(
tooltip: 'Auf den Server laden',
icon: const Icon(Icons.cloud_upload),
onPressed: onServerLaden,
),
IconButton(
tooltip: 'Zur Warteschlange hinzufügen',
icon: const Icon(Icons.queue),
@@ -171,18 +159,3 @@ Future<void> fuegeZuWarteschlangeHinzu(
: '$angehaengt von ${gewaehlte.length} Titeln angehängt'),
));
}
/// Lädt [gewaehlte] zum Melo-Server und meldet das Ergebnis.
///
/// Wohnt neben [fuegeZuWiedergabelisteHinzu]: dieselbe Bauart, dieselbe Art
/// Rückmeldung.
Future<void> ladeAufServer(
BuildContext context, List<Song> gewaehlte) async {
final sync = context.read<SyncService>();
final messenger = ScaffoldMessenger.of(context);
final ergebnis = await sync.ladeAusgewaehlteHoch(gewaehlte);
if (!context.mounted) return;
messenger.showSnackBar(
SnackBar(content: Text(sync.fehler ?? ergebnis.meldung)),
);
}
+91
View File
@@ -0,0 +1,91 @@
import 'dart:math' as math;
import 'package:flutter/material.dart';
import 'theme.dart';
/// Blendet [child] beim ersten Erscheinen leicht gestaffelt ein — statt
/// abrupt aufzupoppen, faded und rutscht es ein kleines Stück von unten
/// heran. Je weiter hinten in der Liste, desto später beginnt es, damit die
/// Liste als Ganzes fließt statt gleichzeitig aufzublitzen.
///
/// Läuft genau einmal je Element-Lebenszeit: ein Rebuild (etwa weil sich der
/// Song-Titel ändert) startet die Animation nicht erneut.
class EinblendItem extends StatefulWidget {
const EinblendItem({super.key, required this.child, required this.index});
final Widget child;
/// Position in der Liste — bestimmt die Verzögerung vor dem Start.
final int index;
@override
State<EinblendItem> createState() => _EinblendItemState();
}
class _EinblendItemState extends State<EinblendItem>
with SingleTickerProviderStateMixin {
/// Ab Index 12 keine zusätzliche Verzögerung mehr — sonst wirkte eine
/// lange Liste beim ersten Erscheinen träge, weil die letzten Zeilen erst
/// spät anfingen.
static const _deckel = 12;
static const _versatzProItem = Duration(milliseconds: 25);
late final AnimationController _controller = AnimationController(
vsync: this,
duration: MeloMotion.normal,
);
late final Animation<double> _kurve = CurvedAnimation(
parent: _controller,
curve: MeloMotion.curve,
);
bool _gestartet = false;
// Kein Start in initState: die Entscheidung hängt an MediaQuery
// (Reduce-Motion), und darauf darf man dort noch nicht zugreifen — siehe
// LaufBalken. didChangeDependencies läuft unmittelbar danach und ein
// _gestartet-Merker verhindert, dass ein späterer Aufruf (z. B. durch
// eine geänderte Textgröße) die Animation erneut anstößt.
@override
void didChangeDependencies() {
super.didChangeDependencies();
if (_gestartet) return;
_gestartet = true;
if (MeloMotion.ruhig(context, MeloMotion.normal) == Duration.zero) {
_controller.value = 1;
return;
}
final verzoegerung = _versatzProItem * math.min(widget.index, _deckel);
if (verzoegerung == Duration.zero) {
_controller.forward();
} else {
Future.delayed(verzoegerung, () {
if (mounted) _controller.forward();
});
}
}
@override
void dispose() {
_controller.dispose();
super.dispose();
}
@override
Widget build(BuildContext context) {
return AnimatedBuilder(
animation: _kurve,
builder: (context, child) => Opacity(
opacity: _kurve.value,
child: Transform.translate(
offset: Offset(0, MeloSpace.sm * (1 - _kurve.value)),
child: child,
),
),
child: widget.child,
);
}
}
-13
View File
@@ -23,7 +23,6 @@ class SortableSongList extends StatefulWidget {
required this.songs,
required this.storeKey,
this.empty,
this.serverUpload = false,
});
final List<Song> songs;
@@ -32,10 +31,6 @@ class SortableSongList extends StatefulWidget {
/// Wird statt der Liste gezeigt, wenn [songs] leer ist.
final Widget? empty;
/// Ob der Auswahl-Modus „Auf den Server laden" anbietet. Standard `false`:
/// dieses Widget steckt in fünf Ansichten, gemeint ist nur „Meine Musik".
final bool serverUpload;
@override
State<SortableSongList> createState() => _SortableSongListState();
}
@@ -72,11 +67,6 @@ class _SortableSongListState extends State<SortableSongList> {
if (mounted) _beendeAuswahl();
}
Future<void> _aufServer(List<Song> gewaehlte) async {
await ladeAufServer(context, gewaehlte);
if (mounted) _beendeAuswahl();
}
@override
void dispose() {
_scroll.dispose();
@@ -206,9 +196,6 @@ class _SortableSongListState extends State<SortableSongList> {
onAbbrechen: _beendeAuswahl,
onWiedergabeliste: () => _inWiedergabeliste(_gewaehlte(sorted)),
onWarteschlange: () => _inWarteschlange(_gewaehlte(sorted)),
onServerLaden: widget.serverUpload
? () => _aufServer(_gewaehlte(sorted))
: null,
)
else
Padding(
-35
View File
@@ -1,35 +0,0 @@
import 'package:flutter/material.dart';
import '../services/sync_service.dart';
/// „Willkommen zurück" — was sich seit dem letzten erfolgreichen Abgleich
/// getan hat. Rein in-App, ohne Benachrichtigungs-Kanal und ohne neue
/// Abhängigkeit.
class SyncBerichtDialog extends StatelessWidget {
const SyncBerichtDialog({super.key, required this.bericht});
final SyncBericht bericht;
static String textFuer(SyncBericht b) {
if (b.istLeer) return 'Nichts Neues seit dem letzten Abgleich.';
final teile = <String>[];
if (b.neueSongs > 0) teile.add('${b.neueSongs} neue Titel');
if (b.geloeschte > 0) teile.add('${b.geloeschte} entfernt');
if (b.favoriten > 0) teile.add('${b.favoriten} Favoriten geändert');
return '${teile.join(' · ')}.';
}
@override
Widget build(BuildContext context) {
return AlertDialog(
title: const Text('Willkommen zurück!'),
content: Text(textFuer(bericht)),
actions: [
FilledButton(
onPressed: () => Navigator.of(context).pop(),
child: const Text('Alles klar'),
),
],
);
}
}
@@ -1,129 +0,0 @@
import 'package:drift/native.dart';
import 'package:flutter/material.dart';
import 'package:flutter_test/flutter_test.dart';
import 'package:provider/provider.dart';
import 'package:melo/library/database.dart';
import 'package:melo/downloads/server_titel_screen.dart';
import 'package:melo/player/audio_handler.dart';
import 'package:melo/services/download_service.dart';
import 'package:melo/services/navidrome_service.dart';
/// Merkt sich nur, was verlangt wurde — echte Downloads brauchen einen
/// Server, und darum geht es hier nicht.
class _FakeDownloads extends DownloadService {
_FakeDownloads(MeloDb db) : super(db: db, navidrome: NavidromeService());
final geladen = <String>[];
final entfernt = <String>[];
@override
bool get laeuft => false;
@override
Future<bool> ladeEinzelnenTitel(SubsonicSong song) async {
geladen.add(song.id);
return true;
}
@override
Future<bool> entferne(String navidromeId) async {
entfernt.add(navidromeId);
return true;
}
}
void main() {
final titel = [
const SubsonicSong(
id: 'nav-1',
titel: 'Nachtpuls',
kuenstler: 'Rotklang',
album: 'Nacht',
dauerSekunden: 200,
),
];
Future<({_FakeDownloads dienst, MeloAudioHandler handler})> pumpe(
WidgetTester tester,
{bool schonGeladen = false}) async {
final db = MeloDb(NativeDatabase.memory());
addTearDown(db.close);
if (schonGeladen) {
// Der Bildschirm liest den Zustand einmal per db.downloadIds().
await db.merkeDownload(DownloadsCompanion.insert(
navidromeId: 'nav-1',
titel: 'Nachtpuls',
groesseBytes: 1,
geladenAmMs: 0,
));
}
final dienst = _FakeDownloads(db);
// MeloAudioHandler startet einen periodischen Timer (Positions-
// Buchführung). Ohne handler.dispose() meldet der Testrahmen ihn als
// „pending" — dasselbe etablierte Muster wie in
// test/library/my_music_screen_test.dart: handler.dispose() explizit am
// Testende aufrufen (addTearDown greift zu spät, außerhalb der
// FakeAsync-Zone, in der der Timer geprüft wird).
final handler = MeloAudioHandler(db: db);
await tester.pumpWidget(
MultiProvider(
providers: [
Provider<MeloDb>.value(value: db),
ChangeNotifierProvider<DownloadService>.value(value: dienst),
Provider<MeloAudioHandler>.value(value: handler),
],
child: MaterialApp(
home: ServerTitelScreen(
titel: 'Nacht',
navidrome: NavidromeService(),
holeTitel: () async => titel,
),
),
),
);
await tester.pumpAndSettle(
const Duration(milliseconds: 100),
EnginePhase.sendSemanticsUpdate,
const Duration(seconds: 5),
);
return (dienst: dienst, handler: handler);
}
testWidgets('ein einzelner Titel lässt sich offline nehmen', (tester) async {
final (:dienst, :handler) = await pumpe(tester);
await tester.tap(find.byTooltip('Offline nehmen'));
await tester.pumpAndSettle(
const Duration(milliseconds: 100),
EnginePhase.sendSemanticsUpdate,
const Duration(seconds: 5),
);
expect(dienst.geladen, ['nav-1']);
expect(dienst.entfernt, isEmpty);
handler.dispose();
});
testWidgets('ein schon geladener Titel bietet den Gegenweg an',
(tester) async {
final (:dienst, :handler) =
await pumpe(tester, schonGeladen: true);
// Zustand „schon offline": statt „Offline nehmen" steht dort das
// Entfernen — ohne diesen Test wäre der halbe Knopf ungeprüft.
expect(find.byTooltip('Offline nehmen'), findsNothing);
await tester.tap(find.byTooltip('Vom Gerät entfernen'));
await tester.pumpAndSettle(
const Duration(milliseconds: 100),
EnginePhase.sendSemanticsUpdate,
const Duration(seconds: 5),
);
expect(dienst.entfernt, ['nav-1']);
expect(dienst.geladen, isEmpty);
handler.dispose();
});
}
+87
View File
@@ -248,6 +248,93 @@ void main() {
findsOneWidget);
});
testWidgets(
'Der Anmelde-Dialog schlägt den bekannten Navidrome-Benutzer vor, '
'nicht immer "Baka"', (tester) async {
final auth = BakaAuth(
client: MockClient((_) async => http.Response('', 500)),
speicher: _MemorySpeicher());
final nav = NavidromeService()
..setCredentials('https://musik.baka-net.de', 'Tinker', 'falsch');
await tester.pumpWidget(_wrap(auth,
db: db, categories: categories, navidrome: nav));
await tester.pumpAndSettle();
await tester.tap(find.text('Beim Baka-Konto anmelden'));
await tester.pumpAndSettle();
final feld = tester.widget<TextField>(find.byType(TextField).first);
expect(feld.controller!.text, 'Tinker');
});
testWidgets(
'Erfolgreiches manuelles Anmelden übernimmt das neue Passwort auch '
'für Navidrome — sonst kommt der Auto-Login-Fehler nach Ablauf des '
'Baka-Tokens garantiert wieder', (tester) async {
final auth = BakaAuth(
client: MockClient((request) async {
final body = jsonDecode(request.body) as Map<String, dynamic>;
if (body['password'] == 'neuesPasswort') {
return http.Response(jsonEncode({'token': 'jwt-neu'}), 200);
}
return http.Response('', 500);
}),
speicher: _MemorySpeicher(),
);
final nav = NavidromeService()
..setCredentials('https://musik.baka-net.de', 'Tinker', 'altesPasswort');
await tester.pumpWidget(_wrap(auth,
db: db, categories: categories, navidrome: nav));
await tester.pumpAndSettle();
await tester.tap(find.text('Beim Baka-Konto anmelden'));
await tester.pumpAndSettle();
await tester.enterText(find.byType(TextField).last, 'neuesPasswort');
await tester.tap(find.text('Anmelden'));
await tester.pumpAndSettle();
expect(nav.passwort, 'neuesPasswort');
expect(nav.benutzer, 'Tinker');
expect(auth.istAngemeldet, isTrue);
});
testWidgets(
'Anmelden trimmt das Passwort — ein unsichtbares Leerzeichen durch '
'Autofill im obscureText-Feld darf den Login nicht scheitern lassen '
'(wie im Navidrome-Dialog, settings_screen.dart)', (tester) async {
late String gesendetesPasswort;
final auth = BakaAuth(
client: MockClient((request) async {
final body = jsonDecode(request.body) as Map<String, dynamic>;
gesendetesPasswort = body['password'] as String;
if (body['password'] == 'geheim') {
return http.Response(jsonEncode({'token': 'jwt-neu'}), 200);
}
return http.Response('', 500);
}),
speicher: _MemorySpeicher(),
);
final nav = NavidromeService()
..setCredentials('https://musik.baka-net.de', 'Tinker', 'altesPasswort');
await tester.pumpWidget(_wrap(auth,
db: db, categories: categories, navidrome: nav));
await tester.pumpAndSettle();
await tester.tap(find.text('Beim Baka-Konto anmelden'));
await tester.pumpAndSettle();
await tester.enterText(find.byType(TextField).last, 'geheim ');
await tester.tap(find.text('Anmelden'));
await tester.pumpAndSettle();
expect(gesendetesPasswort, 'geheim');
expect(nav.passwort, 'geheim');
});
testWidgets(
'Server-User meldet sich im Hintergrund mit denselben Zugangsdaten '
'beim Baka-Konto an', (tester) async {
@@ -0,0 +1,92 @@
import 'package:audio_service/audio_service.dart';
import 'package:drift/drift.dart' show driftRuntimeOptions;
import 'package:drift/native.dart';
import 'package:flutter/material.dart';
import 'package:flutter/services.dart';
import 'package:flutter_test/flutter_test.dart';
import 'package:provider/provider.dart';
import 'package:shared_preferences/shared_preferences.dart';
import 'package:melo/downloads/server_titel_screen.dart';
import 'package:melo/library/database.dart';
import 'package:melo/player/audio_handler.dart';
import 'package:melo/player/now_playing_screen.dart';
import 'package:melo/services/navidrome_service.dart';
/// Ersetzt in [MeloAudioHandler.loadPlaylist] den echten just_audio-Zugriff:
/// der spricht über Plattform-Kanäle, die im Widget-Test nicht existieren
/// und mit `MissingPluginException` scheitern würden. Alles andere
/// (Warteschlange, Mediendaten) bleibt echtes Handler-Verhalten.
class _FakeAudioHandler extends MeloAudioHandler {
_FakeAudioHandler(MeloDb db) : super(db: db);
@override
Future<int> loadPlaylist(List<MediaItem> items, {int startIndex = 0}) async {
queue.add(items);
if (items.isNotEmpty) mediaItem.add(items[startIndex]);
return 0;
}
}
void main() {
late MeloDb db;
late _FakeAudioHandler handler;
void stelleKanaeleRuhig() {
final messenger =
TestDefaultBinaryMessengerBinding.instance.defaultBinaryMessenger;
messenger.setMockMethodCallHandler(
const MethodChannel('plugins.flutter.io/path_provider'),
(call) async => '/tmp/melo-test',
);
messenger.setMockMethodCallHandler(
const MethodChannel('plugins.it_nomads.com/flutter_secure_storage'),
(call) async => null,
);
}
setUp(() async {
TestWidgetsFlutterBinding.ensureInitialized();
driftRuntimeOptions.dontWarnAboutMultipleDatabases = true;
SharedPreferences.setMockInitialValues({});
stelleKanaeleRuhig();
db = MeloDb(NativeDatabase.memory());
handler = _FakeAudioHandler(db);
});
tearDown(() {
handler.dispose();
});
Widget wrap(Widget child) => MultiProvider(
providers: [
Provider<MeloDb>.value(value: db),
Provider<MeloAudioHandler>.value(value: handler),
],
child: MaterialApp(home: child),
);
testWidgets('Titel antippen öffnet den Vollbild-Player', (tester) async {
final navidrome = NavidromeService()
..setCredentials('https://musik.baka-net.de', 'Baka', 'geheim');
await tester.pumpWidget(wrap(ServerTitelScreen(
titel: 'Ablaze',
navidrome: navidrome,
holeTitel: () async => const [
SubsonicSong(id: 's1', titel: 'Feuer', kuenstler: 'X', dauerSekunden: 120),
],
)));
await tester.pumpAndSettle();
expect(find.byType(NowPlayingScreen), findsNothing);
await tester.tap(find.text('Feuer'));
await tester.pumpAndSettle();
expect(find.byType(NowPlayingScreen), findsOneWidget);
// Ohne diesen Abschluss bleibt ein drift-Stream-Abo beim Abbau des
// Baums als offener Fake-Timer stehen.
await tester.pumpWidget(const SizedBox());
await tester.pump(const Duration(milliseconds: 1));
});
}
+67
View File
@@ -72,4 +72,71 @@ void main() {
handler.dispose();
await db.close();
});
testWidgets('Zurück-Geste auf einem Nicht-Start-Tab wechselt zu '
'"Meine Musik" statt die App zu minimieren', (tester) async {
final db = MeloDb(NativeDatabase.memory());
final lib = LibraryService(db);
final playlists = PlaylistService(db);
final handler = MeloAudioHandler(db: db);
final auth = BakaAuth(speicher: _MemorySpeicher());
await tester.pumpWidget(MultiProvider(
providers: [
Provider<MeloDb>.value(value: db),
ChangeNotifierProvider<LibraryService>.value(value: lib),
ChangeNotifierProvider<PlaylistService>.value(value: playlists),
Provider<MeloAudioHandler>.value(value: handler),
ChangeNotifierProvider<CategoryService>(create: (_) => CategoryService(db)),
ChangeNotifierProvider<AppSettings>(create: (_) => AppSettings()),
ChangeNotifierProvider<OfflineMode>(create: (_) => OfflineMode()),
ChangeNotifierProvider<BakaAuth>(create: (_) => auth),
ChangeNotifierProvider<YtDownloadService>(
create: (_) => YtDownloadService(auth: auth)),
ChangeNotifierProvider<YtSearchService>(
create: (_) => YtSearchService(auth: auth)),
ChangeNotifierProvider<DownloadService>(
create: (_) => DownloadService(db: db, navidrome: NavidromeService())),
ChangeNotifierProvider<SyncService>(
create: (_) => SyncService(
db: db, cloud: MeloCloudService(auth: auth))),
],
child: const MaterialApp(home: HomeShell()),
));
await tester.pump();
// Auf "Favoriten" wechseln (Index 3) — kein Navigator.push, nur der Tab.
await tester.tap(find.descendant(
of: find.byType(BottomNavigationBar), matching: find.text('Favoriten')));
await tester.pump();
expect(
tester
.widget<BottomNavigationBar>(find.byType(BottomNavigationBar))
.currentIndex,
3);
// System-Zurück-Geste simulieren — derselbe Weg, über den auch das
// echte Android-Zurück-Gesten-Signal bei WidgetsApp ankommt.
final widgetsAppState = tester.state(find.byType(WidgetsApp));
// ignore: avoid_dynamic_calls
await (widgetsAppState as dynamic).didPopRoute();
await tester.pump();
// Ohne Abfangen bliebe der Tab unverändert (Flutter minimiert dann die
// App statt zu navigieren) — die Geste muss stattdessen zu Tab 0 führen.
expect(
tester
.widget<BottomNavigationBar>(find.byType(BottomNavigationBar))
.currentIndex,
0);
// Baum abbauen, bevor der Test endet: der Positions-Timer des Audio-
// Handlers läuft sonst über das Testende hinaus weiter, und der
// Test-Rahmen meldet einen offenen Timer (wie in hauptmenue_test.dart
// dokumentiert). Aus demselben Grund bewusst kein db.close() nach
// einem tester.tap.
await tester.pumpWidget(const SizedBox());
handler.dispose();
await tester.pump(const Duration(milliseconds: 1));
});
}
+21
View File
@@ -0,0 +1,21 @@
import 'package:flutter_test/flutter_test.dart';
import 'package:melo/library/library_service.dart';
// Bug (Tinker): Auf Android zeigten die Einstellungen zwei Buttons mit
// identischer Aufgabe ("Musik scannen" und "Erneut scannen") — beide riefen
// auf Android denselben Geräte-weiten MediaStore-Scan auf. Die Sichtbarkeit
// des zweiten Buttons hängt eigentlich von Platform.isAndroid ab, das sich
// in Tests nicht sauber auf "Android" umschalten lässt — deshalb ist die
// Entscheidung hier als pure, plattformunabhängig testbare Funktion
// ausgelagert.
void main() {
group('zeigeErneutScannenButton', () {
test('auf Android ausgeblendet (identisch zu "Musik scannen")', () {
expect(zeigeErneutScannenButton(true), isFalse);
});
test('auf Desktop angezeigt (echter Unterschied: bekannte Ordner erneut scannen)', () {
expect(zeigeErneutScannenButton(false), isTrue);
});
});
}
-57
View File
@@ -1,57 +0,0 @@
import 'package:drift/drift.dart' show Migrator;
import 'package:drift/native.dart';
import 'package:flutter_test/flutter_test.dart';
import 'package:melo/library/database.dart';
void main() {
test('Bestandsdaten überleben die neue Spalte', () async {
final db = MeloDb(NativeDatabase.memory());
addTearDown(db.close);
// Den Stand von Schema 10 nachbauen: Tabelle ohne cloud_id, mit Daten.
await db.customStatement('DROP TABLE playlist_songs');
await db.customStatement('DROP TABLE playlists');
await db.customStatement(
'CREATE TABLE playlists ('
'id TEXT NOT NULL, '
'name TEXT NOT NULL, '
'description TEXT NULL, '
'created_at_ms INTEGER NOT NULL, '
'updated_at_ms INTEGER NOT NULL, '
'deleted INTEGER NOT NULL DEFAULT 0, '
'PRIMARY KEY (id))',
);
await db.customStatement(
"INSERT INTO playlists (id, name, created_at_ms, updated_at_ms) "
"VALUES ('alt-1', 'Road Trip', 0, 0)",
);
await Migrator(db).addColumn(db.playlists, db.playlists.cloudId);
final rows = await db.select(db.playlists).get();
expect(rows.single.name, 'Road Trip');
expect(rows.single.cloudId, isNull);
});
test('setPlaylistCloudId merkt sich die Server-ID', () async {
final db = MeloDb(NativeDatabase.memory());
addTearDown(db.close);
final id = await db.createPlaylist('Mix');
await db.setPlaylistCloudId(id, '42');
expect((await db.playlistById(id))!.cloudId, '42');
});
test('countPlaylists zählt auch Grabsteine', () async {
final db = MeloDb(NativeDatabase.memory());
addTearDown(db.close);
final id = await db.createPlaylist('Mix');
await db.deletePlaylist(id);
// Sonst hielte die Wiederherstellung ein Gerät, auf dem der Nutzer alle
// Playlisten gelöscht hat, für eine Neuinstallation.
expect(await db.countPlaylists(), 1);
});
}
-131
View File
@@ -1,32 +1,7 @@
import 'dart:convert';
import 'package:drift/native.dart';
import 'package:flutter_test/flutter_test.dart';
import 'package:http/http.dart' as http;
import 'package:http/testing.dart';
import 'package:melo/library/database.dart';
import 'package:melo/library/playlist_service.dart';
import 'package:melo/services/baka_auth.dart';
import 'package:melo/services/melo_cloud_service.dart';
class _MemorySpeicher implements TokenSpeicher {
_MemorySpeicher(this.werte);
final Map<String, String> werte;
@override
Future<String?> lesen(String key) async => werte[key];
@override
Future<void> schreiben(String key, String wert) async => werte[key] = wert;
@override
Future<void> loeschen(String key) async => werte.remove(key);
}
Future<BakaAuth> _angemeldeteAuth() async {
final auth = BakaAuth(
speicher: _MemorySpeicher({'baka_token': 'tok', 'baka_user': 'Baka'}),
);
await auth.laden();
return auth;
}
void main() {
late MeloDb db;
@@ -86,110 +61,4 @@ void main() {
expect(songs.map((s) => s.id).toList(), ['song-3', 'song-1', 'song-2']);
expect(notified, true);
});
group('Sofort-Push der Favoriten', () {
Future<void> legeSongAn(MeloDb db, {String? cloudId}) async {
await db.into(db.songs).insert(SongsCompanion.insert(
id: 'song-1',
path: '/a.mp3',
title: 'A',
dateAddedMs: 0,
updatedAtMs: 0,
));
if (cloudId != null) await db.setCloudId('song-1', cloudId);
}
test('setzt deterministisch true beim Favorisieren', () async {
final db2 = MeloDb(NativeDatabase.memory());
addTearDown(db2.close);
await legeSongAn(db2, cloudId: 'c1');
final gesendet = <Map<String, dynamic>>[];
final dienst = PlaylistService(
db2,
cloud: MeloCloudService(
auth: await _angemeldeteAuth(),
client: MockClient((anfrage) async {
gesendet.add(jsonDecode(anfrage.body) as Map<String, dynamic>);
return http.Response(jsonEncode({'status': 'ok'}), 200);
}),
),
);
await dienst.toggleFavorite('song-1');
expect(gesendet, [
{'song_id': 'c1', 'set': true}
]);
});
test('setzt deterministisch false beim Ent-Favorisieren', () async {
final db2 = MeloDb(NativeDatabase.memory());
addTearDown(db2.close);
await legeSongAn(db2, cloudId: 'c1');
await db2.setFavorite('song-1', true);
final gesendet = <Map<String, dynamic>>[];
final dienst = PlaylistService(
db2,
cloud: MeloCloudService(
auth: await _angemeldeteAuth(),
client: MockClient((anfrage) async {
gesendet.add(jsonDecode(anfrage.body) as Map<String, dynamic>);
return http.Response(jsonEncode({'status': 'ok'}), 200);
}),
),
);
await dienst.toggleFavorite('song-1');
expect(gesendet, [
{'song_id': 'c1', 'set': false}
]);
});
test('ohne cloudId wird nichts gemeldet', () async {
final db2 = MeloDb(NativeDatabase.memory());
addTearDown(db2.close);
await legeSongAn(db2);
var anfragen = 0;
final dienst = PlaylistService(
db2,
cloud: MeloCloudService(
auth: await _angemeldeteAuth(),
client: MockClient((_) async {
anfragen++;
return http.Response(jsonEncode({'status': 'ok'}), 200);
}),
),
);
await dienst.toggleFavorite('song-1');
expect(anfragen, 0);
expect(await db2.watchIsFavorite('song-1').first, isTrue);
});
test('ein Fehler des Servers ändert lokal nichts und wirft nicht',
() async {
final db2 = MeloDb(NativeDatabase.memory());
addTearDown(db2.close);
await legeSongAn(db2, cloudId: 'c1');
final dienst = PlaylistService(
db2,
cloud: MeloCloudService(
auth: await _angemeldeteAuth(),
client: MockClient(
(_) async => http.Response(jsonEncode({'error': 'weg'}), 500)),
),
);
// Der nächste Voll-Abgleich holt den Push additiv nach.
await dienst.toggleFavorite('song-1');
expect(await db2.watchIsFavorite('song-1').first, isTrue);
});
});
}
-254
View File
@@ -1,254 +0,0 @@
import 'dart:convert';
import 'package:drift/native.dart';
import 'package:flutter_test/flutter_test.dart';
import 'package:http/http.dart' as http;
import 'package:http/testing.dart';
import 'package:melo/library/database.dart';
import 'package:melo/library/playlist_service.dart';
import 'package:melo/services/baka_auth.dart';
import 'package:melo/services/melo_cloud_service.dart';
class _MemorySpeicher implements TokenSpeicher {
_MemorySpeicher(this.werte);
final Map<String, String> werte;
@override
Future<String?> lesen(String key) async => werte[key];
@override
Future<void> schreiben(String key, String wert) async => werte[key] = wert;
@override
Future<void> loeschen(String key) async => werte.remove(key);
}
Future<MeloCloudService> cloudMit(
Future<http.Response> Function(http.Request) antwort) async {
final auth = BakaAuth(
speicher: _MemorySpeicher({'baka_token': 'tok', 'baka_user': 'Baka'}),
);
await auth.laden();
return MeloCloudService(auth: auth, client: MockClient(antwort));
}
void main() {
test('eine neue Playlist wird gemeldet und ihre Server-ID gemerkt',
() async {
final db = MeloDb(NativeDatabase.memory());
addTearDown(db.close);
final dienst = PlaylistService(
db,
cloud: await cloudMit((_) async => http.Response(
// Form von handle_playlist_create: die ID liegt unter „playlist".
jsonEncode({
'status': 'ok',
'playlist': {'id': 7, 'name': 'Road Trip'}
}),
200,
)),
);
final id = await dienst.createPlaylist('Road Trip');
expect((await db.playlistById(id))!.cloudId, '7');
});
test('ein Song ohne cloudId wird nicht mitgemeldet', () async {
final db = MeloDb(NativeDatabase.memory());
addTearDown(db.close);
var songMeldungen = 0;
final dienst = PlaylistService(
db,
cloud: await cloudMit((anfrage) async {
if (anfrage.url.path.endsWith('/songs')) songMeldungen++;
return http.Response(
jsonEncode({
'status': 'ok',
'playlist': {'id': 7, 'name': 'Mix'}
}),
200,
);
}),
);
await db.into(db.songs).insert(SongsCompanion.insert(
id: 'song-1', path: '/a.mp3', title: 'A',
dateAddedMs: 0, updatedAtMs: 0,
));
final id = await dienst.createPlaylist('Mix');
await dienst.addSongToPlaylist(id, 'song-1', 0);
expect(songMeldungen, 0);
// Lokal ist er trotzdem drin — kein Fehler, nur nichts zu melden.
expect(await db.watchPlaylistSongs(id).first, hasLength(1));
});
/// Legt einen Titel mit Server-ID an. Ohne den fällt jeder Push aus, und
/// die Negativtests allein hätten den ganzen Vertrag nie berührt.
Future<void> legeSongAn(MeloDb db, String id, String cloudId) async {
await db.into(db.songs).insert(SongsCompanion.insert(
id: id, path: '/$id.mp3', title: id,
dateAddedMs: 0, updatedAtMs: 0,
));
await db.setCloudId(id, cloudId);
}
test('ein Song mit cloudId wird an die Server-Playlist gemeldet', () async {
final db = MeloDb(NativeDatabase.memory());
addTearDown(db.close);
Object? koerper;
String? pfad;
final dienst = PlaylistService(
db,
cloud: await cloudMit((anfrage) async {
if (anfrage.method == 'POST' && anfrage.url.path.endsWith('/songs')) {
pfad = anfrage.url.path;
koerper = jsonDecode(anfrage.body);
}
return http.Response(
jsonEncode({
'status': 'ok',
'playlist': {'id': 7, 'name': 'Mix'}
}),
200,
);
}),
);
await legeSongAn(db, 'song-1', 'c1');
final id = await dienst.createPlaylist('Mix');
await dienst.addSongToPlaylist(id, 'song-1', 0);
expect(pfad, endsWith('/playlists/7/songs'));
expect(koerper, {
'song_ids': ['c1']
});
});
test('das Entfernen geht als DELETE auf den Song-Pfad', () async {
final db = MeloDb(NativeDatabase.memory());
addTearDown(db.close);
String? geloeschterPfad;
final dienst = PlaylistService(
db,
cloud: await cloudMit((anfrage) async {
if (anfrage.method == 'DELETE') geloeschterPfad = anfrage.url.path;
return http.Response(
jsonEncode({
'status': 'ok',
'playlist': {'id': 7, 'name': 'Mix'}
}),
200,
);
}),
);
await legeSongAn(db, 'song-1', 'c1');
final id = await dienst.createPlaylist('Mix');
await dienst.addSongToPlaylist(id, 'song-1', 0);
await dienst.removeSongFromPlaylist(id, 'song-1');
expect(geloeschterPfad, endsWith('/playlists/7/songs/c1'));
expect(await db.watchPlaylistSongs(id).first, isEmpty);
});
test('eine neue Reihenfolge geht als positions-Paare raus', () async {
final db = MeloDb(NativeDatabase.memory());
addTearDown(db.close);
Object? koerper;
String? methode;
final dienst = PlaylistService(
db,
cloud: await cloudMit((anfrage) async {
if (anfrage.url.path.endsWith('/positions')) {
methode = anfrage.method;
koerper = jsonDecode(anfrage.body);
}
return http.Response(
jsonEncode({
'status': 'ok',
'playlist': {'id': 7, 'name': 'Mix'}
}),
200,
);
}),
);
await legeSongAn(db, 'song-1', 'c1');
await legeSongAn(db, 'song-2', 'c2');
final id = await dienst.createPlaylist('Mix');
await dienst.addSongToPlaylist(id, 'song-1', 0);
await dienst.addSongToPlaylist(id, 'song-2', 1);
await dienst.reorderAll(id, ['song-2', 'song-1']);
// Unter „song_ids" hätte der Server eine leere Liste gelesen und stumm
// „ok" geantwortet — dieser Test ist der einzige Ort, an dem das auffällt.
expect(methode, 'PUT');
expect(koerper, {
'positions': [
{'id': 'c2', 'position': 0},
{'id': 'c1', 'position': 1},
]
});
});
test('ein Endpunkt-Fehler ändert lokal nichts', () async {
final db = MeloDb(NativeDatabase.memory());
addTearDown(db.close);
final dienst = PlaylistService(
db,
cloud: await cloudMit(
(_) async => http.Response(jsonEncode({'error': 'weg'}), 500)),
);
final id = await dienst.createPlaylist('Mix');
expect((await db.playlistById(id))!.cloudId, isNull);
expect(await db.watchPlaylists().first, hasLength(1));
});
test('Wiederherstellung greift nur bei leerer Playlisten-Tabelle', () async {
final db = MeloDb(NativeDatabase.memory());
addTearDown(db.close);
final dienst = PlaylistService(
db,
cloud: await cloudMit((anfrage) async {
if (anfrage.url.path.endsWith('/playlists')) {
return http.Response(
jsonEncode({
'playlists': [
{'id': 7, 'name': 'Vom Server'}
]
}),
200,
);
}
return http.Response(jsonEncode({'songs': []}), 200);
}),
);
expect(await dienst.stelleWiederHer(), 1);
final angelegt = await db.watchPlaylists().first;
expect(angelegt.single.name, 'Vom Server');
expect(angelegt.single.cloudId, '7');
});
test('mit einer lokalen Playlist wird nichts angelegt (kein Rück-Merge)',
() async {
final db = MeloDb(NativeDatabase.memory());
addTearDown(db.close);
final dienst = PlaylistService(
db,
cloud: await cloudMit((_) async => http.Response(
jsonEncode({
'playlists': [
{'id': 7, 'name': 'Vom Server'}
]
}),
200,
)),
);
await db.createPlaylist('Meine eigene');
expect(await dienst.stelleWiederHer(), 0);
expect(await db.watchPlaylists().first, hasLength(1));
});
}
+73
View File
@@ -0,0 +1,73 @@
import 'package:drift/drift.dart';
import 'package:drift/native.dart';
import 'package:flutter_test/flutter_test.dart';
import 'package:melo/library/database.dart';
Future<void> _insertSong(MeloDb db, String id, {bool deleted = false}) {
return db.into(db.songs).insert(SongsCompanion.insert(
id: id,
path: '/$id.mp3',
title: id,
dateAddedMs: 0,
updatedAtMs: 0,
deleted: Value(deleted),
));
}
Future<void> _play(MeloDb db, String songId, int playedAtMs) {
return db.into(db.playbackHistory).insert(PlaybackHistoryCompanion.insert(
songId: songId,
positionMs: 0,
playedAtMs: playedAtMs,
));
}
void main() {
test('ein mehrfach gespielter Song erscheint nur einmal, an der Position '
'seines jüngsten Abspielens', () async {
final db = MeloDb(NativeDatabase.memory());
await _insertSong(db, 'a');
await _insertSong(db, 'b');
await _play(db, 'a', 1000);
await _play(db, 'b', 2000);
await _play(db, 'a', 3000); // a erneut gespielt, jetzt jüngster Play
final result = await db.watchRecentlyPlayed().first;
expect(result.map((s) => s.id).toList(), ['a', 'b']);
await db.close();
});
test('mehrere Songs erscheinen absteigend nach ihrem letzten Abspielen',
() async {
final db = MeloDb(NativeDatabase.memory());
await _insertSong(db, 'a');
await _insertSong(db, 'b');
await _insertSong(db, 'c');
await _play(db, 'a', 1000);
await _play(db, 'b', 3000);
await _play(db, 'c', 2000);
final result = await db.watchRecentlyPlayed().first;
expect(result.map((s) => s.id).toList(), ['b', 'c', 'a']);
await db.close();
});
test('ein gelöschter Song mit Wiedergabe-Historie erscheint nicht',
() async {
final db = MeloDb(NativeDatabase.memory());
await _insertSong(db, 'a', deleted: true);
await _insertSong(db, 'b');
await _play(db, 'a', 2000);
await _play(db, 'b', 1000);
final result = await db.watchRecentlyPlayed().first;
expect(result.map((s) => s.id).toList(), ['b']);
await db.close();
});
}
+128
View File
@@ -0,0 +1,128 @@
import 'package:audio_service/audio_service.dart';
import 'package:drift/drift.dart' show Value, driftRuntimeOptions;
import 'package:drift/native.dart';
import 'package:flutter/material.dart';
import 'package:flutter/services.dart';
import 'package:flutter_test/flutter_test.dart';
import 'package:provider/provider.dart';
import 'package:shared_preferences/shared_preferences.dart';
import 'package:melo/library/category_service.dart';
import 'package:melo/library/database.dart';
import 'package:melo/library/playlist_service.dart';
import 'package:melo/library/song_list.dart';
import 'package:melo/player/audio_handler.dart';
import 'package:melo/player/now_playing_screen.dart';
import 'package:melo/settings/app_settings.dart';
/// Ersetzt in [MeloAudioHandler.loadPlaylist] den echten just_audio-Zugriff:
/// der spricht über Plattform-Kanäle, die im Widget-Test nicht existieren
/// und mit `MissingPluginException` scheitern würden. Alles andere
/// (Warteschlange, Mediendaten) bleibt echtes Handler-Verhalten.
class _FakeAudioHandler extends MeloAudioHandler {
_FakeAudioHandler(MeloDb db) : super(db: db);
@override
Future<int> loadPlaylist(List<MediaItem> items, {int startIndex = 0}) async {
queue.add(items);
if (items.isNotEmpty) mediaItem.add(items[startIndex]);
return 0;
}
}
void main() {
late MeloDb db;
late CategoryService kategorien;
late PlaylistService playlists;
late AppSettings einstellungen;
late _FakeAudioHandler handler;
void stelleKanaeleRuhig() {
final messenger =
TestDefaultBinaryMessengerBinding.instance.defaultBinaryMessenger;
messenger.setMockMethodCallHandler(
const MethodChannel('plugins.flutter.io/path_provider'),
(call) async => '/tmp/melo-test',
);
messenger.setMockMethodCallHandler(
const MethodChannel('plugins.it_nomads.com/flutter_secure_storage'),
(call) async => null,
);
}
setUp(() async {
TestWidgetsFlutterBinding.ensureInitialized();
driftRuntimeOptions.dontWarnAboutMultipleDatabases = true;
SharedPreferences.setMockInitialValues({});
stelleKanaeleRuhig();
db = MeloDb(NativeDatabase.memory());
kategorien = CategoryService(db);
playlists = PlaylistService(db);
einstellungen = AppSettings();
await einstellungen.init();
handler = _FakeAudioHandler(db);
await db.into(db.songs).insert(SongsCompanion.insert(
id: 'song-1',
path: '/music/roses.mp3',
title: 'Roses',
artist: const Value('Neoni'),
dateAddedMs: 0,
updatedAtMs: 0,
));
});
tearDown(() {
handler.dispose();
kategorien.dispose();
playlists.dispose();
});
Song derSong() => Song(
id: 'song-1',
path: '/music/roses.mp3',
title: 'Roses',
artist: 'Neoni',
dateAddedMs: 0,
updatedAtMs: 0,
deleted: false,
playCount: 0,
categoriesEdited: false,
metadataEdited: false,
);
testWidgets('Song antippen öffnet den Vollbild-Player mit großem Cover',
(tester) async {
await tester.pumpWidget(
MultiProvider(
providers: [
Provider<MeloDb>.value(value: db),
Provider<MeloAudioHandler>.value(value: handler),
ChangeNotifierProvider<CategoryService>.value(value: kategorien),
ChangeNotifierProvider<PlaylistService>.value(value: playlists),
ChangeNotifierProvider<AppSettings>.value(value: einstellungen),
],
child: MaterialApp(
home: Scaffold(
body: SongZeile(
song: derSong(),
warteschlange: [derSong()],
index: 0,
),
),
),
),
);
expect(find.byType(NowPlayingScreen), findsNothing);
await tester.tap(find.text('Roses'));
await tester.pumpAndSettle();
expect(find.byType(NowPlayingScreen), findsOneWidget);
// Ohne diesen Abschluss bleibt ein drift-Stream-Abo (Favoriten-Herz)
// beim Abbau des Baums als offener Fake-Timer stehen — dieselbe
// Aufräum-Zeile wie in song_zeile_lauf_test.dart.
await tester.pumpWidget(const SizedBox());
await tester.pump(const Duration(milliseconds: 1));
});
}
+30
View File
@@ -0,0 +1,30 @@
import 'package:audio_service/audio_service.dart';
import 'package:flutter_test/flutter_test.dart';
import 'package:just_audio/just_audio.dart';
import 'package:melo/player/audio_handler.dart';
void main() {
group('toAudioServiceShuffleMode', () {
test('true wird zu AudioServiceShuffleMode.all', () {
expect(toAudioServiceShuffleMode(true), AudioServiceShuffleMode.all);
});
test('false wird zu AudioServiceShuffleMode.none', () {
expect(toAudioServiceShuffleMode(false), AudioServiceShuffleMode.none);
});
});
group('toAudioServiceRepeatMode', () {
test('LoopMode.one wird zu AudioServiceRepeatMode.one', () {
expect(toAudioServiceRepeatMode(LoopMode.one), AudioServiceRepeatMode.one);
});
test('LoopMode.all wird zu AudioServiceRepeatMode.all', () {
expect(toAudioServiceRepeatMode(LoopMode.all), AudioServiceRepeatMode.all);
});
test('LoopMode.off wird zu AudioServiceRepeatMode.none', () {
expect(toAudioServiceRepeatMode(LoopMode.off), AudioServiceRepeatMode.none);
});
});
}
+155
View File
@@ -0,0 +1,155 @@
import 'package:audio_service/audio_service.dart';
import 'package:drift/drift.dart' show Value, driftRuntimeOptions;
import 'package:drift/native.dart';
import 'package:flutter/material.dart';
import 'package:flutter/services.dart';
import 'package:flutter_test/flutter_test.dart';
import 'package:provider/provider.dart';
import 'package:shared_preferences/shared_preferences.dart';
import 'package:melo/library/category_service.dart';
import 'package:melo/library/database.dart';
import 'package:melo/library/playlist_service.dart';
import 'package:melo/library/song_list.dart';
import 'package:melo/player/audio_handler.dart';
import 'package:melo/player/now_playing_screen.dart';
import 'package:melo/settings/app_settings.dart';
import 'package:melo/shared/favorite_button.dart';
/// Ersetzt in [MeloAudioHandler.loadPlaylist] den echten just_audio-Zugriff —
/// dieselbe Klasse wie in song_list_navigation_test.dart, dort erprobt.
class _FakeAudioHandler extends MeloAudioHandler {
_FakeAudioHandler(MeloDb db) : super(db: db);
@override
Future<int> loadPlaylist(List<MediaItem> items, {int startIndex = 0}) async {
queue.add(items);
if (items.isNotEmpty) mediaItem.add(items[startIndex]);
return 0;
}
}
void main() {
late MeloDb db;
late CategoryService kategorien;
late PlaylistService playlists;
late AppSettings einstellungen;
late _FakeAudioHandler handler;
void stelleKanaeleRuhig() {
final messenger =
TestDefaultBinaryMessengerBinding.instance.defaultBinaryMessenger;
messenger.setMockMethodCallHandler(
const MethodChannel('plugins.flutter.io/path_provider'),
(call) async => '/tmp/melo-test',
);
messenger.setMockMethodCallHandler(
const MethodChannel('plugins.it_nomads.com/flutter_secure_storage'),
(call) async => null,
);
}
setUp(() async {
TestWidgetsFlutterBinding.ensureInitialized();
driftRuntimeOptions.dontWarnAboutMultipleDatabases = true;
SharedPreferences.setMockInitialValues({});
stelleKanaeleRuhig();
db = MeloDb(NativeDatabase.memory());
kategorien = CategoryService(db);
playlists = PlaylistService(db);
einstellungen = AppSettings();
await einstellungen.init();
handler = _FakeAudioHandler(db);
await db.into(db.songs).insert(SongsCompanion.insert(
id: 'song-1',
path: '/music/roses.mp3',
title: 'Roses',
artist: const Value('Neoni'),
dateAddedMs: 0,
updatedAtMs: 0,
));
});
tearDown(() {
handler.dispose();
kategorien.dispose();
playlists.dispose();
});
Song derSong() => Song(
id: 'song-1',
path: '/music/roses.mp3',
title: 'Roses',
artist: 'Neoni',
dateAddedMs: 0,
updatedAtMs: 0,
deleted: false,
playCount: 0,
categoriesEdited: false,
metadataEdited: false,
);
// Öffnet den Vollbild-Player über denselben Weg wie in
// song_list_navigation_test.dart (Tap auf eine SongZeile) — dieser Weg ist
// dort nachweislich unproblematisch, im Unterschied zu einem direkten
// Aufbau von NowPlayingScreen mit vorab befülltem MediaItem-Stream.
Future<void> oeffnePlayer(WidgetTester tester) async {
await tester.pumpWidget(
MultiProvider(
providers: [
Provider<MeloDb>.value(value: db),
Provider<MeloAudioHandler>.value(value: handler),
ChangeNotifierProvider<CategoryService>.value(value: kategorien),
ChangeNotifierProvider<PlaylistService>.value(value: playlists),
ChangeNotifierProvider<AppSettings>.value(value: einstellungen),
],
child: MaterialApp(
home: Scaffold(
body: SongZeile(
song: derSong(),
warteschlange: [derSong()],
index: 0,
),
),
),
),
);
await tester.tap(find.text('Roses'));
await tester.pumpAndSettle();
}
Future<void> raeumeAuf(WidgetTester tester) async {
// Ohne diesen Abschluss bleibt ein drift-Stream-Abo (Favoriten-Herz)
// beim Abbau des Baums als offener Fake-Timer stehen — dieselbe
// Aufräum-Zeile wie in song_list_navigation_test.dart.
await tester.pumpWidget(const SizedBox());
await tester.pump(const Duration(milliseconds: 1));
}
testWidgets(
'Herz sitzt neben dem Songnamen, nicht mehr in der AppBar',
(tester) async {
await oeffnePlayer(tester);
expect(find.byType(NowPlayingScreen), findsOneWidget);
// Nicht mehr in der AppBar:
final herzInAppBar = find.descendant(
of: find.byType(AppBar),
matching: find.byType(FavoriteButton),
);
expect(herzInAppBar, findsNothing);
// Aber sichtbar auf dem Bildschirm, in derselben Row wie der Titel.
final titelRow = find
.ancestor(of: find.text('Roses'), matching: find.byType(Row))
.first;
final herzBeimTitel = find.descendant(
of: titelRow,
matching: find.byType(FavoriteButton),
);
expect(herzBeimTitel, findsOneWidget);
await raeumeAuf(tester);
});
}
@@ -0,0 +1,121 @@
import 'package:audio_service/audio_service.dart';
import 'package:drift/drift.dart' show Value, driftRuntimeOptions;
import 'package:drift/native.dart';
import 'package:flutter/material.dart';
import 'package:flutter/services.dart';
import 'package:flutter_test/flutter_test.dart';
import 'package:provider/provider.dart';
import 'package:shared_preferences/shared_preferences.dart';
import 'package:melo/library/category_service.dart';
import 'package:melo/library/database.dart';
import 'package:melo/library/playlist_service.dart';
import 'package:melo/player/audio_handler.dart';
import 'package:melo/player/now_playing_screen.dart';
import 'package:melo/playlists/playlist_detail_screen.dart';
import 'package:melo/settings/app_settings.dart';
/// Ersetzt in [MeloAudioHandler.loadPlaylist] den echten just_audio-Zugriff:
/// der spricht über Plattform-Kanäle, die im Widget-Test nicht existieren
/// und mit `MissingPluginException` scheitern würden. Alles andere
/// (Warteschlange, Mediendaten) bleibt echtes Handler-Verhalten.
class _FakeAudioHandler extends MeloAudioHandler {
_FakeAudioHandler(MeloDb db) : super(db: db);
@override
Future<int> loadPlaylist(List<MediaItem> items, {int startIndex = 0}) async {
queue.add(items);
if (items.isNotEmpty) mediaItem.add(items[startIndex]);
return 0;
}
}
void main() {
late MeloDb db;
late CategoryService kategorien;
late PlaylistService playlists;
late AppSettings einstellungen;
late _FakeAudioHandler handler;
late String playlistId;
void stelleKanaeleRuhig() {
final messenger =
TestDefaultBinaryMessengerBinding.instance.defaultBinaryMessenger;
messenger.setMockMethodCallHandler(
const MethodChannel('plugins.flutter.io/path_provider'),
(call) async => '/tmp/melo-test',
);
messenger.setMockMethodCallHandler(
const MethodChannel('plugins.it_nomads.com/flutter_secure_storage'),
(call) async => null,
);
}
setUp(() async {
TestWidgetsFlutterBinding.ensureInitialized();
driftRuntimeOptions.dontWarnAboutMultipleDatabases = true;
SharedPreferences.setMockInitialValues({});
stelleKanaeleRuhig();
db = MeloDb(NativeDatabase.memory());
kategorien = CategoryService(db);
playlists = PlaylistService(db);
einstellungen = AppSettings();
await einstellungen.init();
handler = _FakeAudioHandler(db);
await db.into(db.songs).insert(SongsCompanion.insert(
id: 'song-1',
path: '/music/roses.mp3',
title: 'Roses',
artist: const Value('Neoni'),
dateAddedMs: 0,
updatedAtMs: 0,
));
playlistId = await db.createPlaylist('Road Trip');
await db.addSongToPlaylist(playlistId, 'song-1', 0);
});
tearDown(() {
handler.dispose();
kategorien.dispose();
playlists.dispose();
});
testWidgets(
'Song in einer Wiedergabeliste antippen öffnet den Vollbild-Player',
(tester) async {
final playlist = Playlist(
id: playlistId,
name: 'Road Trip',
createdAtMs: 0,
updatedAtMs: 0,
deleted: false,
);
await tester.pumpWidget(
MultiProvider(
providers: [
Provider<MeloDb>.value(value: db),
Provider<MeloAudioHandler>.value(value: handler),
ChangeNotifierProvider<CategoryService>.value(value: kategorien),
ChangeNotifierProvider<PlaylistService>.value(value: playlists),
ChangeNotifierProvider<AppSettings>.value(value: einstellungen),
],
child: MaterialApp(
home: PlaylistDetailScreen(playlist: playlist),
),
),
);
await tester.pumpAndSettle();
expect(find.byType(NowPlayingScreen), findsNothing);
await tester.tap(find.text('Roses'));
await tester.pumpAndSettle();
expect(find.byType(NowPlayingScreen), findsOneWidget);
// Ohne diesen Abschluss bleibt ein drift-Stream-Abo beim Abbau des
// Baums als offener Fake-Timer stehen.
await tester.pumpWidget(const SizedBox());
await tester.pump(const Duration(milliseconds: 1));
});
}
+38
View File
@@ -115,6 +115,44 @@ void main() {
expect(auth.benutzer, 'Baka');
});
test(
'autoAnmelden löst bei gleichzeitigen Aufrufen nur EINEN HTTP-Request aus '
'(Race Condition durch IndexedStack, das mehrere Tabs gleichzeitig baut)',
() async {
var aufrufe = 0;
final client = MockClient((_) async {
aufrufe++;
// Künstliche Verzögerung: simuliert, dass der erste Request noch
// nicht zurück ist, wenn der zweite Aufruf startet.
await Future.delayed(const Duration(milliseconds: 50));
return http.Response(jsonEncode({'token': 'jwt-tinker'}), 200);
});
final auth = BakaAuth(client: client, speicher: _MemorySpeicher());
await Future.wait([
auth.autoAnmelden('Tinker', 'geheim'),
auth.autoAnmelden('Tinker', 'geheim'),
]);
expect(aufrufe, 1);
expect(auth.istAngemeldet, isTrue);
expect(auth.benutzer, 'Tinker');
});
test(
'autoAnmelden merkt sich den Fehlergrund für die Diagnose, da es '
'selbst keinen Rückgabewert liefert', () async {
final client = MockClient((_) async => http.Response(
jsonEncode({'status': 'error', 'message': 'Falsches Passwort'}),
200));
final auth = BakaAuth(client: client, speicher: _MemorySpeicher());
await auth.autoAnmelden('Tinker', 'falsch');
expect(auth.letzterAutoLoginFehler, 'Falsches Passwort');
expect(auth.istAngemeldet, isFalse);
});
test('autoAnmelden tut nichts ohne Zugangsdaten', () async {
var aufrufe = 0;
final client = MockClient((_) async {
-24
View File
@@ -1,9 +1,6 @@
import 'package:drift/native.dart';
import 'package:flutter_test/flutter_test.dart';
import 'package:melo/library/database.dart';
import 'package:melo/services/download_service.dart';
import 'package:melo/services/download_speicher.dart';
import 'package:melo/services/navidrome_service.dart';
void main() {
group('brauchtRueckfrage', () {
@@ -57,25 +54,4 @@ void main() {
expect(DownloadSpeicher.dateiName('abc'), endsWith('.mp3'));
});
});
group('ladeEinzelnenTitel', () {
test('ohne Serververbindung wird nichts geladen und der Grund steht da',
() async {
final db = MeloDb(NativeDatabase.memory());
addTearDown(db.close);
final dienst = DownloadService(db: db, navidrome: NavidromeService());
final neu = await dienst.ladeEinzelnenTitel(const SubsonicSong(
id: 'nav-1',
titel: 'Nachtpuls',
kuenstler: 'Rotklang',
album: 'Nacht',
dauerSekunden: 200,
));
expect(neu, isFalse);
expect(dienst.fehler, contains('Musikserver'));
expect(await db.downloadIds(), isEmpty);
});
});
}
@@ -1,150 +0,0 @@
import 'dart:convert';
import 'package:flutter_test/flutter_test.dart';
import 'package:http/http.dart' as http;
import 'package:http/testing.dart';
import 'package:melo/services/baka_auth.dart';
import 'package:melo/services/melo_cloud_service.dart';
class _MemorySpeicher implements TokenSpeicher {
_MemorySpeicher(this.werte);
final Map<String, String> werte;
@override
Future<String?> lesen(String key) async => werte[key];
@override
Future<void> schreiben(String key, String wert) async => werte[key] = wert;
@override
Future<void> loeschen(String key) async => werte.remove(key);
}
Future<MeloCloudService> baue(
Future<http.Response> Function(http.Request) antwort) async {
final auth = BakaAuth(
speicher: _MemorySpeicher({'baka_token': 'tok', 'baka_user': 'Baka'}),
);
await auth.laden();
return MeloCloudService(auth: auth, client: MockClient(antwort));
}
void main() {
test('legePlaylistAn liefert die Server-ID', () async {
final dienst = await baue((anfrage) async {
expect(anfrage.method, 'POST');
expect(anfrage.url.path, endsWith('/playlists'));
expect(jsonDecode(anfrage.body), {'name': 'Road Trip'});
// handle_playlist_create verpackt die ID unter „playlist" — genau so
// antwortet der echte Server, und genau daran ist der Vertrag geknüpft.
return http.Response(
jsonEncode({
'status': 'ok',
'playlist': {'id': 7, 'name': 'Road Trip', 'song_count': 0}
}),
200,
);
});
expect(await dienst.legePlaylistAn('Road Trip'), '7');
});
test('eine Antwort ohne playlist-Block ist ein Fehler', () async {
// Die ID auf oberster Ebene zu suchen wäre der naheliegende Fehler; er
// fiele am echten Server als „null" auf und sonst nirgends.
final dienst = await baue(
(_) async => http.Response(jsonEncode({'status': 'ok'}), 200));
expect(() => dienst.legePlaylistAn('Road Trip'),
throwsA(isA<CloudException>()));
});
test('ein Fehler im 200er-Körper wird geworfen', () async {
final dienst = await baue((_) async =>
http.Response(jsonEncode({'error': 'kein Name'}), 200));
expect(() => dienst.legePlaylistAn(''),
throwsA(isA<CloudException>()));
});
test('fuegePlaylistSongsHinzu meldet die Song-IDs', () async {
Map<String, dynamic>? gesendet;
final dienst = await baue((anfrage) async {
expect(anfrage.url.path, endsWith('/playlists/7/songs'));
gesendet = jsonDecode(anfrage.body) as Map<String, dynamic>;
return http.Response(jsonEncode({'status': 'ok'}), 200);
});
await dienst.fuegePlaylistSongsHinzu('7', ['c1', 'c2']);
expect(gesendet, {
'song_ids': ['c1', 'c2']
});
});
test('entfernePlaylistSong benutzt DELETE auf dem Song-Pfad', () async {
String? pfad;
String? methode;
final dienst = await baue((anfrage) async {
pfad = anfrage.url.path;
methode = anfrage.method;
return http.Response(jsonEncode({'status': 'ok'}), 200);
});
await dienst.entfernePlaylistSong('7', 'c1');
expect(methode, 'DELETE');
expect(pfad, endsWith('/playlists/7/songs/c1'));
});
test('setzePlaylistReihenfolge benutzt PUT auf /positions', () async {
String? methode;
Map<String, dynamic>? gesendet;
final dienst = await baue((anfrage) async {
methode = anfrage.method;
expect(anfrage.url.path, endsWith('/playlists/7/positions'));
gesendet = jsonDecode(anfrage.body) as Map<String, dynamic>;
return http.Response(jsonEncode({'status': 'ok'}), 200);
});
await dienst.setzePlaylistReihenfolge('7', ['c2', 'c1']);
expect(methode, 'PUT');
// Der Router liest „positions", der Handler erwartet Paare. Unter
// „song_ids" bekäme der Server eine leere Liste und antwortete stumm
// „ok" — die Reihenfolge käme nie an, ohne jede Fehlermeldung.
expect(gesendet, {
'positions': [
{'id': 'c2', 'position': 0},
{'id': 'c1', 'position': 1},
]
});
});
test('playlisten liest Name und ID', () async {
final dienst = await baue((_) async => http.Response(
jsonEncode({
'playlists': [
{'id': 7, 'name': 'Road Trip'}
]
}),
200,
));
final listen = await dienst.playlisten();
expect(listen.single.id, '7');
expect(listen.single.name, 'Road Trip');
});
test('playlistSongs liefert die Song-IDs in Reihenfolge', () async {
final dienst = await baue((_) async => http.Response(
jsonEncode({
'songs': [
{'id': 'c1'},
{'id': 'c2'},
]
}),
200,
));
expect(await dienst.playlistSongs('7'), ['c1', 'c2']);
});
}
+3 -81
View File
@@ -1,30 +1,8 @@
import 'dart:convert';
import 'package:flutter_test/flutter_test.dart';
import 'package:http/http.dart' as http;
import 'package:http/testing.dart';
import 'package:melo/services/baka_auth.dart';
import 'package:melo/services/melo_cloud_service.dart';
class _MemorySpeicher implements TokenSpeicher {
_MemorySpeicher(this.werte);
final Map<String, String> werte;
@override
Future<String?> lesen(String key) async => werte[key];
@override
Future<void> schreiben(String key, String wert) async => werte[key] = wert;
@override
Future<void> loeschen(String key) async => werte.remove(key);
}
Future<BakaAuth> _angemeldeteAuth() async {
final auth = BakaAuth(
speicher: _MemorySpeicher({'baka_token': 'tok', 'baka_user': 'Baka'}),
);
await auth.laden();
return auth;
}
void main() {
group('parseListe', () {
test('liest Titel inklusive Grabsteinen', () {
@@ -117,30 +95,9 @@ void main() {
expect(MeloCloudService.parseFavoriten(body), ['a', 'b']);
});
test('eine leere Favoritenliste ist kein Fehler', () {
expect(
MeloCloudService.parseFavoriten(jsonEncode({'favorites': []})),
isEmpty,
);
});
test('fehlender Schlüssel ist ein Fehler, keine leere Menge', () {
// Der Router verdrahtet für GET /favorites hart HTTP 200; sechs Handler
// desselben Servers melden Fehler im 200er-Körper. Ein fälschlich
// leeres Ergebnis wäre von einer echten Leerantwort nicht zu
// unterscheiden — wie parseListe und parseUpload wird deshalb geworfen.
expect(
() => MeloCloudService.parseFavoriten(jsonEncode({'status': 'ok'})),
throwsA(isA<CloudException>()),
);
});
test('Server-Fehler im 200er-Körper wird als CloudException gemeldet', () {
expect(
() => MeloCloudService.parseFavoriten(
jsonEncode({'status': 'error', 'error': 'Auth required'})),
throwsA(isA<CloudException>()),
);
test('ohne Favoriten leere Liste', () {
expect(MeloCloudService.parseFavoriten(jsonEncode({'status': 'ok'})),
isEmpty);
});
});
@@ -177,39 +134,4 @@ void main() {
});
});
});
group('setzeFavorit', () {
test('meldet den Wunsch deterministisch, nicht als Umschalten', () async {
Map<String, dynamic>? gesendet;
String? pfad;
final dienst = MeloCloudService(
auth: await _angemeldeteAuth(),
client: MockClient((anfrage) async {
pfad = anfrage.url.path;
gesendet = jsonDecode(anfrage.body) as Map<String, dynamic>;
return http.Response(jsonEncode({'status': 'ok'}), 200);
}),
);
await dienst.setzeFavorit('c5', true);
expect(pfad, endsWith('/favorites/toggle'));
expect(gesendet, {'song_id': 'c5', 'set': true});
});
test('kann einen Favoriten auch ausdrücklich entfernen', () async {
Map<String, dynamic>? gesendet;
final dienst = MeloCloudService(
auth: await _angemeldeteAuth(),
client: MockClient((anfrage) async {
gesendet = jsonDecode(anfrage.body) as Map<String, dynamic>;
return http.Response(jsonEncode({'status': 'ok'}), 200);
}),
);
await dienst.setzeFavorit('c5', false);
expect(gesendet, {'song_id': 'c5', 'set': false});
});
});
}
-122
View File
@@ -1,122 +0,0 @@
import 'package:flutter_test/flutter_test.dart';
import 'package:melo/services/sync_merge.dart';
void main() {
group('zuPushendeFavoriten', () {
test('leer gegen leer ergibt nichts', () {
expect(
zuPushendeFavoriten(
lokaleFavoriten: const {},
cloudIdVon: const {},
amServer: const {},
),
isEmpty,
);
});
test('was der Server noch nicht hat, geht hoch', () {
expect(
zuPushendeFavoriten(
lokaleFavoriten: const {'s1', 's2'},
cloudIdVon: const {'s1': 'c1', 's2': 'c2'},
amServer: const {'c1'},
),
['c2'],
);
});
test('Titel ohne cloudId kennt der Server nicht und bleiben liegen', () {
// Lokal-only: der Titel wurde nie hochgeladen, es gibt nichts zu melden.
expect(
zuPushendeFavoriten(
lokaleFavoriten: const {'s1'},
cloudIdVon: const {},
amServer: const {},
),
isEmpty,
);
});
test('was beidseitig steht, wird nicht erneut gepusht', () {
expect(
zuPushendeFavoriten(
lokaleFavoriten: const {'s1'},
cloudIdVon: const {'s1': 'c1'},
amServer: const {'c1'},
),
isEmpty,
);
});
test('der Deckel begrenzt einen Lauf', () {
final viele = {for (var i = 0; i < 250; i++) 's$i'};
final zuordnung = {for (var i = 0; i < 250; i++) 's$i': 'c$i'};
final offen = zuPushendeFavoriten(
lokaleFavoriten: viele,
cloudIdVon: zuordnung,
amServer: const {},
);
expect(offen, hasLength(maxFavoritenPushes));
});
});
group('lokalZuSetzendeFavoriten', () {
test('disjunkte Mengen: der Server-Favorit kommt lokal dazu', () {
expect(
lokalZuSetzendeFavoriten(
amServer: const {'c9'},
songIdVonCloudId: const {'c9': 's9'},
lokaleFavoriten: const {},
),
['s9'],
);
});
test('eine lokal unauflösbare cloudId wird übersprungen, nicht gelöscht', () {
// Der Titel ist hier (noch) nicht vorhanden. Ein Favorit ohne Song wäre
// unsichtbar, würde aber ewig mitgeschleppt.
expect(
lokalZuSetzendeFavoriten(
amServer: const {'c9'},
songIdVonCloudId: const {},
lokaleFavoriten: const {},
),
isEmpty,
);
});
test('was lokal schon Favorit ist, wird nicht noch einmal gesetzt', () {
expect(
lokalZuSetzendeFavoriten(
amServer: const {'c1'},
songIdVonCloudId: const {'c1': 's1'},
lokaleFavoriten: const {'s1'},
),
isEmpty,
);
});
});
group('berichtFaellig', () {
final jetzt = DateTime(2026, 8, 27, 12);
test('ohne vorherigen Erfolg nicht fällig', () {
// Neuinstallation: „Willkommen zurück! 325 neue Songs" wäre Unsinn.
expect(berichtFaellig(null, jetzt), isFalse);
});
test('unter 24 Stunden nicht fällig', () {
expect(berichtFaellig(jetzt.subtract(const Duration(hours: 23)), jetzt),
isFalse);
});
test('ab 24 Stunden fällig', () {
expect(berichtFaellig(jetzt.subtract(const Duration(hours: 24)), jetzt),
isTrue);
expect(berichtFaellig(jetzt.subtract(const Duration(days: 3)), jetzt),
isTrue);
});
});
}
+5 -522
View File
@@ -1,4 +1,3 @@
import 'dart:async';
import 'dart:convert';
import 'dart:io';
@@ -164,7 +163,7 @@ void main() {
expect(await db.watchSongs().first, isEmpty);
});
test('lokale Favoriten werden additiv gepusht, nie als Voll-Ersatz', () async {
test('Favoriten werden mit ihren Server-IDs gemeldet', () async {
await db.upsertSongs([
SongsCompanion.insert(
id: 'lokal-1',
@@ -177,54 +176,7 @@ void main() {
await db.setCloudId('lokal-1', 'c5');
await db.setFavorite('lokal-1', true);
final gepusht = <Map<String, dynamic>>[];
var vollErsatz = 0;
final sync = await baue((anfrage) async {
final pfad = anfrage.url.path;
if (pfad.endsWith('/list')) {
return http.Response(
jsonEncode({
'songs': [
{'id': 'c5', 'title': 'Lieblingslied'}
]
}),
200,
);
}
if (pfad.endsWith('/favorites/toggle')) {
gepusht.add(jsonDecode(anfrage.body) as Map<String, dynamic>);
return http.Response(jsonEncode({'status': 'ok'}), 200);
}
if (pfad.endsWith('/favorites')) {
if (anfrage.method == 'POST') vollErsatz++;
return http.Response(jsonEncode({'favorites': []}), 200);
}
return http.Response(jsonEncode({'status': 'ok'}), 200);
});
await sync.synchronisiere();
expect(gepusht, [
{'song_id': 'c5', 'set': true}
]);
// Der Datenverlust-Bug ist strukturell weg: es gibt keinen Aufruf mehr,
// der den Server-Stand ersetzen könnte.
expect(vollErsatz, 0);
expect(sync.fehler, isNull);
});
test('ein Server-Favorit wird lokal nachgezogen', () async {
await db.upsertSongs([
SongsCompanion.insert(
id: 'lokal-1',
path: '${tempDir.path}/fav.mp3',
title: 'Lieblingslied',
dateAddedMs: 0,
updatedAtMs: 0,
),
]);
await db.setCloudId('lokal-1', 'c5');
List<String>? gemeldet;
final sync = await baue((anfrage) async {
final pfad = anfrage.url.path;
if (pfad.endsWith('/list')) {
@@ -238,146 +190,15 @@ void main() {
);
}
if (pfad.endsWith('/favorites')) {
return http.Response(
jsonEncode({
'favorites': [
{'id': 'c5'}
]
}),
200,
);
final d = jsonDecode(anfrage.body) as Map<String, dynamic>;
gemeldet = (d['song_ids'] as List).cast<String>();
}
return http.Response(jsonEncode({'status': 'ok'}), 200);
});
await sync.synchronisiere();
expect(await db.favoriteSongIds(), ['lokal-1']);
});
test('200 mit Fehlerkörper überspringt die Favoriten-Phase ohne Push',
() async {
await db.upsertSongs([
SongsCompanion.insert(
id: 'lokal-1',
path: '${tempDir.path}/fav.mp3',
title: 'Lieblingslied',
dateAddedMs: 0,
updatedAtMs: 0,
),
]);
await db.setCloudId('lokal-1', 'c5');
await db.setFavorite('lokal-1', true);
var pushes = 0;
final sync = await baue((anfrage) async {
final pfad = anfrage.url.path;
if (pfad.endsWith('/list')) {
return http.Response(
jsonEncode({
'songs': [
{'id': 'c5', 'title': 'Lieblingslied'}
]
}),
200,
);
}
if (pfad.endsWith('/favorites/toggle')) {
pushes++;
return http.Response(jsonEncode({'status': 'ok'}), 200);
}
if (pfad.endsWith('/favorites')) {
return http.Response(
jsonEncode({'status': 'error', 'error': 'kaputt'}), 200);
}
return http.Response(jsonEncode({'status': 'ok'}), 200);
});
await sync.synchronisiere();
expect(pushes, 0);
// Nur diese Phase fällt aus, der Lauf geht weiter.
expect(sync.fehler, isNull);
});
test('200 mit leerer Favoritenliste läuft normal durch', () async {
// Gegenprobe zum Test darüber: eine echte Leerantwort darf NICHT als
// Fehler gelten, sonst wäre die Sicherheitsregel trivial erfüllt.
await db.upsertSongs([
SongsCompanion.insert(
id: 'lokal-1',
path: '${tempDir.path}/fav.mp3',
title: 'Lieblingslied',
dateAddedMs: 0,
updatedAtMs: 0,
),
]);
await db.setCloudId('lokal-1', 'c5');
await db.setFavorite('lokal-1', true);
var pushes = 0;
final sync = await baue((anfrage) async {
final pfad = anfrage.url.path;
if (pfad.endsWith('/list')) {
return http.Response(
jsonEncode({
'songs': [
{'id': 'c5', 'title': 'Lieblingslied'}
]
}),
200,
);
}
if (pfad.endsWith('/favorites/toggle')) {
pushes++;
return http.Response(jsonEncode({'status': 'ok'}), 200);
}
if (pfad.endsWith('/favorites')) {
return http.Response(jsonEncode({'favorites': []}), 200);
}
return http.Response(jsonEncode({'status': 'ok'}), 200);
});
await sync.synchronisiere();
expect(pushes, 1);
});
test('eine Zeitüberschreitung beim Hochladen reißt den Lauf nicht ab',
() async {
final datei = File('${tempDir.path}/haengt.mp3');
await datei.writeAsBytes([1]);
await db.upsertSongs([
SongsCompanion.insert(
id: 'lokal-1',
path: datei.path,
title: 'Hängt',
dateAddedMs: 0,
updatedAtMs: 0,
),
]);
final sync = await baue((anfrage) async {
final pfad = anfrage.url.path;
if (pfad.endsWith('/list')) {
return http.Response(jsonEncode({'songs': []}), 200);
}
if (pfad.endsWith('/upload')) {
// Der 120-s-Timeout in melo_cloud_service wirft TimeoutException,
// nicht CloudException — ohne eigenen Zweig riss ein einziger
// hängender Upload den ganzen Lauf ab.
throw TimeoutException('zu lang');
}
if (pfad.endsWith('/favorites')) {
return http.Response(jsonEncode({'favorites': []}), 200);
}
return http.Response(jsonEncode({'status': 'ok'}), 200);
});
await sync.synchronisiere();
expect(sync.fehler, isNull);
expect((await db.songById('lokal-1'))!.cloudId, isNull);
expect(gemeldet, ['c5']);
});
test('eine Löschwelle wird nicht zum Server durchgereicht', () async {
@@ -485,342 +306,4 @@ void main() {
expect(sync.fehler, contains('Anmeldung abgelaufen'));
expect(sync.laeuft, isFalse);
});
group('ladeAusgewaehlteHoch', () {
Future<List<Song>> dreiTitel(Directory ordner, MeloDb db) async {
for (var i = 0; i < 3; i++) {
final datei = File('${ordner.path}/auswahl$i.mp3');
await datei.writeAsBytes([i]);
await db.upsertSongs([
SongsCompanion.insert(
id: 'lokal-$i',
path: datei.path,
title: 'Titel $i',
dateAddedMs: i,
updatedAtMs: 0,
),
]);
}
return db.allSongs();
}
test('lädt nur, was noch keine cloudId hat', () async {
final songs = await dreiTitel(tempDir, db);
await db.setCloudId('lokal-1', 'schon-da');
var uploads = 0;
final sync = await baue((anfrage) async {
if (anfrage.url.path.endsWith('/upload')) {
uploads++;
return http.Response(
jsonEncode({'status': 'ok', 'song_id': 'neu-$uploads'}), 200);
}
return http.Response(jsonEncode({'status': 'ok'}), 200);
});
final ergebnis = await sync.ladeAusgewaehlteHoch(await db.allSongs());
expect(songs, hasLength(3));
expect(uploads, 2);
expect(ergebnis.hochgeladen, 2);
expect(ergebnis.schonDa, 1);
expect(ergebnis.fehler, isEmpty);
});
test('ein abgelehnter Titel stoppt die übrigen nicht', () async {
await dreiTitel(tempDir, db);
var uploads = 0;
final sync = await baue((anfrage) async {
if (anfrage.url.path.endsWith('/upload')) {
uploads++;
// Der Server meldet „zu groß" im Körper — dieselbe Wirkung wie eine
// lokal abgelehnte 50-MB-Datei, ohne 50 MB schreiben zu müssen.
if (uploads == 2) {
return http.Response(
jsonEncode({'error': 'Datei zu groß (max 50 MB)'}), 200);
}
return http.Response(
jsonEncode({'status': 'ok', 'song_id': 'neu-$uploads'}), 200);
}
return http.Response(jsonEncode({'status': 'ok'}), 200);
});
final ergebnis = await sync.ladeAusgewaehlteHoch(await db.allSongs());
expect(ergebnis.hochgeladen, 2);
expect(ergebnis.fehler, hasLength(1));
expect(ergebnis.fehler.single, contains('zu groß'));
});
test('eine Zeitüberschreitung ist ein Einzelfehler, kein Laufabbruch',
() async {
await dreiTitel(tempDir, db);
var uploads = 0;
final sync = await baue((anfrage) async {
if (anfrage.url.path.endsWith('/upload')) {
uploads++;
if (uploads == 1) throw TimeoutException('zu lang');
return http.Response(
jsonEncode({'status': 'ok', 'song_id': 'neu-$uploads'}), 200);
}
return http.Response(jsonEncode({'status': 'ok'}), 200);
});
final ergebnis = await sync.ladeAusgewaehlteHoch(await db.allSongs());
expect(ergebnis.hochgeladen, 2);
expect(ergebnis.fehler, hasLength(1));
});
test('abbrechen() stoppt zwischen zwei Titeln', () async {
await dreiTitel(tempDir, db);
late SyncService sync;
var uploads = 0;
sync = await baue((anfrage) async {
if (anfrage.url.path.endsWith('/upload')) {
uploads++;
sync.abbrechen();
return http.Response(
jsonEncode({'status': 'ok', 'song_id': 'neu-$uploads'}), 200);
}
return http.Response(jsonEncode({'status': 'ok'}), 200);
});
final ergebnis = await sync.ladeAusgewaehlteHoch(await db.allSongs());
expect(uploads, 1);
expect(ergebnis.abgebrochen, isTrue);
expect(sync.laeuft, isFalse);
});
test('schreibt den Sync-Zeitstempel nicht', () async {
await dreiTitel(tempDir, db);
final sync = await baue((anfrage) async {
if (anfrage.url.path.endsWith('/upload')) {
return http.Response(
jsonEncode({'status': 'ok', 'song_id': 'neu'}), 200);
}
return http.Response(jsonEncode({'status': 'ok'}), 200);
});
await sync.ladeAusgewaehlteHoch(await db.allSongs());
// Ein Upload ist kein Abgleich: sonst unterdrückt er 15 Minuten den
// Auto-Sync und verschiebt die 24-h-Uhr des Berichts.
expect(sync.letzterLauf, isNull);
});
test('während eines laufenden Abgleichs wird abgewiesen', () async {
await dreiTitel(tempDir, db);
late SyncService sync;
UploadErgebnis? waehrendSync;
sync = await baue((anfrage) async {
if (anfrage.url.path.endsWith('/list')) {
waehrendSync = await sync.ladeAusgewaehlteHoch(await db.allSongs());
return http.Response(jsonEncode({'songs': []}), 200);
}
return http.Response(jsonEncode({'status': 'ok'}), 200);
});
await sync.synchronisiere();
expect(waehrendSync, isNotNull);
expect(waehrendSync!.hochgeladen, 0);
expect(sync.fehler, contains('Abgleich'));
});
});
group('Sync-Bericht', () {
test('beim allerersten Lauf gibt es keinen Bericht', () async {
final sync = await baue((anfrage) async {
if (anfrage.url.path.endsWith('/list')) {
return http.Response(jsonEncode({'songs': []}), 200);
}
return http.Response(jsonEncode({'status': 'ok'}), 200);
});
await sync.synchronisiere();
// letzterErfolg war null: „Willkommen zurück!" auf einem frisch
// eingerichteten Gerät wäre Unsinn.
expect(sync.bericht, isNull);
});
test('nach mehr als 24 Stunden kommt der Bericht mit Zählern', () async {
final vorgestern = DateTime.now().subtract(const Duration(days: 2));
SharedPreferences.setMockInitialValues({
'cloud_sync_letzter_erfolg': vorgestern.millisecondsSinceEpoch,
});
final sync = await baue((anfrage) async {
final pfad = anfrage.url.path;
if (pfad.endsWith('/list')) {
return http.Response(
jsonEncode({
'songs': [
{'id': 'c1', 'title': 'Neu', 'artist': 'X', 'duration': 100}
]
}),
200,
);
}
if (pfad.contains('/download/')) {
return http.Response.bytes([1], 200,
headers: {'content-type': 'audio/mpeg'});
}
if (pfad.endsWith('/favorites')) {
return http.Response(jsonEncode({'favorites': []}), 200);
}
return http.Response(jsonEncode({'status': 'ok'}), 200);
});
await sync.laden();
await sync.synchronisiere();
expect(sync.bericht, isNotNull);
expect(sync.bericht!.neueSongs, 1);
sync.berichtGesehen();
expect(sync.bericht, isNull);
});
test('eine ausgefallene Phase verschiebt den Erfolgs-Zeitstempel nicht',
() async {
SharedPreferences.setMockInitialValues({});
final sync = await baue((anfrage) async {
final pfad = anfrage.url.path;
if (pfad.endsWith('/list')) {
return http.Response(jsonEncode({'songs': []}), 200);
}
if (pfad.endsWith('/favorites')) {
// Fehler im 200er-Körper: die Favoriten-Phase fällt aus.
return http.Response(
jsonEncode({'status': 'error', 'error': 'kaputt'}), 200);
}
return http.Response(jsonEncode({'status': 'ok'}), 200);
});
await sync.synchronisiere();
final prefs = await SharedPreferences.getInstance();
expect(prefs.getInt('cloud_sync_letzter_erfolg'), isNull);
// Die Drossel läuft trotzdem weiter — sonst rennt der Sync bei jedem
// Tab-Wechsel neu los.
expect(sync.letzterLauf, isNotNull);
});
test('eine gescheiterte Löschmeldung verschiebt den Erfolgs-Zeitstempel '
'nicht', () async {
SharedPreferences.setMockInitialValues({});
await db.upsertSongs([
SongsCompanion.insert(
id: 'lokal-1',
path: '${tempDir.path}/weg.mp3',
title: 'Weg',
dateAddedMs: 0,
updatedAtMs: 0,
deleted: const Value(true),
),
]);
await db.setCloudId('lokal-1', 'c5');
final sync = await baue((anfrage) async {
final pfad = anfrage.url.path;
if (pfad.endsWith('/list')) {
return http.Response(
jsonEncode({
'songs': [
{'id': 'c5', 'title': 'Weg'}
]
}),
200,
);
}
if (pfad.endsWith('/delete')) {
// _meldeLoeschungen schluckt die CloudException — ohne Rückgabe
// bis zum Flag hätte der Lauf trotzdem als erfolgreich gegolten.
return http.Response(jsonEncode({'error': 'kaputt'}), 500);
}
if (pfad.endsWith('/favorites')) {
return http.Response(jsonEncode({'favorites': []}), 200);
}
return http.Response(jsonEncode({'status': 'ok'}), 200);
});
await sync.synchronisiere();
final prefs = await SharedPreferences.getInstance();
expect(prefs.getInt('cloud_sync_letzter_erfolg'), isNull);
expect(sync.letzterLauf, isNotNull);
});
test('ein gescheiterter Upload verschiebt den Erfolgs-Zeitstempel nicht',
() async {
SharedPreferences.setMockInitialValues({});
final datei = File('${tempDir.path}/zu-gross.mp3');
await datei.writeAsBytes([1]);
await db.upsertSongs([
SongsCompanion.insert(
id: 'lokal-1',
path: datei.path,
title: 'Zu groß',
dateAddedMs: 0,
updatedAtMs: 0,
),
]);
final sync = await baue((anfrage) async {
final pfad = anfrage.url.path;
if (pfad.endsWith('/list')) {
return http.Response(jsonEncode({'songs': []}), 200);
}
if (pfad.endsWith('/upload')) {
return http.Response(
jsonEncode({'error': 'Datei zu groß (max 50 MB)'}), 200);
}
if (pfad.endsWith('/favorites')) {
return http.Response(jsonEncode({'favorites': []}), 200);
}
return http.Response(jsonEncode({'status': 'ok'}), 200);
});
await sync.synchronisiere();
final prefs = await SharedPreferences.getInstance();
expect(prefs.getInt('cloud_sync_letzter_erfolg'), isNull);
});
test('der Zeitstempel ist der Stand VOR dem Listen', () async {
final sync = await baue((anfrage) async {
if (anfrage.url.path.endsWith('/list')) {
// Während des Laufs vergeht Zeit — der Zeitstempel darf nicht
// danach genommen werden, sonst fallen zwischenzeitliche
// Änderungen durchs Raster (Tombstone-Race, v2-Lektion).
await Future<void>.delayed(const Duration(milliseconds: 50));
return http.Response(jsonEncode({'songs': []}), 200);
}
return http.Response(jsonEncode({'status': 'ok'}), 200);
});
final vorher = DateTime.now();
await sync.synchronisiere();
final nachher = DateTime.now();
expect(sync.letzterLauf!.isBefore(nachher), isTrue);
expect(
sync.letzterLauf!
.isAfter(vorher.subtract(const Duration(milliseconds: 1))),
isTrue,
);
expect(
nachher.difference(sync.letzterLauf!) >=
const Duration(milliseconds: 50),
isTrue,
);
});
});
}
+76
View File
@@ -0,0 +1,76 @@
import 'package:flutter/material.dart';
import 'package:flutter_test/flutter_test.dart';
import 'package:melo/shared/einblend_item.dart';
void main() {
Widget wrap(Widget child, {bool ruhig = false}) => MaterialApp(
home: MediaQuery(
data: MediaQueryData(disableAnimations: ruhig),
child: Scaffold(body: child),
),
);
double opacityVon(WidgetTester tester, Finder einblendItem) => tester
.widget<Opacity>(
find.descendant(of: einblendItem, matching: find.byType(Opacity)))
.opacity;
double versatzYVon(WidgetTester tester, Finder einblendItem) => tester
.widget<Transform>(
find.descendant(of: einblendItem, matching: find.byType(Transform)))
.transform
.getTranslation()
.y;
testWidgets('Opacity startet bei 0 und erreicht 1,0 nach dem Einblenden',
(tester) async {
await tester.pumpWidget(wrap(
const EinblendItem(index: 0, child: Text('Titel')),
));
final item = find.byType(EinblendItem);
expect(opacityVon(tester, item), 0);
await tester.pumpAndSettle();
expect(opacityVon(tester, item), 1);
expect(versatzYVon(tester, item), 0);
});
testWidgets(
'bei abgeschalteten Systemanimationen erscheint das Element sofort',
(tester) async {
await tester.pumpWidget(wrap(
const EinblendItem(index: 3, child: Text('Titel')),
ruhig: true,
));
final item = find.byType(EinblendItem);
// Bewusst kein weiterer pump() davor: die Reduce-Motion-Einstellung
// darf nicht erst nach einer Zeitverzögerung greifen.
expect(opacityVon(tester, item), 1);
expect(versatzYVon(tester, item), 0);
});
testWidgets('der Deckel bremst die Verzögerung ab Index 12',
(tester) async {
await tester.pumpWidget(wrap(
const Column(
children: [
EinblendItem(index: 12, child: Text('Zwölf')),
EinblendItem(index: 50, child: Text('Fünfzig')),
],
),
));
// Deckel: min(index, 12) * 25ms → beide starten spätestens nach 300ms.
// Ohne Deckel bräuchte Index 50 1250ms Verzögerung und wäre hier noch
// bei Opacity 0.
await tester.pump(const Duration(milliseconds: 300));
await tester.pump(const Duration(milliseconds: 220));
for (final item in find.byType(EinblendItem).evaluate()) {
expect(opacityVon(tester, find.byWidget(item.widget)), 1);
}
});
}
-173
View File
@@ -1,173 +0,0 @@
import 'package:drift/drift.dart' show Value, driftRuntimeOptions;
import 'package:drift/native.dart';
import 'package:flutter/material.dart';
import 'package:flutter_test/flutter_test.dart';
import 'package:http/http.dart' as http;
import 'package:http/testing.dart';
import 'package:provider/provider.dart';
import 'package:shared_preferences/shared_preferences.dart';
import 'package:melo/library/category_service.dart';
import 'package:melo/library/database.dart';
import 'package:melo/library/playlist_service.dart';
import 'package:melo/services/baka_auth.dart';
import 'package:melo/services/melo_cloud_service.dart';
import 'package:melo/services/sync_service.dart';
import 'package:melo/settings/app_settings.dart';
import 'package:melo/shared/sort_store.dart';
import 'package:melo/shared/sortable_song_list.dart';
class _MemorySpeicher implements TokenSpeicher {
_MemorySpeicher(this.werte);
final Map<String, String> werte;
@override
Future<String?> lesen(String key) async => werte[key];
@override
Future<void> schreiben(String key, String wert) async => werte[key] = wert;
@override
Future<void> loeschen(String key) async => werte.remove(key);
}
/// Merkt sich nur, was hochgeladen werden sollte. Der echte Upload braucht
/// Dateien und einen Server — hier geht es um den Weg vom Knopf zum Dienst.
class _FakeSync extends SyncService {
_FakeSync(MeloDb db)
: super(
db: db,
cloud: MeloCloudService(
auth: BakaAuth(speicher: _MemorySpeicher({})),
client: MockClient(
(_) async => http.Response('{"status":"ok"}', 200)),
),
);
final hochgeladen = <String>[];
@override
Future<UploadErgebnis> ladeAusgewaehlteHoch(List<Song> songs) async {
hochgeladen.addAll([for (final s in songs) s.id]);
return const UploadErgebnis(hochgeladen: 1);
}
}
/// „Auf den Server laden" gehört in „Meine Musik" — und **nur** dorthin.
/// [SortableSongList] wird in fünf Ansichten benutzt; ohne Scoping erschiene
/// die Aktion auch bei Favoriten, Wiedergabelisten und Titellisten.
///
/// Aufbau bewusst im Testkörper, nicht in `setUp` (siehe auswahl_modus_test).
void main() {
final lieder = [
for (var i = 0; i < 3; i++)
Song(
id: 'song-$i',
path: '/music/$i.mp3',
title: 'Titel $i',
artist: 'Neoni',
dateAddedMs: i,
updatedAtMs: 0,
deleted: false,
playCount: 0,
categoriesEdited: false,
metadataEdited: false,
),
];
Future<void> beruhige(WidgetTester tester) => tester.pumpAndSettle(
const Duration(milliseconds: 100),
EnginePhase.sendSemanticsUpdate,
const Duration(seconds: 5),
);
/// Räumt den Widget-Baum kontrolliert ab, statt es dem Testrahmen am
/// Testende zu überlassen: sonst bleibt ein von drift/SnackBar beim
/// Aufräumen geplanter Timer offen (siehe auswahl_modus_test.dart /
/// BACKLOG.md — derselbe Hänger, dieselbe Ursache).
Future<void> aufraeumen(WidgetTester tester) async {
await tester.pumpWidget(const SizedBox());
await tester.pump(const Duration(milliseconds: 1));
}
Future<_FakeSync> pumpe(WidgetTester tester,
{required bool serverUpload}) async {
driftRuntimeOptions.dontWarnAboutMultipleDatabases = true;
SharedPreferences.setMockInitialValues({});
final db = MeloDb(NativeDatabase.memory());
// Kein db.close(): drift plant dabei eine Aufräum-Aufgabe (Timer) ein,
// die der Testrahmen nicht mehr abarbeitet (siehe BACKLOG.md und
// auswahl_modus_test.dart — derselbe Hänger, dieselbe Ursache).
final sync = _FakeSync(db);
final einstellungen = AppSettings();
await einstellungen.init();
for (final song in lieder) {
await db.into(db.songs).insert(SongsCompanion.insert(
id: song.id,
path: song.path,
title: song.title,
artist: Value(song.artist),
dateAddedMs: song.dateAddedMs,
updatedAtMs: 0,
));
}
await tester.pumpWidget(
MultiProvider(
providers: [
Provider<MeloDb>.value(value: db),
ChangeNotifierProvider<CategoryService>.value(
value: CategoryService(db)),
ChangeNotifierProvider<PlaylistService>.value(
value: PlaylistService(db)),
ChangeNotifierProvider<AppSettings>.value(value: einstellungen),
// Ohne diesen Provider stürbe schon das erste Antippen der neuen
// Aktion in ladeAufServer mit ProviderNotFoundException.
ChangeNotifierProvider<SyncService>.value(value: sync),
],
child: MaterialApp(
home: Scaffold(
body: SortableSongList(
songs: lieder,
storeKey: SortStore.meineMusik,
serverUpload: serverUpload,
),
),
),
),
);
await beruhige(tester);
await tester.longPress(find.text('Titel 0'));
await beruhige(tester);
return sync;
}
testWidgets('in „Meine Musik" erscheint die Server-Aktion', (tester) async {
await pumpe(tester, serverUpload: true);
expect(find.byTooltip('Auf den Server laden'), findsOneWidget);
await aufraeumen(tester);
});
testWidgets('in den übrigen Ansichten erscheint sie nicht', (tester) async {
await pumpe(tester, serverUpload: false);
// Der Auswahl-Modus läuft, die beiden Bestands-Aktionen sind da …
expect(find.byTooltip('Zur Warteschlange hinzufügen'), findsOneWidget);
// … die neue nicht.
expect(find.byTooltip('Auf den Server laden'), findsNothing);
await aufraeumen(tester);
});
testWidgets('das Antippen reicht die Auswahl an den Upload weiter',
(tester) async {
final sync = await pumpe(tester, serverUpload: true);
await tester.tap(find.byTooltip('Auf den Server laden'));
await beruhige(tester);
// Ein sichtbarer Knopf ist noch keine Funktion: geprüft wird, dass genau
// der lang gedrückte Titel bei ladeAusgewaehlteHoch ankommt.
expect(sync.hochgeladen, ['song-0']);
expect(find.text('1 hochgeladen'), findsOneWidget);
await aufraeumen(tester);
});
}
-33
View File
@@ -1,33 +0,0 @@
import 'package:flutter/material.dart';
import 'package:flutter_test/flutter_test.dart';
import 'package:melo/services/sync_service.dart';
import 'package:melo/shared/sync_bericht_dialog.dart';
void main() {
Future<void> zeige(WidgetTester tester, SyncBericht bericht) async {
await tester.pumpWidget(MaterialApp(
home: Scaffold(body: SyncBerichtDialog(bericht: bericht)),
));
await tester.pump();
}
testWidgets('nennt neue und entfernte Titel', (tester) async {
await zeige(
tester,
const SyncBericht(neueSongs: 3, geloeschte: 1, favoriten: 0),
);
expect(find.text('Willkommen zurück!'), findsOneWidget);
expect(find.textContaining('3 neue Titel'), findsOneWidget);
expect(find.textContaining('1 entfernt'), findsOneWidget);
});
testWidgets('ohne Änderungen sagt er das auch', (tester) async {
await zeige(
tester,
const SyncBericht(neueSongs: 0, geloeschte: 0, favoriten: 0),
);
expect(find.textContaining('Nichts Neues'), findsOneWidget);
});
}