<?php declare(strict_types=1);

namespace Pim\Upgrade\Schema;

use Akeneo\Tool\Component\Batch\Job\BatchStatus;
use Akeneo\Tool\Component\Batch\Job\ExitStatus;
use Doctrine\DBAL\Connection;
use Doctrine\DBAL\Schema\Schema;
use Doctrine\Migrations\AbstractMigration;

/**
 * It updates the status of 'running' execution jobs to 'FAILED'
 * It ensures that executions that crashed (so their status is still 'Running')
 * are correctly displayed in the UI, instead of perpetually staying in "RUNNING" or "STOPPING"
 *
 * This DOES NOT stop a still running execution from proceeding, the right status
 * will be saved back when the process finishes. The only drawback is that such processes will
 * temporarily show as failed in the UI (until the job actually finishes)
 *
 * The command "akeneo:batch:clean-job-executions" has been created to avoid running this migration again.
 */
final class Version_6_0_20210415130338_mark_job_execution_as_failed_when_interrupted extends AbstractMigration
{
    public function up(Schema $schema): void
    {
        $this->addSql(
            <<<SQL
UPDATE akeneo_batch_job_execution job_execution
SET job_execution.status = :failedStatus, job_execution.exit_code = :failedExitCode
WHERE job_execution.status IN (:runningStatuses)
AND job_execution.health_check_time IS NULL;
SQL,
            [
                'failedStatus' => BatchStatus::FAILED,
                'failedExitCode' => ExitStatus::FAILED,
                'runningStatuses' => [BatchStatus::STARTED, BatchStatus::STOPPING],
            ],
            [
                'runningStatuses' => Connection::PARAM_INT_ARRAY,
            ]
        );
    }

    public function down(Schema $schema): void
    {
        $this->throwIrreversibleMigrationException();
    }
}