Skip to content

Commit b91c84f

Browse files
committed
feat: Add support for default input data when executing chains.
1 parent 8357213 commit b91c84f

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

Services/ChainProcessorsManager.php

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -81,9 +81,13 @@ public function getProcessor(string $chainName, array $options): ChainProcessor
8181
public function execute(string $chainName, iterable $iterator, array $params, ?callable $observerCallback = null)
8282
{
8383
$definition = $this->getRawDefinition($chainName);
84+
$definitionArray = $this->definitions[$chainName];
8485

8586
$inputData = ["Iterator! Can't show input data"];
86-
if (is_array($iterator)) {
87+
if (is_array($iterator) && empty($iterator) && isset($definitionArray['defaultInput'])) {
88+
$inputData = $definitionArray['defaultInput'];
89+
$iterator = new \ArrayIterator($definitionArray['defaultInput']);
90+
} elseif (is_array($iterator)) {
8791
$inputData = $iterator;
8892
$iterator = new \ArrayIterator($iterator);
8993
}

0 commit comments

Comments
 (0)