diff --git a/contact_request_manager.go b/contact_request_manager.go index 3be1e1de..60cf79cc 100644 --- a/contact_request_manager.go +++ b/contact_request_manager.go @@ -137,8 +137,8 @@ func (c *contactRequestsManager) metadataWatcher(ctx context.Context) { c.muManager.Unlock() // enqueue all contact with the `ToRequest` state - if err := c.enqueueRequest(ctx, contact); err != nil { - for _, contact := range c.metadataStore.ListContactsByStatus(protocoltypes.ContactState_ContactStateToRequest) { + for _, contact := range c.metadataStore.ListContactsByStatus(protocoltypes.ContactState_ContactStateToRequest) { + if err := c.enqueueRequest(ctx, contact); err != nil { c.logger.Warn("unable to enqueue contact request", logutil.PrivateBinary("pk", contact.Pk), zap.Error(err)) } }