Proof of Concept for storable resources

Author: WyriHaximus

examples/repository-extra-hydrate-refresh-async.php

@@ -0,0 +1,40 @@
+<?php declare(strict_types=1);
+use ApiClients\Client\Travis\AsyncClient;
+use ApiClients\Client\Travis\Resource\RepositoryInterface;
+use React\EventLoop\Factory;
+use function ApiClients\Foundation\resource_pretty_print;
+
+require dirname(__DIR__) . DIRECTORY_SEPARATOR . 'vendor/autoload.php';
+
+$loop   = Factory::create();
+$client = AsyncClient::create($loop);
+
+$repos = [
+    'WyriHaximus/php-travis-client',
+];
+
+if (count($argv) > 1) {
+    unset($argv[0]);
+    foreach ($argv as $repo) {
+        $repos[] = $repo;
+    }
+}
+
+foreach ($repos as $repo) {
+    $client->repository($repo)->then(function (RepositoryInterface $repo) use ($client) {
+        resource_pretty_print($repo);
+        return $client->extract($repo);
+    })->then(function (array $json) use ($client) {
+        var_export($json);
+        return $client->hydrate($json);
+    })->then(function (RepositoryInterface $repo) {
+        resource_pretty_print($repo);
+        return $repo->refresh();
+    })->done(function (RepositoryInterface $repo) {
+        resource_pretty_print($repo);
+    }, function ($e) {
+        echo (string)$e;
+    });
+}
+
+$loop->run();

src/AsyncClient.php

@@ -6,13 +6,17 @@
 use ApiClients\Client\Travis\Resource\HookInterface;
 use ApiClients\Foundation\ClientInterface;
 use ApiClients\Foundation\Factory;
+use ApiClients\Foundation\Hydrator\CommandBus\Command\ExtractFQCNCommand;
+use ApiClients\Foundation\Hydrator\CommandBus\Command\HydrateFQCNCommand;
+use ApiClients\Foundation\Resource\ResourceInterface;
 use React\EventLoop\LoopInterface;
 use React\Promise\CancellablePromiseInterface;
 use React\Promise\PromiseInterface;
 use Rx\ObservableInterface;
 use Rx\React\Promise;
 use Rx\Scheduler;
 use function ApiClients\Tools\Rx\unwrapObservableFromPromise;
+use function React\Promise\resolve;
 
 final class AsyncClient implements AsyncClientInterface
 {
@@ -55,6 +59,26 @@ public static function create(
         return new self($client);
     }
 
+    public function hydrate(array $resource)
+    {
+        $class = $resource['class'];
+        $json = $resource['json'];
+        return $this->client->handle(new HydrateFQCNCommand($class, $json));
+    }
+
+    public function extract(ResourceInterface $resource)
+    {
+        $class = get_class($resource);
+        return $this->client->handle(
+            new ExtractFQCNCommand($class, $resource)
+        )->then(function ($json) use ($class) {
+            return resolve([
+                'class' => $class,
+                'json' => $json,
+            ]);
+        });
+    }
+
     /**
      * Create an AsyncClient from a ApiClients\Foundation\ClientInterface.
      * Be sure to pass in a client with the options from ApiSettings and the Async namespace suffix.