diff --git a/protocol/messenger_communities.go b/protocol/messenger_communities.go index 26c85ba4f..958d698d6 100644 --- a/protocol/messenger_communities.go +++ b/protocol/messenger_communities.go @@ -2558,7 +2558,7 @@ importMessageArchivesLoop: continue importMessageArchivesLoop } - response, err := m.handleArchiveMessages(messagesChunk, communityID) + response, err := m.handleArchiveMessages(messagesChunk) if err != nil { m.communitiesManager.LogStdout("failed to handle archive messages", zap.Error(err)) continue importMessageArchivesLoop diff --git a/protocol/messenger_handler.go b/protocol/messenger_handler.go index 44820003f..bef7bcba0 100644 --- a/protocol/messenger_handler.go +++ b/protocol/messenger_handler.go @@ -1306,7 +1306,7 @@ func (m *Messenger) downloadAndImportHistoryArchives(id types.HexBytes, magnetli m.config.messengerSignalsHandler.DownloadingHistoryArchivesFinished(types.EncodeHex(id)) } -func (m *Messenger) handleArchiveMessages(archiveMessages []*protobuf.WakuMessage, id types.HexBytes) (*MessengerResponse, error) { +func (m *Messenger) handleArchiveMessages(archiveMessages []*protobuf.WakuMessage) (*MessengerResponse, error) { messagesToHandle := make(map[transport.Filter][]*types.Message)