From adbaeb9e54f6cceb9740ec7bd73c89cf3319787a Mon Sep 17 00:00:00 2001
From: Andre Medeiros <hello@andre.cool>
Date: Thu, 19 May 2022 13:02:16 -0400
Subject: [PATCH] Tweak stuck notifications a bit mroe

---
 internal/worker/stuck_notifications.go | 15 +++++++++++++--
 1 file changed, 13 insertions(+), 2 deletions(-)

diff --git a/internal/worker/stuck_notifications.go b/internal/worker/stuck_notifications.go
index cda9fde..18de604 100644
--- a/internal/worker/stuck_notifications.go
+++ b/internal/worker/stuck_notifications.go
@@ -179,7 +179,11 @@ func (snc *stuckNotificationsConsumer) Consume(delivery rmq.Delivery) {
 				break
 			}
 
-			things, err := rac.MessageInbox(snc, reddit.WithQuery("after", account.LastMessageID))
+			if kind == "t4" {
+				return
+			}
+
+			sthings, err := rac.MessageInbox(snc)
 			if err != nil {
 				snc.logger.WithFields(logrus.Fields{
 					"err": err,
@@ -187,7 +191,14 @@ func (snc *stuckNotificationsConsumer) Consume(delivery rmq.Delivery) {
 				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{
 					"account#username": account.NormalizedUsername(),
 					"thing#id":         account.LastMessageID,