admin/rely
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add mobile CRUD-sync flow coverage and stabilize sync repair test

Browse Source
This commit is contained in:
Rijad Zuzo
2026-02-17 23:48:04 +01:00
parent cfe7e05a81
commit d76b31d37d
3 changed files with 230 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
test/features/app/app_mobile_crud_sync_flow_test.dart
+100
View File
@@ -0,0 +1,100 @@
import 'package:flutter/material.dart';
import 'package:flutter_riverpod/flutter_riverpod.dart';
import 'package:flutter_test/flutter_test.dart';
import 'package:relationship_saver/core/auth/in_memory_token_store.dart';
import 'package:relationship_saver/features/local/storage/local_data_store_in_memory.dart';
import 'package:relationship_saver/features/local/storage/local_data_store_provider.dart';
import 'package:relationship_saver/features/sync/storage/sync_state_store_in_memory.dart';
import 'package:relationship_saver/features/sync/storage/sync_state_store_provider.dart';
import 'package:relationship_saver/features/sync/sync_queue_repository.dart';
import 'package:relationship_saver/integrations/backend/backend_gateway_fake.dart';
import 'package:relationship_saver/integrations/backend/backend_gateway_provider.dart';
import 'package:relationship_saver/integrations/backend/models/backend_models.dart';
import 'package:relationship_saver/main.dart';
import 'package:shared_preferences/shared_preferences.dart';
void main() {
setUp(() {
SharedPreferences.setMockInitialValues(<String, Object>{});
});
testWidgets('mobile flow adds person and queues a sync change', (
WidgetTester tester,
) async {
await tester.binding.setSurfaceSize(const Size(390, 844));
addTearDown(() => tester.binding.setSurfaceSize(null));
final ProviderContainer container = ProviderContainer(
overrides: [
tokenStoreProvider.overrideWithValue(InMemoryTokenStore()),
backendGatewayProvider.overrideWithValue(BackendGatewayFake()),
localDataStoreProvider.overrideWithValue(InMemoryLocalDataStore()),
syncStateStoreProvider.overrideWithValue(InMemorySyncStateStore()),
],
);
addTearDown(container.dispose);
await tester.pumpWidget(
UncontrolledProviderScope(
container: container,
child: const RelationshipSaverApp(),
),
);
await tester.pumpAndSettle();
expect(find.text('Sign in to continue'), findsOneWidget);
await tester.tap(find.widgetWithText(FilledButton, 'Sign In'));
await tester.pumpAndSettle(const Duration(milliseconds: 500));
expect(find.text('Dashboard'), findsWidgets);
await tester.tap(find.text('People').last);
await tester.pumpAndSettle(const Duration(milliseconds: 500));
expect(find.text('People'), findsWidgets);
await tester.tap(find.widgetWithText(FilledButton, 'Add person'));
await tester.pumpAndSettle(const Duration(milliseconds: 300));
expect(find.text('Add Person'), findsOneWidget);
await tester.enterText(find.widgetWithText(TextField, 'Name'), 'Taylor Quinn');
await tester.enterText(
find.widgetWithText(TextField, 'Relationship'),
'Partner',
);
await tester.enterText(
find.widgetWithText(TextField, 'Tags (comma separated)'),
'tea, books',
);
await tester.enterText(
find.widgetWithText(TextField, 'Notes'),
'Prefers calm evenings and handmade gifts.',
);
await tester.tap(find.widgetWithText(FilledButton, 'Save'));
await tester.pumpAndSettle(const Duration(milliseconds: 500));
expect(find.text('Taylor Quinn'), findsWidgets);
final syncState = await container.read(syncQueueRepositoryProvider.future);
expect(syncState.pendingChanges.isNotEmpty, isTrue);
expect(
syncState.pendingChanges.any((ChangeEnvelope change) {
return change.entityType == 'person' &&
change.op == ChangeOperation.upsert &&
change.payload?['name'] == 'Taylor Quinn';
}),
isTrue,
);
await tester.tap(find.byTooltip('More'));
await tester.pumpAndSettle(const Duration(milliseconds: 250));
await tester.tap(find.text('Sync').last);
await tester.pumpAndSettle(const Duration(milliseconds: 500));
expect(find.text('Queue Status'), findsOneWidget);
expect(find.text('Pending changes'), findsOneWidget);
});
}
test/features/sync/sync_rejection_repair_flow_test.dart
+102
View File
@@ -0,0 +1,102 @@
import 'package:flutter/material.dart';
import 'package:flutter_riverpod/flutter_riverpod.dart';
import 'package:flutter_test/flutter_test.dart';
import 'package:relationship_saver/core/config/app_theme.dart';
import 'package:relationship_saver/features/local/local_repository.dart';
import 'package:relationship_saver/features/local/storage/local_data_store_in_memory.dart';
import 'package:relationship_saver/features/local/storage/local_data_store_provider.dart';
import 'package:relationship_saver/features/sync/storage/sync_state_store_in_memory.dart';
import 'package:relationship_saver/features/sync/storage/sync_state_store_provider.dart';
import 'package:relationship_saver/features/sync/sync_queue_repository.dart';
import 'package:relationship_saver/features/sync/sync_view.dart';
import 'package:relationship_saver/integrations/backend/models/backend_models.dart';
void main() {
testWidgets(
'rejected person mutation can be repaired directly from Sync view',
(WidgetTester tester) async {
final ProviderContainer container = ProviderContainer(
overrides: [
localDataStoreProvider.overrideWithValue(InMemoryLocalDataStore()),
syncStateStoreProvider.overrideWithValue(InMemorySyncStateStore()),
],
);
addTearDown(container.dispose);
final localBefore = await container.read(localRepositoryProvider.future);
final person = localBefore.people.first;
final ChangeEnvelope rejectedChange = ChangeEnvelope(
schemaVersion: 1,
entityType: 'person',
entityId: person.id,
op: ChangeOperation.upsert,
modifiedAt: DateTime(2026, 2, 15, 12).toUtc(),
clientMutationId: 'cm-repair-1',
payload: <String, dynamic>{
'name': person.name,
'relationship': person.relationship,
'notes': person.notes,
'tags': person.tags,
},
);
final syncNotifier = container.read(syncQueueRepositoryProvider.notifier);
await syncNotifier.enqueue(rejectedChange);
await syncNotifier.applyPushResult(
const SyncPushResult(
cursor: 'cursor-1',
rejected: <MutationRejection>[
MutationRejection(
clientMutationId: 'cm-repair-1',
code: 'VALIDATION_FAILED',
message: 'Bad payload',
),
],
),
);
final syncState = await container.read(syncQueueRepositoryProvider.future);
expect(syncState.lastRejected.length, 1);
await tester.pumpWidget(
UncontrolledProviderScope(
container: container,
child: MaterialApp(theme: AppTheme.light(), home: const SyncView()),
),
);
await tester.pumpAndSettle(const Duration(milliseconds: 500));
await tester.scrollUntilVisible(
find.text('Rejected Changes'),
240,
scrollable: find.byType(Scrollable).first,
);
expect(find.text('Rejected Changes'), findsOneWidget);
await tester.scrollUntilVisible(
find.widgetWithText(TextButton, 'Open Related Screen'),
120,
scrollable: find.byType(Scrollable).first,
);
final Finder openRelatedScreenButton = find.widgetWithText(
TextButton,
'Open Related Screen',
);
expect(openRelatedScreenButton, findsOneWidget);
await tester.ensureVisible(openRelatedScreenButton);
await tester.pumpAndSettle(const Duration(milliseconds: 200));
await tester.tap(openRelatedScreenButton, warnIfMissed: false);
await tester.pumpAndSettle(const Duration(milliseconds: 500));
expect(find.textContaining('Focus: person:'), findsOneWidget);
await tester.enterText(find.byType(TextField).first, 'Renamed Person');
await tester.tap(find.widgetWithText(FilledButton, 'Save Changes'));
await tester.pumpAndSettle(const Duration(milliseconds: 500));
final localAfter = await container.read(localRepositoryProvider.future);
final updated = localAfter.people.firstWhere(
(item) => item.id == person.id,
);
expect(updated.name, 'Renamed Person');
},
);
}