Flutter-Tests: ApiClient, Offline-Queue, Login-/Objektliste-Widgets

ApiClient nimmt jetzt einen injizierbaren http.Client entgegen (Testbarkeit, kein Verhaltensunterschied im Betrieb). Tests mocken ihn mit mocktail statt echter Netzwerkaufrufe. offline_queue_test.dart nutzt sqflite_common_ffi (reines Dart) für die Queue-Logik ohne Gerät/Emulator: Erfolg entfernt Eintrag, Netzwerkfehler bleibt "wartet", 4xx setzt "fehler" ohne Auto-Retry. Dazu Widget-Tests für Login-Flow und Objektliste-Suchfilter. Co-Authored-By: Claude Sonnet 5 <noreply@anthropic.com> Claude-Session: https://claude.ai/code/session_01CVgbozhYmuEhiEJHffRXCV
2026-09-04 18:38:17 +02:00
parent c68d39b45f
commit 0909dacf2b
9 changed files with 347 additions and 10 deletions
@@ -0,0 +1,96 @@
+import 'dart:convert';
+import 'dart:io';
+
+import 'package:flutter_test/flutter_test.dart';
+import 'package:http/http.dart' as http;
+import 'package:mocktail/mocktail.dart';
+import 'package:shared_preferences/shared_preferences.dart';
+import 'package:sqflite_common_ffi/sqflite_ffi.dart';
+
+import 'package:mabea_app/api/api_client.dart';
+import 'package:mabea_app/offline/queue.dart';
+
+class _MockClient extends Mock implements http.Client {}
+
+/// OfflineQueue ist ein Singleton mit eigenem Datenbank-Handle (analog zur
+/// PWA-Queue, siehe frontend/src/offline/queue.ts) - für isolierte Tests
+/// hier über Reflection auf das private Feld nicht nötig: jeder Test nutzt
+/// eigene kontrolleId/materialId-Kombinationen, damit sich Einträge nicht
+/// überschneiden, plus Aufräumen am Ende.
+void main() {
+  setUpAll(() {
+    sqfliteFfiInit();
+    databaseFactory = databaseFactoryFfi;
+  });
+
+  late _MockClient httpClient;
+  late ApiClient apiClient;
+
+  setUp(() {
+    SharedPreferences.setMockInitialValues({});
+    httpClient = _MockClient();
+    apiClient = ApiClient(baseUrl: 'http://test.local/api/v1', httpClient: httpClient);
+  });
+
+  test('enqueue speichert Eintrag, verschwindet nach erfolgreicher Übertragung', () async {
+    const kontrolleId = 'k-erfolg';
+    when(() => httpClient.put(
+          Uri.parse('http://test.local/api/v1/kontrollen/$kontrolleId/positionen/10'),
+          headers: any(named: 'headers'),
+          body: any(named: 'body'),
+        )).thenAnswer((_) async => http.Response(jsonEncode({'id': 'kp-1'}), 200));
+
+    await OfflineQueue.instance.enqueue(kontrolleId: kontrolleId, materialId: 10, istmenge: '5');
+    var eintraege = await OfflineQueue.instance.eintraegeFuerKontrolle(kontrolleId);
+    expect(eintraege, hasLength(1));
+    expect(eintraege.single.status, 'wartet');
+
+    await OfflineQueue.instance.synchronisiere(apiClient);
+
+    eintraege = await OfflineQueue.instance.eintraegeFuerKontrolle(kontrolleId);
+    expect(eintraege, isEmpty);
+  });
+
+  test('Netzwerkfehler lässt Eintrag auf "wartet" stehen, kein Datenverlust', () async {
+    const kontrolleId = 'k-netzwerkfehler';
+    when(() => httpClient.put(
+          Uri.parse('http://test.local/api/v1/kontrollen/$kontrolleId/positionen/20'),
+          headers: any(named: 'headers'),
+          body: any(named: 'body'),
+        )).thenThrow(const SocketException('Keine Verbindung'));
+
+    await OfflineQueue.instance.enqueue(kontrolleId: kontrolleId, materialId: 20, istmenge: '3');
+    await OfflineQueue.instance.synchronisiere(apiClient);
+
+    final eintraege = await OfflineQueue.instance.eintraegeFuerKontrolle(kontrolleId);
+    expect(eintraege, hasLength(1));
+    expect(eintraege.single.status, 'wartet');
+  });
+
+  test('4xx-Antwort setzt Eintrag auf "fehler", kein Auto-Retry', () async {
+    const kontrolleId = 'k-4xx';
+    when(() => httpClient.put(
+          Uri.parse('http://test.local/api/v1/kontrollen/$kontrolleId/positionen/30'),
+          headers: any(named: 'headers'),
+          body: any(named: 'body'),
+        )).thenAnswer((_) async => http.Response(jsonEncode({'detail': 'Objekt gesperrt'}), 409));
+
+    await OfflineQueue.instance.enqueue(kontrolleId: kontrolleId, materialId: 30, istmenge: '3');
+    await OfflineQueue.instance.synchronisiere(apiClient);
+    var eintraege = await OfflineQueue.instance.eintraegeFuerKontrolle(kontrolleId);
+    expect(eintraege.single.status, 'fehler');
+    expect(eintraege.single.fehlerText, contains('409'));
+
+    // Erneuter Sync-Lauf darf den Fehler-Eintrag NICHT automatisch erneut senden.
+    await OfflineQueue.instance.synchronisiere(apiClient);
+    verify(() => httpClient.put(
+          Uri.parse('http://test.local/api/v1/kontrollen/$kontrolleId/positionen/30'),
+          headers: any(named: 'headers'),
+          body: any(named: 'body'),
+        )).called(1);
+
+    await OfflineQueue.instance.entferneFehlerEintrag(kontrolleId, 30);
+    eintraege = await OfflineQueue.instance.eintraegeFuerKontrolle(kontrolleId);
+    expect(eintraege, isEmpty);
+  });
+}