From 686315a11b9e8000a5c57d7c3ecbdcc1503f8cf4 Mon Sep 17 00:00:00 2001
From: Jake Taylor <jake@elixxir.io>
Date: Tue, 21 Mar 2023 13:18:54 -0500
Subject: [PATCH] fix minor bug preventing callback from being exercised in
channels em
---
indexedDb/impl/channels/implementation.go | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/indexedDb/impl/channels/implementation.go b/indexedDb/impl/channels/implementation.go
index b7d14d8b..627dd313 100644
--- a/indexedDb/impl/channels/implementation.go
+++ b/indexedDb/impl/channels/implementation.go
@@ -168,6 +168,7 @@ func (w *wasmModel) ReceiveMessage(channelID *id.ID, messageID message.ID,
uuid, err := w.upsertMessage(msgToInsert)
if err != nil {
jww.ERROR.Printf("Failed to receive Message: %+v", err)
+ return 0
}
go w.receivedMessageCB(uuid, channelID, false)
@@ -202,9 +203,9 @@ func (w *wasmModel) ReceiveReply(channelID *id.ID, messageID,
timestamp, lease, round.ID, mType, hidden, false, status)
uuid, err := w.upsertMessage(msgToInsert)
-
if err != nil {
jww.ERROR.Printf("Failed to receive reply: %+v", err)
+ return 0
}
go w.receivedMessageCB(uuid, channelID, false)
return uuid
@@ -241,6 +242,7 @@ func (w *wasmModel) ReceiveReaction(channelID *id.ID, messageID,
uuid, err := w.upsertMessage(msgToInsert)
if err != nil {
jww.ERROR.Printf("Failed to receive reaction: %+v", err)
+ return 0
}
go w.receivedMessageCB(uuid, channelID, false)
return uuid
--
GitLab