GitLab/fluffychat
2
0
Fork 0
mirror of https://gitlab.com/famedly/fluffychat.git synced 2024-12-24 14:32:37 +01:00
Code Issues Projects Releases Wiki Activity

chore: Make file storing unencrypted

Browse Source
This commit is contained in:
Christian Pauly 2021-06-14 08:18:55 +02:00
parent 9e8050525e
commit 07d4842b28
1 changed files with 17 additions and 67 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

84
lib/utils/database/flutter_famedly_sdk_hive_database.dart
View File

@ -3,8 +3,6 @@ import 'dart:io';
import 'dart:typed_data'; import 'dart:typed_data';
import 'package:famedlysdk/famedlysdk.dart'; import 'package:famedlysdk/famedlysdk.dart';
import 'package:famedlysdk/src/utils/crypto/encrypted_file.dart';
import 'package:fluffychat/utils/platform_infos.dart';
import 'package:flutter/foundation.dart'; import 'package:flutter/foundation.dart';
import 'package:flutter/services.dart'; import 'package:flutter/services.dart';
import 'package:flutter_secure_storage/flutter_secure_storage.dart'; import 'package:flutter_secure_storage/flutter_secure_storage.dart';
@ -17,10 +15,7 @@ class FlutterFamedlySdkHiveDatabase extends FamedlySdkHiveDatabase {
: super( : super(
name, name,
encryptionCipher: encryptionCipher, encryptionCipher: encryptionCipher,
) { );
_clearOldFiles();
Hive.registerAdapter(EncryptedFileAdapter());
}
static bool _hiveInitialized = false; static bool _hiveInitialized = false;
static const String _hiveCipherStorageKey = 'hive_encryption_key'; static const String _hiveCipherStorageKey = 'hive_encryption_key';
@ -53,8 +48,7 @@ class FlutterFamedlySdkHiveDatabase extends FamedlySdkHiveDatabase {
); );
hiverCipher = HiveAesCipher(encryptionKey); hiverCipher = HiveAesCipher(encryptionKey);
} on MissingPluginException catch (_) { } on MissingPluginException catch (_) {
Logs().i( Logs().i('Hive encryption is not supported on this platform');
'Hive encryption is not supported on ${kIsWeb ? 'Web' : Platform.operatingSystem}');
} }
final db = FamedlySdkHiveDatabase( final db = FamedlySdkHiveDatabase(
client.clientName, client.clientName,
@ -67,85 +61,41 @@ class FlutterFamedlySdkHiveDatabase extends FamedlySdkHiveDatabase {
} }
@override @override
int get maxFileSize => PlatformInfos.isMobile ? 100 * 1024 * 1024 : 0; int get maxFileSize => supportsFileStoring ? 100 * 1024 * 1024 : 0;
@override @override
bool get supportsFileStoring => PlatformInfos.isMobile; bool get supportsFileStoring =>
!kIsWeb && (Platform.isIOS || Platform.isAndroid);
LazyBox<EncryptedFile> _fileEncryptionKeysBox; Future<String> _getFileStoreDirectory() async {
static const String __fileEncryptionKeysBoxName = 'box.file_encryption_keys'; try {
return (await getApplicationDocumentsDirectory()).path;
@override } on MissingPlatformDirectoryException catch (_) {
Future<void> open() async { return (await getDownloadsDirectory()).path;
await super.open(); }
_fileEncryptionKeysBox ??= await Hive.openLazyBox<EncryptedFile>(
__fileEncryptionKeysBoxName,
encryptionCipher: encryptionCipher,
);
} }
@override @override
Future<Uint8List> getFile(String mxcUri) async { Future<Uint8List> getFile(String mxcUri) async {
if (!PlatformInfos.isMobile) return null; if (!supportsFileStoring) return null;
final tempDirectory = (await getTemporaryDirectory()).path; final tempDirectory = await _getFileStoreDirectory();
final file = File('$tempDirectory/$mxcUri'); final file = File('$tempDirectory/$mxcUri');
if (await file.exists() == false) return null; if (await file.exists() == false) return null;
final bytes = await file.readAsBytes(); final bytes = await file.readAsBytes();
final encryptedFile = await _fileEncryptionKeysBox.get(mxcUri); return bytes;
encryptedFile.data = bytes;
return await decryptFile(encryptedFile);
} }
@override @override
Future storeFile(String mxcUri, Uint8List bytes, int time) async { Future storeFile(String mxcUri, Uint8List bytes, int time) async {
if (!PlatformInfos.isMobile) return null; if (!supportsFileStoring) return null;
final tempDirectory = (await getTemporaryDirectory()).path; final tempDirectory = await _getFileStoreDirectory();
final file = File('$tempDirectory/$mxcUri'); final file = File('$tempDirectory/$mxcUri');
if (await file.exists()) return; if (await file.exists()) return;
final encryptedFile = await encryptFile(bytes); await file.writeAsBytes(bytes);
await _fileEncryptionKeysBox.put(mxcUri, encryptedFile);
await file.writeAsBytes(encryptedFile.data);
return; return;
} }
static const int _maxAllowedFileAge = 1000 * 60 * 60 * 24 * 30;
@override @override
Future<void> clear(int clientId) async { Future<void> clear(int clientId) async {
await super.clear(clientId); await super.clear(clientId);
await _clearOldFiles(true);
}
Future<void> _clearOldFiles([bool clearAll = false]) async {
if (!PlatformInfos.isMobile) return null;
final tempDirectory = (await getTemporaryDirectory());
final entities = tempDirectory.listSync();
for (final entity in entities) {
final file = File(entity.path);
final createdAt = await file.lastModified();
final age = DateTime.now().millisecondsSinceEpoch -
createdAt.millisecondsSinceEpoch;
if (clearAll || age > _maxAllowedFileAge) {
final mxcUri = file.path.split('/').last;
Logs().v('Delete old cashed file: $mxcUri');
await file.delete();
await _fileEncryptionKeysBox.delete(mxcUri);
}
}
}
}
class EncryptedFileAdapter extends TypeAdapter<EncryptedFile> {
@override
final typeId = 0;
@override
EncryptedFile read(BinaryReader reader) {
final map = reader.read();
return EncryptedFile(k: map['k'], iv: map['iv'], sha256: map['sha256']);
}
@override
void write(BinaryWriter writer, EncryptedFile obj) {
writer.write({'k': obj.k, 'iv': obj.iv, 'sha256': obj.sha256});
} }
} }