<?php declare(strict_types = 1);

namespace MailPoet\Automation\Engine\Control;

use MailPoet\Automation\Engine\Data\AutomationRunLog;
use MailPoet\Automation\Engine\Exceptions;
use MailPoet\Automation\Engine\Hooks;
use MailPoet\Automation\Engine\Storage\AutomationRunLogStorage;

class AutomationController {
  private ActionScheduler $actionScheduler;
  private AutomationRunLogStorage $automationRunLogStorage;

  public function __construct(
    ActionScheduler $actionScheduler,
    AutomationRunLogStorage $automationRunLogStorage
  ) {
    $this->actionScheduler = $actionScheduler;
    $this->automationRunLogStorage = $automationRunLogStorage;
  }

  public function enqueueProgress(int $runId, string $stepId): void {
    $log = $this->automationRunLogStorage->getAutomationRunLogByRunAndStepId($runId, $stepId);
    if (!$log) {
      throw Exceptions::stepNotStarted($stepId, $runId);
    }

    if ($log->getStatus() !== AutomationRunLog::STATUS_RUNNING) {
      throw Exceptions::stepNotRunning($stepId, $log->getStatus(), $runId);
    }

    $runNumber = $log->getRunNumber() + 1;
    $args = [
      'automation_run_id' => $runId,
      'step_id' => $stepId,
      'run_number' => $runNumber,
    ];
    $this->actionScheduler->enqueue(Hooks::AUTOMATION_STEP, [$args]);
  }
}