cron_job_refresh_cache.inc

<?php
require_once SQ_CORE_PACKAGE_PATH.'/system/cron/cron_job/cron_job.inc';

class Cron_Job_Refresh_Cache extends Cron_Job
{


    function __construct($assetid=0)
    {
        parent::__construct($assetid);

    }//end constructor


    protected function _getName($short_name=FALSE)
    {
        $id = $this->attr('asset');
        if ($GLOBALS['SQ_SYSTEM']->am->assetExists($id)) {
            $asset = $GLOBALS['SQ_SYSTEM']->am->getAsset($id);
            $name = $asset->name;
        }
        return "Refresh Cache \"$name\" [#$asset->id]";

    }//end _getName()


    protected function _exec(&$msg)
    {
        // Caching Off? Do nothing
        $cm = $GLOBALS['SQ_SYSTEM']->am->getSystemAsset('cache_manager');
        if (!$cm->attr('enabled')) {
            return SQ_CRON_JOB_COMPLETED;
        }
        $am = $GLOBALS['SQ_SYSTEM']->am;

        // Start
        $this->setAttrValue('running', TRUE);
        $this->saveAttributes();

        // Clear the existing cache
        $assetid = $this->attr('asset');
        $cm->clearCache(Array($assetid));
        $asset = $am->getAsset($assetid);
        $urls_info = $asset->getURLs();
        if (empty($urls_info)) {
            return SQ_CRON_JOB_COMPLETED;
        } else {
            foreach ($urls_info as $url_info) {
                if ($url_info['http'] == '1') {
                    $urls[] = 'http://'.$url_info['url'];
                }
                if ($url_info['https'] == '1') {
                    $urls[] = 'https://'.$url_info['url'];
                }
            }
        }

        // Request each URL as public user
        $public_user  = $GLOBALS['SQ_SYSTEM']->am->getSystemAsset('public_user');
        $GLOBALS['SQ_SYSTEM']->setCurrentUser($public_user);

        // Re-generate the cache per URL
        foreach ($urls as $url) {
            $url_info = parse_url($url);

            // Let's pretend this is web accessed
            $_SERVER['HTTP_HOST'] = $url_info['host'];
            $_SERVER['PHP_SELF'] = $url_info['path'];
            $_SERVER['HTTP'] = ($url_info['scheme'] == 'http') ? 'on' : 'off';
            $_SERVER['HTTPS'] = ($url_info['scheme'] == 'https') ? 'on' : 'off';

            // Re-generate cache
            ob_start();
            $asset->printBody();
            ob_end_clean();
        }
        $GLOBALS['SQ_SYSTEM']->restoreCurrentUser();

        return SQ_CRON_JOB_COMPLETED;

    }//end _exec()


    public function run()
    {
        $res = parent::run();
        if ($res & SQ_CRON_JOB_COMPLETED) {
            if ($GLOBALS['SQ_SYSTEM']->am->acquireLock($this->id, 'all')) {
                $this->setAttrValue('running', FALSE);
                $this->saveAttributes();
                $GLOBALS['SQ_SYSTEM']->am->releaseLock($this->id, 'all');
            }
        }

        return $res;

    }//end run()


}//end class


?>