X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=src%2FWorker%2FDirectory.php;h=b66b662d4c8c4432d937d534d42c9098caf343ff;hb=4fe278be7d605810c0bb848d10d48344df186747;hp=63f2e3b6743f93f0d0fa4a7a26e64066fe8da7eb;hpb=71ec84f6dc83f753fe80170cfdfd32d202850d90;p=friendica.git diff --git a/src/Worker/Directory.php b/src/Worker/Directory.php index 63f2e3b674..b66b662d4c 100644 --- a/src/Worker/Directory.php +++ b/src/Worker/Directory.php @@ -1,22 +1,42 @@ . + * */ namespace Friendica\Worker; -use Friendica\Core\Addon; -use Friendica\Core\Config; +use Friendica\Core\Hook; +use Friendica\Core\Logger; +use Friendica\Core\Search; use Friendica\Core\Worker; use Friendica\Database\DBA; -use Friendica\Util\Network; +use Friendica\DI; +use Friendica\Network\HTTPClient\Client\HttpClientAccept; +/** + * Sends updated profile data to the directory + */ class Directory { - public static function execute($url = '') + public static function execute(string $url = '') { - $dir = Config::get('system', 'directory'); + $dir = Search::getGlobalDirectory(); if (!strlen($dir)) { return; @@ -31,27 +51,21 @@ class Directory $arr = ['url' => $url]; - Addon::callHooks('globaldir_update', $arr); + Hook::callAll('globaldir_update', $arr); - logger('Updating directory: ' . $arr['url'], LOGGER_DEBUG); + Logger::info('Updating directory: ' . $arr['url']); if (strlen($arr['url'])) { - Network::fetchUrl($dir . '?url=' . bin2hex($arr['url'])); + DI::httpClient()->fetch($dir . '?url=' . bin2hex($arr['url']), HttpClientAccept::HTML); } return; } private static function updateAll() { - $r = q("SELECT `url` FROM `contact` - INNER JOIN `profile` ON `profile`.`uid` = `contact`.`uid` - INNER JOIN `user` ON `user`.`uid` = `contact`.`uid` - WHERE `contact`.`self` AND `profile`.`net-publish` AND `profile`.`is-default` AND - NOT `user`.`account_expired` AND `user`.`verified`"); - - if (DBA::isResult($r)) { - foreach ($r AS $user) { - Worker::add(PRIORITY_LOW, 'Directory', $user['url']); - } + $users = DBA::select('owner-view', ['url'], ['net-publish' => true, 'account_expired' => false, 'verified' => true]); + while ($user = DBA::fetch($users)) { + Worker::add(Worker::PRIORITY_LOW, 'Directory', $user['url']); } + DBA::close($users); } }