X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=src%2FWorker%2FPubSubPublish.php;h=03608bea66d540c8a3376fca791fd533b1d52a1c;hb=3220c78d70c76cd10b38ec364cb3d58d26e9309b;hp=e2ecedbdf0f0189c4b25a432405c4e5c9f32fca6;hpb=5108115fc150b242abd1f61ba2d1931ba7ffd2e4;p=friendica.git diff --git a/src/Worker/PubSubPublish.php b/src/Worker/PubSubPublish.php index e2ecedbdf0..03608bea66 100644 --- a/src/Worker/PubSubPublish.php +++ b/src/Worker/PubSubPublish.php @@ -11,6 +11,7 @@ use Friendica\Core\Config; use Friendica\Core\Worker; use Friendica\Database\DBM; use Friendica\Protocol\OStatus; +use Friendica\Util\Network; require_once 'include/items.php'; @@ -26,7 +27,7 @@ class PubSubPublish { foreach ($r as $rr) { logger("Publish feed to ".$rr["callback_url"], LOGGER_DEBUG); - Worker::add(array('priority' => PRIORITY_HIGH, 'created' => $a->queue['created'], 'dont_fork' => true), + Worker::add(['priority' => PRIORITY_HIGH, 'created' => $a->queue['created'], 'dont_fork' => true], 'PubSubPublish', (int)$rr["id"]); } } @@ -52,7 +53,7 @@ class PubSubPublish { logger("Generate feed of user ".$rr['nickname']." to ".$rr['callback_url']." - last updated ".$rr['last_update'], LOGGER_DEBUG); $last_update = $rr['last_update']; - $params = OStatus::feed($a, $rr['nickname'], $last_update); + $params = OStatus::feed($rr['nickname'], $last_update); if (!$params) { return; @@ -60,15 +61,15 @@ class PubSubPublish { $hmac_sig = hash_hmac("sha1", $params, $rr['secret']); - $headers = array("Content-type: application/atom+xml", + $headers = ["Content-type: application/atom+xml", sprintf("Link: <%s>;rel=hub,<%s>;rel=self", System::baseUrl().'/pubsubhubbub/'.$rr['nickname'], $rr['topic']), - "X-Hub-Signature: sha1=".$hmac_sig); + "X-Hub-Signature: sha1=".$hmac_sig]; logger('POST '.print_r($headers, true)."\n".$params, LOGGER_DEBUG); - post_url($rr['callback_url'], $params, $headers); + Network::post($rr['callback_url'], $params, $headers); $ret = $a->get_curl_code(); if ($ret >= 200 && $ret <= 299) {