Renamed PingWebHook* to WebHook\Ping*

Author: WyriHaximus

src/CommandBus/Command/PingWebHookCommand.php renamed to src/CommandBus/Command/WebHook/PingCommand.php

@@ -1,13 +1,13 @@
 <?php declare(strict_types=1);
 
-namespace ApiClients\Client\Github\CommandBus\Command;
+namespace ApiClients\Client\Github\CommandBus\Command\WebHook;
 
 use WyriHaximus\Tactician\CommandHandler\Annotations\Handler;
 
 /**
- * @Handler("ApiClients\Client\Github\CommandBus\Handler\PingWebHookHandler")
+ * @Handler("ApiClients\Client\Github\CommandBus\Handler\WebHook\PingHandler")
  */
-final class PingWebHookCommand
+final class PingCommand
 {
     /**
      * @var string

src/CommandBus/Handler/PingWebHookHandler.php

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

src/CommandBus/Handler/WebHook/PingHandler.php

@@ -2,7 +2,7 @@
 
 namespace ApiClients\Client\Github\Resource\Async;
 
-use ApiClients\Client\Github\CommandBus\Command\PingWebHookCommand;
+use ApiClients\Client\Github\CommandBus\Command\WebHook\PingCommand;
 use ApiClients\Client\Github\Resource\WebHook as BaseWebHook;
 use React\Promise\PromiseInterface;
 
@@ -16,7 +16,7 @@ public function refresh(): WebHook
     public function ping(): PromiseInterface
     {
         return $this->handleCommand(
-            new PingWebHookCommand($this->pingUrl())
+            new PingCommand($this->pingUrl())
         );
     }
 }

src/Resource/Async/WebHook.php

@@ -0,0 +1,46 @@
+<?php declare(strict_types=1);
+
+namespace ApiClients\Tests\Github\CommandBus\Handler\WebHook;
+
+use ApiClients\Client\Github\CommandBus\Command\WebHook\PingCommand;
+use ApiClients\Client\Github\CommandBus\Handler\WebHook\PingHandler;
+use ApiClients\Foundation\Transport\Service\RequestService;
+use ApiClients\Tools\TestUtilities\TestCase;
+use RingCentral\Psr7\Request;
+use RingCentral\Psr7\Response;
+use function React\Promise\resolve;
+
+final class PingHandlerTest extends TestCase
+{
+    public function testCommand()
+    {
+        $url = 'url';
+
+        $request = new Request('POST', $url);
+        $response = new Response(204);
+
+        $service = $this->prophesize(RequestService::class);
+        $service->request($request)->shouldBeCalled()->willReturn(resolve($response));
+
+        $handler = new PingHandler($service->reveal());
+        self::assertTrue($this->await($handler->handle(new PingCommand(
+            $url
+        ))));
+    }
+
+    public function testCommandError()
+    {
+        $url = 'url';
+
+        $request = new Request('POST', $url);
+        $response = new Response(500);
+
+        $service = $this->prophesize(RequestService::class);
+        $service->request($request)->shouldBeCalled()->willReturn(resolve($response));
+
+        $handler = new PingHandler($service->reveal());
+        self::assertFalse($this->await($handler->handle(new PingCommand(
+            $url
+        ))));
+    }
+}