mirrors/apollo-backend
2
0
Fork 0
mirror of https://github.com/christianselig/apollo-backend synced 2024-11-25 21:27:42 +00:00
Code Issues Projects Releases Packages Wiki Activity

Tweak stuck notifications a bit mroe

Browse source
This commit is contained in:
Andre Medeiros 2022-05-19 13:02:16 -04:00
parent af592c446f
commit adbaeb9e54
1 changed files with 13 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
internal/worker/stuck_notifications.go
View file

@ -179,7 +179,11 @@ func (snc *stuckNotificationsConsumer) Consume(delivery rmq.Delivery) {
break break
} }
things, err := rac.MessageInbox(snc, reddit.WithQuery("after", account.LastMessageID)) if kind == "t4" {
return
}
sthings, err := rac.MessageInbox(snc)
if err != nil { if err != nil {
snc.logger.WithFields(logrus.Fields{ snc.logger.WithFields(logrus.Fields{
"err": err, "err": err,
@ -187,7 +191,14 @@ func (snc *stuckNotificationsConsumer) Consume(delivery rmq.Delivery) {
return return
} }
if things.Count == 0 { found := false
for _, sthing := range sthings.Children {
if sthing.FullName() == account.LastMessageID {
found = true
}
}
if !found {
snc.logger.WithFields(logrus.Fields{ snc.logger.WithFields(logrus.Fields{
"account#username": account.NormalizedUsername(), "account#username": account.NormalizedUsername(),
"thing#id": account.LastMessageID, "thing#id": account.LastMessageID,