whmcsProxmoxAddon/core/Queue/Manager.php

<?php

namespace ModulesGarden\ProxmoxAddon\Core\Queue;

use ModulesGarden\ProxmoxAddon\Core\DependencyInjection\DependencyInjection;
use ModulesGarden\ProxmoxAddon\Core\Queue\Services\Log;

class Manager {
    /**
     * @var Models\Job
     */
    protected $job;

    /**
     * @var Log
     */
    protected $log;

    /**
     * Manager constructor.
     * @param Models\Job $job
     */
    public function __construct(\ModulesGarden\ProxmoxAddon\Core\Queue\Models\Job $job) {
        $this->job  = $job;
        $this->log  = new Log($this->job);
    }

    /**
     *  snapshot name 'Snapshot_320_08_30_02' already used
     */
    public function fire(){
        try  {
            $this->job->setRunning();

            $ret    = $this->resolveAndFire($this->job->job, $this->job->data);
            if($ret !== false) {
                $this->job->setFinished();
            }
        } catch(\Exception $ex) {
    	    $message = $ex->getMessage();
    	    if (strpos($message,"snapshot") !== false && strpos($message,"already") !== false && strpos($message,"used") !== false) {
    		$this->job->setFinished();
    	    
    		//add log message
        	$this->log->error($ex->getMessage(), debug_backtrace(DEBUG_BACKTRACE_IGNORE_ARGS));
    	    } else {
        	//Set error in job
                $this->job->setError();
	        $this->job->setRetryAfter(date('Y-m-d H:i:s', strtotime('+ 60 seconds')));
    	        $this->job->increaseRetryCount();

        	//add log message
        	$this->log->error($ex->getMessage(), debug_backtrace(DEBUG_BACKTRACE_IGNORE_ARGS));
    	    }
        
        }
    }

    /**
     * @param $job
     * @param $data
     * @return mixed
     */
    protected function resolveAndFire($job, $data)  {
        list($class, $method)   = $this->parseJob($job);
        $instance               = $this->resolve($class);

        return call_user_func_array([$instance, $method], unserialize($data));
    }

    /**
     * @param $class
     * @return mixed
     */
    protected function resolve($class) {
        return new $class($this->job, $this->log);
    }

    /**
     * Parse the job declaration into class and method.
     *
     * @param  string  $job
     * @return array
     */
    protected function parseJob($job)  {
        $segments = explode('@', $job);
        return count($segments) > 1 ? $segments : array($segments[0], 'fire');
    }
}