Made that the Remove and Update commands in the Cloud context can be …

…used with several satellites in a single file
php-etl · Jan 22, 2024 · ea5204c · ea5204c
1 parent 85aaa1f
commit ea5204c
Show file tree

Hide file tree

Showing 2 changed files with 24 additions and 16 deletions.
diff --git a/src/Cloud/Console/Command/RemoveCommand.php b/src/Cloud/Console/Command/RemoveCommand.php
@@ -124,14 +124,18 @@ protected function execute(Console\Input\InputInterface $input, Console\Output\O
         }
 
         $context = new Satellite\Cloud\Context($client, $auth, $url);
-        $instance = match (true) {
-            \array_key_exists('pipeline', $configuration) => new Satellite\Cloud\Pipeline($context),
-            \array_key_exists('workflow', $configuration) => new Satellite\Cloud\Workflow($context),
-            default => throw new \RuntimeException('Invalid runtime satellite configuration.'),
-        };
-
-        foreach ($instance->remove($instance::fromApiWithCode($client, array_key_first($configuration['satellites']))->id()) as $command) {
-            $bus->push($command);
+
+        foreach ($configuration['satellites'] as $code => $satellite) {
+            $satellite['code'] = $code;
+            $instance = match (true) {
+                \array_key_exists('pipeline', $satellite) => new Satellite\Cloud\Pipeline($context),
+                \array_key_exists('workflow', $satellite) => new Satellite\Cloud\Workflow($context),
+                default => throw new \RuntimeException('Invalid runtime satellite configuration.'),
+            };
+
+            foreach ($instance->remove($instance::fromApiWithCode($client, array_key_first($configuration['satellites']))->id()) as $command) {
+                $bus->push($command);
+            }
         }
 
         $bus->execute();

diff --git a/src/Cloud/Console/Command/UpdateCommand.php b/src/Cloud/Console/Command/UpdateCommand.php
@@ -126,14 +126,18 @@ protected function execute(Console\Input\InputInterface $input, Console\Output\O
         }
 
         $context = new Satellite\Cloud\Context($client, $auth, $url);
-        $instance = match (true) {
-            \array_key_exists('pipeline', $configuration) => new Satellite\Cloud\Pipeline($context),
-            \array_key_exists('workflow', $configuration) => new Satellite\Cloud\Workflow($context),
-            default => throw new \RuntimeException('Invalid runtime satellite configuration.'),
-        };
-
-        foreach ($instance->update($instance::fromApiWithCode($client, array_key_first($configuration['satellites'])), $instance::fromLegacyConfiguration($configuration['satellite'])) as $command) {
-            $bus->push($command);
+
+        foreach ($configuration['satellites'] as $code => $satellite) {
+            $satellite['code'] = $code;
+            $instance = match (true) {
+                \array_key_exists('pipeline', $satellite) => new Satellite\Cloud\Pipeline($context),
+                \array_key_exists('workflow', $satellite) => new Satellite\Cloud\Workflow($context),
+                default => throw new \RuntimeException('Invalid runtime satellite configuration.'),
+            };
+
+            foreach ($instance->update($instance::fromApiWithCode($client, array_key_first($configuration['satellites'])), $instance::fromLegacyConfiguration($configuration['satellite'])) as $command) {
+                $bus->push($command);
+            }
         }
 
         $bus->execute();