Updates

Author: 27pchrisl

src/Commands/Listen.php

@@ -10,8 +10,6 @@
 use Amp\Socket\InternetAddress;
 use Amp\Websocket\Server\Rfc6455Acceptor;
 use Amp\Websocket\Server\Websocket;
-use Flat3\RevPi\Interfaces\Hardware\PiControl;
-use Flat3\RevPi\Interfaces\Hardware\Terminal;
 use Flat3\RevPi\JsonRpc\JsonRpcPeer;
 use Illuminate\Console\Command;
 use Psr\Log\LoggerInterface;
@@ -35,16 +33,16 @@ public function handle(LoggerInterface $logger): void
 
         $router = new Router($server, $logger, new DefaultErrorHandler);
 
-            $router->addRoute(
-                method: 'GET',
-                uri: '/',
-                requestHandler: new Websocket(
-                    httpServer: $server,
-                    logger: $logger,
-                    acceptor: new Rfc6455Acceptor,
-                    clientHandler: app(JsonRpcPeer::class),
-                )
-            );
+        $router->addRoute(
+            method: 'GET',
+            uri: '/',
+            requestHandler: new Websocket(
+                httpServer: $server,
+                logger: $logger,
+                acceptor: app(Rfc6455Acceptor::class),
+                clientHandler: app(JsonRpcPeer::class),
+            )
+        );
 
         $server->start(
             $router,

src/JsonRpc/JsonRpcPeer.php

@@ -23,6 +23,7 @@
 use Flat3\RevPi\JsonRpc\Response as JsonRpcResponse;
 use Revolt\EventLoop;
 use Throwable;
+
 use function Amp\async;
 
 /**
@@ -53,7 +54,7 @@ class JsonRpcPeer implements WebsocketClientHandler
     public function withSocket(WebsocketClient $socket): self
     {
         $this->socket = $socket;
-        async(fn() => $this->handleResponse());
+        async(fn () => $this->handleResponse());
 
         return $this;
     }
@@ -102,13 +103,13 @@ protected function handleResponse(): void
                     continue;
                 }
 
-                if (!$response instanceof JsonRpcResponse) {
+                if (! $response instanceof JsonRpcResponse) {
                     continue;
                 }
 
                 $id = $response->id;
 
-                if (!isset($this->pending[$id])) {
+                if (! isset($this->pending[$id])) {
                     continue;
                 }
 
@@ -263,7 +264,7 @@ public function handle(string $method, array $params): mixed
                         $request->payload = $newData;
 
                         $this->socket->sendBinary(serialize($request));
-                    } elseif (!is_resource($stream) || @feof($stream)) {
+                    } elseif (! is_resource($stream) || @feof($stream)) {
                         EventLoop::cancel($callbackId);
                     }
                 });

src/Modules/Connect5.php

@@ -5,7 +5,6 @@
 namespace Flat3\RevPi\Modules;
 
 use Flat3\RevPi\Interfaces\Modules\Connect5 as Connect5ModuleInterface;
-use Flat3\RevPi\Interfaces\SerialPort;
 use Flat3\RevPi\Led\Connect5Led;
 use Flat3\RevPi\Led\Led;
 use Flat3\RevPi\Led\LedPosition;

src/Modules/Module.php

@@ -19,9 +19,7 @@ abstract class Module implements ModuleInterface
 
     protected float $frequency = Constants::f20Hz;
 
-    public function __construct(protected ProcessImage $processImage)
-    {
-    }
+    public function __construct(protected ProcessImage $processImage) {}
 
     public function getProcessImage(): ProcessImage
     {
@@ -64,7 +62,7 @@ public function monitor(Trigger $monitor): void
             $next = $this->processImage->readVariable($monitor->name);
 
             if ($previous !== null && $previous !== $next) {
-                EventLoop::defer(fn() => $monitor->evaluate($previous, $next));
+                EventLoop::defer(fn () => $monitor->evaluate($previous, $next));
             }
 
             $previous = $next;

src/Modules/Remote.php

@@ -16,6 +16,7 @@
 use Flat3\RevPi\Led\RemoteLed;
 use Flat3\RevPi\Monitors\Trigger;
 use Flat3\RevPi\ProcessImage\ProcessImage;
+
 use function Amp\Websocket\Client\connect;
 
 class Remote implements RemoteInterface