mirrors/apollo-backend
2
0
Fork 0
mirror of https://github.com/christianselig/apollo-backend synced 2024-11-22 19:57:43 +00:00
Code Issues Projects Releases Packages Wiki Activity

be more forgiving with comment age

Browse source
This commit is contained in:
Andre Medeiros 2022-10-26 19:31:16 -04:00
parent cd8b0b0dca
commit 9154ee8e7f
1 changed files with 15 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
internal/worker/live_activities.go
View file

@ -227,13 +227,24 @@ func (lac *liveActivitiesConsumer) Consume(delivery rmq.Delivery) {
// Filter out comments in the last minute // Filter out comments in the last minute
candidates := make([]*reddit.Thing, 0) candidates := make([]*reddit.Thing, 0)
cutoff := now.Add(-domain.LiveActivityCheckInterval) cutoffs := []time.Time{
now.Add(-domain.LiveActivityCheckInterval),
now.Add(-domain.LiveActivityCheckInterval * 2),
now.Add(-domain.LiveActivityCheckInterval * 4),
}
for _, cutoff := range cutoffs {
for _, t := range tr.Children { for _, t := range tr.Children {
if t.CreatedAt.After(cutoff) { if t.CreatedAt.After(cutoff) {
candidates = append(candidates, t) candidates = append(candidates, t)
} }
} }
if len(candidates) > 0 {
break
}
}
if len(candidates) == 0 { if len(candidates) == 0 {
lac.logger.Debug("no new comments found", zap.String("live_activity#apns_token", at)) lac.logger.Debug("no new comments found", zap.String("live_activity#apns_token", at))
return return