feat(mobile) - Add better offline support

mobile/lib/modules/login/providers/authentication.provider.dart

@@ -136,38 +136,62 @@ class AuthenticationNotifier extends StateNotifier<AuthenticationState> {
   Future<bool> setSuccessLoginInfo({
     required String accessToken,
     required String serverUrl,
+    bool offlineLogin = false,
   }) async {
     _apiService.setAccessToken(accessToken);
     UserResponseDto? userResponseDto;
-    try {
-      userResponseDto = await _apiService.userApi.getMyUserInfo();
-    } on ApiException catch (e) {
-      if (e.innerException is SocketException) {
-        state = state.copyWith(isAuthenticated: true);
+    String? deviceId;
+
+    if (offlineLogin) {
+      deviceId = Store.tryGet(StoreKey.deviceId);
+      User? offlineUser = Store.tryGet(StoreKey.currentUser);
+
+      if (deviceId != null && offlineUser != null) {
+        state = state.copyWith(
+          isAuthenticated: true,
+          userId: offlineUser.id,
+          userEmail: offlineUser.email,
+          firstName: offlineUser.firstName,
+          lastName: offlineUser.lastName,
+          profileImagePath: offlineUser.profileImagePath,
+          isAdmin: offlineUser.isAdmin,
+          shouldChangePassword: false,
+          deviceId: deviceId,
+        );
+        return false;
+      }
+    } else {
+      try {
+        userResponseDto = await _apiService.userApi.getMyUserInfo();
+      } on ApiException catch (e) {
+        if (e.innerException is SocketException) {
+          state = state.copyWith(isAuthenticated: true);
+        }
       }
-    }
 
-    if (userResponseDto != null) {
-      final deviceId = await FlutterUdid.consistentUdid;
-      Store.put(StoreKey.deviceId, deviceId);
-      Store.put(StoreKey.deviceIdHash, fastHash(deviceId));
-      Store.put(StoreKey.currentUser, User.fromDto(userResponseDto));
-      Store.put(StoreKey.serverUrl, serverUrl);
-      Store.put(StoreKey.accessToken, accessToken);
-
-      state = state.copyWith(
-        isAuthenticated: true,
-        userId: userResponseDto.id,
-        userEmail: userResponseDto.email,
-        firstName: userResponseDto.firstName,
-        lastName: userResponseDto.lastName,
-        profileImagePath: userResponseDto.profileImagePath,
-        isAdmin: userResponseDto.isAdmin,
-        shouldChangePassword: userResponseDto.shouldChangePassword,
-        deviceId: deviceId,
-      );
+      if (userResponseDto != null) {
+        deviceId = await FlutterUdid.consistentUdid;
+        Store.put(StoreKey.deviceId, deviceId);
+        Store.put(StoreKey.deviceIdHash, fastHash(deviceId));
+        Store.put(StoreKey.currentUser, User.fromDto(userResponseDto));
+        Store.put(StoreKey.serverUrl, serverUrl);
+        Store.put(StoreKey.accessToken, accessToken);
+
+        state = state.copyWith(
+          isAuthenticated: true,
+          userId: userResponseDto.id,
+          userEmail: userResponseDto.email,
+          firstName: userResponseDto.firstName,
+          lastName: userResponseDto.lastName,
+          profileImagePath: userResponseDto.profileImagePath,
+          isAdmin: userResponseDto.isAdmin,
+          shouldChangePassword: userResponseDto.shouldChangePassword,
+          deviceId: deviceId,
+        );
+        return true;
+      }
     }
-    return true;
+    return false;
   }
 }
 

mobile/lib/routing/auth_guard.dart

@@ -4,29 +4,40 @@ import 'package:auto_route/auto_route.dart';
 import 'package:flutter/foundation.dart';
 import 'package:immich_mobile/routing/router.dart';
 import 'package:immich_mobile/shared/services/api.service.dart';
+import 'package:logging/logging.dart';
 import 'package:openapi/api.dart';
 
 class AuthGuard extends AutoRouteGuard {
   final ApiService _apiService;
   AuthGuard(this._apiService);
   @override
   void onNavigation(NavigationResolver resolver, StackRouter router) async {
+    var log = Logger("AuthGuard");
+
+    resolver.next(true);
+
     try {
       var res = await _apiService.authenticationApi.validateAccessToken();
-      if (res != null && res.authStatus) {
-        resolver.next(true);
-      } else {
+      if (res == null || res.authStatus != true) {
+        // If the access token is invalid, take user back to login
+        log.info("User token is invalid. Redirecting to login");
         router.replaceAll([const LoginRoute()]);
       }
     } on ApiException catch (e) {
       if (e.code == HttpStatus.badRequest &&
           e.innerException is SocketException) {
         // offline?
-        resolver.next(true);
+        log.info(
+          "Unable to validate user token. User may be offline and offline browsing is allowed.",
+        );
       } else {
         debugPrint("Error [onNavigation] ${e.toString()}");
         router.replaceAll([const LoginRoute()]);
+        return;
       }
+    } catch (e) {
+      debugPrint("Error [onNavigation] ${e.toString()}");
+      router.replaceAll([const LoginRoute()]);
       return;
     }
   }

mobile/lib/shared/models/user.dart

@@ -16,6 +16,7 @@ class User {
     required this.isAdmin,
     this.isPartnerSharedBy = false,
     this.isPartnerSharedWith = false,
+    this.profileImagePath = '',
   });
 
   Id get isarId => fastHash(id);
@@ -28,6 +29,7 @@ class User {
         lastName = dto.lastName,
         isPartnerSharedBy = false,
         isPartnerSharedWith = false,
+        profileImagePath = dto.profileImagePath,
         isAdmin = dto.isAdmin;
 
   @Index(unique: true, replace: false, type: IndexType.hash)
@@ -39,6 +41,7 @@ class User {
   bool isPartnerSharedBy;
   bool isPartnerSharedWith;
   bool isAdmin;
+  String profileImagePath;
   @Backlink(to: 'owner')
   final IsarLinks<Album> albums = IsarLinks<Album>();
   @Backlink(to: 'sharedUsers')
@@ -54,6 +57,7 @@ class User {
         lastName == other.lastName &&
         isPartnerSharedBy == other.isPartnerSharedBy &&
         isPartnerSharedWith == other.isPartnerSharedWith &&
+        profileImagePath == other.profileImagePath &&
         isAdmin == other.isAdmin;
   }
 
@@ -67,5 +71,6 @@ class User {
       lastName.hashCode ^
       isPartnerSharedBy.hashCode ^
       isPartnerSharedWith.hashCode ^
+      profileImagePath.hashCode ^
       isAdmin.hashCode;
 }

mobile/lib/shared/services/api.service.dart

@@ -1,4 +1,6 @@
+import 'dart:async';
 import 'dart:convert';
+import 'dart:io';
 
 import 'package:flutter/material.dart';
 import 'package:immich_mobile/shared/models/store.dart';
@@ -62,6 +64,8 @@ class ApiService {
   Future<String> _resolveEndpoint(String serverUrl) async {
     final url = sanitizeUrl(serverUrl);
 
+    await _isEndpointAvailable(serverUrl);
+
     // Check for /.well-known/immich
     final wellKnownEndpoint = await _getWellKnownEndpoint(url);
     if (wellKnownEndpoint.isNotEmpty) return wellKnownEndpoint;
@@ -70,6 +74,29 @@ class ApiService {
     return url;
   }
 
+  Future<void> _isEndpointAvailable(String serverUrl) async {
+    final Client client = Client();
+
+    if (!serverUrl.endsWith('/api')) {
+      serverUrl += '/api';
+    }
+
+    // Throw Socket or Timeout exceptions,
+    // we do not care if the endpoints hits an HTTP error
+    try {
+      await client
+          .get(
+            Uri.parse(serverUrl),
+          )
+          .timeout(const Duration(seconds: 5));
+      return;
+    } on TimeoutException catch (_) {
+      rethrow;
+    } on SocketException catch (_) {
+      rethrow;
+    }
+  }
+
   Future<String> _getWellKnownEndpoint(String baseUrl) async {
     final Client client = Client();
 

mobile/lib/shared/views/splash_screen.dart

@@ -20,21 +20,26 @@ class SplashScreenPage extends HookConsumerWidget {
 
     void performLoggingIn() async {
       bool isSuccess = false;
+      bool deviceIsOffline = false;
       if (accessToken != null && serverUrl != null) {
         try {
           // Resolve API server endpoint from user provided serverUrl
           await apiService.resolveAndSetEndpoint(serverUrl);
         } catch (e) {
           // okay, try to continue anyway if offline
+          deviceIsOffline = true;
         }
 
         isSuccess =
             await ref.read(authenticationProvider.notifier).setSuccessLoginInfo(
                   accessToken: accessToken,
                   serverUrl: serverUrl,
+                  offlineLogin: deviceIsOffline,
                 );
       }
-      if (isSuccess) {
+      if (deviceIsOffline) {
+        AutoRouter.of(context).replace(const TabControllerRoute());
+      } else if (isSuccess) {
         final hasPermission =
             await ref.read(galleryPermissionNotifier.notifier).hasPermission;
         if (hasPermission) {