287 lines
9.0 KiB
Dart
287 lines
9.0 KiB
Dart
import 'dart:convert';
|
|
|
|
import 'package:firebase_messaging/firebase_messaging.dart';
|
|
import 'package:flutter/foundation.dart';
|
|
import 'package:simplecloudnotifier/api/api_client.dart';
|
|
import 'package:simplecloudnotifier/api/api_exception.dart';
|
|
import 'package:simplecloudnotifier/models/client.dart';
|
|
import 'package:simplecloudnotifier/models/user.dart';
|
|
import 'package:simplecloudnotifier/state/application_log.dart';
|
|
import 'package:simplecloudnotifier/state/globals.dart';
|
|
import 'package:simplecloudnotifier/state/token_source.dart';
|
|
|
|
class AppAuth extends ChangeNotifier implements TokenSource {
|
|
String? _clientID;
|
|
String? _userID;
|
|
String? _tokenAdmin;
|
|
String? _tokenSend;
|
|
|
|
(User, DateTime)? _user;
|
|
|
|
(Client, DateTime)? _client;
|
|
|
|
String? get userID => _userID;
|
|
String? get tokenAdmin => _tokenAdmin;
|
|
String? get tokenSend => _tokenSend;
|
|
|
|
static AppAuth? _singleton = AppAuth._internal();
|
|
|
|
factory AppAuth() {
|
|
return _singleton ?? (_singleton = AppAuth._internal());
|
|
}
|
|
|
|
AppAuth._internal() {
|
|
load();
|
|
}
|
|
|
|
bool isAuth() {
|
|
return _userID != null && _tokenAdmin != null && _tokenSend != null;
|
|
}
|
|
|
|
void set(User user, Client client, String tokenAdmin, String tokenSend) {
|
|
_client = (client, DateTime.now());
|
|
|
|
_user = (user, DateTime.now());
|
|
|
|
_userID = user.userID;
|
|
_clientID = client.clientID;
|
|
|
|
_tokenAdmin = tokenAdmin;
|
|
_tokenSend = tokenSend;
|
|
|
|
notifyListeners();
|
|
}
|
|
|
|
void setClientAndClientID(Client client) {
|
|
_client = (client, DateTime.now());
|
|
_clientID = client.clientID;
|
|
notifyListeners();
|
|
}
|
|
|
|
void clear() {
|
|
_clientID = null;
|
|
_userID = null;
|
|
_tokenAdmin = null;
|
|
_tokenSend = null;
|
|
|
|
_client = null;
|
|
_user = null;
|
|
|
|
notifyListeners();
|
|
}
|
|
|
|
Future<bool> tryMigrateFromV1() async {
|
|
try {
|
|
final sp = Globals().sharedPrefs;
|
|
|
|
if (sp.containsKey("auth.userid") || !sp.containsKey("user_id") || !sp.containsKey("user_key")) {
|
|
return false;
|
|
}
|
|
|
|
final fcmToken = await FirebaseMessaging.instance.getToken();
|
|
|
|
if (fcmToken == null) {
|
|
ApplicationLog.error('Failed to migrate from v1: No FCM Token');
|
|
return false;
|
|
}
|
|
|
|
// migrate from v1
|
|
|
|
final oldUserID = sp.getString('user_id');
|
|
final oldUserKey = sp.getString('user_key');
|
|
|
|
if (oldUserID == null || oldUserKey == null || oldUserID.isEmpty || oldUserKey.isEmpty) {
|
|
ApplicationLog.error('Failed to migrate from v1: user_id or user_key is null|empty');
|
|
return false;
|
|
}
|
|
|
|
final newTokenSend = await APIClient.createKeyToken(DirectTokenSource(oldUserID, oldUserKey), "SendKey (auto-migration to SCN v2)", "CS", true);
|
|
|
|
final user = await APIClient.getUser(DirectTokenSource(oldUserID, oldUserKey), oldUserID);
|
|
|
|
final client = await APIClient.addClient(DirectTokenSource(oldUserID, oldUserKey), fcmToken, Globals().deviceModel, Globals().version, Globals().hostname, Globals().clientType);
|
|
|
|
set(user, client, oldUserKey, newTokenSend.token);
|
|
|
|
sp.remove('user_id');
|
|
sp.remove('user_key');
|
|
|
|
ApplicationLog.info('Migrated prefs from v1 to v2', additional: 'UserID: ${oldUserID}, ClientID: ${client.clientID}, TokenAdmin: ${oldUserKey}, TokenSend: ${newTokenSend.token}');
|
|
|
|
return true;
|
|
} catch (exc, trace) {
|
|
ApplicationLog.error('Failed to migrate from v1: ' + exc.toString(), trace: trace);
|
|
return false;
|
|
}
|
|
}
|
|
|
|
void load() {
|
|
//final cdat = Globals().sharedPrefs.getString('auth.cdate');
|
|
//final mdat = Globals().sharedPrefs.getString('auth.mdate');
|
|
final uid = Globals().sharedPrefs.getString('auth.userid');
|
|
final cid = Globals().sharedPrefs.getString('auth.clientid');
|
|
final toka = Globals().sharedPrefs.getString('auth.tokenadmin');
|
|
final toks = Globals().sharedPrefs.getString('auth.tokensend');
|
|
|
|
if (uid == null || toka == null || toks == null || cid == null) {
|
|
clear();
|
|
return;
|
|
}
|
|
|
|
_clientID = cid;
|
|
_userID = uid;
|
|
_tokenAdmin = toka;
|
|
_tokenSend = toks;
|
|
|
|
_client = null;
|
|
_user = null;
|
|
|
|
final userjson = Globals().sharedPrefs.getString('auth.user.obj');
|
|
final userqdate = Globals().sharedPrefs.getString('auth.user.qdate');
|
|
final clientjson = Globals().sharedPrefs.getString('auth.client.obj');
|
|
final clientqdate = Globals().sharedPrefs.getString('auth.client.qdate');
|
|
|
|
if (userjson != null && userqdate != null) {
|
|
try {
|
|
final ts = DateTime.parse(userqdate);
|
|
final obj = User.fromJson(jsonDecode(userjson) as Map<String, dynamic>);
|
|
_user = (obj, ts);
|
|
} catch (exc, trace) {
|
|
ApplicationLog.error('failed to parse user object from shared-prefs (auth.user.obj): ' + exc.toString(), additional: 'Data:\n${userjson}\nQDate:\n${userqdate}', trace: trace);
|
|
_user = null;
|
|
}
|
|
}
|
|
|
|
if (clientjson != null && clientqdate != null) {
|
|
try {
|
|
final ts = DateTime.parse(clientqdate);
|
|
final obj = Client.fromJson(jsonDecode(clientjson) as Map<String, dynamic>);
|
|
_client = (obj, ts);
|
|
} catch (exc, trace) {
|
|
ApplicationLog.error('failed to parse user object from shared-prefs (auth.client.obj): ' + exc.toString(), additional: 'Data:\n${clientjson}\nQDate:\n${clientqdate}', trace: trace);
|
|
_client = null;
|
|
}
|
|
}
|
|
|
|
notifyListeners();
|
|
}
|
|
|
|
Future<void> save() async {
|
|
if (_clientID == null || _userID == null || _tokenAdmin == null || _tokenSend == null) {
|
|
await Globals().sharedPrefs.remove('auth.userid');
|
|
await Globals().sharedPrefs.remove('auth.clientid');
|
|
await Globals().sharedPrefs.remove('auth.tokenadmin');
|
|
await Globals().sharedPrefs.remove('auth.tokensend');
|
|
await Globals().sharedPrefs.setString('auth.cdate', "");
|
|
await Globals().sharedPrefs.setString('auth.mdate', DateTime.now().toIso8601String());
|
|
await Globals().sharedPrefs.remove('auth.user.obj');
|
|
await Globals().sharedPrefs.remove('auth.user.qdate');
|
|
await Globals().sharedPrefs.remove('auth.client.obj');
|
|
await Globals().sharedPrefs.remove('auth.client.qdate');
|
|
} else {
|
|
await Globals().sharedPrefs.setString('auth.userid', _userID!);
|
|
await Globals().sharedPrefs.setString('auth.clientid', _clientID!);
|
|
await Globals().sharedPrefs.setString('auth.tokenadmin', _tokenAdmin!);
|
|
await Globals().sharedPrefs.setString('auth.tokensend', _tokenSend!);
|
|
if (Globals().sharedPrefs.getString('auth.cdate') == null) await Globals().sharedPrefs.setString('auth.cdate', DateTime.now().toIso8601String());
|
|
await Globals().sharedPrefs.setString('auth.mdate', DateTime.now().toIso8601String());
|
|
|
|
if (_user != null) {
|
|
await Globals().sharedPrefs.setString('auth.user.obj', jsonEncode(_user!.$1.toJson()));
|
|
await Globals().sharedPrefs.setString('auth.user.qdate', _user!.$2.toIso8601String());
|
|
} else {
|
|
await Globals().sharedPrefs.remove('auth.user.obj');
|
|
await Globals().sharedPrefs.remove('auth.user.qdate');
|
|
}
|
|
|
|
if (_client != null) {
|
|
await Globals().sharedPrefs.setString('auth.client.obj', jsonEncode(_client!.$1.toJson()));
|
|
await Globals().sharedPrefs.setString('auth.client.qdate', _client!.$2.toIso8601String());
|
|
} else {
|
|
await Globals().sharedPrefs.remove('auth.client.obj');
|
|
await Globals().sharedPrefs.remove('auth.client.qdate');
|
|
}
|
|
}
|
|
|
|
Globals().sharedPrefs.setString('auth.mdate', DateTime.now().toIso8601String());
|
|
}
|
|
|
|
Future<User> loadUser({bool force = false, Duration? forceIfOlder = null}) async {
|
|
if (forceIfOlder != null && _user != null && _user!.$2.difference(DateTime.now()) > forceIfOlder) {
|
|
force = true;
|
|
}
|
|
|
|
if (!force && _user != null && _user!.$1.userID == _userID) {
|
|
return _user!.$1;
|
|
}
|
|
|
|
if (_userID == null || _tokenAdmin == null) {
|
|
throw Exception('Not authenticated');
|
|
}
|
|
|
|
final user = await APIClient.getUser(this, _userID!);
|
|
|
|
_user = (user, DateTime.now());
|
|
|
|
await save();
|
|
|
|
return user;
|
|
}
|
|
|
|
User? getUserOrNull() {
|
|
return _user?.$1;
|
|
}
|
|
|
|
Future<Client?> loadClient({bool force = false, Duration? forceIfOlder = null}) async {
|
|
if (forceIfOlder != null && _client != null && _client!.$2.difference(DateTime.now()) > forceIfOlder) {
|
|
force = true;
|
|
}
|
|
|
|
if (!force && _client != null && _client!.$1.clientID == _clientID) {
|
|
return _client!.$1;
|
|
}
|
|
|
|
if (_clientID == null || _tokenAdmin == null) {
|
|
throw Exception('Not authenticated');
|
|
}
|
|
|
|
try {
|
|
final client = await APIClient.getClient(this, _clientID!);
|
|
|
|
_client = (client, DateTime.now());
|
|
|
|
await save();
|
|
|
|
return client;
|
|
} on APIException catch (_) {
|
|
_client = null;
|
|
return null;
|
|
} catch (exc) {
|
|
_client = null;
|
|
rethrow;
|
|
}
|
|
}
|
|
|
|
Client? getClientOrNull() {
|
|
return _client?.$1;
|
|
}
|
|
|
|
@override
|
|
String getToken() {
|
|
return _tokenAdmin!;
|
|
}
|
|
|
|
String? getTokenOrNull() {
|
|
return _tokenAdmin;
|
|
}
|
|
|
|
@override
|
|
String getUserID() {
|
|
return _userID!;
|
|
}
|
|
|
|
String? getClientID() {
|
|
return _clientID;
|
|
}
|
|
}
|