bubble up err

leo-lox · Dec 12, 2024 · 5d384d8 · 5d384d8
1 parent 9f11908
commit 5d384d8
Show file tree

Hide file tree

Showing 3 changed files with 30 additions and 16 deletions.
diff --git a/lib/data_layer/repositories/note_repository_impl.dart b/lib/data_layer/repositories/note_repository_impl.dart
@@ -226,11 +226,15 @@ class NoteRepositoryImpl implements NoteRepository {
 
   @override
   Future<void> broadcastNote(NostrNote noteToPublish) async {
-    NostrNoteModel noteModel = NostrNoteModel.fromEntity(noteToPublish);
-    final response = dartNdkSource.dartNdk.broadcast
-        .broadcast(nostrEvent: noteModel.toNDKEvent());
-
-    await response.broadcastDoneFuture;
+    try {
+      NostrNoteModel noteModel = NostrNoteModel.fromEntity(noteToPublish);
+      final response = dartNdkSource.dartNdk.broadcast
+          .broadcast(nostrEvent: noteModel.toNDKEvent());
+
+      await response.broadcastDoneFuture;
+    } catch (e) {
+      return Future.error(e);
+    }
   }
 
   @override

diff --git a/lib/domain_layer/usecases/get_notes.dart b/lib/domain_layer/usecases/get_notes.dart
@@ -113,6 +113,11 @@ class GetNotes {
   }
 
   Future<void> broadcastNote(NostrNote noteToPublish) async {
-    await _noteRepository.broadcastNote(noteToPublish);
+    await _noteRepository.broadcastNote(noteToPublish).onError(
+      (error, stackTrace) {
+        log('Error broadcasting note: $error', stackTrace: stackTrace);
+        return Future.error(error ?? 'Error broadcasting note');
+      },
+    );
   }
 }
diff --git a/lib/presentation_layer/components/write_post.dart b/lib/presentation_layer/components/write_post.dart
@@ -320,16 +320,21 @@ class _WritePostState extends ConsumerState<WritePost> {
 
     final int now = DateTime.now().millisecondsSinceEpoch ~/ 1000;
 
-    await notesP.broadcastNote(
-      NostrNote(
-        id: '',
-        pubkey: pubkey,
-        created_at: now,
-        kind: 1,
-        content: content,
-        sig: '',
-        tags: tags,
-      ),
+    await notesP
+        .broadcastNote(NostrNote(
+      id: '',
+      pubkey: pubkey,
+      created_at: now,
+      kind: 1,
+      content: content,
+      sig: '',
+      tags: tags,
+    ))
+        .onError(
+      (error, stackTrace) {
+        _showErrorMsg('Error broadcasting note: $error');
+        return;
+      },
     );
 
     setState(() {