Merge pull request #17 from php-api-clients/storable-resources

Storable resources

Author: WyriHaximus

src/Client.php

@@ -2,9 +2,14 @@
 
 namespace ApiClients\Foundation;
 
+use ApiClients\Foundation\Hydrator\CommandBus\Command\ExtractFQCNCommand;
+use ApiClients\Foundation\Hydrator\CommandBus\Command\HydrateFQCNCommand;
+use ApiClients\Foundation\Resource\ResourceInterface;
 use ApiClients\Tools\CommandBus\CommandBusInterface;
+use InvalidArgumentException;
 use Psr\Container\ContainerInterface;
 use React\Promise\CancellablePromiseInterface;
+use function React\Promise\resolve;
 
 final class Client implements ClientInterface
 {
@@ -51,4 +56,33 @@ public function handle($command): CancellablePromiseInterface
     {
         return $this->commandBus->handle($command);
     }
+
+    public function hydrate(string $resource): CancellablePromiseInterface
+    {
+        $resource = json_decode($resource, true);
+        if (!isset($resource['class'], $resource['properties'])) {
+            throw new InvalidArgumentException();
+        }
+
+        if (!class_exists($resource['class'])) {
+            throw new InvalidArgumentException();
+        }
+
+        $class = $resource['class'];
+        $json = $resource['properties'];
+        return $this->handle(new HydrateFQCNCommand($class, $json));
+    }
+
+    public function extract(ResourceInterface $resource): CancellablePromiseInterface
+    {
+        $class = get_class($resource);
+        return $this->handle(
+            new ExtractFQCNCommand($class, $resource)
+        )->then(function ($json) use ($class) {
+            return resolve(json_encode([
+                'class' => $class,
+                'properties' => $json,
+            ]));
+        });
+    }
 }

tests/ClientTest.php

@@ -3,6 +3,9 @@
 namespace ApiClients\Tests\Foundation;
 
 use ApiClients\Foundation\Client;
+use ApiClients\Foundation\Hydrator\CommandBus\Command\ExtractFQCNCommand;
+use ApiClients\Foundation\Hydrator\CommandBus\Command\HydrateFQCNCommand;
+use ApiClients\Foundation\Resource\ResourceInterface;
 use ApiClients\Tools\CommandBus\CommandBus;
 use ApiClients\Tools\CommandBus\CommandBusInterface;
 use ApiClients\Tools\TestUtilities\TestCase;
@@ -57,4 +60,44 @@ public function testCommandBusMissing()
     {
         new Client(ContainerBuilder::buildDevContainer());
     }
+
+    public function testHydrate()
+    {
+        $resource = $this->prophesize(ResourceInterface::class)->reveal();
+
+        $commandBus = $this->prophesize(CommandBusInterface::class);
+        $commandBus->handle(new HydrateFQCNCommand('stdClass', []))->shouldBeCalled()->willReturn(resolve($resource));
+
+        $container = ContainerBuilder::buildDevContainer();
+        $container->set(CommandBusInterface::class, $commandBus->reveal());
+        $client = new Client($container);
+
+        $json = json_encode([
+            'class' => 'stdClass',
+            'properties' => [],
+        ]);
+
+        self::assertSame($resource, await($client->hydrate($json), Factory::create()));
+    }
+
+    public function testExtract()
+    {
+        $resource = $this->prophesize(ResourceInterface::class)->reveal();
+
+        $json = json_encode([
+            'class' => get_class($resource),
+            'properties' => [],
+        ]);
+
+        $commandBus = $this->prophesize(CommandBusInterface::class);
+        $commandBus->handle(
+            new ExtractFQCNCommand(get_class($resource), $resource)
+        )->shouldBeCalled()->willReturn(resolve([]));
+
+        $container = ContainerBuilder::buildDevContainer();
+        $container->set(CommandBusInterface::class, $commandBus->reveal());
+        $client = new Client($container);
+
+        self::assertSame($json, await($client->extract($resource), Factory::create()));
+    }
 }