jshiffer/matterbridge
1
0
Fork 1
mirror of https://github.com/42wim/matterbridge.git synced 2025-02-21 20:59:02 -08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Add descriptive errors to persistent store

Browse Source
This commit is contained in:
Yousef Mansy 2023-03-11 14:33:16 -08:00
parent c0f5d0c5f7
commit eaa8907d17
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
gateway/persistent.go
View File

@ -31,6 +31,7 @@ func (gw *Gateway) getCanonicalMessageFromStore(messageID string) string {
canonicalMsgID := new(string) canonicalMsgID := new(string)
found, err := gw.CanonicalStore.Get(messageID, canonicalMsgID) found, err := gw.CanonicalStore.Get(messageID, canonicalMsgID)
if err != nil { if err != nil {
gw.logger.Errorf("Error getting destination messages for canonical message id {%s}", messageID)
gw.logger.Error(err) gw.logger.Error(err)
} }
@ -44,6 +45,7 @@ func (gw *Gateway) getCanonicalMessageFromStore(messageID string) string {
func (gw *Gateway) setCanonicalMessageToStore(messageID string, canonicalMsgID string) { func (gw *Gateway) setCanonicalMessageToStore(messageID string, canonicalMsgID string) {
err := gw.CanonicalStore.Set(messageID, canonicalMsgID) err := gw.CanonicalStore.Set(messageID, canonicalMsgID)
if err != nil { if err != nil {
gw.logger.Errorf("Error setting canomical message mapping {%s}->{%s}", messageID, canonicalMsgID)
gw.logger.Error(err) gw.logger.Error(err)
} }
} }
@ -56,6 +58,7 @@ func (gw *Gateway) getDestMessagesFromStore(canonicalMsgID string, dest *bridge.
destMessageIds := new([]BrMsgID) destMessageIds := new([]BrMsgID)
found, err := gw.MessageStore.Get(canonicalMsgID, destMessageIds) found, err := gw.MessageStore.Get(canonicalMsgID, destMessageIds)
if err != nil { if err != nil {
gw.logger.Errorf("Error getting destination messages for canonical message id {%s}", canonicalMsgID)
gw.logger.Error(err) gw.logger.Error(err)
} }