Added connection monitoring

Author: mmasiukevich

composer.json

@@ -20,13 +20,13 @@
   "require": {
     "php": ">=8.0",
     "amphp/amp": "v2.6.*",
-    "amphp/socket": "v1.1.*",
+    "amphp/socket": "v1.2.*",
     "phpinnacle/buffer": "v1.2.*"
   },
   "require-dev": {
     "phpunit/phpunit": "v9.5.*",
-    "vimeo/psalm": "v4.13.*",
-    "phpstan/phpstan": "v1.2.*"
+    "vimeo/psalm": "v4.18.*",
+    "phpstan/phpstan": "v1.4.*"
   },
   "prefer-stable": true,
   "autoload": {
@@ -52,6 +52,9 @@
   },
   "config": {
     "sort-packages": true,
-    "optimize-autoloader": true
+    "optimize-autoloader": true,
+    "allow-plugins": {
+      "composer/package-versions-deprecated": false
+    }
   }
 }

phpstan.neon

@@ -1,5 +1,4 @@
 parameters:
 	checkMissingIterableValueType: false
 	checkGenericClassInNonGenericObjectType: false
-	ignoreErrors:
-		- '#Cannot cast mixed to int#'
+

src/Client.php

@@ -136,6 +136,8 @@ function () {
 
                         $this->connection->write($buffer);
                         $this->connection->close();
+
+                        $this->disableConnectionMonitor();
                     }
                 );
 
@@ -161,6 +163,8 @@ function(): void
      */
     public function disconnect(int $code = 0, string $reason = ''): Promise
     {
+        $this->disableConnectionMonitor();
+
         return call(
             function () use ($code, $reason) {
                 if (\in_array($this->state, [self::STATE_NOT_CONNECTED, self::STATE_DISCONNECTING])) {
@@ -446,4 +450,13 @@ static function (Protocol\AbstractFrame $frame) use ($deferred) {
 
         return $deferred->promise();
     }
+
+    private function disableConnectionMonitor(): void {
+        if($this->connectionMonitorWatcherId !== null) {
+
+            Loop::cancel($this->connectionMonitorWatcherId);
+
+            $this->connectionMonitorWatcherId = null;
+        }
+    }
 }

tests/AsyncTest.php

@@ -53,6 +53,8 @@ protected function runTestAsync(...$args)
 
                 $return = yield call([$this, $this->realTestName], ...$args);
 
+                yield $client->disconnect();
+
                 $info  = Loop::getInfo();
                 $count = $info['enabled_watchers']['referenced'];