Apply style fixer to examples

amphp · Dec 29, 2023 · ee45d5a · ee45d5a
1 parent 3804e3b
commit ee45d5a
Show file tree

Hide file tree

Showing 3 changed files with 11 additions and 12 deletions.
diff --git a/.php-cs-fixer.dist.php b/.php-cs-fixer.dist.php
@@ -2,6 +2,7 @@
 
 $config = new Amp\CodeStyle\Config;
 $config->getFinder()
+    ->in(__DIR__ . '/examples')
     ->in(__DIR__ . '/src')
     ->in(__DIR__ . '/test')
     ->in(__DIR__ . '/test-autobahn');

diff --git a/examples/broadcast-server/server.php b/examples/broadcast-server/server.php
@@ -1,4 +1,4 @@
-<?php
+<?php declare(strict_types=1);
 
 // Note that this example requires amphp/http-server-router,
 // amphp/http-server-static-content and amphp/log to be installed.
@@ -20,7 +20,6 @@
 use Amp\Websocket\Server\WebsocketGateway;
 use Amp\Websocket\WebsocketClient;
 use Monolog\Logger;
-use Psr\Log\NullLogger;
 use function Amp\ByteStream\getStdout;
 
 require __DIR__ . '/../../vendor/autoload.php';
@@ -50,7 +49,7 @@ public function handleClient(WebsocketClient $client, Request $request, Response
         $this->gateway->addClient($client);
 
         while ($message = $client->receive()) {
-            $this->gateway->broadcastText(\sprintf('%d: %s', $client->getId(), (string) $message))->ignore();
+            $this->gateway->broadcastText(sprintf('%d: %s', $client->getId(), (string) $message))->ignore();
         }
     }
 };
@@ -65,7 +64,7 @@ public function handleClient(WebsocketClient $client, Request $request, Response
 
 $errorHandler = new DefaultErrorHandler();
 
-$router = new Router($server, new NullLogger(), $errorHandler);
+$router = new Router($server, $logger, $errorHandler);
 $router->addRoute('GET', '/broadcast', $websocket);
 $router->setFallback(new DocumentRoot($server, $errorHandler, __DIR__ . '/public'));
 
@@ -74,6 +73,6 @@ public function handleClient(WebsocketClient $client, Request $request, Response
 // Await SIGINT or SIGTERM to be received.
 $signal = Amp\trapSignal([\SIGINT, \SIGTERM]);
 
-$logger->info(\sprintf("Received signal %d, stopping HTTP server", $signal));
+$logger->info(sprintf("Received signal %d, stopping HTTP server", $signal));
 
 $server->stop();
diff --git a/examples/stackexchange-questions/server.php b/examples/stackexchange-questions/server.php
@@ -1,4 +1,4 @@
-<?php
+<?php declare(strict_types=1);
 
 // Note that this example requires amphp/http-client, amphp/http-server-router,
 // amphp/http-server-static-content and amphp/log to be installed.
@@ -22,7 +22,6 @@
 use Amp\Websocket\Server\WebsocketGateway;
 use Amp\Websocket\WebsocketClient;
 use Monolog\Logger;
-use Psr\Log\NullLogger;
 use Revolt\EventLoop;
 use function Amp\ByteStream\getStdout;
 
@@ -65,16 +64,16 @@ private function onStart(): void
             );
             $json = $response->getBody()->buffer();
 
-            $data = \json_decode($json, true);
+            $data = json_decode($json, true);
 
             if (!isset($data['items'])) {
                 return;
             }
 
-            foreach (\array_reverse($data['items']) as $question) {
+            foreach (array_reverse($data['items']) as $question) {
                 if ($this->newestQuestion === null || $question['question_id'] > $this->newestQuestion) {
                     $this->newestQuestion = $question['question_id'];
-                    $this->gateway->broadcastText(\json_encode($question))->ignore();
+                    $this->gateway->broadcastText(json_encode($question))->ignore();
                 }
             }
         });
@@ -104,7 +103,7 @@ public function handleClient(WebsocketClient $client, Request $request, Response
     clientHandler: $clientHandler,
 );
 
-$router = new Router($server, new NullLogger(), $errorHandler);
+$router = new Router($server, $logger, $errorHandler);
 $router->addRoute('GET', '/live', $websocket);
 $router->setFallback(new DocumentRoot($server, $errorHandler, __DIR__ . '/public'));
 
@@ -113,6 +112,6 @@ public function handleClient(WebsocketClient $client, Request $request, Response
 // Await SIGINT or SIGTERM to be received.
 $signal = Amp\trapSignal([\SIGINT, \SIGTERM]);
 
-$logger->info(\sprintf("Received signal %d, stopping HTTP server", $signal));
+$logger->info(sprintf("Received signal %d, stopping HTTP server", $signal));
 
 $server->stop();