1- <?php
1+ <?php declare (strict_types= 1 );
22
33// Note that this example requires amphp/http-client, amphp/http-server-router,
44// amphp/http-server-static-content and amphp/log to be installed.
2222use Amp \Websocket \Server \WebsocketGateway ;
2323use Amp \Websocket \WebsocketClient ;
2424use Monolog \Logger ;
25- use Psr \Log \NullLogger ;
2625use Revolt \EventLoop ;
2726use function Amp \ByteStream \getStdout ;
2827
@@ -65,16 +64,16 @@ private function onStart(): void
6564 );
6665 $ json = $ response ->getBody ()->buffer ();
6766
68- $ data = \ json_decode ($ json , true );
67+ $ data = json_decode ($ json , true );
6968
7069 if (!isset ($ data ['items ' ])) {
7170 return ;
7271 }
7372
74- foreach (\ array_reverse ($ data ['items ' ]) as $ question ) {
73+ foreach (array_reverse ($ data ['items ' ]) as $ question ) {
7574 if ($ this ->newestQuestion === null || $ question ['question_id ' ] > $ this ->newestQuestion ) {
7675 $ this ->newestQuestion = $ question ['question_id ' ];
77- $ this ->gateway ->broadcastText (\ json_encode ($ question ))->ignore ();
76+ $ this ->gateway ->broadcastText (json_encode ($ question ))->ignore ();
7877 }
7978 }
8079 });
@@ -104,7 +103,7 @@ public function handleClient(WebsocketClient $client, Request $request, Response
104103 clientHandler: $ clientHandler ,
105104);
106105
107- $ router = new Router ($ server , new NullLogger () , $ errorHandler );
106+ $ router = new Router ($ server , $ logger , $ errorHandler );
108107$ router ->addRoute ('GET ' , '/live ' , $ websocket );
109108$ router ->setFallback (new DocumentRoot ($ server , $ errorHandler , __DIR__ . '/public ' ));
110109
@@ -113,6 +112,6 @@ public function handleClient(WebsocketClient $client, Request $request, Response
113112// Await SIGINT or SIGTERM to be received.
114113$ signal = Amp \trapSignal ([\SIGINT , \SIGTERM ]);
115114
116- $ logger ->info (\ sprintf ("Received signal %d, stopping HTTP server " , $ signal ));
115+ $ logger ->info (sprintf ("Received signal %d, stopping HTTP server " , $ signal ));
117116
118117$ server ->stop ();
0 commit comments