chore: Updated push and pull timeouts.

Author: Skyost

lib/model/backend/backend.dart

@@ -23,15 +23,18 @@ final backendClientProvider = AsyncNotifierProvider<BackendClient, Map<String, S
 /// Allows to communicate with the backend.
 class BackendClient extends AsyncNotifier<Map<String, String>> {
   /// The default timeout in seconds.
-  static const int _kDefaultTimeout = 10;
+  static const Duration _kDefaultTimeout = Duration(seconds: 10);
+
+  /// The app client ID storage key.
+  static const String _kAppClientIdKey = 'appClientId';
 
   /// The HTTP client instance.
   final http.Client _client = http.Client();
 
   @override
   FutureOr<Map<String, String>> build() async {
     PackageInfo packageInfo = await PackageInfo.fromPlatform();
-    String? appClientId = await SimpleSecureStorage.read('appClientId');
+    String? appClientId = await SimpleSecureStorage.read(_kAppClientIdKey);
     ref.onDispose(_client.close);
     return {
       'App-Version': packageInfo.version,
@@ -46,7 +49,7 @@ class BackendClient extends AsyncNotifier<Map<String, String>> {
     if (!headers.containsKey('App-Client-Id')) {
       String appClientId = currentPlatform.generateAppClientId();
       headers['App-Client-Id'] = appClientId;
-      await SimpleSecureStorage.write('appClientId', appClientId);
+      await SimpleSecureStorage.write(_kAppClientIdKey, appClientId);
       if (ref.mounted) {
         state = AsyncData(headers);
       }
@@ -60,6 +63,7 @@ class BackendClient extends AsyncNotifier<Map<String, String>> {
     String? backendUrl,
     Session? session,
     bool autoRefreshAccessToken = true,
+    Duration timeout = _kDefaultTimeout,
   }) async {
     try {
       bool isConnected = await ref.read(connectivityStateProvider.future);
@@ -89,7 +93,7 @@ class BackendClient extends AsyncNotifier<Map<String, String>> {
             ).build(),
             headers: headers,
           )
-          .timeout(const Duration(seconds: _kDefaultTimeout));
+          .timeout(timeout);
       return ResultSuccess(
         value: request.toResponse(response),
       );

lib/model/backend/synchronization/queue.dart

@@ -25,6 +25,9 @@ final pushOperationsQueueProvider = AsyncNotifierProvider<PushOperationsQueue, L
 
 /// Allows to manage the push operations queue.
 class PushOperationsQueue extends AsyncNotifier<List<PushOperation>> {
+  /// The push operation timeout.
+  static const Duration _kPushOperationTimeout = Duration(seconds: 20);
+
   @override
   Future<List<PushOperation>> build() async {
     AppDatabase database = ref.watch(appDatabaseProvider);
@@ -71,6 +74,7 @@ class PushOperationsQueue extends AsyncNotifier<List<PushOperation>> {
           SynchronizationPushRequest(
             operations: compactedOperations.reversed.toList(),
           ),
+          timeout: _kPushOperationTimeout,
         );
     if (result is! ResultSuccess<SynchronizationPushResponse>) {
       return result;
@@ -93,6 +97,9 @@ final synchronizationControllerProvider = NotifierProvider<SynchronizationContro
 
 /// Allows to control the synchronization process.
 class SynchronizationController extends Notifier<SynchronizationStatus> with WidgetsBindingObserver {
+  /// The synchronization pull timeout.
+  static const Duration _kPullTimeout = Duration(seconds: 20);
+
   /// The synchronization periodic interval.
   static const Duration _kPeriodicInterval = Duration(minutes: 10);
 
@@ -301,6 +308,7 @@ class SynchronizationController extends Notifier<SynchronizationStatus> with Wid
             },
             deleted: deletedTotps,
           ),
+          timeout: _kPullTimeout,
         );
 
     if (result is! ResultSuccess<SynchronizationPullResponse>) {