Org add webhook

Author: WyriHaximus

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 $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->organization = $repository;
+        $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/Handler/Organization/AddWebHookHandler.php

@@ -0,0 +1,57 @@
+<?php declare(strict_types=1);
+
+namespace ApiClients\Client\Github\CommandBus\Handler\Organization;
+
+use ApiClients\Client\Github\CommandBus\Command\Organization\AddWebHookCommand;
+use ApiClients\Client\Github\Resource\WebHookInterface;
+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 AddWebHookHandler
+{
+    /**
+     * @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;
+    }
+
+    /**
+     * @param  AddWebHookCommand $command
+     * @return PromiseInterface
+     */
+    public function handle(AddWebHookCommand $command): PromiseInterface
+    {
+        return $this->requestService->request(
+            new Request(
+                'POST',
+                'orgs/' . $command->getOrganization() . '/hooks',
+                [],
+                new JsonStream([
+                    'name'   => $command->getName(),
+                    'config' => $command->getConfig(),
+                    'events' => $command->getEvents(),
+                    'active' => $command->isActive(),
+                ])
+            )
+        )->then(function ($hook) {
+            return $this->hydrator->hydrate(WebHookInterface::HYDRATE_CLASS, $hook->getBody()->getParsedContents());
+        });
+    }
+}

src/CommandBus/Handler/Repository/AddWebHookHandler.php

@@ -50,8 +50,8 @@ public function handle(AddWebHookCommand $command): PromiseInterface
                     'active' => $command->isActive(),
                 ])
             )
-        )->then(function ($label) {
-            return $this->hydrator->hydrate(WebHookInterface::HYDRATE_CLASS, $label->getBody()->getParsedContents());
+        )->then(function ($hook) {
+            return $this->hydrator->hydrate(WebHookInterface::HYDRATE_CLASS, $hook->getBody()->getParsedContents());
         });
     }
 }

tests/CommandBus/Handler/Organization/AddWebHookHandlerTest.php

@@ -0,0 +1,62 @@
+<?php declare(strict_types=1);
+
+namespace ApiClients\Tests\Github\CommandBus\Handler\Organization;
+
+use ApiClients\Client\Github\CommandBus\Command\Organization\AddWebHookCommand;
+use ApiClients\Client\Github\CommandBus\Handler\Organization\AddWebHookHandler;
+use ApiClients\Client\Github\Resource\WebHookInterface;
+use ApiClients\Foundation\Hydrator\Hydrator;
+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 AddWebHookHandlerTest extends TestCase
+{
+    public function testCommand()
+    {
+        $resource = $this->prophesize(WebHookInterface::class)->reveal();
+        $org = 'repository';
+        $name = 'repository';
+        $config = [
+            'url' => 'https://www.example.com/',
+        ];
+        $events = ['all'];
+        $active = true;
+        $webhook = [];
+
+        $request = new Request(
+            'POST',
+            'orgs/' . $org . '/hooks',
+            [],
+            new JsonStream([
+                'name'   => $name,
+                'config' => $config,
+                'events' => $events,
+                'active' => $active,
+            ])
+        );
+        $response = new Response(
+            200,
+            [],
+            new JsonStream([])
+        );
+
+        $service = $this->prophesize(RequestService::class);
+        $service->request($request)->shouldBeCalled()->willReturn(resolve($response));
+
+        $hydrator = $this->prophesize(Hydrator::class);
+        $hydrator->hydrate(WebHookInterface::HYDRATE_CLASS, $webhook)->shouldBeCalled()->willReturn($resource);
+
+        $handler = new AddWebHookHandler($service->reveal(), $hydrator->reveal());
+        $handler->handle(new AddWebHookCommand(
+            $org,
+            $name,
+            $config,
+            $events,
+            $active
+        ));
+    }
+}