#!/usr/bin/env php
<?php
require_once(getenv('COLLECTIVEACCESS_HOME') . '/setup.php');
$sleep = getenv('WORKER_JOB_SLEEP_TIME') ?: 1;
$sleep = $sleep * 1000000;
$queue = new TaskQueue();

// We are starting the queue, so no current process should exist
$o_appvars = new ApplicationVars();
$o_appvars->setVar("taskqueue_processes", []);
$o_appvars->save();

$queue->resetUnfinishedTasks();

while (true) {
    $queue->processQueue();        // Process queued tasks
    $queue->runPeriodicTasks();    // Process recurring tasks implemented in plugins
    usleep($sleep);
}

