38 lines
984 B
PHP
38 lines
984 B
PHP
<?php
|
|
/**
|
|
* @file src/Model/PushSubscriber.php
|
|
*/
|
|
namespace Friendica\Model;
|
|
|
|
use Friendica\Core\Worker;
|
|
use dba;
|
|
|
|
require_once 'include/dba.php';
|
|
|
|
class PushSubscriber
|
|
{
|
|
/**
|
|
* @param string $priority Priority for push workers
|
|
*/
|
|
public static function publishFeed($default_priority = PRIORITY_HIGH)
|
|
{
|
|
// We'll push to each subscriber that has push > 0,
|
|
// i.e. there has been an update (set in notifier.php).
|
|
$subscribers = dba::select('push_subscriber', ['id', 'push', 'callback_url'], ["`push` > 0 AND `next_try` < UTC_TIMESTAMP()"]);
|
|
|
|
while ($subscriber = dba::fetch($subscribers)) {
|
|
// We always handle retries with low priority
|
|
if ($subscriber["push"] > 1) {
|
|
$priority = PRIORITY_LOW;
|
|
} else {
|
|
$priority = $default_priority;
|
|
}
|
|
|
|
logger("Publish feed to " . $subscriber["callback_url"] . " with priority " . $priority, LOGGER_DEBUG);
|
|
Worker::add($priority, 'PubSubPublish', (int)$subscriber["id"]);
|
|
}
|
|
|
|
dba::close($subscribers);
|
|
}
|
|
}
|