save streak score locally

lib/src/model/puzzle/puzzle_controller.dart

@@ -21,6 +21,7 @@ import 'package:lichess_mobile/src/model/puzzle/puzzle_service.dart';
 import 'package:lichess_mobile/src/model/puzzle/puzzle_session.dart';
 import 'package:lichess_mobile/src/model/puzzle/puzzle_streak.dart';
 import 'package:lichess_mobile/src/model/puzzle/puzzle_theme.dart';
+import 'package:lichess_mobile/src/model/puzzle/streak_storage.dart';
 import 'package:lichess_mobile/src/network/http.dart';
 import 'package:lichess_mobile/src/utils/rate_limit.dart';
 import 'package:result_extensions/result_extensions.dart';
@@ -273,7 +274,15 @@ class PuzzleController extends _$PuzzleController {
     state = _loadNewContext(nextContext, nextStreak ?? state.streak);
   }
 
-  void sendStreakResult() {
+  void saveStreakResultLocally() {
+    ref.read(streakStorageProvider(initialContext.userId)).saveActiveStreak(
+          state.streak!,
+        );
+  }
+
+  void _sendStreakResult() {
+    ref.read(streakStorageProvider(initialContext.userId)).clearActiveStreak();
+
     if (initialContext.userId != null) {
       final streak = state.streak?.index;
       if (streak != null && streak > 0) {
@@ -420,7 +429,7 @@ class PuzzleController extends _$PuzzleController {
             finished: true,
           ),
         );
-        sendStreakResult();
+        _sendStreakResult();
       } else {
         if (_nextPuzzleFuture == null) {
           assert(false, 'next puzzle future cannot be null with streak');

lib/src/model/puzzle/puzzle_providers.dart

@@ -11,8 +11,10 @@ import 'package:lichess_mobile/src/model/puzzle/puzzle_opening.dart';
 import 'package:lichess_mobile/src/model/puzzle/puzzle_repository.dart';
 import 'package:lichess_mobile/src/model/puzzle/puzzle_service.dart';
 import 'package:lichess_mobile/src/model/puzzle/puzzle_storage.dart';
+import 'package:lichess_mobile/src/model/puzzle/puzzle_streak.dart';
 import 'package:lichess_mobile/src/model/puzzle/puzzle_theme.dart';
 import 'package:lichess_mobile/src/model/puzzle/storm.dart';
+import 'package:lichess_mobile/src/model/puzzle/streak_storage.dart';
 import 'package:lichess_mobile/src/network/http.dart';
 import 'package:lichess_mobile/src/utils/riverpod.dart';
 import 'package:riverpod_annotation/riverpod_annotation.dart';
@@ -35,9 +37,40 @@ Future<PuzzleContext?> nextPuzzle(Ref ref, PuzzleAngle angle) async {
   );
 }
 
+typedef InitialStreak = ({
+  PuzzleStreak streak,
+  Puzzle puzzle,
+});
+
+/// Fetches the active streak from the local storage if available, otherwise fetches it from the server.
 @riverpod
-Future<PuzzleStreakResponse> streak(Ref ref) {
-  return ref.withClient((client) => PuzzleRepository(client).streak());
+Future<InitialStreak> streak(Ref ref) async {
+  final session = ref.watch(authSessionProvider);
+  final streakStorage = ref.watch(streakStorageProvider(session?.user.id));
+  final activeStreak = await streakStorage.loadActiveStreak();
+  if (activeStreak != null) {
+    final puzzle = await ref
+        .read(puzzleProvider(activeStreak.streak[activeStreak.index]).future);
+
+    return (
+      streak: activeStreak,
+      puzzle: puzzle,
+    );
+  }
+
+  final rsp =
+      await ref.withClient((client) => PuzzleRepository(client).streak());
+
+  return (
+    streak: PuzzleStreak(
+      streak: rsp.streak,
+      index: 0,
+      hasSkipped: false,
+      finished: false,
+      timestamp: rsp.timestamp,
+    ),
+    puzzle: rsp.puzzle,
+  );
 }
 
 @riverpod

lib/src/model/puzzle/puzzle_streak.dart

@@ -2,11 +2,12 @@ import 'package:fast_immutable_collections/fast_immutable_collections.dart';
 import 'package:freezed_annotation/freezed_annotation.dart';
 import 'package:lichess_mobile/src/model/common/id.dart';
 
+part 'puzzle_streak.g.dart';
 part 'puzzle_streak.freezed.dart';
 
 typedef Streak = IList<PuzzleId>;
 
-@freezed
+@Freezed(fromJson: true, toJson: true)
 class PuzzleStreak with _$PuzzleStreak {
   const PuzzleStreak._();
 
@@ -19,4 +20,7 @@ class PuzzleStreak with _$PuzzleStreak {
   }) = _PuzzleStreak;
 
   PuzzleId? get nextId => streak.getOrNull(index + 1);
+
+  factory PuzzleStreak.fromJson(Map<String, dynamic> json) =>
+      _$PuzzleStreakFromJson(json);
 }

lib/src/model/puzzle/streak_storage.dart

@@ -0,0 +1,49 @@
+import 'dart:convert';
+
+import 'package:flutter_riverpod/flutter_riverpod.dart';
+import 'package:freezed_annotation/freezed_annotation.dart';
+import 'package:lichess_mobile/src/binding.dart';
+import 'package:lichess_mobile/src/model/common/id.dart';
+import 'package:lichess_mobile/src/model/puzzle/puzzle_streak.dart';
+import 'package:riverpod_annotation/riverpod_annotation.dart';
+import 'package:shared_preferences/shared_preferences.dart';
+
+part 'streak_storage.g.dart';
+
+@Riverpod(keepAlive: true)
+StreakStorage streakStorage(Ref ref, UserId? userId) {
+  return StreakStorage(userId);
+}
+
+/// Local storage for the current puzzle streak.
+class StreakStorage {
+  const StreakStorage(this.userId);
+  final UserId? userId;
+
+  Future<PuzzleStreak?> loadActiveStreak() async {
+    final stored = _store.getString(_storageKey);
+    if (stored == null) {
+      return null;
+    }
+
+    return PuzzleStreak.fromJson(
+      jsonDecode(stored) as Map<String, dynamic>,
+    );
+  }
+
+  Future<void> saveActiveStreak(PuzzleStreak streak) async {
+    await _store.setString(
+      _storageKey,
+      jsonEncode(streak),
+    );
+  }
+
+  Future<void> clearActiveStreak() async {
+    await _store.remove(_storageKey);
+  }
+
+  SharedPreferencesWithCache get _store =>
+      LichessBinding.instance.sharedPreferences;
+
+  String get _storageKey => 'puzzle_streak.${userId ?? '**anon**'}';
+}

lib/src/view/puzzle/streak_screen.dart

@@ -65,13 +65,7 @@ class _Load extends ConsumerWidget {
             angle: const PuzzleTheme(PuzzleThemeKey.mix),
             userId: session?.user.id,
           ),
-          streak: PuzzleStreak(
-            streak: data.streak,
-            index: 0,
-            hasSkipped: false,
-            finished: false,
-            timestamp: data.timestamp,
-          ),
+          streak: data.streak,
         );
       },
       loading: () => const Center(child: CircularProgressIndicator.adaptive()),
@@ -219,9 +213,10 @@ class _Body extends ConsumerWidget {
           context: context,
           builder: (context) => YesNoDialog(
             title: Text(context.l10n.mobileAreYouSure),
-            content: Text(context.l10n.mobilePuzzleStreakAbortWarning),
+            content:
+                const Text('No worries, your score will be saved locally.'),
             onYes: () {
-              ref.read(ctrlProvider.notifier).sendStreakResult();
+              ref.read(ctrlProvider.notifier).saveStreakResultLocally();
               return Navigator.of(context).pop(true);
             },
             onNo: () => Navigator.of(context).pop(false),