Shared app client service

Author: WyriHaximus

src/CommandBus/Handler/SharedAppClientHandler.php

@@ -2,32 +2,26 @@
 
 namespace ApiClients\Client\Pusher\CommandBus\Handler;
 
-use ApiClients\Client\Pusher\AsyncClient;
 use ApiClients\Client\Pusher\CommandBus\Command\SharedAppClientCommand;
-use React\EventLoop\LoopInterface;
+use ApiClients\Client\Pusher\Service\SharedAppClientService;
 use React\Promise\PromiseInterface;
 use function React\Promise\resolve;
 use function WyriHaximus\React\futureFunctionPromise;
 
 final class SharedAppClientHandler
 {
     /**
-     * @var LoopInterface
+     * @var SharedAppClientService
      */
-    private $loop;
-
-    /**
-     * @var array
-     */
-    private $apps = [];
+    private $service;
 
     /**
      * SharedAppClientHandler constructor.
-     * @param LoopInterface $loop
+     * @param SharedAppClientService $service
      */
-    public function __construct(LoopInterface $loop)
+    public function __construct(SharedAppClientService $service)
     {
-        $this->loop = $loop;
+        $this->service = $service;
     }
 
     /**
@@ -36,11 +30,6 @@ public function __construct(LoopInterface $loop)
      */
     public function handle(SharedAppClientCommand $command): PromiseInterface
     {
-        if (isset($this->apps[$command->getAppId()])) {
-            return resolve($this->apps[$command->getAppId()]);
-        }
-
-        $this->apps[$command->getAppId()] = new AsyncClient($this->loop, $command->getAppId());
-        return resolve($this->apps[$command->getAppId()]);
+        return resolve($this->service->handle($command->getAppId()));
     }
 }

src/Service/SharedAppClientService.php

@@ -0,0 +1,46 @@
+<?php declare(strict_types=1);
+
+namespace ApiClients\Client\Pusher\Service;
+
+use ApiClients\Client\Pusher\AsyncClient;
+use ApiClients\Foundation\Service\ServiceInterface;
+use React\EventLoop\LoopInterface;
+use React\Promise\CancellablePromiseInterface;
+use function React\Promise\resolve;
+use function WyriHaximus\React\futureFunctionPromise;
+
+final class SharedAppClientService implements ServiceInterface
+{
+    /**
+     * @var LoopInterface
+     */
+    private $loop;
+
+    /**
+     * @var array
+     */
+    private $apps = [];
+
+    /**
+     * SharedAppClientHandler constructor.
+     * @param LoopInterface $loop
+     */
+    public function __construct(LoopInterface $loop)
+    {
+        $this->loop = $loop;
+    }
+
+    /**
+     * @param string|null $appId
+     * @return CancellablePromiseInterface
+     */
+    public function handle(string $appId = null): CancellablePromiseInterface
+    {
+        if (isset($this->apps[$appId])) {
+            return resolve($this->apps[$appId]);
+        }
+
+        $this->apps[$appId] = new AsyncClient($this->loop, $appId);
+        return resolve($this->apps[$appId]);
+    }
+}