<?php
/**
 * @copyright: Copyright © 2017 Firebear Studio. All rights reserved.
 * @author   : Firebear Studio <fbeardev@gmail.com>
 */

/**
 * Prepare cron jobs data
 */

namespace Firebear\ImportExport\Plugin\Config;

use Firebear\ImportExport\Cron\RunExportJobs;
use Firebear\ImportExport\Cron\RunImportJobs;
use Firebear\ImportExport\Model\ExportJob;
use Firebear\ImportExport\Model\ExportJobFactory;
use Firebear\ImportExport\Model\JobFactory;
use Psr\Log\LoggerInterface;

/**
 * Class Data
 * @package Firebear\ImportExport\Plugin\Config
 */
class Data
{
    /**
     * Import Job factory
     *
     * @var JobFactory
     */
    protected $jobFactory;

    /**
     * @var ExportJobFactory
     */
    protected $exportJobFactory;

    /**
     * @var LoggerInterface
     */
    protected $logger;

    /**
     * @var string
     */
    protected $jobCodePattern = 'importexport_jobs_run_id_%u';

    protected $jobCodeExportPattern = 'importexport_export_jobs_run_id_%u';

    /**
     * Data constructor.
     *
     * @param ExportJobFactory $exportJobFactory
     * @param JobFactory $jobFactory
     * @param LoggerInterface $logger
     */
    public function __construct(
        ExportJobFactory $exportJobFactory,
        JobFactory $jobFactory,
        LoggerInterface $logger
    ) {
        $this->exportJobFactory = $exportJobFactory;
        $this->jobFactory = $jobFactory;
        $this->logger = $logger;
    }

    /**
     * Implement cron jobs created via admin panel into system cron jobs generated from xml files
     *
     * @param \Magento\Cron\Model\Config\Data $subject
     * @param                                 $result
     *
     * @return mixed
     */
    public function afterGetJobs(\Magento\Cron\Model\Config\Data $subject, $result)
    {
        $result = $this->scopeCrons($result, $this->jobFactory, RunImportJobs::class, $this->jobCodePattern);
        $result = $this->scopeCrons(
            $result,
            $this->exportJobFactory,
            RunExportJobs::class,
            $this->jobCodeExportPattern
        );
        return $result;
    }

    /**
     * @param $result
     * @param $factory
     * @param $instance
     * @param $pattern
     *
     * @return mixed
     */
    protected function scopeCrons($result, $factory, $instance, $pattern)
    {
        $jobCollection = $factory->create()->getCollection();
        $jobCollection->addFieldToFilter('is_active', 1);
        $jobCollection->addFieldToFilter('cron', ['neq' => '']);
        $jobCollection->load();
        foreach ($jobCollection as $job) {
            $jobName = sprintf($pattern, $job->getId());
            $jobSourceData = $job->getData('source_data');
            if ($job instanceof ExportJob) {
                $jobSourceData = $job->getData('export_source');
            }
            $cronGroupName = $jobSourceData['cron_groups'] ?? 'firebear_importexport';
            $result[$cronGroupName][$jobName] = [
                'name' => $jobName,
                'instance' => $instance,
                'method' => 'execute',
                'schedule' => $job->getCron()
            ];
        }

        return $result;
    }
}