ProcessEventSubscriber.php

<?php

declare(strict_types=1);

/*
 * This file is part of the CleverAge/UiProcessBundle package.
 *
 * Copyright (c) Clever-Age
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace CleverAge\UiProcessBundle\EventSubscriber;

use CleverAge\ProcessBundle\Event\ProcessEvent;
use CleverAge\UiProcessBundle\Entity\Enum\ProcessExecutionStatus;
use CleverAge\UiProcessBundle\Entity\ProcessExecution;
use CleverAge\UiProcessBundle\Manager\ProcessExecutionManager;
use CleverAge\UiProcessBundle\Monolog\Handler\DoctrineProcessHandler;
use CleverAge\UiProcessBundle\Monolog\Handler\ProcessHandler;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;
use Symfony\Component\Uid\Uuid;

/**
 * PHP 8.2 : Replace by readonly class.
 */
final class ProcessEventSubscriber implements EventSubscriberInterface
{
    public function __construct(
        private readonly ProcessHandler $processHandler,
        private readonly DoctrineProcessHandler $doctrineProcessHandler,
        private readonly ProcessExecutionManager $processExecutionManager,
    ) {
    }

    public function onProcessStart(ProcessEvent $event): void
    {
        if (false === $this->processHandler->hasFilename()) {
            $this->processHandler->setFilename(\sprintf('%s/%s.log', $event->getProcessCode(), Uuid::v4()));
        }
        if (!$this->processExecutionManager->getCurrentProcessExecution() instanceof ProcessExecution) {
            $processExecution = new ProcessExecution(
                $event->getProcessCode(),
                basename((string) $this->processHandler->getFilename()),
                $event->getProcessContext()
            );
            $this->processExecutionManager->setCurrentProcessExecution($processExecution)->save();
        }
    }

    public function success(ProcessEvent $event): void
    {
        if ($event->getProcessCode() === $this->processExecutionManager->getCurrentProcessExecution()?->getCode()) {
            $this->processExecutionManager->getCurrentProcessExecution()->setStatus(ProcessExecutionStatus::Finish);
            $this->processExecutionManager->getCurrentProcessExecution()->end();
            $this->processExecutionManager->save()->unsetProcessExecution($event->getProcessCode());
            $this->processHandler->close();
        }
    }

    public function fail(ProcessEvent $event): void
    {
        if ($event->getProcessCode() === $this->processExecutionManager->getCurrentProcessExecution()?->getCode()) {
            $this->processExecutionManager->getCurrentProcessExecution()->setStatus(ProcessExecutionStatus::Failed);
            $this->processExecutionManager->getCurrentProcessExecution()->end();
            $this->processExecutionManager->save()->unsetProcessExecution($event->getProcessCode());
            $this->processHandler->close();
        }
    }

    public function flushDoctrineLogs(ProcessEvent $event): void
    {
        $this->doctrineProcessHandler->flush();
    }

    public static function getSubscribedEvents(): array
    {
        return [
            ProcessEvent::EVENT_PROCESS_STARTED => 'onProcessStart',
            ProcessEvent::EVENT_PROCESS_ENDED => [
                ['flushDoctrineLogs', 100],
                ['success', 100],
            ],
            ProcessEvent::EVENT_PROCESS_FAILED => [
                ['flushDoctrineLogs', 100],
                ['fail', 100],
            ],
        ];
    }
}