X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=src%2FWorker%2FDiscoverPoCo.php;h=497684497fbd4cc778558cc7627626a5bc5c1ce6;hb=481b0ac138511825f3736342b40dd9b3a2e2a8d5;hp=89b3a0a115f1ea4a57f8cd71c5ea3e3bc3da9d6f;hpb=eaf81e5e66db1f722192005ff75bb5831c1912eb;p=friendica.git diff --git a/src/Worker/DiscoverPoCo.php b/src/Worker/DiscoverPoCo.php index 89b3a0a115..497684497f 100644 --- a/src/Worker/DiscoverPoCo.php +++ b/src/Worker/DiscoverPoCo.php @@ -6,6 +6,7 @@ namespace Friendica\Worker; use Friendica\Core\Cache; use Friendica\Core\Config; +use Friendica\Core\Protocol; use Friendica\Core\Worker; use Friendica\Database\DBA; use Friendica\Model\GContact; @@ -147,8 +148,8 @@ class DiscoverPoCo WHERE `last_contact` < UTC_TIMESTAMP - INTERVAL 1 MONTH AND `last_failure` < UTC_TIMESTAMP - INTERVAL 1 MONTH AND `network` IN ('%s', '%s', '%s', '%s', '') ORDER BY rand()", - DBA::escape(NETWORK_DFRN), DBA::escape(NETWORK_DIASPORA), - DBA::escape(NETWORK_OSTATUS), DBA::escape(NETWORK_FEED)); + DBA::escape(Protocol::DFRN), DBA::escape(Protocol::DIASPORA), + DBA::escape(Protocol::OSTATUS), DBA::escape(Protocol::FEED)); if (!$users) { return; @@ -159,13 +160,13 @@ class DiscoverPoCo $urlparts = parse_url($user["url"]); if (!isset($urlparts["scheme"])) { - DBA::update('gcontact', ['network' => NETWORK_PHANTOM], + DBA::update('gcontact', ['network' => Protocol::PHANTOM], ['nurl' => normalise_link($user["url"])]); continue; } if (in_array($urlparts["host"], ["twitter.com", "identi.ca"])) { - $networks = ["twitter.com" => NETWORK_TWITTER, "identi.ca" => NETWORK_PUMPIO]; + $networks = ["twitter.com" => Protocol::TWITTER, "identi.ca" => Protocol::PUMPIO]; DBA::update('gcontact', ['network' => $networks[$urlparts["host"]]], ['nurl' => normalise_link($user["url"])]); @@ -182,7 +183,7 @@ class DiscoverPoCo $server_url = $user["server_url"]; } - if ((($server_url == "") && ($user["network"] == NETWORK_FEED)) || $force_update || PortableContact::checkServer($server_url, $user["network"])) { + if ((($server_url == "") && ($user["network"] == Protocol::FEED)) || $force_update || PortableContact::checkServer($server_url, $user["network"])) { logger('Check profile '.$user["url"]); Worker::add(PRIORITY_LOW, "DiscoverPoCo", "check_profile", $user["url"]); @@ -215,7 +216,7 @@ class DiscoverPoCo $x = Network::fetchUrl(get_server()."/lsearch?p=1&n=500&search=".urlencode($search)); $j = json_decode($x); - if (count($j->results)) { + if (!empty($j->results)) { foreach ($j->results as $jj) { // Check if the contact already exists $exists = q("SELECT `id`, `last_contact`, `last_failure`, `updated` FROM `gcontact` WHERE `nurl` = '%s'", normalise_link($jj->url)); @@ -241,7 +242,7 @@ class DiscoverPoCo } $data = Probe::uri($jj->url); - if ($data["network"] == NETWORK_DFRN) { + if ($data["network"] == Protocol::DFRN) { logger("Profile ".$jj->url." is reachable (".$search.")", LOGGER_DEBUG); logger("Add profile ".$jj->url." to local directory (".$search.")", LOGGER_DEBUG); @@ -273,12 +274,12 @@ class DiscoverPoCo $url = "http://gstools.org/api/users_search/".urlencode($search); - $result = Network::curl($url); - if (!$result["success"]) { + $curlResult = Network::curl($url); + if (!$curlResult->isSuccess()) { return false; } - $contacts = json_decode($result["body"]); + $contacts = json_decode($curlResult->getBody()); if ($contacts->status == 'ERROR') { return false; @@ -288,7 +289,7 @@ class DiscoverPoCo /// @TODO find all those and convert to all lower-case which is a keyword then foreach ($contacts->data AS $user) { $contact = Probe::uri($user->site_address."/".$user->name); - if ($contact["network"] != NETWORK_PHANTOM) { + if ($contact["network"] != Protocol::PHANTOM) { $contact["about"] = $user->description; GContact::update($contact); }