Arsse/lib/Service.php

<?php
declare(strict_types=1);
namespace JKingWeb\Arsse;
use JKingWeb\Arsse\Misc\Date;

class Service {
    
    /** @var Service\Driver */
    protected $drv;
    /** @var \DateInterval */
    protected $interval;
    
    protected static function interval(): \DateInterval {
        return new \DateInterval(Arsse::$conf->serviceFrequency); // FIXME: this needs to fall back in case of incorrect input
    }

    function __construct() {
        $driver = Arsse::$conf->serviceDriver;
        $this->drv = new $driver();
        $this->interval = static::interval();
    }

    function watch(bool $loop = true) {
        $t = new \DateTime();
        do {
            $this->checkIn();
            static::cleanupPre();
            $list = Arsse::$db->feedListStale();
            if($list) {
                echo date("H:i:s")." Updating feeds ".json_encode($list)."\n";
                $this->drv->queue(...$list);
                $this->drv->exec();
                $this->drv->clean();
                static::cleanupPost();
            }
            $t->add($this->interval);
            do {
                @time_sleep_until($t->getTimestamp());
            } while($t->getTimestamp() > time());
        } while($loop);
    }

    function checkIn(): bool {
        return Arsse::$db->metaSet("service_last_checkin", time(), "datetime");
    }

    static function hasCheckedIn(): bool {
        $checkin = Arsse::$db->metaGet("service_last_checkin");
        // if the service has never checked in, return false
        if(!$checkin) return false;
        // convert the check-in timestamp to a DateTime instance
        $checkin = Date::normalize($checkin, "sql");
        // get the checking interval
        $int = static::interval();
        // subtract twice the checking interval from the current time to the earliest acceptable check-in time
        $limit = new \DateTime();
        $limit->sub($int);
        $limit->sub($int);
        // return whether the check-in time is less than the acceptable limit
        return ($checkin < $limit);
    }

    static function cleanupPre(): bool {
        // TODO: stub
        return true;
    }

    static function cleanupPost():bool {
        // TODO: stub
        return true;
    }
}