Cavemanon/piratepoet
7
Fork 0
Code Pull Requests Actions Releases 16 Activity

Create new workflow run in trigger handler

Browse Source 
[MAILPOET-4136]
This commit is contained in:
Jan Jakes
2022-03-07 12:04:47 +01:00
committed by Veljko V
parent b88e310f7e
commit e4b09ab6de
1 changed files with 12 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
mailpoet/lib/Automation/Engine/Control/TriggerHandler.php
View File

@ -4,9 +4,11 @@ namespace MailPoet\Automation\Engine\Control;
use MailPoet\Automation\Engine\Exceptions; use MailPoet\Automation\Engine\Exceptions;
use MailPoet\Automation\Engine\Hooks; use MailPoet\Automation\Engine\Hooks;
use MailPoet\Automation\Engine\Storage\WorkflowRunStorage;
use MailPoet\Automation\Engine\Storage\WorkflowStorage; use MailPoet\Automation\Engine\Storage\WorkflowStorage;
use MailPoet\Automation\Engine\WordPress; use MailPoet\Automation\Engine\WordPress;
use MailPoet\Automation\Engine\Workflows\Trigger; use MailPoet\Automation\Engine\Workflows\Trigger;
use MailPoet\Automation\Engine\Workflows\WorkflowRun;
class TriggerHandler { class TriggerHandler {
/** @var ActionScheduler */ /** @var ActionScheduler */
@ -18,14 +20,19 @@ class TriggerHandler {
/** @var WorkflowStorage */ /** @var WorkflowStorage */
private $workflowStorage; private $workflowStorage;
/** @var WorkflowRunStorage */
private $workflowRunStorage;
public function __construct( public function __construct(
ActionScheduler $actionScheduler, ActionScheduler $actionScheduler,
WordPress $wordPress, WordPress $wordPress,
WorkflowStorage $workflowStorage WorkflowStorage $workflowStorage,
WorkflowRunStorage $workflowRunStorage
) { ) {
$this->actionScheduler = $actionScheduler; $this->actionScheduler = $actionScheduler;
$this->wordPress = $wordPress; $this->wordPress = $wordPress;
$this->workflowStorage = $workflowStorage; $this->workflowStorage = $workflowStorage;
$this->workflowRunStorage = $workflowRunStorage;
} }
public function initialize(): void { public function initialize(): void {
@ -40,7 +47,10 @@ class TriggerHandler {
throw Exceptions::workflowTriggerNotFound($workflow->getId(), $trigger->getKey()); throw Exceptions::workflowTriggerNotFound($workflow->getId(), $trigger->getKey());
} }
// TODO: create new workflow run $workflowRun = new WorkflowRun($workflow->getId(), $trigger->getKey());
$this->workflowRunStorage->createWorkflowRun($workflowRun);
// TODO: enqueue next workflow step
} }
} }
} }