X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=src%2FWorker%2FExpire.php;h=21e873502ba1add6c95a555eab7b3e96b4699d16;hb=7458d793ed6c5eaa9220bf14e05fa8cb76c122f1;hp=de2133bdc804f4bff06017e57a2357980702cca0;hpb=9c9ebfc7c97016881d9ad2bb3c3b54a5640d2f08;p=friendica.git diff --git a/src/Worker/Expire.php b/src/Worker/Expire.php index de2133bdc8..21e873502b 100644 --- a/src/Worker/Expire.php +++ b/src/Worker/Expire.php @@ -9,6 +9,7 @@ namespace Friendica\Worker; use Friendica\BaseObject; use Friendica\Core\Config; use Friendica\Core\Hook; +use Friendica\Core\Logger; use Friendica\Core\Worker; use Friendica\Database\DBA; use Friendica\Model\Item; @@ -26,7 +27,7 @@ class Expire Hook::loadHooks(); if ($param == 'delete') { - logger('Delete expired items', LOGGER_DEBUG); + Logger::log('Delete expired items', Logger::DEBUG); // physically remove anything that has been deleted for more than two months $condition = ["`deleted` AND `changed` < UTC_TIMESTAMP() - INTERVAL 60 DAY"]; $rows = DBA::select('item', ['id'], $condition); @@ -37,62 +38,62 @@ class Expire // Normally we shouldn't have orphaned data at all. // If we do have some, then we have to check why. - logger('Deleting orphaned item activities - start', LOGGER_DEBUG); + Logger::log('Deleting orphaned item activities - start', Logger::DEBUG); $condition = ["NOT EXISTS (SELECT `iaid` FROM `item` WHERE `item`.`iaid` = `item-activity`.`id`)"]; DBA::delete('item-activity', $condition); - logger('Orphaned item activities deleted: ' . DBA::affectedRows(), LOGGER_DEBUG); + Logger::log('Orphaned item activities deleted: ' . DBA::affectedRows(), Logger::DEBUG); - logger('Deleting orphaned item content - start', LOGGER_DEBUG); + Logger::log('Deleting orphaned item content - start', Logger::DEBUG); $condition = ["NOT EXISTS (SELECT `icid` FROM `item` WHERE `item`.`icid` = `item-content`.`id`)"]; DBA::delete('item-content', $condition); - logger('Orphaned item content deleted: ' . DBA::affectedRows(), LOGGER_DEBUG); + Logger::log('Orphaned item content deleted: ' . DBA::affectedRows(), Logger::DEBUG); // make this optional as it could have a performance impact on large sites if (intval(Config::get('system', 'optimize_items'))) { DBA::e("OPTIMIZE TABLE `item`"); } - logger('Delete expired items - done', LOGGER_DEBUG); + Logger::log('Delete expired items - done', Logger::DEBUG); return; } elseif (intval($param) > 0) { $user = DBA::selectFirst('user', ['uid', 'username', 'expire'], ['uid' => $param]); if (DBA::isResult($user)) { - logger('Expire items for user '.$user['uid'].' ('.$user['username'].') - interval: '.$user['expire'], LOGGER_DEBUG); + Logger::log('Expire items for user '.$user['uid'].' ('.$user['username'].') - interval: '.$user['expire'], Logger::DEBUG); Item::expire($user['uid'], $user['expire']); - logger('Expire items for user '.$user['uid'].' ('.$user['username'].') - done ', LOGGER_DEBUG); + Logger::log('Expire items for user '.$user['uid'].' ('.$user['username'].') - done ', Logger::DEBUG); } return; } elseif ($param == 'hook' && !empty($hook_function)) { foreach (Hook::getByName('expire') as $hook) { if ($hook[1] == $hook_function) { - logger("Calling expire hook '" . $hook[1] . "'", LOGGER_DEBUG); + Logger::log("Calling expire hook '" . $hook[1] . "'", Logger::DEBUG); Hook::callSingle($a, 'expire', $hook, $data); } } return; } - logger('expire: start'); + Logger::log('expire: start'); Worker::add(['priority' => $a->queue['priority'], 'created' => $a->queue['created'], 'dont_fork' => true], 'Expire', 'delete'); $r = DBA::p("SELECT `uid`, `username` FROM `user` WHERE `expire` != 0"); while ($row = DBA::fetch($r)) { - logger('Calling expiry for user '.$row['uid'].' ('.$row['username'].')', LOGGER_DEBUG); + Logger::log('Calling expiry for user '.$row['uid'].' ('.$row['username'].')', Logger::DEBUG); Worker::add(['priority' => $a->queue['priority'], 'created' => $a->queue['created'], 'dont_fork' => true], 'Expire', (int)$row['uid']); } DBA::close($r); - logger('expire: calling hooks'); + Logger::log('expire: calling hooks'); foreach (Hook::getByName('expire') as $hook) { - logger("Calling expire hook for '" . $hook[1] . "'", LOGGER_DEBUG); + Logger::log("Calling expire hook for '" . $hook[1] . "'", Logger::DEBUG); Worker::add(['priority' => $a->queue['priority'], 'created' => $a->queue['created'], 'dont_fork' => true], 'Expire', 'hook', $hook[1]); } - logger('expire: end'); + Logger::log('expire: end'); return; }