Run tests on PHP 8.4 and update test environment

Author: PaulRotmann

.github/workflows/ci.yml

@@ -7,10 +7,11 @@ on:
 jobs:
   PHPUnit:
     name: PHPUnit (PHP ${{ matrix.php }})
-    runs-on: ubuntu-22.04
+    runs-on: ubuntu-24.04
     strategy:
       matrix:
         php:
+          - 8.4
           - 8.3
           - 8.2
           - 8.1
@@ -38,7 +39,7 @@ jobs:
 
   PHPUnit-hhvm:
     name: PHPUnit (HHVM)
-    runs-on: ubuntu-22.04
+    runs-on: ubuntu-24.04
     continue-on-error: true
     steps:
       - uses: actions/checkout@v4

composer.json

@@ -22,9 +22,9 @@
     },
     "require": {
         "php": ">=5.3",
-        "clue/multicast-react": "^1.0 || ^0.2",
+        "clue/multicast-react": "^1.2 || ^0.2",
         "react/event-loop": "^1.2",
-        "react/promise": "^2.0 || ^1.0"
+        "react/promise": "^2.6.0"
     },
     "require-dev": {
         "phpunit/phpunit": "^9.6 || ^5.7 || ^4.8.36"

src/Client.php

@@ -28,7 +28,7 @@ class Client
      * @param ?LoopInterface $loop
      * @param ?MulticastFactory $multicast
      */
-    public function __construct(LoopInterface $loop = null, MulticastFactory $multicast = null)
+    public function __construct(?LoopInterface $loop = null, ?MulticastFactory $multicast = null)
     {
         $this->loop = $loop ?: Loop::get();
         $this->multicast = $multicast ?: new MulticastFactory($this->loop);
@@ -46,24 +46,30 @@ public function search($searchTarget = 'ssdp:all', $mx = 2)
         $socket = $this->multicast->createSender();
         // TODO: The TTL for the IP packet SHOULD default to 2 and SHOULD be configurable.
 
-        $timer = $this->loop->addTimer($mx, function() use ($socket, &$deferred) {
-            $deferred->resolve();
+        $deferred = new Deferred(function () use (&$socket, &$timer, $this) {
+            // canceling resulting promise cancels timer and closes socket
+            if ($timer !== null) {
+                $this->loop->cancelTimer($timer);
+            }
             $socket->close();
+            throw new RuntimeException('Cancelled');
         });
 
-        $loop = $this->loop;
-        $deferred = new Deferred(function () use ($socket, &$timer, $loop) {
-            // canceling resulting promise cancels timer and closes socket
-            $loop->cancelTimer($timer);
+        $timer = $this->loop->addTimer($mx, function() use ($socket, $deferred) {
+            $deferred->resolve();
             $socket->close();
-            throw new RuntimeException('Cancelled');
         });
 
         $that = $this;
         $socket->on('message', function ($data, $remote) use ($deferred, $that) {
             $message = $that->parseMessage($data, $remote);
 
-            $deferred->progress($message);
+            // React Promise v3+ doesn't support progress(), use emit() instead
+            if (method_exists($deferred, 'progress')) {
+                $deferred->progress($message);
+            } else {
+                $deferred->notify($message);
+            }
         });
 
         $socket->send($data, self::ADDRESS);