diff --git a/indexedDb/impl/channels/implementation.go b/indexedDb/impl/channels/implementation.go index b7d14d8b72c0dbb5285018d37fc0c1c91a2de8d5..627dd313a36974be2ff40ead5b00ee9f0635bfd3 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