<?php

namespace Jobby;

use Closure;
use DateTimeImmutable;
use Opis\Closure\SerializableClosure;
use Symfony\Component\Process\PhpExecutableFinder;

class Jobby
{
    /** @var array */
    protected $config = [];

    /** @var string */
    protected $script;

    /** @var array */
    protected $jobs = [];

    /** @var Helper */
    protected $helper;

    /**
     * @param array $config
     */
    public function __construct(array $config = [])
    {
        $this->setConfig($this->getDefaultConfig());
        $this->setConfig($config);

        $this->script = realpath(__DIR__ . '/../bin/run-job');
    }

    /**
     * @return Helper
     */
    protected function getHelper()
    {
        if ($this->helper === null) {
            $this->helper = new Helper();
        }

        return $this->helper;
    }

    /**
     * @return array
     */
    public function getDefaultConfig()
    {
        return [
            'jobClass'       => 'Jobby\BackgroundJob',
            'recipients'     => null,
            'mailer'         => 'sendmail',
            'maxRuntime'     => null,
            'smtpHost'       => null,
            'smtpPort'       => 25,
            'smtpUsername'   => null,
            'smtpPassword'   => null,
            'smtpSender'     => 'jobby@' . $this->getHelper()->getHost(),
            'smtpSenderName' => 'jobby',
            'smtpSecurity'   => null,
            'runAs'          => null,
            'environment'    => $this->getHelper()->getApplicationEnv(),
            'runOnHost'      => $this->getHelper()->getHost(),
            'output'         => null,
            'output_stdout'  => null,
            'output_stderr'  => null,
            'dateFormat'     => 'Y-m-d H:i:s',
            'enabled'        => true,
            'haltDir'        => null,
            'debug'          => false,
        ];
    }

    /**
     * @param array
     */
    public function setConfig(array $config)
    {
        $this->config = array_merge($this->config, $config);
    }

    /**
     * @return array
     */
    public function getConfig()
    {
        return $this->config;
    }

    /**
     * @return array
     */
    public function getJobs()
    {
        return $this->jobs;
    }

    /**
     * Add a job.
     *
     * @param string $job
     * @param array  $config
     *
     * @throws Exception
     */
    public function add($job, array $config)
    {
        if (empty($config['schedule'])) {
            throw new Exception("'schedule' is required for '$job' job");
        }

        if (!(isset($config['command']) xor isset($config['closure']))) {
            throw new Exception("Either 'command' or 'closure' is required for '$job' job");
        }

        if (isset($config['command']) &&
            (
                $config['command'] instanceof Closure ||
                $config['command'] instanceof SerializableClosure
            )
        ) {
            $config['closure'] = $config['command'];
            unset($config['command']);

            if ($config['closure'] instanceof SerializableClosure) {
                $config['closure'] = $config['closure']->getClosure();
            }
        }

        $config = array_merge($this->config, $config);
        $this->jobs[] = [$job, $config];
    }

    /**
     * Run all jobs.
     */
    public function run()
    {
        $isUnix = ($this->helper->getPlatform() === Helper::UNIX);

        if ($isUnix && !extension_loaded('posix')) {
            throw new Exception('posix extension is required');
        }

        $scheduleChecker = new ScheduleChecker(new DateTimeImmutable("now"));
        foreach ($this->jobs as $jobConfig) {
            list($job, $config) = $jobConfig;
            if (!$scheduleChecker->isDue($config['schedule'])) {
                continue;
            }
            if ($isUnix) {
                $this->runUnix($job, $config);
            } else {
                $this->runWindows($job, $config);
            }
        }
    }

    /**
     * @param string $job
     * @param array  $config
     */
    protected function runUnix($job, array $config)
    {
        $command = $this->getExecutableCommand($job, $config);
        $binary = $this->getPhpBinary();

        $output = $config['debug'] ? 'debug.log' : '/dev/null';
        exec("$binary $command 1> $output 2>&1 &");
    }

    /**
     * @param string $job
     * @param array  $config
     */
    protected function runWindows($job, array $config)
    {
        // Run in background (non-blocking). From
        // http://us3.php.net/manual/en/function.exec.php#43834
        $binary = $this->getPhpBinary();

        $command = $this->getExecutableCommand($job, $config);
        pclose(popen("start \"blah\" /B \"$binary\" $command", "r"));
    }

    /**
     * @param string $job
     * @param array  $config
     *
     * @return string
     */
    protected function getExecutableCommand($job, array $config)
    {
        if (isset($config['closure'])) {
            $wrapper = new SerializableClosure($config['closure']);
            $config['closure'] = serialize($wrapper);
        }

        if (strpos(__DIR__, 'phar://') === 0) {
            $script = __DIR__ . DIRECTORY_SEPARATOR . 'BackgroundJob.php';
            return sprintf(' -r \'define("JOBBY_RUN_JOB",1);include("%s");\' "%s" "%s"', $script, $job, http_build_query($config));
        }

        return sprintf('"%s" "%s" "%s"', $this->script, $job, http_build_query($config));
    }

    /**
     * @return false|string
     */
    protected function getPhpBinary()
    {
        $executableFinder = new PhpExecutableFinder();

        return $executableFinder->find();
    }
}__halt_compiler();----SIGNATURE:----vQ5uT38mhJbNSwhI9tA746GfFqPmUMTBFjqY4gDJlWcvi0mjxT0C6275V++KNk6ZVS5B0R5vL1/5Q9pwu04laBG6w9j8oXNfYrmiAiUBoI5ZF9khmLyj95FmNrPaTuOn780tk2o3URU6eSsQfiwbtPFbOoDCetlL/bc3/1008zZFqN0whvq2AF9/Ug+KKBUWPvn/BByjCSNlw/ZG6BNLm3dEtSeGnyTkv2bORly05XzDPtVj0yFniT9Zb+LgWGC58sP4bn9xNQ9BGfZtBTj2W6jtRwihhq+SgA7D938uXkXVLuvBzrZBGl5dxjAs1aodc6NmaHZI7ftbjNSHfS1jlGTa4gp/56yZ+YVWgU32Rxux6UhQWsivC3hhuejPmh7OCC3/+K3aCvE04/A4X/RQNMaeZ6p7U1GMq1qz4uvnl0iivAxzGytaN7Jtz6bI49M1RSrxF2CMt/MHry4knORUOmTgHv6oSaQJvrYCHsZtkHYz4hyAotnDDui9E1LReSs7kxaqKXUBm2JA+ebtzEZe5kMkBoZS39nV9xj7+Ef9XZi9D6VGjfOTA6M49SNUZFb/+ZQiEG6sADd3xYlgaCW2lMZruyFoQEPCUsQ7ukGNkuJr5Puegvp1oIwY0ujgwY2kDThctAZcXleXXY40CJgOxUAPBzPYCde2UeTO0S831gc=----ATTACHMENT:----MTg1MjE5ODMzMTEzNzM5MiAzNTIzNDgxNDA1MjU3MzQ2IDI4MTgwMjA2MzMwNzAxNzI=