Ping webhook

Author: WyriHaximus

src/CommandBus/Command/PingWebHookCommand.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\PingWebHookHandler")
+ */
+final class PingWebHookCommand
+{
+    /**
+     * @var string
+     */
+    private $pingUrl;
+
+    /**
+     * @param string $pingUrl
+     */
+    public function __construct(string $pingUrl)
+    {
+        $this->pingUrl = $pingUrl;
+    }
+
+    /**
+     * @return string
+     */
+    public function getPingUrl(): string
+    {
+        return $this->pingUrl;
+    }
+}

src/CommandBus/Handler/PingWebHookHandler.php

@@ -0,0 +1,36 @@
+<?php declare(strict_types=1);
+
+namespace ApiClients\Client\Github\CommandBus\Handler;
+
+use ApiClients\Client\Github\CommandBus\Command\PingWebHookCommand;
+use ApiClients\Foundation\Transport\Service\RequestService;
+use Psr\Http\Message\ResponseInterface;
+use React\Promise\PromiseInterface;
+
+final class PingWebHookHandler
+{
+    /**
+     * @var RequestService
+     */
+    private $requestService;
+
+    /**
+     * @param RequestService $requestService
+     */
+    public function __construct(RequestService $requestService)
+    {
+        $this->requestService = $requestService;
+    }
+
+    /**
+     * @param  PingWebHookCommand $command
+     * @return PromiseInterface
+     */
+    public function handle(PingWebHookCommand $command): PromiseInterface
+    {
+        return $this->requestService->request($command->getPingUrl())
+            ->then(function (ResponseInterface $response) {
+                return $response->getStatusCode() == 204;
+            });
+    }
+}

src/Resource/Async/WebHook.php

@@ -2,12 +2,21 @@
 
 namespace ApiClients\Client\Github\Resource\Async;
 
+use ApiClients\Client\Github\CommandBus\Command\PingWebHookCommand;
 use ApiClients\Client\Github\Resource\WebHook as BaseWebHook;
+use React\Promise\PromiseInterface;
 
 class WebHook extends BaseWebHook
 {
     public function refresh(): WebHook
     {
         throw new \Exception('TODO: create refresh method!');
     }
+
+    public function ping(): PromiseInterface
+    {
+        return $this->handleCommand(
+            new PingWebHookCommand($this->pingUrl())
+        );
+    }
 }

tests/CommandBus/Handler/PingWebhookHandlerTest.php

@@ -0,0 +1,51 @@
+<?php declare(strict_types=1);
+
+namespace ApiClients\Tests\Github\CommandBus\Handler;
+
+use ApiClients\Client\Github\CommandBus\Command\SaveCommand;
+use ApiClients\Client\Github\CommandBus\Handler\SaveHandler;
+use ApiClients\Client\Github\Resource\OrganizationInterface;
+use ApiClients\Foundation\Hydrator\Hydrator;
+use ApiClients\Foundation\Resource\ResourceInterface;
+use ApiClients\Foundation\Transport\Service\RequestService;
+use ApiClients\Middleware\Json\JsonStream;
+use ApiClients\Tools\TestUtilities\TestCase;
+use RingCentral\Psr7\Request;
+use RingCentral\Psr7\Response;
+use function React\Promise\resolve;
+
+final class PingWebhookHandlerTest extends TestCase
+{
+    public function testCommand()
+    {
+        $url = 'url';
+        $data = [];
+
+        $request = new Request(
+            'PATCH',
+            $url,
+            [],
+            new JsonStream($data)
+        );
+        $response = new Response(
+            200,
+            [],
+            new JsonStream($data)
+        );
+
+        $resource = $this->prophesize(ResourceInterface::class)->reveal();
+
+        $service = $this->prophesize(RequestService::class);
+        $service->request($request)->shouldBeCalled()->willReturn(resolve($response));
+
+        $hydrator = $this->prophesize(Hydrator::class);
+        $hydrator->hydrate(OrganizationInterface::HYDRATE_CLASS, $data)->shouldBeCalled()->willReturn($resource);
+
+        $handler = new SaveHandler($service->reveal(), $hydrator->reveal());
+        $handler->handle(new SaveCommand(
+            OrganizationInterface::HYDRATE_CLASS,
+            $data,
+            $url
+        ));
+    }
+}