Added more tests

Author: Raül Pérez

Makefile

@@ -14,3 +14,5 @@ cs:
 	./phpcbf.phar tests
 	./phpcbf.phar examples
 	./phpcs.phar src tests examples
+
+.PHONY: lint test cs cover

src/Connection.php

@@ -282,11 +282,6 @@ public function wait($quantity = 0)
         while (!feof($this->_fp)) {
             $line = $this->_receive();
 
-            // Debug
-            if ($line) {
-                echo ">>>>>>>>> " . $line . PHP_EOL;
-            }
-
             // PING
             if (strpos($line, 'PING') === 0) {
                 $this->_send("PONG");

tests/Unit/ConnectionTest.php

@@ -58,7 +58,9 @@ public function testPing()
         $c->connect();
         $c->ping();
         $c->ping();
-        $this->assertGreaterThan(0, $c->pingsCount());
+        $count = $c->pingsCount();
+        $this->assertInternalType("int", $count);
+        $this->assertGreaterThan(0, $count);
         $c->close();
     }
 
@@ -72,7 +74,47 @@ public function testPublish()
         $c = new Nats\Connection();
         $c->connect();
         $c->publish("foo", "bar");
-        $this->assertGreaterThan(0, $c->pubsCount());
+        $count = $c->pubsCount();
+        $this->assertInternalType("int", $count);
+        $this->assertGreaterThan(0, $count);
         $c->close();
     }
+
+    /**
+     * Test Server reconnection
+     *
+     * @return null
+     */
+    public function testReconnect()
+    {
+        $c = new Nats\Connection();
+        $c->connect();
+        $c->reconnect();
+        $count = $c->reconnectsCount();
+        $this->assertInternalType("int", $count);
+        $this->assertGreaterThan(0, $count);
+        $c->close();
+    }
+
+    /**
+     * Test Server subscription
+     *
+     * @return null
+     */
+    public function testSubscription()
+    {
+        $c = new Nats\Connection();
+        $c->connect();
+        $c->subscribe(
+            "foo", function ($message) {
+                $this->assertNotNull($message);
+            }
+        );
+        $this->assertGreaterThan(0, $c->subscriptionsCount());
+        $subscriptions = $c->getSubscriptions();
+        $this->assertInternalType("array", $subscriptions);
+
+        $c->publish("foo", "bar");
+        $c->wait(1);
+    }
 }