status-im
/
status-go
mirror of https://github.com/status-im/status-go.git
2
0
Fork 0
Code Issues Projects Releases Wiki Activity

chore(no-torrent)_: removed TorrentManager from handleImportedMessages

This commit is contained in:
Samuel Hawksby-Robinson 2024-06-02 18:52:39 +01:00
parent 66d57a3fd0
commit 96b4684647
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
protocol/messenger.go
View File

@ -3743,11 +3743,11 @@ func (m *Messenger) handleImportedMessages(messagesToHandle map[transport.Filter
importMessagesToSave := messageState.Response.DiscordMessages() importMessagesToSave := messageState.Response.DiscordMessages()
if len(importMessagesToSave) > 0 { if len(importMessagesToSave) > 0 {
m.torrentManager.LogStdout(fmt.Sprintf("saving %d discord messages", len(importMessagesToSave))) m.logger.Debug(fmt.Sprintf("saving %d discord messages", len(importMessagesToSave)))
m.handleImportMessagesMutex.Lock() m.handleImportMessagesMutex.Lock()
err := m.persistence.SaveDiscordMessages(importMessagesToSave) err := m.persistence.SaveDiscordMessages(importMessagesToSave)
if err != nil { if err != nil {
m.torrentManager.LogStdout("failed to save discord messages", zap.Error(err)) m.logger.Debug("failed to save discord messages", zap.Error(err))
m.handleImportMessagesMutex.Unlock() m.handleImportMessagesMutex.Unlock()
return err return err
} }
@ -3756,11 +3756,11 @@ func (m *Messenger) handleImportedMessages(messagesToHandle map[transport.Filter
messageAttachmentsToSave := messageState.Response.DiscordMessageAttachments() messageAttachmentsToSave := messageState.Response.DiscordMessageAttachments()
if len(messageAttachmentsToSave) > 0 { if len(messageAttachmentsToSave) > 0 {
m.torrentManager.LogStdout(fmt.Sprintf("saving %d discord message attachments", len(messageAttachmentsToSave))) m.logger.Debug(fmt.Sprintf("saving %d discord message attachments", len(messageAttachmentsToSave)))
m.handleImportMessagesMutex.Lock() m.handleImportMessagesMutex.Lock()
err := m.persistence.SaveDiscordMessageAttachments(messageAttachmentsToSave) err := m.persistence.SaveDiscordMessageAttachments(messageAttachmentsToSave)
if err != nil { if err != nil {
m.torrentManager.LogStdout("failed to save discord message attachments", zap.Error(err)) m.logger.Debug("failed to save discord message attachments", zap.Error(err))
m.handleImportMessagesMutex.Unlock() m.handleImportMessagesMutex.Unlock()
return err return err
} }
@ -3769,7 +3769,7 @@ func (m *Messenger) handleImportedMessages(messagesToHandle map[transport.Filter
messagesToSave := messageState.Response.Messages() messagesToSave := messageState.Response.Messages()
if len(messagesToSave) > 0 { if len(messagesToSave) > 0 {
m.torrentManager.LogStdout(fmt.Sprintf("saving %d app messages", len(messagesToSave))) m.logger.Debug(fmt.Sprintf("saving %d app messages", len(messagesToSave)))
m.handleMessagesMutex.Lock() m.handleMessagesMutex.Lock()
err := m.SaveMessages(messagesToSave) err := m.SaveMessages(messagesToSave)
if err != nil { if err != nil {