|
|
@ -8,13 +8,12 @@ class Scheduler::SubscriptionsScheduler |
|
|
|
|
|
|
|
def perform |
|
|
|
logger.info 'Queueing PuSH re-subscriptions' |
|
|
|
|
|
|
|
Pubsubhubbub::SubscribeWorker.push_bulk(expiring_accounts.pluck(:id)) |
|
|
|
end |
|
|
|
|
|
|
|
private |
|
|
|
|
|
|
|
def expiring_accounts |
|
|
|
Account.expiring(1.day.from_now).partitioned |
|
|
|
Account.where(protocol: :ostatus).expiring(1.day.from_now).partitioned |
|
|
|
end |
|
|
|
end |