mirror of
https://codeberg.org/streams/streams.git
synced 2024-09-22 04:35:24 +00:00
205 lines
6.8 KiB
PHP
205 lines
6.8 KiB
PHP
<?php
|
|
|
|
/** @file */
|
|
|
|
namespace Zotlabs\Daemon;
|
|
|
|
use Zotlabs\Lib\ServiceClass;
|
|
|
|
class Poller
|
|
{
|
|
|
|
public static function run($argc, $argv)
|
|
{
|
|
|
|
$maxsysload = intval(get_config('system', 'maxloadavg'));
|
|
if ($maxsysload < 1) {
|
|
$maxsysload = 50;
|
|
}
|
|
if (function_exists('sys_getloadavg')) {
|
|
$load = sys_getloadavg();
|
|
if (intval($load[0]) > $maxsysload) {
|
|
logger('system: load ' . $load . ' too high. Poller deferred to next scheduled run.');
|
|
return;
|
|
}
|
|
}
|
|
|
|
$interval = intval(get_config('system', 'poll_interval'));
|
|
if (! $interval) {
|
|
$interval = ((get_config('system', 'delivery_interval') === false) ? 3 : intval(get_config('system', 'delivery_interval')));
|
|
}
|
|
|
|
// Check for a lockfile. If it exists, but is over an hour old, it's stale. Ignore it.
|
|
$lockfile = 'cache/poller';
|
|
if (
|
|
(file_exists($lockfile)) && (filemtime($lockfile) > (time() - 3600))
|
|
&& (! get_config('system', 'override_poll_lockfile'))
|
|
) {
|
|
logger("poller: Already running");
|
|
return;
|
|
}
|
|
|
|
// Create a lockfile.
|
|
file_put_contents($lockfile, EMPTY_STR);
|
|
|
|
logger('poller: start');
|
|
|
|
$manual_id = 0;
|
|
$generation = 0;
|
|
|
|
$force = false;
|
|
$restart = false;
|
|
|
|
if (($argc > 1) && ($argv[1] == 'force')) {
|
|
$force = true;
|
|
}
|
|
|
|
if (($argc > 1) && ($argv[1] == 'restart')) {
|
|
$restart = true;
|
|
$generation = intval($argv[2]);
|
|
if (! $generation) {
|
|
return;
|
|
}
|
|
}
|
|
|
|
if (($argc > 1) && intval($argv[1])) {
|
|
$manual_id = intval($argv[1]);
|
|
$force = true;
|
|
}
|
|
|
|
|
|
$sql_extra = (($manual_id) ? " AND abook_id = " . intval($manual_id) . " " : "");
|
|
|
|
reload_plugins();
|
|
|
|
$d = datetime_convert();
|
|
|
|
// Only poll from those with suitable relationships
|
|
|
|
// $abandon_sql = (($abandon_days)
|
|
// ? sprintf(" AND account_lastlog > %s - INTERVAL %s ", db_utcnow(), db_quoteinterval(intval($abandon_days).' DAY'))
|
|
// : ''
|
|
// );
|
|
|
|
$abandon_sql = EMPTY_STR;
|
|
|
|
$randfunc = db_getfunc('RAND');
|
|
|
|
$contacts = q(
|
|
"SELECT abook.abook_updated, abook.abook_connected, abook.abook_feed,
|
|
abook.abook_channel, abook.abook_id, abook.abook_archived, abook.abook_pending,
|
|
abook.abook_ignored, abook.abook_blocked,
|
|
xchan.xchan_network,
|
|
account.account_lastlog, account.account_flags
|
|
FROM abook LEFT JOIN xchan on abook_xchan = xchan_hash
|
|
LEFT JOIN account on abook_account = account_id
|
|
where abook_self = 0
|
|
$sql_extra
|
|
AND (( account_flags = %d ) OR ( account_flags = %d )) $abandon_sql ORDER BY $randfunc",
|
|
intval(ACCOUNT_OK),
|
|
intval(ACCOUNT_UNVERIFIED) // FIXME
|
|
);
|
|
|
|
if ($contacts) {
|
|
foreach ($contacts as $contact) {
|
|
$update = false;
|
|
|
|
$t = $contact['abook_updated'];
|
|
$c = $contact['abook_connected'];
|
|
|
|
if (intval($contact['abook_feed'])) {
|
|
$min = ServiceClass::fetch($contact['abook_channel'], 'minimum_feedcheck_minutes');
|
|
if (! $min) {
|
|
$min = intval(get_config('system', 'minimum_feedcheck_minutes'));
|
|
}
|
|
if (! $min) {
|
|
$min = 60;
|
|
}
|
|
$x = datetime_convert('UTC', 'UTC', "now - $min minutes");
|
|
if ($c < $x) {
|
|
Run::Summon([ 'Onepoll', $contact['abook_id'] ]);
|
|
if ($interval) {
|
|
@time_sleep_until(microtime(true) + (float) $interval);
|
|
}
|
|
}
|
|
continue;
|
|
}
|
|
|
|
if (! in_array($contact['xchan_network'],['nomad','zot6'])) {
|
|
continue;
|
|
}
|
|
|
|
if ($c == $t) {
|
|
if (datetime_convert('UTC', 'UTC', 'now') > datetime_convert('UTC', 'UTC', $t . " + 1 day")) {
|
|
$update = true;
|
|
}
|
|
} else {
|
|
// if we've never connected with them, start the mark for death countdown from now
|
|
|
|
if ($c <= NULL_DATE) {
|
|
$r = q(
|
|
"update abook set abook_connected = '%s' where abook_id = %d",
|
|
dbesc(datetime_convert()),
|
|
intval($contact['abook_id'])
|
|
);
|
|
$c = datetime_convert();
|
|
$update = true;
|
|
}
|
|
|
|
// He's dead, Jim
|
|
|
|
if (strcmp(datetime_convert('UTC', 'UTC', 'now'), datetime_convert('UTC', 'UTC', $c . " + 30 day")) > 0) {
|
|
$r = q(
|
|
"update abook set abook_archived = 1 where abook_id = %d",
|
|
intval($contact['abook_id'])
|
|
);
|
|
$update = false;
|
|
continue;
|
|
}
|
|
|
|
if (intval($contact['abook_archived'])) {
|
|
$update = false;
|
|
continue;
|
|
}
|
|
|
|
// might be dead, so maybe don't poll quite so often
|
|
|
|
// recently deceased, so keep up the regular schedule for 3 days
|
|
|
|
if (
|
|
(strcmp(datetime_convert('UTC', 'UTC', 'now'), datetime_convert('UTC', 'UTC', $c . " + 3 day")) > 0)
|
|
&& (strcmp(datetime_convert('UTC', 'UTC', 'now'), datetime_convert('UTC', 'UTC', $t . " + 1 day")) > 0)
|
|
) {
|
|
$update = true;
|
|
}
|
|
|
|
// After that back off and put them on a morphine drip
|
|
|
|
if (strcmp(datetime_convert('UTC', 'UTC', 'now'), datetime_convert('UTC', 'UTC', $t . " + 2 day")) > 0) {
|
|
$update = true;
|
|
}
|
|
}
|
|
|
|
if (intval($contact['abook_pending']) || intval($contact['abook_archived']) || intval($contact['abook_ignored']) || intval($contact['abook_blocked'])) {
|
|
continue;
|
|
}
|
|
|
|
if ((! $update) && (! $force)) {
|
|
continue;
|
|
}
|
|
|
|
Run::Summon([ 'Onepoll',$contact['abook_id'] ]);
|
|
if ($interval) {
|
|
@time_sleep_until(microtime(true) + (float) $interval);
|
|
}
|
|
}
|
|
}
|
|
|
|
set_config('system', 'lastpoll', datetime_convert());
|
|
|
|
//All done - clear the lockfile
|
|
@unlink($lockfile);
|
|
|
|
return;
|
|
}
|
|
}
|