eliseuamaro/gnu-social
1
0
Fork 0
forked from GNUsocial/gnu-social
Code Issues Pull Requests Releases Wiki Activity

Enqueue renewals

Browse Source 
Better for request times, etc
This commit is contained in:
Stephen Paul Weber
2015-10-21 01:50:03 +00:00
parent df21c3c95d
commit 4b31bc3fd2
2 changed files with 55 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
plugins/OStatus/OStatusPlugin.php
View File

@@ -104,6 +104,9 @@ class OStatusPlugin extends Plugin
// Incoming from a foreign PuSH hub
$qm->connect('pushin', 'PushInQueueHandler');
// Re-subscribe feeds that need renewal
$qm->connect('pushrenew', 'PushRenewQueueHandler');
return true;
}
@@ -1361,9 +1364,10 @@ class OStatusPlugin extends Plugin
return;
}
$qm = QueueManager::get();
while ($sub->fetch()) {
common_log(LOG_INFO, "Renewing feed subscription\n\tExp.: {$sub->sub_end}\n\tFeed: {$sub->uri}\n\tHub: {$sub->huburi}");
$sub->renew();
$item = array('feedsub_id' => $sub->id);
$qm->enqueue($item, 'pushrenew');
}
}
}