]> git.mxchange.org Git - friendica.git/blob - src/Worker/UpdateGServers.php
Inverted condition
[friendica.git] / src / Worker / UpdateGServers.php
1 <?php
2 /**
3  * @copyright Copyright (C) 2010-2021, the Friendica project
4  *
5  * @license GNU AGPL version 3 or any later version
6  *
7  * This program is free software: you can redistribute it and/or modify
8  * it under the terms of the GNU Affero General Public License as
9  * published by the Free Software Foundation, either version 3 of the
10  * License, or (at your option) any later version.
11  *
12  * This program is distributed in the hope that it will be useful,
13  * but WITHOUT ANY WARRANTY; without even the implied warranty of
14  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
15  * GNU Affero General Public License for more details.
16  *
17  * You should have received a copy of the GNU Affero General Public License
18  * along with this program.  If not, see <https://www.gnu.org/licenses/>.
19  *
20  */
21
22 namespace Friendica\Worker;
23
24 use Friendica\Core\Logger;
25 use Friendica\Core\Worker;
26 use Friendica\Database\DBA;
27 use Friendica\DI;
28 use Friendica\Util\Strings;
29
30 class UpdateGServers
31 {
32         /**
33          * Updates a defined number of servers
34          */
35         public static function execute()
36         {
37                 $update_limit = DI::config()->get('system', 'gserver_update_limit');
38                 if (empty($update_limit)) {
39                         return;
40                 }
41
42                 $updating = Worker::countWorkersByCommand('UpdateGServer');
43                 $limit = $update_limit - $updating;
44                 if ($limit <= 0) {
45                         Logger::info('The number of currently running jobs exceed the limit');
46                         return;
47                 }
48
49                 $total = DBA::count('gserver');
50                 $condition = ["`next_contact` < UTC_TIMESTAMP() AND (`nurl` != ? OR `url` != ?)", '', ''];
51                 $outdated = DBA::count('gserver', $condition);
52                 Logger::info('Server status', ['total' => $total, 'outdated' => $outdated, 'updating' => $limit]);
53
54                 $gservers = DBA::select('gserver', ['url', 'nurl'], $condition, ['limit' => $limit]);
55                 if (!DBA::isResult($gservers)) {
56                         return;
57                 }
58
59                 $count = 0;
60                 while ($gserver = DBA::fetch($gservers)) {
61                         // Sometimes the "nurl" and "url" doesn't seem to fit, see https://forum.friendi.ca/display/ec054ce7-155f-c94d-6159-f50372664245
62                         // There are duplicated "url" but not "nurl". So we check both addresses instead of just overwriting them,
63                         // since that would mean loosing data.
64                         if (!empty($gserver['url'])) {
65                                 if (Worker::add(PRIORITY_LOW, 'UpdateGServer', $gserver['url'])) {
66                                         $count++;
67                                 }
68                         }
69                         if (!empty($gserver['nurl']) && ($gserver['nurl'] != Strings::normaliseLink($gserver['url']))) {
70                                 if (Worker::add(PRIORITY_LOW, 'UpdateGServer', $gserver['nurl'])) {
71                                         $count++;
72                                 }
73                         }
74                 }
75                 DBA::close($gservers);
76                 Logger::info('Updated servers', ['count' => $count]);
77         }
78 }