Tupambae_Org/friendica_2021-01
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

"CheckServer" added

Browse source
This commit is contained in:
Michael 2019-12-20 21:46:30 +00:00
parent ef9bdfdff2
commit b4f690839a
4 changed files with 39 additions and 51 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
src/Protocol/PortableContact.php
View file

@ -315,7 +315,7 @@ class PortableContact
if (!DBA::isResult($r)) {
Logger::log("Call server check for server ".$server_url, Logger::DEBUG);
Worker::add(PRIORITY_LOW, "DiscoverPoCo", "server", $server_url);
Worker::add(PRIORITY_LOW, 'CheckServer', $server_url);
}
}
}
@ -340,7 +340,7 @@ class PortableContact
if (!empty($servers['pods'])) {
foreach ($servers['pods'] as $server) {
Worker::add(PRIORITY_LOW, "DiscoverPoCo", "server", "https://" . $server['host']);
Worker::add(PRIORITY_LOW, 'CheckServer', 'https://' . $server['host']);
}
}
}
@ -359,7 +359,7 @@ class PortableContact
foreach ($servers['instances'] as $server) {
$url = (is_null($server['https_score']) ? 'http' : 'https') . '://' . $server['name'];
Worker::add(PRIORITY_LOW, "DiscoverPoCo", "server", $url);
Worker::add(PRIORITY_LOW, 'CheckServer', $url);
}
}
}

28
src/Worker/CheckServer.php Normal file
View file

@ -0,0 +1,28 @@
<?php
/**
* @file src/Worker/CheckServer.php
*/
namespace Friendica\Worker;
use Friendica\Core\Logger;
use Friendica\Model\GServer;
use Friendica\Util\Strings;
class CheckServer
{
// Searches for the poco server list.
public static function execute($server_url)
{
if (empty($server_url)) {
return;
}
$server_url = filter_var($server_url, FILTER_SANITIZE_URL);
if (substr(Strings::normaliseLink($server_url), 0, 7) != 'http://') {
return;
}
$ret = GServer::check($server_url);
Logger::log('Checking server', ['url' => $server_url, 'result' => $ret]);
}
}

54
src/Worker/DiscoverPoCo.php
View file

@ -6,63 +6,23 @@ namespace Friendica\Worker;
use Friendica\Core\Config;
use Friendica\Core\Logger;
use Friendica\Core\Protocol;
use Friendica\Core\Worker;
use Friendica\Database\DBA;
use Friendica\Model\GContact;
use Friendica\Model\Contact;
use Friendica\Model\GServer;
use Friendica\Protocol\PortableContact;
use Friendica\Util\Strings;
class DiscoverPoCo
{
/// @todo Clean up this mess of a parameter hell and split it in several classes
public static function execute($command = '', $param1 = '', $param2 = '', $param3 = '', $param4 = '')
public static function execute()
{
/*
This function can be called in these ways:
- server <poco url>: Searches for the poco server list. "poco url" is base64 encoded.
*/
$search = "";
$mode = 0;
if ($command == "server") {
$server_url = $param1;
if ($server_url == "") {
return;
}
$server_url = filter_var($server_url, FILTER_SANITIZE_URL);
if (substr(Strings::normaliseLink($server_url), 0, 7) != "http://") {
return;
}
$result = "Checking server ".$server_url." - ";
$ret = GServer::check($server_url);
if ($ret) {
$result .= "success";
} else {
$result .= "failed";
}
Logger::log($result, Logger::DEBUG);
} elseif ($command !== "") {
Logger::log("Unknown or missing parameter ".$command."\n");
if (Config::get('system', 'poco_discovery') == PortableContact::DISABLED) {
return;
}
Logger::log('start '.$search);
// Query Friendica and Hubzilla servers for their users
PortableContact::discover();
if (($mode == 0) && ($search == "") && (Config::get('system', 'poco_discovery') != PortableContact::DISABLED)) {
// Query Friendica and Hubzilla servers for their users
PortableContact::discover();
// Query GNU Social servers for their users ("statistics" addon has to be enabled on the GS server)
if (!Config::get('system', 'ostatus_disabled')) {
GContact::discoverGsUsers();
}
// Query GNU Social servers for their users ("statistics" addon has to be enabled on the GS server)
if (!Config::get('system', 'ostatus_disabled')) {
GContact::discoverGsUsers();
}
Logger::log('end '.$search);
return;
}
}

2
src/Worker/UpdateServers.php
View file

@ -30,7 +30,7 @@ class UpdateServers
}
Logger::info('Update server status', ['server' => $gserver['url']]);
Worker::add(PRIORITY_LOW, 'DiscoverPoCo', 'server', $gserver['url']);
Worker::add(PRIORITY_LOW, 'CheckServer', $gserver['url']);
if (++$updated > 250) {
return;