From cc6e862ba6987010ffa30d8a2ff3c6271738208c Mon Sep 17 00:00:00 2001
From: Andre Medeiros <hello@andre.cool>
Date: Thu, 19 May 2022 11:51:56 -0400
Subject: [PATCH] be less noisy about rate limits

---
 internal/worker/notifications.go       | 2 +-
 internal/worker/stuck_notifications.go | 8 +++++---
 2 files changed, 6 insertions(+), 4 deletions(-)

diff --git a/internal/worker/notifications.go b/internal/worker/notifications.go
index 0c0fe2e..8ab3757 100644
--- a/internal/worker/notifications.go
+++ b/internal/worker/notifications.go
@@ -255,7 +255,7 @@ func (nc *notificationsConsumer) Consume(delivery rmq.Delivery) {
 
 	if err != nil {
 		switch err {
-		case reddit.ErrTimeout: // Don't log timeouts
+		case reddit.ErrTimeout, reddit.ErrRateLimited: // Don't log timeouts or rate limits
 			break
 		case reddit.ErrOauthRevoked:
 			err = nc.deleteAccount(account)
diff --git a/internal/worker/stuck_notifications.go b/internal/worker/stuck_notifications.go
index 7a82d1a..1ede379 100644
--- a/internal/worker/stuck_notifications.go
+++ b/internal/worker/stuck_notifications.go
@@ -152,9 +152,11 @@ func (snc *stuckNotificationsConsumer) Consume(delivery rmq.Delivery) {
 
 		things, err = rac.MessageInbox(snc)
 		if err != nil {
-			snc.logger.WithFields(logrus.Fields{
-				"err": err,
-			}).Error("failed to fetch last thing via inbox")
+			if err != reddit.ErrRateLimited {
+				snc.logger.WithFields(logrus.Fields{
+					"err": err,
+				}).Error("failed to fetch last thing via inbox")
+			}
 			return
 		}
 	} else {