Skip to content

Commit

Permalink
style: code format
Browse files Browse the repository at this point in the history
  • Loading branch information
ice-damocles committed Dec 30, 2024
1 parent 8cfd695 commit 5026c68
Showing 1 changed file with 9 additions and 19 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -29,10 +29,8 @@ import 'package:riverpod_annotation/riverpod_annotation.dart';
part 'conversation_message_management_provider.c.g.dart';

@Riverpod(keepAlive: true)
Future<ConversationMessageManagementService>
conversationMessageManagementService(Ref ref) async {
final eventSigner =
await ref.watch(currentUserNostrEventSignerProvider.future);
Future<ConversationMessageManagementService> conversationMessageManagementService(Ref ref) async {
final eventSigner = await ref.watch(currentUserNostrEventSignerProvider.future);

return ConversationMessageManagementService(
eventSigner: eventSigner,
Expand Down Expand Up @@ -87,8 +85,7 @@ class ConversationMessageManagementService {

final results = await Future.wait(
participantsPubkeys.map((participantPubkey) async {
final encryptedMediaFiles =
await _encryptMediaFiles(compressedMediaFiles);
final encryptedMediaFiles = await _encryptMediaFiles(compressedMediaFiles);

final uploadedMediaFilesWithKeys = await Future.wait(
encryptedMediaFiles.map((encryptedMediaFile) async {
Expand Down Expand Up @@ -190,8 +187,7 @@ class ConversationMessageManagementService {
);

if (attachment.mediaType == MediaType.unknown) {
final decompressedFile =
await compressionService.decompressBrotli(file);
final decompressedFile = await compressionService.decompressBrotli(file);

decryptedDecompressedFiles.add(decompressedFile);
} else {
Expand Down Expand Up @@ -282,8 +278,7 @@ class ConversationMessageManagementService {
final mediaType = MediaType.fromMimeType(mediaFile.mimeType ?? '');

final compressedMediaFile = switch (mediaType) {
MediaType.video =>
await compressionService.compressVideo(mediaFile),
MediaType.video => await compressionService.compressVideo(mediaFile),
MediaType.image => await compressionService.compressImage(
mediaFile,
width: mediaFile.width,
Expand All @@ -296,9 +291,7 @@ class ConversationMessageManagementService {
path: await compressionService.compressAudio(mediaFile.path),
),
MediaType.unknown => MediaFile(
path: (await compressionService
.compressWithBrotli(File(mediaFile.path)))
.path,
path: (await compressionService.compressWithBrotli(File(mediaFile.path))).path,
)
};

Expand All @@ -320,14 +313,12 @@ class ConversationMessageManagementService {
) async {
final encryptedMediaFiles = await Future.wait(
compressedMediaFiles.map(
(compressedMediaFile) =>
Isolate.run<(MediaFile, String, String, String)>(() async {
(compressedMediaFile) => Isolate.run<(MediaFile, String, String, String)>(() async {
final secretKey = await AesGcm.with256bits().newSecretKey();
final secretKeyBytes = await secretKey.extractBytes();
final secretKeyString = base64Encode(secretKeyBytes);

final compressedMediaFileBytes =
await File(compressedMediaFile.path).readAsBytes();
final compressedMediaFileBytes = await File(compressedMediaFile.path).readAsBytes();

final secretBox = await AesGcm.with256bits().encrypt(
compressedMediaFileBytes,
Expand All @@ -338,8 +329,7 @@ class ConversationMessageManagementService {
final nonceString = base64Encode(nonceBytes);
final macString = base64Encode(secretBox.mac.bytes);

final compressedEncryptedFile =
File('${compressedMediaFile.path}.enc');
final compressedEncryptedFile = File('${compressedMediaFile.path}.enc');
// Rewrite compressed fieles with encrypted data
await compressedEncryptedFile.writeAsBytes(secretBox.cipherText);

Expand Down

0 comments on commit 5026c68

Please sign in to comment.