From 301d7cc778cb5fd20ffb726a2b3079d5259a2041 Mon Sep 17 00:00:00 2001
From: Jono Wenger <jono@elixxir.io>
Date: Mon, 9 Jan 2023 10:44:16 -0800
Subject: [PATCH] Fix missing tag
---
indexedDb/channels/handlers.go | 2 +-
indexedDb/dm/handlers.go | 3 +--
indexedDbWorker/channels/init.go | 4 ++--
indexedDbWorker/dm/init.go | 4 ++--
indexedDbWorker/tag.go | 11 ++++++++---
5 files changed, 14 insertions(+), 10 deletions(-)
diff --git a/indexedDb/channels/handlers.go b/indexedDb/channels/handlers.go
index ddae6568..fd7eba40 100644
--- a/indexedDb/channels/handlers.go
+++ b/indexedDb/channels/handlers.go
@@ -99,7 +99,7 @@ func (m *manager) messageReceivedCallback(
// Send it to the main thread
m.mh.SendResponse(
- worker.GetMessageTag, worker.InitID, data)
+ worker.MessageReceivedCallbackTag, worker.InitID, data)
}
// storeDatabaseName sends the database name to the main thread and waits for
diff --git a/indexedDb/dm/handlers.go b/indexedDb/dm/handlers.go
index ba3d33d4..d599cc4e 100644
--- a/indexedDb/dm/handlers.go
+++ b/indexedDb/dm/handlers.go
@@ -92,8 +92,7 @@ func (m *manager) messageReceivedCallback(
}
// Send it to the main thread
- m.mh.SendResponse(
- worker.GetMessageTag, worker.InitID, data)
+ m.mh.SendResponse(worker.MessageReceivedCallbackTag, worker.InitID, data)
}
// storeDatabaseName sends the database name to the main thread and waits for
diff --git a/indexedDbWorker/channels/init.go b/indexedDbWorker/channels/init.go
index 586ed8aa..b73d6f7d 100644
--- a/indexedDbWorker/channels/init.go
+++ b/indexedDbWorker/channels/init.go
@@ -61,8 +61,8 @@ func NewWASMEventModel(path string, encryption cryptoChannel.Cipher,
}
// Register handler to manage messages for the MessageReceivedCallback
- wh.RegisterHandler(indexedDbWorker.GetMessageTag, indexedDbWorker.InitID,
- false, messageReceivedCallbackHandler(cb))
+ wh.RegisterHandler(indexedDbWorker.MessageReceivedCallbackTag,
+ indexedDbWorker.InitID, false, messageReceivedCallbackHandler(cb))
// Register handler to manage checking encryption status from local storage
wh.RegisterHandler(indexedDbWorker.EncryptionStatusTag,
diff --git a/indexedDbWorker/dm/init.go b/indexedDbWorker/dm/init.go
index 5e4044e9..46003628 100644
--- a/indexedDbWorker/dm/init.go
+++ b/indexedDbWorker/dm/init.go
@@ -52,8 +52,8 @@ func NewWASMEventModel(path string, encryption cryptoChannel.Cipher,
}
// Register handler to manage messages for the MessageReceivedCallback
- wh.RegisterHandler(indexedDbWorker.GetMessageTag, indexedDbWorker.InitID,
- false, messageReceivedCallbackHandler(cb))
+ wh.RegisterHandler(indexedDbWorker.MessageReceivedCallbackTag,
+ indexedDbWorker.InitID, false, messageReceivedCallbackHandler(cb))
// Register handler to manage checking encryption status from local storage
wh.RegisterHandler(indexedDbWorker.EncryptionStatusTag,
diff --git a/indexedDbWorker/tag.go b/indexedDbWorker/tag.go
index fafc1753..dcda42cc 100644
--- a/indexedDbWorker/tag.go
+++ b/indexedDbWorker/tag.go
@@ -20,9 +20,10 @@ type Tag string
const (
ReadyTag Tag = "Ready"
- NewWASMEventModelTag Tag = "NewWASMEventModel"
- EncryptionStatusTag Tag = "EncryptionStatus"
- StoreDatabaseNameTag Tag = "StoreDatabaseName"
+ NewWASMEventModelTag Tag = "NewWASMEventModel"
+ MessageReceivedCallbackTag Tag = "MessageReceivedCallback"
+ EncryptionStatusTag Tag = "EncryptionStatus"
+ StoreDatabaseNameTag Tag = "StoreDatabaseName"
JoinChannelTag Tag = "JoinChannel"
LeaveChannelTag Tag = "LeaveChannel"
@@ -53,5 +54,9 @@ var deleteAfterReceiving = map[Tag]struct{}{
ReceiveReactionTag: {},
UpdateFromUUIDTag: {},
UpdateFromMessageIDTag: {},
+ GetMessageTag: {},
DeleteMessageTag: {},
+ ReceiveTag: {},
+ ReceiveTextTag: {},
+ UpdateSentStatusTag: {},
}
--
GitLab