storage = $storage; } public function updateWorkflow(int $id, array $data): Workflow { // TODO: data & workflow validation (trigger existence, graph consistency, etc.) // TODO: new revisions when content is changed // TODO: validation when status being is changed $workflow = $this->storage->getWorkflow($id); if (!$workflow) { throw Exceptions::workflowNotFound($id); } $changed = false; if (array_key_exists('name', $data)) { $workflow->setName($data['name']); $changed = true; } if (array_key_exists('status', $data)) { $this->checkWorkflowStatus($data['status']); $workflow->setStatus($data['status']); $changed = true; } if ($changed) { $this->storage->updateWorkflow($workflow); } $workflow = $this->storage->getWorkflow($id); if (!$workflow) { throw Exceptions::workflowNotFound($id); } return $workflow; } private function checkWorkflowStatus(string $status): void { if (!in_array($status, [Workflow::STATUS_ACTIVE, Workflow::STATUS_INACTIVE, Workflow::STATUS_DRAFT], true)) { throw UnexpectedValueException::create()->withMessage(__(sprintf('Invalid status: %s', $status), 'mailpoet')); } } }