mirrors/apollo-backend
2
0
Fork 0
mirror of https://github.com/christianselig/apollo-backend synced 2024-09-21 05:37:07 +00:00
Code Issues Projects Releases Packages Wiki Activity

check if notification was sent too

Browse source
This commit is contained in:
Andre Medeiros 2022-01-14 15:29:56 -05:00
parent 39ccc1972a
commit dfae5d6c77
4 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
internal/worker/notifications.go
View file

@ -333,7 +333,7 @@ func (nc *notificationsConsumer) Consume(delivery rmq.Delivery) {
} }
res, err := client.Push(notification) res, err := client.Push(notification)
if err != nil { if err != nil || !res.Sent() {
_ = nc.statsd.Incr("apns.notification.errors", []string{}, 1) _ = nc.statsd.Incr("apns.notification.errors", []string{}, 1)
nc.logger.WithFields(logrus.Fields{ nc.logger.WithFields(logrus.Fields{
"account#username": account.NormalizedUsername(), "account#username": account.NormalizedUsername(),

2
internal/worker/subreddits.go
View file

@ -401,7 +401,7 @@ func (sc *subredditsConsumer) Consume(delivery rmq.Delivery) {
} }
res, err := client.Push(notification) res, err := client.Push(notification)
if err != nil { if err != nil || !res.Sent() {
_ = sc.statsd.Incr("apns.notification.errors", []string{}, 1) _ = sc.statsd.Incr("apns.notification.errors", []string{}, 1)
sc.logger.WithFields(logrus.Fields{ sc.logger.WithFields(logrus.Fields{
"subreddit#id": subreddit.ID, "subreddit#id": subreddit.ID,

2
internal/worker/trending.go
View file

@ -286,7 +286,7 @@ func (tc *trendingConsumer) Consume(delivery rmq.Delivery) {
} }
res, err := client.Push(notification) res, err := client.Push(notification)
if err != nil { if err != nil || !res.Sent() {
_ = tc.statsd.Incr("apns.notification.errors", []string{}, 1) _ = tc.statsd.Incr("apns.notification.errors", []string{}, 1)
tc.logger.WithFields(logrus.Fields{ tc.logger.WithFields(logrus.Fields{
"subreddit#id": subreddit.ID, "subreddit#id": subreddit.ID,

2
internal/worker/users.go
View file

@ -281,7 +281,7 @@ func (uc *usersConsumer) Consume(delivery rmq.Delivery) {
} }
res, err := client.Push(notification) res, err := client.Push(notification)
if err != nil { if err != nil || !res.Sent() {
_ = uc.statsd.Incr("apns.notification.errors", []string{}, 1) _ = uc.statsd.Incr("apns.notification.errors", []string{}, 1)
uc.logger.WithFields(logrus.Fields{ uc.logger.WithFields(logrus.Fields{
"user#id": user.ID, "user#id": user.ID,