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

Add filters to to automation template builder

Browse Source 
[MAILPOET-5372]
This commit is contained in:
Jan Jakes
2023-06-14 17:18:37 +02:00
committed by Aschepikov
parent b753a97ad6
commit c8fdf6e7f0
1 changed files with 59 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

60
mailpoet/lib/Automation/Integrations/MailPoet/Templates/AutomationBuilder.php
View File

@ -3,8 +3,12 @@
namespace MailPoet\Automation\Integrations\MailPoet\Templates; namespace MailPoet\Automation\Integrations\MailPoet\Templates;
use MailPoet\Automation\Engine\Data\Automation; use MailPoet\Automation\Engine\Data\Automation;
use MailPoet\Automation\Engine\Data\Filter;
use MailPoet\Automation\Engine\Data\FilterGroup;
use MailPoet\Automation\Engine\Data\Filters;
use MailPoet\Automation\Engine\Data\NextStep; use MailPoet\Automation\Engine\Data\NextStep;
use MailPoet\Automation\Engine\Data\Step; use MailPoet\Automation\Engine\Data\Step;
use MailPoet\Automation\Engine\Exceptions\InvalidStateException;
use MailPoet\Automation\Engine\Integration\Trigger; use MailPoet\Automation\Engine\Integration\Trigger;
use MailPoet\Automation\Engine\Registry; use MailPoet\Automation\Engine\Registry;
use MailPoet\Util\Security; use MailPoet\Util\Security;
@ -27,6 +31,17 @@ class AutomationBuilder {
* array{ * array{
* key: string, * key: string,
* args?: array<string, mixed>, * args?: array<string, mixed>,
* filters?: array{
* operator: 'and' | 'or',
* groups: array{
* operator: 'and' | 'or',
* filters: array{
* field: string,
* condition: string,
* value: mixed,
* }[],
* }[],
* },
* } * }
* > $sequence * > $sequence
* @param array<string, mixed> $meta * @param array<string, mixed> $meta
@ -42,12 +57,14 @@ class AutomationBuilder {
continue; continue;
} }
$args = array_merge($this->getDefaultArgs($automationStep->getArgsSchema()), $data['args'] ?? []); $args = array_merge($this->getDefaultArgs($automationStep->getArgsSchema()), $data['args'] ?? []);
$filters = isset($data['filters']) ? $this->getFilters($data['filters']) : null;
$step = new Step( $step = new Step(
$this->uniqueId(), $this->uniqueId(),
in_array(Trigger::class, (array)class_implements($automationStep)) ? Step::TYPE_TRIGGER : Step::TYPE_ACTION, in_array(Trigger::class, (array)class_implements($automationStep)) ? Step::TYPE_TRIGGER : Step::TYPE_ACTION,
$stepKey, $stepKey,
$args, $args,
$nextSteps $nextSteps,
$filters
); );
$nextSteps = [new NextStep($step->getId())]; $nextSteps = [new NextStep($step->getId())];
$steps[$step->getId()] = $step; $steps[$step->getId()] = $step;
@ -78,4 +95,45 @@ class AutomationBuilder {
} }
return $args; return $args;
} }
/**
* @param array{
* operator: 'and' | 'or',
* groups: array{
* operator: 'and' | 'or',
* filters: array{
* field: string,
* condition: string,
* value: mixed,
* }[],
* }[],
* } $filters
* @return Filters
*/
private function getFilters(array $filters): Filters {
$groups = [];
foreach ($filters['groups'] as $group) {
$groups[] = new FilterGroup(
$this->uniqueId(),
$group['operator'],
array_map(
function (array $filter): Filter {
$field = $this->registry->getField($filter['field']);
if (!$field) {
throw new InvalidStateException(sprintf("Field with key '%s' not found", $filter['field']));
}
return new Filter(
$this->uniqueId(),
$field->getType(),
$filter['field'],
$filter['condition'],
['value' => $filter['value']]
);
},
$group['filters']
)
);
}
return new Filters($filters['operator'], $groups);
}
} }