112 lines
2.4 KiB
PHP
112 lines
2.4 KiB
PHP
<?php chdir(__DIR__) ?>
|
|
<?php require 'base.php' ?>
|
|
<?php
|
|
|
|
if (file_exists('.cron.lock'))
|
|
die('cron.php is locked by ".cron.lock"');
|
|
touch('.cron.lock');
|
|
|
|
function logi($thing) { echo date('Y/m/d H:i:s').' INFO | '.strval($thing)."\n"; }
|
|
function loge($thing) { echo date('Y/m/d H:i:s').' ERROR | '.strval($thing)."\n"; }
|
|
|
|
function end_cronjobs() {
|
|
unlink('.cron.lock');
|
|
die;
|
|
}
|
|
|
|
|
|
////////////////
|
|
// INITIAL SETUP
|
|
//
|
|
$GLOBALS['_crondir'] = $GLOBALS['appconf']['data_dir'].'/cron';
|
|
if (!file_exists($GLOBALS['_crondir'])) {
|
|
mkdir($GLOBALS['_crondir']);
|
|
end_cronjobs();
|
|
}
|
|
$time_start = time();
|
|
//
|
|
////////////////
|
|
|
|
|
|
////////////////////////////////
|
|
// CRONJOBS for database caching
|
|
//
|
|
function run__cronjobs_db() {
|
|
$dir = $GLOBALS['_crondir'].'/db';
|
|
if (!file_exists($dir)) {
|
|
mkdir($dir);
|
|
return false;
|
|
}
|
|
$jobs = [];
|
|
foreach (scandir($dir) as $jf) {
|
|
if (in_array($jf,['.','..']))
|
|
continue;
|
|
$ps = explode(',',$jf);
|
|
$jobs []= (object)[
|
|
'id' => $ps[2],
|
|
'file' => $dir.'/'.$jf,
|
|
'software' => $ps[0],
|
|
'instance' => $ps[1],
|
|
'time' => intval($ps[3]),
|
|
];
|
|
}
|
|
foreach ($jobs as $job) {
|
|
$ms = time() - filemtime($job->file);
|
|
$sql = file_get_contents($job->file);
|
|
if ($ms < $job->time) continue;
|
|
|
|
logi("Processing job: {$job->id}, software={$job->software}, instance={$job->instance}");
|
|
$ok = false;
|
|
switch ($job->software) {
|
|
case 'mastodon':
|
|
$pg = new PgDatabase($job->software, $job->instance);
|
|
if ($pg->is_ok()) {
|
|
$result = $pg->fetch_all($sql);
|
|
content_cache__put($job->software.$job->instance.$sql, 'always,'.$job->time, $result);
|
|
$pg->close();
|
|
$ok = true;
|
|
}
|
|
break;
|
|
}
|
|
if ($ok) {
|
|
logi("Job done: {$job->id}");
|
|
touch($job->file);
|
|
}
|
|
}
|
|
}
|
|
run__cronjobs_db();
|
|
//
|
|
////////////////////////////////
|
|
|
|
|
|
///////////////////////////////
|
|
// CRONJOBS for caching cleanup
|
|
//
|
|
function run__cronjobs_cache_cleanup() {
|
|
$cache_dir = $GLOBALS['appconf']['data_dir'].'/cache';
|
|
if (!file_exists($cache_dir))
|
|
return;
|
|
foreach (scandir($cache_dir) as $fl) {
|
|
if (in_array($fl, ['.','..']))
|
|
continue;
|
|
$ps = explode(',',$fl);
|
|
if ($ps[1] !== 'ondemand')
|
|
continue;
|
|
$time = intval($ps[2]);
|
|
$mtime = filemtime($cache_dir.'/'.$fl);
|
|
if (time() - $mtime >= $time) {
|
|
logi('CACHE-CLEANUP remove old file: '.$fl);
|
|
unlink($cache_dir.'/'.$fl);
|
|
}
|
|
}
|
|
}
|
|
run__cronjobs_cache_cleanup();
|
|
//
|
|
///////////////////////////////
|
|
|
|
|
|
$ms_total = time() - $time_start;
|
|
logi("Cron has finished in {$ms_total} seconds");
|
|
|
|
end_cronjobs();
|