Fetch status of and add github repositories

Author: WyriHaximus

examples/add-repository-async.php

@@ -0,0 +1,17 @@
+<?php declare(strict_types=1);
+
+use ApiClients\Client\Scrutinizer\AsyncClient;
+use React\EventLoop\Factory;
+
+require dirname(__DIR__) . DIRECTORY_SEPARATOR . 'vendor/autoload.php';
+
+$loop = Factory::create();
+$client = AsyncClient::create($loop, require __DIR__ . DIRECTORY_SEPARATOR . 'resolve_token.php');
+
+$client->github()->addRepository('php-api-clients/scrutinizer')->done(function ($response) {
+    var_export($response);
+}, function ($error) {
+    var_export($error->getResponse());
+});
+
+$loop->run();

examples/repository-async.php

@@ -0,0 +1,17 @@
+<?php declare(strict_types=1);
+
+use ApiClients\Client\Scrutinizer\AsyncClient;
+use ApiClients\Client\Scrutinizer\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, require __DIR__ . DIRECTORY_SEPARATOR . 'resolve_token.php');
+
+$client->github()->repository('php-api-clients', 'scrutinizer')->done(function (RepositoryInterface $meta) {
+    resource_pretty_print($meta);
+});
+
+$loop->run();

examples/resolve_token.php

@@ -0,0 +1,10 @@
+<?php declare(strict_types=1);
+
+$keyFile = dirname(__DIR__) . DIRECTORY_SEPARATOR . 'token.php';
+
+if (!file_exists($keyFile)) {
+    echo 'No key file find, copy token.sample.php to token.php and add a token from https://scrutinizer-ci.com/profile/applications to run examples.', PHP_EOL;
+    exit(1);
+}
+
+return require $keyFile;

src/AsyncClient.php

@@ -5,6 +5,8 @@
 namespace ApiClients\Client\Scrutinizer;
 
 use ApiClients\Client\Scrutinizer\CommandBus\Command\MetaCommand;
+use ApiClients\Client\Scrutinizer\Github\AsyncClient as AsyncGithubClient;
+use ApiClients\Client\Scrutinizer\Github\AsyncClientInterface as AsyncGithubClientInterface;
 use ApiClients\Foundation\ClientInterface;
 use ApiClients\Foundation\Factory;
 use ApiClients\Foundation\Resource\ResourceInterface;
@@ -32,9 +34,9 @@ private function __construct(ClientInterface $client)
      * @param  array         $options
      * @return AsyncClient
      */
-    public static function create(LoopInterface $loop, array $options = []): self
+    public static function create(LoopInterface $loop, string $token, array $options = []): self
     {
-        $options = ApiSettings::getOptions($options, 'Async');
+        $options = ApiSettings::getOptions($token, $options, 'Async');
         $client = Factory::create($loop, $options);
 
         return new self($client);
@@ -64,4 +66,9 @@ public function meta(): PromiseInterface
     {
         return $this->client->handle(new MetaCommand());
     }
+
+    public function github(): AsyncGithubClientInterface
+    {
+        return new AsyncGithubClient($this->client);
+    }
 }

src/AsyncClientInterface.php

@@ -4,9 +4,12 @@
 
 namespace ApiClients\Client\Scrutinizer;
 
+use ApiClients\Client\Scrutinizer\Github\AsyncClientInterface as AsyncGithubClientInterface;
 use React\Promise\PromiseInterface;
 
 interface AsyncClientInterface
 {
+    public function github(): AsyncGithubClientInterface;
+
     public function meta(): PromiseInterface;
 }

src/CommandBus/Command/Github/AddRepositoryCommand.php

@@ -0,0 +1,34 @@
+<?php
+
+declare(strict_types=1);
+
+namespace ApiClients\Client\Scrutinizer\CommandBus\Command\Github;
+
+use WyriHaximus\Tactician\CommandHandler\Annotations\Handler;
+
+/**
+ * @Handler("ApiClients\Client\Scrutinizer\CommandBus\Handler\Github\AddRepositoryHandler")
+ */
+final class AddRepositoryCommand
+{
+    /**
+     * @var string
+     */
+    private $name;
+
+    /**
+     * @param string $name
+     */
+    public function __construct(string $name)
+    {
+        $this->name = $name;
+    }
+
+    /**
+     * @return string
+     */
+    public function getName(): string
+    {
+        return $this->name;
+    }
+}

src/CommandBus/Command/Github/RepositoryCommand.php

@@ -0,0 +1,49 @@
+<?php
+
+declare(strict_types=1);
+
+namespace ApiClients\Client\Scrutinizer\CommandBus\Command\Github;
+
+use WyriHaximus\Tactician\CommandHandler\Annotations\Handler;
+
+/**
+ * @Handler("ApiClients\Client\Scrutinizer\CommandBus\Handler\Github\RepositoryHandler")
+ */
+final class RepositoryCommand
+{
+    /**
+     * @var string
+     */
+    private $login;
+
+    /**
+     * @var string
+     */
+    private $name;
+
+    /**
+     * @param string $login
+     * @param string $name
+     */
+    public function __construct(string $login, string $name)
+    {
+        $this->login = $login;
+        $this->name = $name;
+    }
+
+    /**
+     * @return string
+     */
+    public function getLogin(): string
+    {
+        return $this->login;
+    }
+
+    /**
+     * @return string
+     */
+    public function getName(): string
+    {
+        return $this->name;
+    }
+}

src/CommandBus/Handler/Github/AddRepositoryHandler.php

@@ -0,0 +1,58 @@
+<?php
+
+declare(strict_types=1);
+
+namespace ApiClients\Client\Scrutinizer\CommandBus\Handler\Github;
+
+use ApiClients\Client\Scrutinizer\CommandBus\Command\Github\AddRepositoryCommand;
+use ApiClients\Client\Scrutinizer\Resource\RepositoryInterface;
+use ApiClients\Foundation\Hydrator\Hydrator;
+use ApiClients\Foundation\Transport\Service\RequestService;
+use ApiClients\Middleware\Json\JsonStream;
+use React\Promise\PromiseInterface;
+use RingCentral\Psr7\Request;
+
+final class AddRepositoryHandler
+{
+    /**
+     * @var RequestService
+     */
+    private $requestService;
+
+    /**
+     * @var Hydrator
+     */
+    private $hydrator;
+
+    /**
+     * @param RequestService $requestService
+     * @param Hydrator       $hydrator
+     */
+    public function __construct(RequestService $requestService, Hydrator $hydrator)
+    {
+        $this->requestService = $requestService;
+        $this->hydrator = $hydrator;
+    }
+
+    /**
+     * Fetch the given repository and hydrate it.
+     *
+     * @param  AddRepositoryCommand $command
+     * @return PromiseInterface
+     */
+    public function handle(AddRepositoryCommand $command): PromiseInterface
+    {
+        return $this->requestService->request(
+            new Request(
+                'POST',
+                'repositories/g',
+                [],
+                new JsonStream([
+                    'name' => $command->getName(),
+                ])
+            )
+        )->then(function ($repository) {
+            return $this->hydrator->hydrate(RepositoryInterface::HYDRATE_CLASS, $repository->getBody()->getJson());
+        });
+    }
+}

src/CommandBus/Handler/Github/RepositoryHandler.php

@@ -0,0 +1,41 @@
+<?php
+
+declare(strict_types=1);
+
+namespace ApiClients\Client\Scrutinizer\CommandBus\Handler\Github;
+
+use ApiClients\Client\Scrutinizer\CommandBus\Command\Github\RepositoryCommand;
+use ApiClients\Client\Scrutinizer\Resource\RepositoryInterface;
+use ApiClients\Tools\Services\Client\FetchAndHydrateService;
+use React\Promise\PromiseInterface;
+
+final class RepositoryHandler
+{
+    /**
+     * @var FetchAndHydrateService
+     */
+    private $service;
+
+    /**
+     * @param FetchAndHydrateService $service
+     */
+    public function __construct(FetchAndHydrateService $service)
+    {
+        $this->service = $service;
+    }
+
+    /**
+     * Fetch the given repository and hydrate it.
+     *
+     * @param  RepositoryCommand $command
+     * @return PromiseInterface
+     */
+    public function handle(RepositoryCommand $command): PromiseInterface
+    {
+        return $this->service->fetch(
+            'repositories/g/' . $command->getLogin() . '/' . $command->getName(),
+            '',
+            RepositoryInterface::HYDRATE_CLASS
+        );
+    }
+}

src/Github/AsyncClient.php

@@ -0,0 +1,48 @@
+<?php
+
+declare(strict_types=1);
+
+namespace ApiClients\Client\Scrutinizer\Github;
+
+use ApiClients\Client\Scrutinizer\CommandBus\Command\Github\AddRepositoryCommand;
+use ApiClients\Client\Scrutinizer\CommandBus\Command\Github\RepositoryCommand;
+use ApiClients\Foundation\ClientInterface as FoundationClientInterface;
+use ApiClients\Foundation\Resource\ResourceInterface;
+use React\Promise\CancellablePromiseInterface;
+use React\Promise\PromiseInterface;
+
+final class AsyncClient implements AsyncClientInterface
+{
+    /**
+     * @var FoundationClientInterface
+     */
+    protected $client;
+
+    /**
+     * @param FoundationClientInterface $client
+     */
+    public function __construct(FoundationClientInterface $client)
+    {
+        $this->client = $client;
+    }
+
+    public function hydrate(string $resource): CancellablePromiseInterface
+    {
+        return $this->client->hydrate($resource);
+    }
+
+    public function extract(ResourceInterface $resource): CancellablePromiseInterface
+    {
+        return $this->client->extract($resource);
+    }
+
+    public function repository(string $login, string $name): PromiseInterface
+    {
+        return $this->client->handle(new RepositoryCommand($login, $name));
+    }
+
+    public function addRepository(string $name): PromiseInterface
+    {
+        return $this->client->handle(new AddRepositoryCommand($name));
+    }
+}