diff options
| author | Neil Alexander <neilalexander@users.noreply.github.com> | 2022-03-03 12:01:19 +0000 |
|---|---|---|
| committer | Neil Alexander <neilalexander@users.noreply.github.com> | 2022-03-03 12:01:19 +0000 |
| commit | bcc27e9e1884add0ba272eaf2bb4c45a03f76e85 (patch) | |
| tree | 4c27048379b3409cce3b0024848134d43f8b4215 /userapi | |
| parent | f05ce478f05dcaf650fbae68a39aaf5d9880a580 (diff) | |
Only store notifications for users with pushers, de-parallelise `TestSessionCleanUp` for now
Diffstat (limited to 'userapi')
| -rw-r--r-- | userapi/consumers/syncapi_streamevent.go | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/userapi/consumers/syncapi_streamevent.go b/userapi/consumers/syncapi_streamevent.go index 11081327..d86078cb 100644 --- a/userapi/consumers/syncapi_streamevent.go +++ b/userapi/consumers/syncapi_streamevent.go @@ -139,6 +139,9 @@ func (s *OutputStreamEventConsumer) processMessage(ctx context.Context, event *g // removing it means we can send all notifications to // e.g. Element's Push gateway in one go. for _, mem := range members { + if p, err := s.db.GetPushers(ctx, mem.Localpart); err != nil || len(p) == 0 { + continue + } if err := s.notifyLocal(ctx, event, pos, mem, roomSize, roomName); err != nil { log.WithFields(log.Fields{ "localpart": mem.Localpart, |