chore: Update matrix sdk
Christian Pauly
3 years ago
parent
77d5ca4f0a
commit
3e31c9945f
@ -1,151 +0,0 @@
|
|||||||
// ignore_for_file: depend_on_referenced_packages
|
|
||||||
|
|
||||||
import 'dart:convert';
|
|
||||||
import 'dart:io';
|
|
||||||
|
|
||||||
import 'package:flutter/foundation.dart' hide Key;
|
|
||||||
import 'package:flutter/services.dart';
|
|
||||||
|
|
||||||
import 'package:fluffybox/hive.dart' as fluffybox;
|
|
||||||
import 'package:flutter_secure_storage/flutter_secure_storage.dart';
|
|
||||||
import 'package:hive_flutter/hive_flutter.dart';
|
|
||||||
import 'package:matrix/matrix.dart';
|
|
||||||
import 'package:path_provider/path_provider.dart';
|
|
||||||
|
|
||||||
import '../client_manager.dart';
|
|
||||||
import '../famedlysdk_store.dart';
|
|
||||||
|
|
||||||
// ignore: deprecated_member_use
|
|
||||||
class FlutterFluffyBoxDatabase extends FluffyBoxDatabase {
|
|
||||||
FlutterFluffyBoxDatabase(
|
|
||||||
String name,
|
|
||||||
String path, {
|
|
||||||
fluffybox.HiveCipher? key,
|
|
||||||
}) : super(
|
|
||||||
name,
|
|
||||||
path,
|
|
||||||
key: key,
|
|
||||||
);
|
|
||||||
|
|
||||||
static const String _cipherStorageKey = 'database_encryption_key';
|
|
||||||
|
|
||||||
// ignore: deprecated_member_use
|
|
||||||
static Future<FluffyBoxDatabase> databaseBuilder(Client client) async {
|
|
||||||
Logs().d('Open FluffyBox...');
|
|
||||||
fluffybox.HiveAesCipher? hiverCipher;
|
|
||||||
try {
|
|
||||||
// Workaround for secure storage is calling Platform.operatingSystem on web
|
|
||||||
if (kIsWeb) throw MissingPluginException();
|
|
||||||
|
|
||||||
const secureStorage = FlutterSecureStorage();
|
|
||||||
final containsEncryptionKey =
|
|
||||||
await secureStorage.read(key: _cipherStorageKey) != null;
|
|
||||||
if (!containsEncryptionKey) {
|
|
||||||
// do not try to create a buggy secure storage for new Linux users
|
|
||||||
if (Platform.isLinux) throw MissingPluginException();
|
|
||||||
final key = Hive.generateSecureKey();
|
|
||||||
await secureStorage.write(
|
|
||||||
key: _cipherStorageKey,
|
|
||||||
value: base64UrlEncode(key),
|
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
// workaround for if we just wrote to the key and it still doesn't exist
|
|
||||||
final rawEncryptionKey = await secureStorage.read(key: _cipherStorageKey);
|
|
||||||
if (rawEncryptionKey == null) throw MissingPluginException();
|
|
||||||
|
|
||||||
hiverCipher = fluffybox.HiveAesCipher(base64Url.decode(rawEncryptionKey));
|
|
||||||
} on MissingPluginException catch (_) {
|
|
||||||
Logs().i('FluffyBox encryption is not supported on this platform');
|
|
||||||
} catch (e, s) {
|
|
||||||
const FlutterSecureStorage()
|
|
||||||
.delete(key: _cipherStorageKey)
|
|
||||||
.catchError((_) {});
|
|
||||||
Logs().w('Unable to init FluffyBox encryption', e, s);
|
|
||||||
}
|
|
||||||
|
|
||||||
// ignore: deprecated_member_use
|
|
||||||
final db = FluffyBoxDatabase(
|
|
||||||
'fluffybox_${client.clientName.replaceAll(' ', '_').toLowerCase()}',
|
|
||||||
await _findDatabasePath(client),
|
|
||||||
key: hiverCipher,
|
|
||||||
);
|
|
||||||
try {
|
|
||||||
await db.open();
|
|
||||||
} catch (_) {
|
|
||||||
Logs().w('Unable to open FluffyBox. Delete database and storage key...');
|
|
||||||
await Store().deleteItem(ClientManager.clientNamespace);
|
|
||||||
const FlutterSecureStorage().delete(key: _cipherStorageKey);
|
|
||||||
await db.clear();
|
|
||||||
rethrow;
|
|
||||||
}
|
|
||||||
Logs().d('FluffyBox is ready');
|
|
||||||
return db;
|
|
||||||
}
|
|
||||||
|
|
||||||
static Future<String> _findDatabasePath(Client client) async {
|
|
||||||
String path = client.clientName;
|
|
||||||
if (!kIsWeb) {
|
|
||||||
Directory directory;
|
|
||||||
try {
|
|
||||||
if (Platform.isLinux) {
|
|
||||||
directory = await getApplicationSupportDirectory();
|
|
||||||
} else {
|
|
||||||
directory = await getApplicationDocumentsDirectory();
|
|
||||||
}
|
|
||||||
} catch (_) {
|
|
||||||
try {
|
|
||||||
directory = await getLibraryDirectory();
|
|
||||||
} catch (_) {
|
|
||||||
directory = Directory.current;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
// do not destroy your stable FluffyChat in debug mode
|
|
||||||
if (kDebugMode) {
|
|
||||||
directory = Directory(directory.uri.resolve('debug').toFilePath());
|
|
||||||
directory.create(recursive: true);
|
|
||||||
}
|
|
||||||
path = directory.path;
|
|
||||||
}
|
|
||||||
return path;
|
|
||||||
}
|
|
||||||
|
|
||||||
@override
|
|
||||||
int get maxFileSize => supportsFileStoring ? 100 * 1024 * 1024 : 0;
|
|
||||||
@override
|
|
||||||
bool get supportsFileStoring => !kIsWeb;
|
|
||||||
|
|
||||||
Future<String> _getFileStoreDirectory() async {
|
|
||||||
try {
|
|
||||||
try {
|
|
||||||
return (await getApplicationSupportDirectory()).path;
|
|
||||||
} catch (_) {
|
|
||||||
return (await getApplicationDocumentsDirectory()).path;
|
|
||||||
}
|
|
||||||
} catch (_) {
|
|
||||||
return (await getDownloadsDirectory())!.path;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
@override
|
|
||||||
Future<Uint8List?> getFile(Uri mxcUri) async {
|
|
||||||
if (!supportsFileStoring) return null;
|
|
||||||
final tempDirectory = await _getFileStoreDirectory();
|
|
||||||
final file =
|
|
||||||
File('$tempDirectory/${Uri.encodeComponent(mxcUri.toString())}');
|
|
||||||
if (await file.exists() == false) return null;
|
|
||||||
final bytes = await file.readAsBytes();
|
|
||||||
return bytes;
|
|
||||||
}
|
|
||||||
|
|
||||||
@override
|
|
||||||
Future storeFile(Uri mxcUri, Uint8List bytes, int time) async {
|
|
||||||
if (!supportsFileStoring) return null;
|
|
||||||
final tempDirectory = await _getFileStoreDirectory();
|
|
||||||
final file =
|
|
||||||
File('$tempDirectory/${Uri.encodeComponent(mxcUri.toString())}');
|
|
||||||
if (await file.exists()) return;
|
|
||||||
await file.writeAsBytes(bytes);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
Loading…
Reference in New Issue