X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=src%2FModel%2FPushSubscriber.php;h=f6839307249c67542e605e71389e26279828fc2a;hb=f1d3f60499a325557be866fedd31b46093d477ae;hp=92d1dd21d1249a9bdbd103833aef0a2b61f1b710;hpb=f1e7d97b8cae93e1c77f5a5085880409b01fcdbe;p=friendica.git diff --git a/src/Model/PushSubscriber.php b/src/Model/PushSubscriber.php index 92d1dd21d1..f683930724 100644 --- a/src/Model/PushSubscriber.php +++ b/src/Model/PushSubscriber.php @@ -1,18 +1,36 @@ . + * */ + namespace Friendica\Model; use Friendica\Core\Logger; use Friendica\Core\Worker; use Friendica\Database\DBA; use Friendica\Util\DateTimeFormat; +use Friendica\Util\Network; class PushSubscriber { /** - * @brief Send subscription notifications for the given user + * Send subscription notifications for the given user * * @param integer $uid User ID * @param int $default_priority @@ -27,7 +45,7 @@ class PushSubscriber } /** - * @brief start workers to transmit the feed data + * start workers to transmit the feed data * * @param int $default_priority * @throws \Friendica\Network\HTTPException\InternalServerErrorException @@ -54,7 +72,7 @@ class PushSubscriber } /** - * @brief Renew the feed subscription + * Renew the feed subscription * * @param integer $uid User ID * @param string $nick Priority for push workers @@ -98,7 +116,7 @@ class PushSubscriber } /** - * @brief Delay the push subscriber + * Delay the push subscriber * * @param integer $id Subscriber ID * @throws \Exception @@ -136,7 +154,7 @@ class PushSubscriber } /** - * @brief Reset the push subscriber + * Reset the push subscriber * * @param integer $id Subscriber ID * @param string $last_update Date of last transmitted item @@ -153,5 +171,13 @@ class PushSubscriber $fields = ['push' => 0, 'next_try' => DBA::NULL_DATETIME, 'last_update' => $last_update]; DBA::update('push_subscriber', $fields, ['id' => $id]); Logger::log('Subscriber ' . $subscriber['callback_url'] . ' for ' . $subscriber['nickname'] . ' is marked as vital', Logger::DEBUG); + + $parts = parse_url($subscriber['callback_url']); + unset($parts['path']); + $server_url = Network::unparseURL($parts); + $gsid = GServer::getID($server_url, true); + if (!empty($gsid)) { + GServer::setProtocol($gsid, Post\DeliveryData::OSTATUS); + } } }