X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;ds=sidebyside;f=src%2FWorker%2FCron.php;h=edd3e22ef41361d5295c3856ed8a9bc01c4073c7;hb=eaf81e5e66db1f722192005ff75bb5831c1912eb;hp=e523f75118af8ad0c415f2db2374a33f6ccf3799;hpb=29f7ebe307c22b275466390937b82ccb3820fb1c;p=friendica.git diff --git a/src/Worker/Cron.php b/src/Worker/Cron.php index e523f75118..edd3e22ef4 100644 --- a/src/Worker/Cron.php +++ b/src/Worker/Cron.php @@ -4,18 +4,21 @@ */ namespace Friendica\Worker; +use Friendica\BaseObject; use Friendica\Core\Addon; use Friendica\Core\Config; use Friendica\Core\Worker; -use Friendica\Database\DBM; +use Friendica\Database\DBA; +use Friendica\Model\Contact; use Friendica\Util\DateTimeFormat; -use dba; require_once 'include/dba.php'; -Class Cron { - public static function execute($parameter = '', $generation = 0) { - global $a; +class Cron +{ + public static function execute($parameter = '', $generation = 0) + { + $a = BaseObject::getApp(); // Poll contacts with specific parameters if (!empty($parameter)) { @@ -58,9 +61,6 @@ Class Cron { // Call possible post update functions Worker::add(PRIORITY_LOW, "CronJobs", "post_update"); - // update nodeinfo data - Worker::add(PRIORITY_LOW, "CronJobs", "nodeinfo"); - // Clear cache entries Worker::add(PRIORITY_LOW, "CronJobs", "clear_cache"); @@ -74,27 +74,49 @@ Class Cron { $d1 = Config::get('system', 'last_expire_day'); $d2 = intval(DateTimeFormat::utcNow('d')); + // Daily cron calls if ($d2 != intval($d1)) { Worker::add(PRIORITY_LOW, "CronJobs", "update_contact_birthdays"); + Worker::add(PRIORITY_LOW, "CronJobs", "update_photo_albums"); + + // update nodeinfo data + Worker::add(PRIORITY_LOW, "CronJobs", "nodeinfo"); + Worker::add(PRIORITY_LOW, "DiscoverPoCo", "update_server"); Worker::add(PRIORITY_LOW, "DiscoverPoCo", "suggestions"); - Config::set('system', 'last_expire_day', $d2); - Worker::add(PRIORITY_LOW, 'Expire'); Worker::add(PRIORITY_MEDIUM, 'DBClean'); - Worker::add(PRIORITY_LOW, "CronJobs", "update_photo_albums"); + // check upstream version? + Worker::add(PRIORITY_LOW, 'CheckVersion'); + + Config::set('system', 'last_expire_day', $d2); + } + + // Hourly cron calls + if (Config::get('system', 'last_cron_hourly', 0) + 3600 < time()) { // Delete all done workerqueue entries - dba::delete('workerqueue', ['`done` AND `executed` < UTC_TIMESTAMP() - INTERVAL 12 HOUR']); + DBA::delete('workerqueue', ['`done` AND `executed` < UTC_TIMESTAMP() - INTERVAL 1 HOUR']); - // check upstream version? - Worker::add(PRIORITY_LOW, 'CheckVersion'); + // Optimizing this table only last seconds + if (Config::get('system', 'optimize_workerqueue', false)) { + DBA::e("OPTIMIZE TABLE `workerqueue`"); + } + + Config::set('system', 'last_cron_hourly', time()); + } + + // Ensure to have a .htaccess file. + // this is a precaution for systems that update automatically + $basepath = $a->get_basepath(); + if (!file_exists($basepath . '/.htaccess')) { + copy($basepath . '/.htaccess-dist', $basepath . '/.htaccess'); } // Poll contacts @@ -166,14 +188,14 @@ Class Cron { AND `contact`.`network` IN ('%s', '%s', '%s', '%s', '%s') $sql_extra AND NOT `contact`.`self` AND NOT `contact`.`blocked` WHERE NOT `user`.`account_expired` AND NOT `user`.`account_removed` $abandon_sql", - dbesc(NETWORK_DFRN), - dbesc(NETWORK_OSTATUS), - dbesc(NETWORK_DIASPORA), - dbesc(NETWORK_FEED), - dbesc(NETWORK_MAIL) + DBA::escape(NETWORK_DFRN), + DBA::escape(NETWORK_OSTATUS), + DBA::escape(NETWORK_DIASPORA), + DBA::escape(NETWORK_FEED), + DBA::escape(NETWORK_MAIL) ); - if (!DBM::is_result($contacts)) { + if (!DBA::isResult($contacts)) { return; } @@ -200,7 +222,7 @@ Class Cron { } // Check Diaspora contacts or followers once a week - if (($contact["network"] == NETWORK_DIASPORA) || ($contact["rel"] == CONTACT_IS_FOLLOWER)) { + if (($contact["network"] == NETWORK_DIASPORA) || ($contact["rel"] == Contact::FOLLOWER)) { $contact['priority'] = 4; }