cron_job_remove_soap_response_files.inc

<?php
require_once SQ_CORE_PACKAGE_PATH.'/system/cron/cron_job/cron_job.inc';
require_once SQ_FUDGE_PATH.'/general/datetime.inc';
require_once SQ_FUDGE_PATH.'/general/file_system.inc';

class Cron_Job_Remove_SOAP_Response_Files extends Cron_Job
{


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

    }//end constructor


    public function create(Array &$link)
    {
        require_once SQ_CORE_PACKAGE_PATH.'/system/system_asset_fns.inc';
        if (!system_asset_fns_create_pre_check($this)) {
            return FALSE;
        }
        $GLOBALS['SQ_SYSTEM']->changeDatabaseConnection('db2');
        $GLOBALS['SQ_SYSTEM']->doTransaction('BEGIN');

        if ($linkid = parent::create($link)) {
            if (!system_asset_fns_create_cleanup($this)) {
                $linkid = FALSE;
            }
        }

        if ($linkid) {
            $GLOBALS['SQ_SYSTEM']->doTransaction('COMMIT');
        } else {
            $GLOBALS['SQ_SYSTEM']->doTransaction('ROLLBACK');
        }

        $GLOBALS['SQ_SYSTEM']->restoreDatabaseConnection();
        return $linkid;

    }//end create()


    protected function _getName($short_name=FALSE)
    {
        return 'Remove SOAP Response Files Cron Job';

    }//end _getName()


    public function canClone()
    {
        return FALSE;

    }//end canClone()


    public function canDelete()
    {
        return FALSE;

    }//end canDelete()
    
    
    protected function _exec(&$msg)
    {
        $dir_to_check = SQ_DATA_PATH.'/private/soap_action_file_responses/';
        // no dir found...nothing to do
        if (!is_dir($dir_to_check)) return SQ_CRON_JOB_COMPLETED;

        $session_dirs = list_dirs($dir_to_check, TRUE);
        // no sessions dirs found safely bail out
        // as we got nothing to delete here
        if (empty($session_dirs)) return SQ_CRON_JOB_COMPLETED;

        if (!self::remove_temp_files($session_dirs)) return SQ_CRON_JOB_ERROR;

        return SQ_CRON_JOB_COMPLETED;

    }//end _exec()


    public function run()
    {
        $res = parent::run();
        if ($res & SQ_CRON_JOB_REMOVE) {
            $res = $res - SQ_CRON_JOB_REMOVE;
        }
        return $res;

    }//end run()


    public static function remove_temp_files($dirs=Array())
    {
        $success = TRUE;
        foreach ($dirs as $dir) {
            // delete all(1) files under this dir
            if (!clear_directory($dir)) {
                $success = FALSE;
            } else {
                // if the file deletion was super awesome
                // go ahead and remove the dir itself too
                if (!delete_directory($dir)) $success = FALSE;
            }
        }// end foreach

        return $success;

    }// end remove_temp_files()


}//end class



?>