Skip to content

Commit

Permalink
chore_: apply review comments
Browse files Browse the repository at this point in the history
  • Loading branch information
chaitanyaprem committed Dec 23, 2024
1 parent 398c28c commit a8951fd
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 6 deletions.
4 changes: 2 additions & 2 deletions protocol/messenger.go
Original file line number Diff line number Diff line change
Expand Up @@ -3345,10 +3345,10 @@ func (m *Messenger) handleRetrievedMessages(chatWithMessages map[transport.Filte
logger.Info("failed to retrieve admin communities", zap.Error(err))
}

//fetch universal chatIDs as well.
// fetch universal chatIDs as well.
controlledCommunitiesUniversalChatIDs, err := m.communitiesManager.GetOwnedCommunitiesUniversalChatIDs()
if err != nil {
logger.Info("failed to retrieve admin communities", zap.Error(err))
logger.Info("failed to retrieve controlled communities", zap.Error(err))
}
for chatID, flag := range controlledCommunitiesUniversalChatIDs {
controlledCommunitiesChatIDs[chatID] = flag
Expand Down
6 changes: 2 additions & 4 deletions protocol/messenger_communities.go
Original file line number Diff line number Diff line change
Expand Up @@ -3956,10 +3956,8 @@ func (m *Messenger) InitHistoryArchiveTasks(communities []*communities.Community
for _, filter := range filters {
topics = append(topics, filter.ContentTopic)
}
// adding the content-topic used for member updates.
// since member updates would not be too frequent i.e only addition/deletion would add a new message,
// this shouldn't cause too much increase in size of archive generated.
filters = append(filters, m.transport.FilterByChatID(c.MemberUpdateChannelID()))

filters = append(filters, m.transport.FilterByChatID(c.UniversalChatID()))

// First we need to know the timestamp of the latest waku message
// we've received for this community, so we can request messages we've
Expand Down

0 comments on commit a8951fd

Please sign in to comment.