diff --git a/webhooks/queue.go b/webhooks/queue.go index ac8107f85e10f0f50b74d82bd2839473da17688e..5cfcc6719028fc2e8c3489a4caa75300670f62f7 100644 --- a/webhooks/queue.go +++ b/webhooks/queue.go @@ -152,7 +152,9 @@ &sub.TokenHash, &sub.Grants, &sub.ClientID, &sub.Expires, &sub.NodeID); err != nil { panic(err) } - subs = append(subs, &sub) + if sub.Expires.After(time.Now()) { + subs = append(subs, &sub) + } } return nil