src/Worker/UpdateBlockedServers.php

   1 <?php
   2 /**
   3  * @copyright Copyright (C) 2010-2023, 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\Database\DBA;
  26 use Friendica\DI;
  27 use Friendica\Model\GServer;
  28 use Friendica\Util\Network;
  29
  30 class UpdateBlockedServers
  31 {
  32         /**
  33          * Updates the server blocked status
  34          */
  35         public static function execute()
  36         {
  37                 Logger::info('Update blocked servers - start');
  38                 $gservers = DBA::select('gserver', ['id', 'url', 'blocked']);
  39                 $changed  = 0;
  40                 $unchanged = 0;
  41                 while ($gserver = DBA::fetch($gservers)) {
  42                         $blocked = Network::isUrlBlocked($gserver['url']);
  43                         if (!is_null($gserver['blocked']) && ($blocked == $gserver['blocked'])) {
  44                                 $unchanged++;
  45                                 continue;
  46                         }
  47
  48                         if ($blocked) {
  49                                 GServer::setBlockedById($gserver['id']);
  50                         } else {
  51                                 GServer::setUnblockedById($gserver['id']);
  52                         }
  53                         $changed++;
  54                 }
  55                 DBA::close($gservers);
  56                 Logger::info('Update blocked servers - done', ['changed' => $changed, 'unchanged' => $unchanged]);
  57
  58                 if (DI::config()->get('system', 'delete-blocked-servers')) {
  59                         Logger::info('Delete blocked servers - start');
  60                         $ret = DBA::delete('gserver', ["`blocked` AND NOT EXISTS(SELECT `gsid` FROM `inbox-status` WHERE `gsid` = `gserver`.`id`) AND NOT EXISTS(SELECT `gsid` FROM `contact` WHERE gsid= `gserver`.`id`) AND NOT EXISTS(SELECT `gsid` FROM `apcontact` WHERE `gsid` = `gserver`.`id`) AND NOT EXISTS(SELECT `gsid` FROM `delivery-queue` WHERE `gsid` = `gserver`.`id`) AND NOT EXISTS(SELECT `gsid` FROM `diaspora-contact` WHERE `gsid` = `gserver`.`id`) AND NOT EXISTS(SELECT `gserver-id` FROM `gserver-tag` WHERE `gserver-id` = `gserver`.`id`)"]);
  61                         Logger::info('Delete blocked servers - done', ['ret' => $ret, 'rows' => DBA::affectedRows()]);
  62                 }
  63         }
  64 }