init

2026-10-01 16:03:32 +05:30
commit 3db47c4648
102 changed files with 5067 additions and 0 deletions
@@ -0,0 +1,103 @@
+import 'package:flutter/foundation.dart';
+import 'package:flutter_secure_storage/flutter_secure_storage.dart';
+
+import '../models/models.dart';
+import 'api_client.dart';
+
+class AuthController extends ChangeNotifier {
+  AuthController({FlutterSecureStorage? storage, ApiClient? apiClient})
+    : _storage = storage ?? const FlutterSecureStorage(),
+      api = apiClient ?? ApiClient();
+
+  final FlutterSecureStorage _storage;
+  final ApiClient api;
+
+  AppUser? user;
+  bool ready = false;
+  bool busy = false;
+  String? error;
+
+  Future<void> bootstrap() async {
+    try {
+      final stored = await _storage.read(key: 'jwt_token');
+      if (stored == null || stored.isEmpty) return;
+      api.token = stored;
+      user = await api.me();
+    } catch (_) {
+      api.token = null;
+      user = null;
+      await _storage.delete(key: 'jwt_token');
+    } finally {
+      ready = true;
+      notifyListeners();
+    }
+  }
+
+  Future<void> staffLogin(String phone, String password) async {
+    await _run(() async {
+      final result = await api.staffLogin(phone, password);
+      await _storeSession(result.token, result.user);
+    });
+  }
+
+  Future<({String requestId, String secret})> startDealerLogin(String phone) async {
+    late ({String requestId, String secret}) started;
+    await _run(() async {
+      started = await api.dealerLogin(phone);
+    });
+    return started;
+  }
+
+  Future<String> pollDealerLogin(String requestId, String secret) async {
+    final status = await api.dealerLoginStatus(requestId, secret);
+    if (status.status == 'approved' && status.token != null && status.user != null) {
+      await _storeSession(status.token!, status.user!);
+      notifyListeners();
+    } else if (status.status == 'rejected') {
+      error = 'Login was rejected';
+      notifyListeners();
+    } else if (status.status == 'expired' || status.status == 'consumed') {
+      error = 'Login request expired. Try again.';
+      notifyListeners();
+    }
+    return status.status;
+  }
+
+  Future<void> _storeSession(String token, AppUser profile) async {
+    api.token = token;
+    await _storage.write(key: 'jwt_token', value: token);
+    user = profile;
+  }
+
+  Future<void> refreshProfile() async {
+    if (api.token == null) return;
+    user = await api.me();
+    notifyListeners();
+  }
+
+  Future<void> logout() async {
+    api.token = null;
+    user = null;
+    error = null;
+    await _storage.delete(key: 'jwt_token');
+    notifyListeners();
+  }
+
+  Future<void> _run(Future<void> Function() action) async {
+    busy = true;
+    error = null;
+    notifyListeners();
+    try {
+      await action();
+    } on ApiException catch (error) {
+      this.error = error.message;
+      rethrow;
+    } catch (error) {
+      this.error = 'Network request failed';
+      rethrow;
+    } finally {
+      busy = false;
+      notifyListeners();
+    }
+  }
+}