From c99f8e21e67162538caa1eff6fff94b35931c382 Mon Sep 17 00:00:00 2001
From: sebprt <sebastien@kiboko.fr>
Date: Mon, 1 Jul 2024 12:28:09 +0200
Subject: [PATCH] Added tests for the Cloud

---
 tests/unit/Cloud/Client/GetWorkflowItem.php   |  19 ++
 .../GetWorkflowItemThrowNotFoundException.php |  14 +
 tests/unit/Cloud/DummyContext.php             |  32 ++
 tests/unit/Cloud/WorkflowTest.php             | 306 ++++++++++++++++++
 4 files changed, 371 insertions(+)
 create mode 100644 tests/unit/Cloud/Client/GetWorkflowItem.php
 create mode 100644 tests/unit/Cloud/Client/GetWorkflowItemThrowNotFoundException.php
 create mode 100644 tests/unit/Cloud/DummyContext.php
 create mode 100644 tests/unit/Cloud/WorkflowTest.php

diff --git a/tests/unit/Cloud/Client/GetWorkflowItem.php b/tests/unit/Cloud/Client/GetWorkflowItem.php
new file mode 100644
index 00000000..effb222c
--- /dev/null
+++ b/tests/unit/Cloud/Client/GetWorkflowItem.php
@@ -0,0 +1,19 @@
+<?php
+
+namespace unit\Kiboko\Component\Satellite\Cloud\CLient;
+
+use Gyroscops;
+use Gyroscops\Api\Model\WorkflowRead;
+
+class GetWorkflowItem extends Gyroscops\Api\Client
+{
+    public function getWorkflowItem(string $id, string $fetch = self::FETCH_OBJECT, array $accept = []): WorkflowRead
+    {
+        $workflowRead = new WorkflowRead();
+        $workflowRead->setId($id);
+        $workflowRead->setLabel('Extract data from Akeneo');
+        $workflowRead->setCode('from_akeneo');
+
+        return $workflowRead;
+    }
+}
diff --git a/tests/unit/Cloud/Client/GetWorkflowItemThrowNotFoundException.php b/tests/unit/Cloud/Client/GetWorkflowItemThrowNotFoundException.php
new file mode 100644
index 00000000..421157c9
--- /dev/null
+++ b/tests/unit/Cloud/Client/GetWorkflowItemThrowNotFoundException.php
@@ -0,0 +1,14 @@
+<?php
+
+namespace unit\Kiboko\Component\Satellite\Cloud\CLient;
+
+use Gyroscops\Api\Client;
+use Gyroscops\Api\Exception\GetWorkflowItemNotFoundException;
+
+class GetWorkflowItemThrowNotFoundException extends Client
+{
+    public function getWorkflowItem($id, string $fetch = self::FETCH_OBJECT, array $accept = [])
+    {
+        throw new GetWorkflowItemNotFoundException();
+    }
+}
diff --git a/tests/unit/Cloud/DummyContext.php b/tests/unit/Cloud/DummyContext.php
new file mode 100644
index 00000000..4c8fec27
--- /dev/null
+++ b/tests/unit/Cloud/DummyContext.php
@@ -0,0 +1,32 @@
+<?php
+
+declare(strict_types=1);
+
+namespace unit\Kiboko\Component\Satellite\Cloud;
+
+use Kiboko\Component\Satellite\Cloud\ContextInterface;
+use Kiboko\Component\Satellite\Cloud\DTO\OrganizationId;
+use Kiboko\Component\Satellite\Cloud\DTO\WorkspaceId;
+
+final readonly class DummyContext implements ContextInterface
+{
+    public function changeOrganization(OrganizationId $organization): void
+    {
+        // Todo: write this method
+    }
+
+    public function organization(): OrganizationId
+    {
+        return new OrganizationId('93af28a3-c7f9-4392-a013-b4ece257ecf5');
+    }
+
+    public function changeWorkspace(WorkspaceId $workspace): void
+    {
+        // Todo: write this method
+    }
+
+    public function workspace(): WorkspaceId
+    {
+        return new WorkspaceId('eb6ed674-5198-4be2-a8b9-8ef5d5292be4');
+    }
+}
diff --git a/tests/unit/Cloud/WorkflowTest.php b/tests/unit/Cloud/WorkflowTest.php
new file mode 100644
index 00000000..6e33917a
--- /dev/null
+++ b/tests/unit/Cloud/WorkflowTest.php
@@ -0,0 +1,306 @@
+<?php
+
+namespace unit\Kiboko\Component\Satellite\Cloud;
+
+use Kiboko\Component\Satellite;
+use PHPUnit\Framework\Constraint\LogicalNot;
+use PHPUnit\Framework\Constraint\StringStartsWith;
+use PHPUnit\Framework\TestCase;
+use Symfony\Component\ExpressionLanguage\Expression;
+use unit\Kiboko\Component\Satellite\Cloud\CLient\GetWorkflowItemThrowNotFoundException;
+use unit\Kiboko\Component\Satellite\Cloud\CLient\GetWorkflowItem;
+
+class WorkflowTest extends TestCase
+{
+    protected function setUp(): void
+    {
+        $context = new DummyContext();
+        $context->changeOrganization(new Satellite\Cloud\DTO\OrganizationId('5624f073-4085-42ee-b33b-e8869c3f2f51'));
+        $context->changeWorkspace(new Satellite\Cloud\DTO\WorkspaceId('577d9281-88ad-45be-8e12-307adf5e787c'));
+    }
+
+    public function testLegacyConfiguration(): void
+    {
+        $workflow = Satellite\Cloud\Workflow::fromLegacyConfiguration(
+            [
+                'composer' => [
+                    'autoload' => ['psr4' => ['Namespace\\' => ['paths' => ['path/to/namespace']]]],
+                    'require' => ['vendor/package', 'vendor/package2'],
+                    'repositories' => [['name' => 'Repo Name', 'type' => 'git', 'url' => 'http://repo.url']],
+                    'auth' => [['url' => 'http://auth.url', 'token' => 'authToken']]
+                ],
+                'code' => 'my_workflow',
+                'workflow' => [
+                    'jobs' => [
+                        [
+                            'pipeline' => [
+                                'name' => 'My products pipeline',
+                                'code' => 'products_pipeline',
+                                'steps' => [
+                                    [
+                                        'name' => 'Extract products',
+                                        'code' => 'csv.extractor',
+                                        'csv' =>
+                                            [
+                                                'extractor' =>
+                                                    [
+                                                        'file_path' => '../data/products.csv',
+                                                    ],
+                                            ],
+                                    ],
+                                    [
+                                        'name' => 'Transform',
+                                        'code' => 'fastmap',
+                                        'fastmap' =>
+                                            [
+                                                'map' =>
+                                                    [
+                                                        [
+                                                            'copy' => '[identifier]',
+                                                            'field' => '[sku]',
+                                                        ],
+                                                    ],
+                                            ],
+                                    ],
+                                    [
+                                        'name' => 'Loads products',
+                                        'code' => 'stream.loader',
+                                        'stream' =>
+                                            [
+                                                'loader' =>
+                                                    [
+                                                        'destination' => '../data/products.ldjson',
+                                                        'format' => 'json',
+                                                    ],
+                                            ],
+                                    ],
+                                ],
+                            ],
+                        ],
+                        ['action' => ['name' => 'Test Action', 'code' => 'action123']]
+
+                    ],
+                ],
+            ],
+        );
+
+        $this->assertInstanceOf(Satellite\Cloud\DTO\Workflow::class, $workflow);
+        $this->assertEquals('my_workflow', $workflow->code());
+        $this->assertEquals(1, $workflow->composer()->autoload()->count());
+        $this->assertEquals(1, $workflow->composer()->auths()->count());
+        $this->assertEquals(1, $workflow->composer()->repositories()->count());
+        $this->assertEquals(2, $workflow->composer()->packages()->count());
+        $this->assertEquals(2, $workflow->jobs()->count());
+    }
+
+    public function testCreatesDefaultNameAndCodeIfNotProvided(): void {
+        $configuration = [
+            'workflow' => [
+                'name' => 'Test Workflow',
+                'jobs' => [
+                    ['pipeline' => ['name' => 'Test Pipeline', 'code' => 'pipeline123', 'steps' => []]],
+                    ['action' => ['name' => 'Test Action', 'code' => 'action123']]
+                ]
+            ]
+        ];
+
+        $workflow = Satellite\Cloud\Workflow::fromLegacyConfiguration($configuration);
+
+        $this->assertInstanceOf(Satellite\Cloud\DTO\Workflow::class, $workflow);
+        $this->assertMatchesRegularExpression('/workflow[a-f0-9]{8}/', $workflow->code());
+    }
+
+    public function testFromLegacyConfigurationWithEmptyConfig()
+    {
+        $this->expectException(\RuntimeException::class);
+
+        $workflow = Satellite\Cloud\Workflow::fromLegacyConfiguration([]);
+
+        $this->assertInstanceOf(Satellite\Cloud\DTO\Workflow::class, $workflow);
+    }
+
+    public function testThrowsExceptionForUnsupportedJobType()
+    {
+        $configuration = [
+            'workflow' => ['jobs' => [['invalidType' => []]]],
+            'composer' => [
+                'autoload' => ['psr4' => []],
+                'require' => [],
+                'repositories' => []
+            ]
+        ];
+
+        $this->expectException(\RuntimeException::class);
+
+        Satellite\Cloud\Workflow::fromLegacyConfiguration($configuration);
+    }
+
+    public function testFromLegacyConfigurationWithExpressions()
+    {
+        $configuration = [
+            'workflow' => [
+                'jobs' => [
+                    [
+                        'pipeline' => [
+                            'code' => 'pipelineCode',
+                            'steps' => [
+                                [
+                                    'csv' => [
+                                        'extractor' => [
+                                            'file_path' => new Expression('../data/products.csv'),
+                                        ],
+                                    ],
+                                ],
+                                [
+                                    'fastmap' => [
+                                        'map' => [
+                                            'expression' => new Expression('value > 100'),
+                                        ],
+                                    ],
+                                ],
+                            ],
+                        ],
+                    ],
+                ],
+            ],
+            'composer' => [
+                'autoload' => ['psr4' => []],
+                'require' => [],
+                'repositories' => []
+            ]
+        ];
+
+        $workflow = Satellite\Cloud\Workflow::fromLegacyConfiguration($configuration);
+
+        WorkflowTest::assertStringNotStartsWith(
+            '@=', $workflow->jobs()->get('pipelineCode')->stepList->get('step1')->config['fastmap']['map']['expression']
+        );
+        WorkflowTest::assertStringStartsWith(
+            '@=', $workflow->jobs()->get('pipelineCode')->stepList->get('step0')->config['csv']['extractor']['file_path']
+        );
+    }
+
+    public function testFromApiWithIdIsSuccessful()
+    {
+        $workflowId = new Satellite\Cloud\DTO\WorkflowId('fe8a4711-624d-44ad-a4a5-e578427a7887');
+
+        $result = Satellite\Cloud\Workflow::fromApiWithId(
+            GetWorkflowItem::create(),
+            $workflowId
+        );
+
+        $this->assertInstanceOf(Satellite\Cloud\DTO\ReferencedWorkflow::class, $result);
+        $this->assertEquals('fe8a4711-624d-44ad-a4a5-e578427a7887', $result->id()->asString());
+    }
+
+    public function testFromApiWithIdThrowException()
+    {
+        $workflowId = new Satellite\Cloud\DTO\WorkflowId('fe8a4711-624d-44ad-a4a5-e578427a7887');
+
+        $this->expectException(Satellite\Cloud\AccessDeniedException::class);
+        $this->expectExceptionMessage('Could not retrieve the workflow.');
+
+        Satellite\Cloud\Workflow::fromApiWithId(
+            GetWorkflowItemThrowNotFoundException::create(),
+            $workflowId
+        );
+    }
+
+    public function testCreate()
+    {
+        $workflow = new Satellite\Cloud\Workflow(
+            new DummyContext()
+        );
+
+        $commandBatch = $workflow->create(
+            new Satellite\Cloud\DTO\Workflow(
+                'Test Workflow',
+                'test_workflow',
+                new Satellite\Cloud\DTO\JobList(),
+                new Satellite\Cloud\DTO\Composer(
+                    new Satellite\Cloud\DTO\Autoload(),
+                    new Satellite\Cloud\DTO\PackageList(),
+                    new Satellite\Cloud\DTO\RepositoryList(),
+                    new Satellite\Cloud\DTO\AuthList(),
+                ),
+            )
+        );
+
+        $this->assertInstanceOf(Satellite\Cloud\DTO\CommandBatch::class, $commandBatch);
+        $this->assertCount(1, $commands = $commandBatch->getIterator());
+
+        $this->assertInstanceOf(Satellite\Cloud\Command\Workflow\DeclareWorkflowCommand::class, $commands[0]);
+    }
+
+    public function testUpdate()
+    {
+        $workflow = new Satellite\Cloud\Workflow(
+            new DummyContext()
+        );
+
+        $commandBatch = $workflow->update(
+            new Satellite\Cloud\DTO\ReferencedWorkflow(
+                new Satellite\Cloud\DTO\WorkflowId('fe8a4711-624d-44ad-a4a5-e578427a7887'),
+                new Satellite\Cloud\DTO\Workflow(
+                    'Test Workflow',
+                    'test_workflow',
+                    new Satellite\Cloud\DTO\JobList(),
+                    new Satellite\Cloud\DTO\Composer(
+                        new Satellite\Cloud\DTO\Autoload(),
+                        new Satellite\Cloud\DTO\PackageList(),
+                        new Satellite\Cloud\DTO\RepositoryList(),
+                        new Satellite\Cloud\DTO\AuthList(),
+                    ),
+                ),
+            ),
+            new Satellite\Cloud\DTO\Workflow(
+                'Test Workflow',
+                'test_workflow',
+                new Satellite\Cloud\DTO\JobList(
+                    new Satellite\Cloud\DTO\Workflow\Pipeline(
+                        'Extract product from csv',
+                        new Satellite\Cloud\DTO\JobCode('csv.extractor'),
+                        new Satellite\Cloud\DTO\StepList(),
+                        0
+                    )
+                ),
+                new Satellite\Cloud\DTO\Composer(
+                    new Satellite\Cloud\DTO\Autoload(),
+                    new Satellite\Cloud\DTO\PackageList(),
+                    new Satellite\Cloud\DTO\RepositoryList(),
+                    new Satellite\Cloud\DTO\AuthList(),
+                ),
+            ),
+        );
+
+        $this->assertInstanceOf(Satellite\Cloud\DTO\CommandBatch::class, $commandBatch);
+        $this->assertCount(1, $commands = $commandBatch->getIterator());
+
+        $this->assertInstanceOf(Satellite\Cloud\Command\Workflow\PrependWorkflowJobCommand::class, $commands[0]);
+    }
+
+    public function testRemove()
+    {
+        $workflow = new Satellite\Cloud\Workflow(
+            new DummyContext()
+        );
+
+        $commandBatch = $workflow->remove(
+            new Satellite\Cloud\DTO\WorkflowId('fe8a4711-624d-44ad-a4a5-e578427a7887')
+        );
+
+        $this->assertInstanceOf(Satellite\Cloud\DTO\CommandBatch::class, $commandBatch);
+        $this->assertCount(1, $commands = $commandBatch->getIterator());
+
+        $this->assertInstanceOf(Satellite\Cloud\Command\Workflow\RemoveWorkflowCommand::class, $commands[0]);
+    }
+
+    public static function assertStringNotStartsWith(mixed $needle, string $haystack, string $message = ''): void
+    {
+        $constraint = new LogicalNot(
+            new StringStartsWith($needle),
+        );
+
+        static::assertThat($haystack, $constraint, $message);
+    }
+}