WIP

Author: 4rthem

databox/api/src/Border/UploaderClient.php

@@ -6,9 +6,9 @@
 
 use Symfony\Contracts\HttpClient\HttpClientInterface;
 
-readonly class UploaderClient
+class UploaderClient
 {
-    public function __construct(private HttpClientInterface $client)
+    public function __construct(private readonly HttpClientInterface $client)
     {
     }
 

databox/api/src/Border/UploaderClientMock.php

@@ -7,14 +7,42 @@
 
 #[When('test')]
 #[AsAlias(id: UploaderClient::class)]
-readonly class UploaderClientMock extends UploaderClient
+class UploaderClientMock extends UploaderClient
 {
+    private array $acknowledgedAssets = [];
+
     public function getCommit(string $baseUrl, string $id, string $token): array
     {
         return [
             'id' => $id,
             'userId' => 'test_user',
-            'assets' => [],
+            'assets' => [
+                '42',
+            ],
+        ];
+    }
+
+    public function getAsset(string $baseUrl, string $id, string $token): array
+    {
+        return [
+            'originalName' => 'test_file.txt',
+            'mimeType' => 'text/plain',
+            'size' => 42,
+            'url' => 'http://localhost/path/to/test_file.txt',
+            'data' => [
+            ],
+            'formData' => [
+            ],
         ];
     }
+
+    public function ackAsset(string $baseUrl, string $id, string $token): void
+    {
+        $this->acknowledgedAssets[] = $id;
+    }
+
+    public function getAcknowledgedAssets(): array
+    {
+        return $this->acknowledgedAssets;
+    }
 }

databox/api/src/Border/UriDownloaderMock.php

@@ -0,0 +1,26 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Border;
+
+use Symfony\Component\DependencyInjection\Attribute\AsAlias;
+use Symfony\Component\DependencyInjection\Attribute\When;
+
+#[When('test')]
+#[AsAlias(id: UriDownloader::class)]
+readonly class UriDownloaderMock extends UriDownloader
+{
+    /**
+     * @return string The temporary file path
+     */
+    public function download(string $uri, array &$headers = []): string
+    {
+        $tmpFile = sys_get_temp_dir().'/'.uniqid('incoming-file');
+        $fileHandler = fopen($tmpFile, 'w');
+        fwrite($fileHandler, 'foo');
+        fclose($fileHandler);
+
+        return $tmpFile;
+    }
+}

databox/api/tests/AbstractDataboxTestCase.php

@@ -17,11 +17,6 @@ abstract class AbstractDataboxTestCase extends ApiTestCase
 
     protected static function bootKernel(array $options = []): KernelInterface
     {
-        if (static::$kernel) {
-            return static::$kernel;
-        }
-        static::bootKernelWithFixtures($options);
-
-        return static::$kernel;
+        return static::bootKernelWithFixtures($options);
     }
 }

databox/api/tests/Integration/Aws/Transcribe/AwsTranscribeEventTest.php

@@ -108,12 +108,7 @@ private function assertHasData(string $integrationId, string $name, int $expecte
 
     protected static function bootKernel(array $options = []): KernelInterface
     {
-        if (static::$kernel) {
-            return static::$kernel;
-        }
-        static::bootKernelWithFixtures($options);
-
-        return static::$kernel;
+        return static::bootKernelWithFixtures($options);
     }
 
     public function testNotificationWillBeHandled(): void

databox/api/tests/Integration/Phrasea/Uploader/UploaderIntegrationTest.php

@@ -5,12 +5,16 @@
 use Alchemy\TestBundle\Helper\FixturesTrait;
 use Alchemy\TestBundle\Helper\TestServicesTrait;
 use ApiPlatform\Symfony\Bundle\Test\ApiTestCase;
+use App\Border\UploaderClient;
+use App\Border\UploaderClientMock;
 use App\Entity\Core\Workspace;
 use App\Entity\Integration\WorkspaceIntegration;
 use App\Integration\Phrasea\Uploader\UploaderIntegration;
+use App\Repository\Core\AssetRepository;
 use App\Tests\FileUploadTrait;
 use App\Tests\Rendition\Phraseanet\PhraseanetApiClientFactoryMock;
 use Doctrine\ORM\EntityManagerInterface;
+use Symfony\Component\HttpKernel\KernelInterface;
 
 class UploaderIntegrationTest extends ApiTestCase
 {
@@ -23,8 +27,6 @@ public function testUploaderCanTriggerIntegrationEndpoint(): void
         self::enableFixtures();
         $apiClient = static::createClient();
 
-        $queueName = 'p2';
-        $inMemoryTransport = $this->interceptMessengerEvents($queueName);
         $em = self::getService(EntityManagerInterface::class);
         /** @var PhraseanetApiClientFactoryMock $clientFactory */
 
@@ -65,5 +67,22 @@ public function testUploaderCanTriggerIntegrationEndpoint(): void
             'json' => $payload,
         ]);
         $this->assertEquals(200, $response->getStatusCode());
+
+        $em->clear();
+        $assetRepo = $this->getService(AssetRepository::class);
+        $asset = $assetRepo->findOneBy([
+            'title' => 'test_file.txt',
+        ]);
+        $this->assertNotNull($asset);
+        $this->assertEquals('test_file.txt', $asset->getTitle());
+
+        /** @var UploaderClientMock $uploadClient */
+        $uploadClient = $this->getService(UploaderClient::class);
+        $this->assertCount(1, $uploadClient->getAcknowledgedAssets());
+    }
+
+    protected static function bootKernel(array $options = []): KernelInterface
+    {
+        return static::bootKernelWithFixtures($options);
     }
 }

databox/api/tests/Rendition/Phraseanet/PhraseanetRenditionApiV3SubDefMethodTest.php

@@ -26,12 +26,7 @@ class PhraseanetRenditionApiV3SubDefMethodTest extends ApiTestCase
 
     protected static function bootKernel(array $options = []): KernelInterface
     {
-        if (static::$kernel) {
-            return static::$kernel;
-        }
-        static::bootKernelWithFixtures($options);
-
-        return static::$kernel;
+        return static::bootKernelWithFixtures($options);
     }
 
     public function testApiV3SubDefIsTriggered(): void

databox/api/tests/Rendition/Phraseanet/PhraseanetRenditionEnqueueMethodTest.php

@@ -28,12 +28,7 @@ class PhraseanetRenditionEnqueueMethodTest extends ApiTestCase
 
     protected static function bootKernel(array $options = []): KernelInterface
     {
-        if (static::$kernel) {
-            return static::$kernel;
-        }
-        static::bootKernelWithFixtures($options);
-
-        return static::$kernel;
+        return static::bootKernelWithFixtures($options);
     }
 
     public function testEnqueueIsTriggered(): void

databox/api/tests/Search/SearchTestTrait.php

@@ -20,7 +20,7 @@ trait SearchTestTrait
 
     protected static function bootSearch(KernelInterface $kernel): void
     {
-        $container = static::getContainer() ?? static::$kernel->getContainer();
+        $container = static::getContainer() ?? $kernel->getContainer();
 
         $indexes = [
             'asset',