X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=mod%2Fpubsubhubbub.php;h=051ae2e84264d74e6678869f02f0620aaef26902;hb=0454d0a670e051e8519e9a4220606f83d1408214;hp=77f27dff5faa536ecfee1035be3b253b1074c500;hpb=acb4630eed14175ef35f09e21609d6329f3f990c;p=friendica.git diff --git a/mod/pubsubhubbub.php b/mod/pubsubhubbub.php index 77f27dff5f..051ae2e842 100644 --- a/mod/pubsubhubbub.php +++ b/mod/pubsubhubbub.php @@ -2,6 +2,10 @@ use Friendica\App; use Friendica\Core\Config; +use Friendica\Core\System; +use Friendica\Database\DBM; +use Friendica\Util\DateTimeFormat; +use Friendica\Util\Network; function post_var($name) { return (x($_POST, $name)) ? notags(trim($_POST[$name])) : ''; @@ -11,7 +15,7 @@ function pubsubhubbub_init(App $a) { // PuSH subscription must be considered "public" so just block it // if public access isn't enabled. if (Config::get('system', 'block_public')) { - http_status_exit(403); + System::httpExit(403); } // Subscription request from subscriber @@ -39,7 +43,7 @@ function pubsubhubbub_init(App $a) { $subscribe = 0; } else { logger("pubsubhubbub: invalid hub_mode=$hub_mode, ignoring."); - http_status_exit(404); + System::httpExit(404); } logger("pubsubhubbub: $hub_mode request from " . @@ -55,7 +59,7 @@ function pubsubhubbub_init(App $a) { if (!$nick) { logger('pubsubhubbub: bad hub_topic=$hub_topic, ignoring.'); - http_status_exit(404); + System::httpExit(404); } // fetch user from database given the nickname @@ -63,9 +67,9 @@ function pubsubhubbub_init(App $a) { " AND `account_expired` = 0 AND `account_removed` = 0 LIMIT 1", dbesc($nick)); - if (!dbm::is_result($r)) { + if (!DBM::is_result($r)) { logger('pubsubhubbub: local account not found: ' . $nick); - http_status_exit(404); + System::httpExit(404); } $owner = $r[0]; @@ -74,16 +78,16 @@ function pubsubhubbub_init(App $a) { if ($r[0]['hidewall']) { logger('pubsubhubbub: local user ' . $nick . 'has chosen to hide wall, ignoring.'); - http_status_exit(403); + System::httpExit(403); } // get corresponding row from contact table $r = q("SELECT * FROM `contact` WHERE `uid` = %d AND NOT `blocked`". " AND NOT `pending` AND `self` LIMIT 1", intval($owner['uid'])); - if (!dbm::is_result($r)) { + if (!DBM::is_result($r)) { logger('pubsubhubbub: contact not found.'); - http_status_exit(404); + System::httpExit(404); } $contact = $r[0]; @@ -92,7 +96,7 @@ function pubsubhubbub_init(App $a) { if (!link_compare($hub_topic, $contact['poll'])) { logger('pubsubhubbub: hub topic ' . $hub_topic . ' != ' . $contact['poll']); - http_status_exit(404); + System::httpExit(404); } // do subscriber verification according to the PuSH protocol @@ -108,14 +112,14 @@ function pubsubhubbub_init(App $a) { // we don't actually enforce the lease time because GNU // Social/StatusNet doesn't honour it (yet) - $body = fetch_url($hub_callback . "?" . $params); + $body = Network::fetchUrl($hub_callback . "?" . $params); $ret = $a->get_curl_code(); // give up if the HTTP return code wasn't a success (2xx) if ($ret < 200 || $ret > 299) { logger("pubsubhubbub: subscriber verification at $hub_callback ". "returned $ret, ignoring."); - http_status_exit(404); + System::httpExit(404); } // check that the correct hub_challenge code was echoed back @@ -123,7 +127,7 @@ function pubsubhubbub_init(App $a) { logger("pubsubhubbub: subscriber did not echo back ". "hub.challenge, ignoring."); logger("\"$hub_challenge\" != \"".trim($body)."\""); - http_status_exit(404); + System::httpExit(404); } // fetch the old subscription if it exists @@ -135,12 +139,12 @@ function pubsubhubbub_init(App $a) { dbesc($hub_callback)); if ($subscribe) { - $last_update = datetime_convert('UTC','UTC','now','Y-m-d H:i:s'); + $last_update = DateTimeFormat::utcNow(); $push_flag = 0; // if we are just updating an old subscription, keep the // old values for push and last_update - if (dbm::is_result($r)) { + if (DBM::is_result($r)) { $last_update = $r[0]['last_update']; $push_flag = $r[0]['push']; } @@ -161,7 +165,7 @@ function pubsubhubbub_init(App $a) { logger("pubsubhubbub: successfully unsubscribed [$hub_callback]."); // we do nothing here, since the row was already deleted } - http_status_exit(202); + System::httpExit(202); } killme();