Issue planetteamspeak#204: Exit loops when disconnected

This change should help to exit stuck loops, when the library is not connected to the remote server anymore.

- Fixes the existing `isConnected()` function to properly return TRUE or FALSE
- Adds a PHPUnit test for the `isConnected()` function
- Adds the connection status as condition to loops in order to abort, when it disconnected

src/Adapter/ServerQuery.php

@@ -137,6 +137,9 @@ public function request(string $cmd, bool $throw = true): Reply
         $rpl = [];
 
         do {
+            if (! $this->getTransport()->isConnected()) {
+                break;
+            }
             $str = $this->getTransport()->readLine();
             $rpl[] = $str;
         } while ($str->section(TeamSpeak3::SEPARATOR_CELL) != TeamSpeak3::ERROR);
@@ -163,6 +166,9 @@ public function wait(): Event
         }
 
         do {
+            if (! $this->getTransport()->isConnected()) {
+                break;
+            }
             $evt = $this->getTransport()->readLine();
         } while (!$evt->section(TeamSpeak3::SEPARATOR_CELL)->startsWith(TeamSpeak3::EVENT));
 

src/Transport/Transport.php

@@ -246,7 +246,7 @@ public function getMetaData(): array
      */
     public function isConnected(): bool
     {
-        return is_resource($this->stream);
+        return ($this->getStream() === null) ? false : true;
     }
 
     /**

tests/Transport/TCPTest.php

@@ -3,6 +3,7 @@
 namespace PlanetTeamSpeak\TeamSpeak3Framework\Tests\Transport;
 
 use PHPUnit\Framework\TestCase;
+use PlanetTeamSpeak\TeamSpeak3Framework\Adapter\MockServerQuery;
 use PlanetTeamSpeak\TeamSpeak3Framework\Adapter\ServerQuery;
 use PlanetTeamSpeak\TeamSpeak3Framework\Exception\ServerQueryException;
 use PlanetTeamSpeak\TeamSpeak3Framework\Transport\TCP;
@@ -91,6 +92,25 @@ public function testGetStream()
         $this->assertNull($transport->getStream());
     }
 
+    /**
+     * @throws AdapterException
+     */
+    protected function createMockServerQuery(): MockServerQuery
+    {
+        return new MockServerQuery(['host' => '0.0.0.0', 'port' => 9987]);
+    }
+
+    /**
+     * Tests if the connection status gets properly returned.
+     */
+    public function testConnectionStatus()
+    {
+        $mockServerQuery = $this->createMockServerQuery();
+        $this->assertTrue($mockServerQuery->getTransport()->isConnected());
+        $mockServerQuery->getTransport()->disconnect();
+        $this->assertFalse($mockServerQuery->getTransport()->isConnected());
+    }
+
     /**
      * @throws TransportException
      * @throws ServerQueryException