Merge pull request #35 from shahmal1yev/bss-94

[BSS-94] Add support for handling blobs via array

.gitignore

@@ -107,7 +107,7 @@ fabric.properties
 
 # PHPUnit
 /app/phpunit.xml
-
+phpunit.dist.xml
 # Build data
 /build/
 

phpunit.xml

@@ -24,4 +24,5 @@
             <directory suffix=".php">src</directory>
         </include>
     </coverage>
+
 </phpunit>

src/Contracts/DataModel/BlobContract.php

@@ -9,6 +9,7 @@ interface BlobContract extends Stringable, \JsonSerializable
 {
     public static function viaFile(FileSupport $file): BlobContract;
     public static function viaBinary(string $binary): BlobContract;
+    public static function viaArray(array $blobContent): BlobContract;
 
     public function size(): int;
     public function mimeType(): string;

src/Contracts/DataModel/BlobHandler.php

@@ -2,7 +2,9 @@
 
 namespace Atproto\Contracts\DataModel;
 
-interface BlobHandler
+use Atproto\Contracts\Stringable;
+
+interface BlobHandler extends Stringable
 {
     public function size(): int;
     public function mimeType(): string;

src/DataModel/Blob/ArrayBlobHandler.php

@@ -0,0 +1,46 @@
+<?php
+
+namespace Atproto\DataModel\Blob;
+
+use Atproto\Contracts\DataModel\BlobHandler;
+use Atproto\Exceptions\InvalidArgumentException;
+use Atproto\Support\Arr;
+
+class ArrayBlobHandler implements BlobHandler
+{
+    private array $blob;
+
+    /**
+     * @throws InvalidArgumentException
+     */
+    public function __construct(array $blob)
+    {
+        $this->blob = $blob;
+
+        if (! isset($this->blob['size'], $this->blob['mimeType'], $this->blob['ref']['$link'])) {
+            throw new InvalidArgumentException(
+                "ArrayBlobHandler requires 'ref.\$link', 'mimeType', and 'size' fields."
+            );
+        }
+    }
+
+    public function size(): int
+    {
+        return Arr::get($this->blob, 'size');
+    }
+
+    public function mimeType(): string
+    {
+        return Arr::get($this->blob, 'mimeType');
+    }
+
+    public function content(): string
+    {
+        throw new \LogicException("Content does not exists for array blob handler.");
+    }
+
+    public function __toString(): string
+    {
+        return Arr::get($this->blob, 'ref.$link');
+    }
+}

src/DataModel/Blob/BinaryBlobHandler.php

@@ -4,11 +4,15 @@
 
 use Atproto\Contracts\DataModel\BlobHandler;
 use Atproto\Exceptions\InvalidArgumentException;
+use Atproto\IPFS\CID\CID;
+use Atproto\IPFS\MultiFormats\MultiBase\MultiBase;
+use Atproto\IPFS\MultiFormats\MultiCodec;
 use finfo;
 
 class BinaryBlobHandler implements BlobHandler
 {
     private string $binary;
+    private CID $cid;
 
     /**
      * @throws InvalidArgumentException
@@ -20,6 +24,12 @@ public function __construct(string $binary)
         }
 
         $this->binary = $binary;
+
+        $this->cid = new CID(
+            MultiCodec::get('raw'),
+            MultiBase::get('base32'),
+            $this->binary
+        );
     }
 
     private function isBinary(string $binary): bool
@@ -41,4 +51,9 @@ public function content(): string
     {
         return $this->binary;
     }
+
+    public function __toString(): string
+    {
+        return $this->cid->__toString();
+    }
 }

src/DataModel/Blob/Blob.php

@@ -17,11 +17,6 @@ class Blob implements BlobContract
     private function __construct(BlobHandler $handler)
     {
         $this->handler = $handler;
-        $this->cid = new CID(
-            MultiCodec::get('raw'),
-            MultiBase::get('base32'),
-            $handler->content()
-        );
     }
 
     public static function viaBinary(string $binary): BlobContract
@@ -34,6 +29,11 @@ public static function viaFile(FileSupport $file): BlobContract
         return new self(new FileBlobHandler($file));
     }
 
+    public static function viaArray(array $blobContent): BlobContract
+    {
+        return new self(new ArrayBlobHandler($blobContent));
+    }
+
     public function size(): int
     {
         return $this->handler->size();
@@ -51,7 +51,7 @@ public function __toString(): string
 
     public function link(): string
     {
-        return $this->cid->__toString();
+        return $this->handler->__toString();
     }
 
     public function jsonSerialize(): array

src/DataModel/Blob/FileBlobHandler.php

@@ -4,12 +4,19 @@
 
 use Atproto\Contracts\DataModel\BlobHandler;
 use Atproto\Exceptions\InvalidArgumentException;
+use Atproto\IPFS\CID\CID;
+use Atproto\IPFS\MultiFormats\MultiBase\MultiBase;
+use Atproto\IPFS\MultiFormats\MultiCodec;
 use Atproto\Support\FileSupport;
 
 class FileBlobHandler implements BlobHandler
 {
     private FileSupport $file;
+    private CID $cid;
 
+    /**
+     * @throws InvalidArgumentException
+     */
     public function __construct(FileSupport $file)
     {
         if (! $file->exists()) {
@@ -25,6 +32,12 @@ public function __construct(FileSupport $file)
         }
 
         $this->file = $file;
+
+        $this->cid = new CID(
+            MultiCodec::get('raw'),
+            MultiBase::get('base32'),
+            $this->file->getBlob()
+        );
     }
 
     public function size(): int
@@ -41,4 +54,9 @@ public function content(): string
     {
         return $this->file->getBlob();
     }
+
+    public function __toString(): string
+    {
+        return $this->cid->__toString();
+    }
 }

tests/Unit/DataModel/Blob/BlobTest.php

@@ -140,4 +140,55 @@ public function createSchema(string $link, string $mimeType = null): array
             'size' => 7,
         ];
     }
+
+    public function testViaArrayConstructorWorkingCorrectly(): void
+    {
+        $blobContent = [
+            'ref' => ['$link' => 'mock-link'],
+            'mimeType' => 'application/json',
+            'size' => 1024,
+        ];
+
+        $blob = Blob::viaArray($blobContent);
+
+        $this->assertSame(1024, $blob->size());
+        $this->assertSame('application/json', $blob->mimeType());
+        $this->assertSame('mock-link', $blob->link());
+    }
+
+    public function testViaArrayConstructorThrowsExceptionForMissingFields(): void
+    {
+        $this->expectException(InvalidArgumentException::class);
+        $this->expectExceptionMessage(
+            "ArrayBlobHandler requires 'ref.\$link', 'mimeType', and 'size' fields."
+        );
+
+        Blob::viaArray([
+            'mimeType' => 'application/json',
+            'size' => 1024,
+            // 'ref.$link' missing
+        ]);
+    }
+
+    public function testJsonSerializeForArrayBlob(): void
+    {
+        $blobContent = [
+            'ref' => ['$link' => 'mock-link'],
+            'mimeType' => 'application/json',
+            'size' => 1024,
+        ];
+
+        $blob = Blob::viaArray($blobContent);
+
+        $expectedSerialization = [
+            '$type' => 'blob',
+            'ref' => [
+                '$link' => 'mock-link',
+            ],
+            'mimeType' => 'application/json',
+            'size' => 1024,
+        ];
+
+        $this->assertSame($expectedSerialization, $blob->jsonSerialize());
+    }
 }