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: log errors generated while registering filters

This commit is contained in:
Richard Ramos 2023-01-05 12:58:17 -04:00 committed by Jonathan Rainville
parent 76dce0c8a6
commit ad67eb52e5
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
protocol/transport/filters_manager.go
View File

@ -143,6 +143,7 @@ func (f *FiltersManager) InitCommunityFilters(pks []*ecdsa.PrivateKey) ([]*Filte
identityStr := PublicKeyToStr(&pk.PublicKey) identityStr := PublicKeyToStr(&pk.PublicKey)
rawFilter, err := f.addAsymmetric(identityStr, pk, true) rawFilter, err := f.addAsymmetric(identityStr, pk, true)
if err != nil { if err != nil {
f.logger.Debug("could not register community filter", zap.Error(err))
return nil, err return nil, err
} }
@ -356,6 +357,7 @@ func (f *FiltersManager) LoadPersonal(publicKey *ecdsa.PublicKey, identity *ecds
// but we discard envelopes if listen is false. // but we discard envelopes if listen is false.
filter, err := f.addAsymmetric(chatID, identity, listen) filter, err := f.addAsymmetric(chatID, identity, listen)
if err != nil { if err != nil {
f.logger.Debug("could not register personal topic filter", zap.Error(err))
return nil, err return nil, err
} }
@ -393,6 +395,7 @@ func (f *FiltersManager) loadPartitioned(publicKey *ecdsa.PublicKey, identity *e
// but we discard envelopes if listen is false. // but we discard envelopes if listen is false.
filter, err := f.addAsymmetric(chatID, identity, listen) filter, err := f.addAsymmetric(chatID, identity, listen)
if err != nil { if err != nil {
f.logger.Debug("could not register partitioned topic", zap.String("chatID", chatID), zap.Error(err))
return nil, err return nil, err
} }
@ -427,6 +430,7 @@ func (f *FiltersManager) LoadNegotiated(secret types.NegotiatedSecret) (*Filter,
keyString := hex.EncodeToString(secret.Key) keyString := hex.EncodeToString(secret.Key)
filter, err := f.addSymmetric(keyString) filter, err := f.addSymmetric(keyString)
if err != nil { if err != nil {
f.logger.Debug("could not register negotiated topic", zap.Error(err))
return nil, err return nil, err
} }
@ -482,6 +486,7 @@ func (f *FiltersManager) LoadDiscovery() ([]*Filter, error) {
discoveryResponse, err := f.addAsymmetric(personalDiscoveryChat.ChatID, f.privateKey, true) discoveryResponse, err := f.addAsymmetric(personalDiscoveryChat.ChatID, f.privateKey, true)
if err != nil { if err != nil {
f.logger.Debug("could not register discovery topic", zap.String("chatID", personalDiscoveryChat.ChatID), zap.Error(err))
return nil, err return nil, err
} }
@ -512,6 +517,7 @@ func (f *FiltersManager) LoadPublic(chatID string) (*Filter, error) {
filterAndTopic, err := f.addSymmetric(chatID) filterAndTopic, err := f.addSymmetric(chatID)
if err != nil { if err != nil {
f.logger.Debug("could not register public chat topic", zap.String("chatID", chatID), zap.Error(err))
return nil, err return nil, err
} }
@ -544,6 +550,7 @@ func (f *FiltersManager) LoadContactCode(pubKey *ecdsa.PublicKey) (*Filter, erro
contactCodeFilter, err := f.addSymmetric(chatID) contactCodeFilter, err := f.addSymmetric(chatID)
if err != nil { if err != nil {
f.logger.Debug("could not register contact code topic", zap.String("chatID", chatID), zap.Error(err))
return nil, err return nil, err
} }