<?php

declare(strict_types=1);

namespace Akeneo\Platform\Bundle\ImportExportBundle\Query;

use Akeneo\Platform\Bundle\ImportExportBundle\Model\JobExecutionTracking;
use Akeneo\Platform\Bundle\ImportExportBundle\Model\StepExecutionTracking;
use Akeneo\Platform\Bundle\ImportExportBundle\Repository\InternalApi\JobExecutionRepository;
use Akeneo\Tool\Bundle\BatchQueueBundle\Manager\JobExecutionManager;
use Akeneo\Tool\Component\Batch\Job\BatchStatus;
use Akeneo\Tool\Component\Batch\Job\JobInterface;
use Akeneo\Tool\Component\Batch\Job\JobRegistry;
use Akeneo\Tool\Component\Batch\Job\JobWithStepsInterface;
use Akeneo\Tool\Component\Batch\Job\UndefinedJobException;
use Akeneo\Tool\Component\Batch\Model\JobExecution;
use Akeneo\Tool\Component\Batch\Model\StepExecution;
use Akeneo\Tool\Component\Batch\Step\StepInterface;
use Akeneo\Tool\Component\Batch\Step\TrackableStepInterface;
use Doctrine\Common\Collections\Collection;

/**
 * @author    Samir Boulil <samir.boulil@akeneo.com>
 * @copyright 2020 Akeneo SAS (http://www.akeneo.com)
 * @license   http://opensource.org/licenses/osl-3.0.php  Open Software License (OSL 3.0)
 */
class GetJobExecutionTracking
{
    public function __construct(
        private JobRegistry $jobRegistry,
        private JobExecutionRepository $jobExecutionRepository,
        private JobExecutionManager $jobExecutionManager,
        private ClockInterface $clock,
    ) {
    }

    public function execute(int $jobExecutionId): JobExecutionTracking
    {
        $jobExecution = $this->jobExecutionRepository->find($jobExecutionId);
        if (!$jobExecution instanceof JobExecution) {
            throw new \RuntimeException('The JobExecutionTracking query expect to find an existing JobExecution');
        }

        $jobExecution = $this->jobExecutionManager->resolveJobExecutionStatus($jobExecution);
        $jobName = $jobExecution->getJobInstance()->getJobName();

        try {
            $job = $this->jobRegistry->get($jobName);

            return $this->createJobExecutionTrackingWithJob($jobExecution, $job);
        } catch (UndefinedJobException $e) {
            return $this->createJobExecutionTrackingWithoutJob($jobExecution);
        }
    }

    private function createJobExecutionTrackingWithJob(
        JobExecution $jobExecution,
        JobInterface $job
    ): JobExecutionTracking {
        $stepExecutions = $jobExecution->getStepExecutions();

        $jobExecutionTracking = new JobExecutionTracking();
        $jobExecutionTracking->status = (string) $jobExecution->getStatus();
        $jobExecutionTracking->currentStep = count($jobExecution->getStepExecutions());
        $jobExecutionTracking->totalSteps = $job instanceof JobWithStepsInterface ? count($job->getSteps()) : 0;
        $jobExecutionTracking->steps = $this->createStepExecutionsTrackingWithJob($job, $stepExecutions, $jobExecution->getCreateTime());

        return $jobExecutionTracking;
    }

    private function createJobExecutionTrackingWithoutJob(JobExecution $jobExecution): JobExecutionTracking
    {
        $stepExecutions = $jobExecution->getStepExecutions();

        $jobExecutionTracking = new JobExecutionTracking();
        $jobExecutionTracking->status = (string) $jobExecution->getStatus();
        $jobExecutionTracking->currentStep = count($jobExecution->getStepExecutions());
        $jobExecutionTracking->totalSteps = count($jobExecution->getStepExecutions());
        $jobExecutionTracking->steps = $this->createStepExecutionsTrackingWithoutJob(
            $stepExecutions,
            $jobExecution->getJobInstance()->getCode(),
        );

        return $jobExecutionTracking;
    }

    private function createStepExecutionsTrackingWithJob(JobInterface $job, Collection $stepExecutions, \DateTime $createdTime): array
    {
        if (!$job instanceof JobWithStepsInterface) {
            return [];
        }

        $stepsExecutionTracking = [];
        foreach ($job->getSteps() as $step) {
            $stepName = $step->getName();
            $stepExecutionIndex = $this->searchFirstMatchingStepExecutionIndex($stepExecutions, $stepName);
            if (-1 === $stepExecutionIndex) {
                $stepsExecutionTracking[] = $this->createNotStartedStepExecutionTracking($step, $job->getName());
                continue;
            }

            $stepExecution = $stepExecutions[$stepExecutionIndex];
            $stepsExecutionTracking[] = $this->createAlreadyStartedStepExecutionTracking(
                $step,
                $stepExecution,
                $job->getName()
            );

            unset($stepExecutions[$stepExecutionIndex]);
        }

        return $stepsExecutionTracking;
    }

    private function searchFirstMatchingStepExecutionIndex(Collection $stepExecutions, string $stepName): int
    {
        foreach ($stepExecutions as $stepExecutionIndex => $stepExecution) {
            if ($stepExecution->getStepName() === $stepName) {
                return $stepExecutionIndex;
            }
        }

        return -1;
    }

    private function createNotStartedStepExecutionTracking(StepInterface $step, string $jobName): StepExecutionTracking
    {
        $stepExecutionTracking = new StepExecutionTracking();
        $stepExecutionTracking->jobName = $jobName;
        $stepExecutionTracking->stepName = $step->getName();
        $stepExecutionTracking->status = (string) (new BatchStatus(BatchStatus::STARTING));
        if ($step instanceof TrackableStepInterface && $step->isTrackable()) {
            $stepExecutionTracking->isTrackable = true;
        }

        return $stepExecutionTracking;
    }

    private function createAlreadyStartedStepExecutionTracking(
        StepInterface $step,
        StepExecution $stepExecution,
        string $jobName
    ): StepExecutionTracking {
        $stepExecutionTracking = $this->createStepExecutionTrackingFromStepExecution($stepExecution, $jobName);
        if ($step instanceof TrackableStepInterface && $step->isTrackable()) {
            $stepExecutionTracking->isTrackable = true;
            $stepExecutionTracking->processedItems = $stepExecution->getProcessedItems();
            $stepExecutionTracking->totalItems = $stepExecution->getTotalItems();
        }

        return $stepExecutionTracking;
    }

    private function computeDuration(StepExecution $stepExecution): int
    {
        $now = $this->clock->now();
        if (BatchStatus::STARTING === $stepExecution->getStatus()->getValue()) {
            return 0;
        }

        $duration = $now->getTimestamp() - $stepExecution->getStartTime()->getTimestamp();
        if ($stepExecution->getEndTime()) {
            $duration = $stepExecution->getEndTime()->getTimestamp() - $stepExecution->getStartTime()->getTimestamp();
        }

        return $duration;
    }

    private function createStepExecutionsTrackingWithoutJob(Collection $stepExecutions, string $jobName)
    {
        $stepExecutionsTracking = [];
        /** @var StepExecution $stepExecution */
        foreach ($stepExecutions as $stepExecution) {
            $stepExecutionsTracking[] = $this->createStepExecutionTrackingFromStepExecution($stepExecution, $jobName);
        }

        return $stepExecutionsTracking;
    }

    private function createStepExecutionTrackingFromStepExecution(StepExecution $stepExecution, string $jobName)
    {
        $duration = $this->computeDuration($stepExecution);

        $stepExecutionTracking = new StepExecutionTracking();
        $stepExecutionTracking->jobName = $jobName;
        $stepExecutionTracking->stepName = $stepExecution->getStepName();
        $stepExecutionTracking->status = (string) $stepExecution->getStatus();
        $stepExecutionTracking->duration = $duration;
        $stepExecutionTracking->hasError = 0 !== count($stepExecution->getFailureExceptions()) || 0 !== count($stepExecution->getErrors());
        $stepExecutionTracking->hasWarning = 0 !== count($stepExecution->getWarnings());

        return $stepExecutionTracking;
    }
}