fix(events): parse newline-delimited JSON from Docker event stream

Docker's /events endpoint returns newline-delimited JSON with
Content-Type: application/json, not Server-Sent Events. The previous
loop only handled ServerSentEvent chunks, which a plain HttpClient
never emits, so listenForEvents() never invoked the callback and all
container events were silently dropped.

Buffer the raw data chunks and split on newlines, decoding each
complete JSON line. Also drops the duplicate /events request that was
issued on every loop iteration via the while() condition.

Verified end-to-end against a live Docker daemon: start/stop/die/restart
events now reach the callback.

Drive-by: cs:fix adds a missing closure return type in EventsListenCommand.

Author: Fahl-Design

src/Client/DockerApiClientWrapper.php

@@ -5,7 +5,6 @@
 namespace WebProject\DockerApiClient\Client;
 
 use JsonException;
-use Symfony\Component\HttpClient\Chunk\ServerSentEvent;
 use Symfony\Component\HttpClient\HttpClient;
 use Symfony\Component\HttpClient\Psr18Client;
 use Symfony\Component\Serializer\Encoder\JsonEncoder;
@@ -17,6 +16,10 @@
 use WebProject\DockerApiClient\Event\ContainerEvent;
 use function is_array;
 use function json_decode;
+use function json_validate;
+use function strpos;
+use function substr;
+use function trim;
 
 final class DockerApiClientWrapper
 {
@@ -46,35 +49,37 @@ public function listenForEvents(callable $eventCallback): void
             encoders: [new JsonEncoder()]
         );
 
-        // Connect to the Docker API event stream
+        // Connect to the Docker API event stream. Docker streams
+        // newline-delimited JSON objects (Content-Type: application/json),
+        // NOT Server-Sent Events, so the payload arrives as plain data chunks
+        // that must be buffered and split on newlines before decoding.
         $source = $client->request(method: 'GET', url: '/events');
 
-        while ($client->request(method: 'GET', url: '/events')) {
-            foreach ($client->stream(responses: $source, timeout: 2) as $r => $chunk) {
-                if ($chunk->isTimeout()) {
-                    // Handle timeout
-                    continue;
-                }
+        $buffer = '';
+        foreach ($client->stream(responses: $source) as $chunk) {
+            if ($chunk->isTimeout()) {
+                continue;
+            }
 
-                if ($chunk->isLast()) {
-                    // Handle end of stream
-                    return;
-                }
+            if ($chunk->isLast()) {
+                return;
+            }
 
-                // Process the ServerSentEvent chunk
-                if ($chunk instanceof ServerSentEvent) {
-                    // Do something with the event data
-                    $content = $chunk->getContent();
-                    if (!json_validate($content)) {
-                        continue;
-                    }
+            $buffer .= $chunk->getContent();
+
+            while (false !== ($newlinePos = strpos($buffer, "\n"))) {
+                $line   = trim(substr($buffer, 0, $newlinePos));
+                $buffer = substr($buffer, $newlinePos + 1);
+
+                if ('' === $line || !json_validate($line)) {
+                    continue;
+                }
 
-                    $eventObject = json_decode(json: $content, associative: true, depth: 512, flags: JSON_THROW_ON_ERROR);
-                    if (is_array($eventObject) && ($eventObject['Type'] ?? false) === 'container') {
-                        $event = $serializer->deserialize(data: $content, type: ContainerEvent::class, format: 'json');
+                $eventObject = json_decode(json: $line, associative: true, depth: 512, flags: JSON_THROW_ON_ERROR);
+                if (is_array($eventObject) && ($eventObject['Type'] ?? false) === 'container') {
+                    $event = $serializer->deserialize(data: $line, type: ContainerEvent::class, format: 'json');
 
-                        $eventCallback($event);
-                    }
+                    $eventCallback($event);
                 }
             }
         }

src/Command/EventsListenCommand.php

@@ -39,7 +39,7 @@ protected function execute(InputInterface $input, OutputInterface $output): int
             'stop',
         ];
 
-        $service->listenForEvents(function (ContainerEvent $event) use ($service, $actions, $io) {
+        $service->listenForEvents(function (ContainerEvent $event) use ($service, $actions, $io): void {
             $container = $this->containers[$event->Actor->ID] ?? null;
             $prefix    = '[event]';
             if ($container) {