Webhooks

composer.json

@@ -33,7 +33,7 @@
     "api-clients/middleware-pool": "^3.0",
     "api-clients/resource-generator": "^1.0",
     "api-clients/resource-test-utilities": "^1.0",
-    "api-clients/test-utilities": "^4.1"
+    "api-clients/test-utilities": "^4.3"
   },
   "autoload": {
     "psr-4": {

examples/organization-async.php

@@ -0,0 +1,38 @@
+<?php declare(strict_types=1);
+
+use ApiClients\Client\Github\AsyncClient;
+use ApiClients\Client\Github\Resource\Async\Organization;
+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 'resolve_token.php');
+
+$organizations = [
+    'php-api-clients',
+    'reactphp',
+    'recoilphp',
+];
+
+if (count($argv) > 1) {
+    unset($argv[0]);
+    foreach ($argv as $organization) {
+        $organizations[] = $organization;
+    }
+}
+
+foreach ($organizations as $organization) {
+    $client->organization($organization)->then(function (Organization $user) {
+        resource_pretty_print($user);
+
+        return $user->refresh();
+    })->done(function (Organization $user) {
+        resource_pretty_print($user);
+    }, 'display_throwable');
+}
+
+$loop->run();
+
+displayState($client->getRateLimitState());

examples/organization-webhooks-async.php

@@ -0,0 +1,24 @@
+<?php declare(strict_types=1);
+use ApiClients\Client\Github\AsyncClient;
+use ApiClients\Client\Github\Resource\Async\Organization;
+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 'resolve_token.php');
+
+$client->organization($argv[1] ?? 'php-api-clients')->then(function (Organization $organization) {
+    resource_pretty_print($organization);
+    $organization->webHooks()->subscribe(function ($webHook) {
+        resource_pretty_print($webHook, 2, true);
+    }, function ($error) {
+        echo (string)$error;
+    });
+})->done(null, 'display_throwable');
+
+$loop->run();
+
+displayState($client->getRateLimitState());

examples/user-repositories-webhooks-async.php

@@ -0,0 +1,29 @@
+<?php declare(strict_types=1);
+use ApiClients\Client\Github\AsyncClient;
+use ApiClients\Client\Github\Resource\Async\Repository;
+use ApiClients\Client\Github\Resource\Async\User;
+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 'resolve_token.php');
+
+$client->user($argv[1] ?? 'php-api-clients')->then(function (User $user) use ($argv) {
+    resource_pretty_print($user);
+
+    return $user->repository($argv[2] ?? 'github');
+})->then(function (Repository $repository) {
+    resource_pretty_print($repository, 1, true);
+    $repository->webHooks()->subscribe(function ($webHook) {
+        resource_pretty_print($webHook, 2, true);
+    }, function ($error) {
+        echo (string)$error;
+    });
+})->done(null, 'display_throwable');
+
+$loop->run();
+
+displayState($client->getRateLimitState());

examples/user-repository.php

@@ -0,0 +1,12 @@
+<?php declare(strict_types=1);
+use ApiClients\Client\Github\Client;
+use function ApiClients\Foundation\resource_pretty_print;
+
+require dirname(__DIR__) . DIRECTORY_SEPARATOR . 'vendor/autoload.php';
+
+$client = Client::create(require 'resolve_token.php');
+
+$repository = $client->user($argv[1] ?? 'php-api-clients')->repository($argv[2] ?? 'github');
+resource_pretty_print($repository);
+
+displayState($client->getRateLimitState());

src/AsyncClient.php

@@ -98,6 +98,15 @@ public function user(string $user): PromiseInterface
         return $this->client->handle(new Command\UserCommand($user));
     }
 
+    /**
+     * @param  string           $organization
+     * @return PromiseInterface
+     */
+    public function organization(string $organization): PromiseInterface
+    {
+        return $this->client->handle(new Command\OrganizationCommand($organization));
+    }
+
     /**
      * @return PromiseInterface
      */

src/AsyncClientInterface.php

@@ -29,6 +29,8 @@ public function meta(): PromiseInterface;
 
     public function user(string $user): PromiseInterface;
 
+    public function organization(string $organization): PromiseInterface;
+
     public function whoami(): PromiseInterface;
 
     public function emojis(): Observable;

src/CommandBus/Command/DeleteCommand.php

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

src/CommandBus/Command/Organization/AddWebHookCommand.php

@@ -0,0 +1,92 @@
+<?php declare(strict_types=1);
+
+namespace ApiClients\Client\Github\CommandBus\Command\Organization;
+
+use WyriHaximus\Tactician\CommandHandler\Annotations\Handler;
+
+/**
+ * @Handler("ApiClients\Client\Github\CommandBus\Handler\Organization\AddWebHookHandler")
+ */
+final class AddWebHookCommand
+{
+    /**
+     * @var string
+     */
+    private $organization;
+
+    /**
+     * @var string
+     */
+    private $name;
+
+    /**
+     * @var array
+     */
+    private $config;
+
+    /**
+     * @var array
+     */
+    private $events;
+
+    /**
+     * @var bool
+     */
+    private $active;
+
+    /**
+     * @param string $organization
+     * @param string $name
+     * @param array  $config
+     * @param array  $events
+     * @param bool   $active
+     */
+    public function __construct(string $organization, string $name, array $config, array $events, bool $active)
+    {
+        $this->organization = $organization;
+        $this->name = $name;
+        $this->config = $config;
+        $this->events = $events;
+        $this->active = $active;
+    }
+
+    /**
+     * @return string
+     */
+    public function getOrganization(): string
+    {
+        return $this->organization;
+    }
+
+    /**
+     * @return string
+     */
+    public function getName(): string
+    {
+        return $this->name;
+    }
+
+    /**
+     * @return array
+     */
+    public function getConfig(): array
+    {
+        return $this->config;
+    }
+
+    /**
+     * @return array
+     */
+    public function getEvents(): array
+    {
+        return $this->events;
+    }
+
+    /**
+     * @return bool
+     */
+    public function isActive(): bool
+    {
+        return $this->active;
+    }
+}

src/CommandBus/Command/OrganizationCommand.php

@@ -0,0 +1,32 @@
+<?php declare(strict_types=1);
+
+namespace ApiClients\Client\Github\CommandBus\Command;
+
+use WyriHaximus\Tactician\CommandHandler\Annotations\Handler;
+
+/**
+ * @Handler("ApiClients\Client\Github\CommandBus\Handler\OrganizationHandler")
+ */
+final class OrganizationCommand
+{
+    /**
+     * @var string
+     */
+    private $organization;
+
+    /**
+     * @param string $organization
+     */
+    public function __construct(string $organization = '')
+    {
+        $this->organization = $organization;
+    }
+
+    /**
+     * @return string
+     */
+    public function getOrganization(): string
+    {
+        return $this->organization;
+    }
+}

src/CommandBus/Command/Repository/AddWebHookCommand.php

@@ -0,0 +1,92 @@
+<?php declare(strict_types=1);
+
+namespace ApiClients\Client\Github\CommandBus\Command\Repository;
+
+use WyriHaximus\Tactician\CommandHandler\Annotations\Handler;
+
+/**
+ * @Handler("ApiClients\Client\Github\CommandBus\Handler\Repository\AddWebHookHandler")
+ */
+final class AddWebHookCommand
+{
+    /**
+     * @var string
+     */
+    private $repository;
+
+    /**
+     * @var string
+     */
+    private $name;
+
+    /**
+     * @var array
+     */
+    private $config;
+
+    /**
+     * @var array
+     */
+    private $events;
+
+    /**
+     * @var bool
+     */
+    private $active;
+
+    /**
+     * @param string $repository
+     * @param string $name
+     * @param array  $config
+     * @param array  $events
+     * @param bool   $active
+     */
+    public function __construct(string $repository, string $name, array $config, array $events, bool $active)
+    {
+        $this->repository = $repository;
+        $this->name = $name;
+        $this->config = $config;
+        $this->events = $events;
+        $this->active = $active;
+    }
+
+    /**
+     * @return string
+     */
+    public function getRepository(): string
+    {
+        return $this->repository;
+    }
+
+    /**
+     * @return string
+     */
+    public function getName(): string
+    {
+        return $this->name;
+    }
+
+    /**
+     * @return array
+     */
+    public function getConfig(): array
+    {
+        return $this->config;
+    }
+
+    /**
+     * @return array
+     */
+    public function getEvents(): array
+    {
+        return $this->events;
+    }
+
+    /**
+     * @return bool
+     */
+    public function isActive(): bool
+    {
+        return $this->active;
+    }
+}