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); } if (array_key_exists('name', $data)) { $this->checkWorkflowName($data['name']); $workflow->setName($data['name']); $this->storage->updateWorkflow($workflow); } if (array_key_exists('status', $data)) { $this->checkWorkflowStatus($data['status']); $workflow->setStatus($data['status']); $this->storage->updateWorkflow($workflow); } $workflow = $this->storage->getWorkflow($id); if (!$workflow) { throw Exceptions::workflowNotFound($id); } return $workflow; } private function checkWorkflowName(string $name): void { if (empty($name)) { throw UnexpectedValueException::create()->withMessage(__('Workflow name must not be empty', 'mailpoet')); } } 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')); } } }