Merge branch 'release/0.0.2'

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

VERSION

@@ -1 +1 @@
-0.0.1
+0.0.2

features/bootstrap/FeatureContext.php

@@ -0,0 +1,44 @@
+<?php
+
+use Behat\Behat\Context\ClosuredContextInterface,
+    Behat\Behat\Context\TranslatedContextInterface,
+    Behat\Behat\Context\BehatContext,
+    Behat\Behat\Exception\PendingException;
+use Behat\Gherkin\Node\PyStringNode,
+    Behat\Gherkin\Node\TableNode;
+
+//
+// Require 3rd-party libraries here:
+//
+//   require_once 'PHPUnit/Autoload.php';
+//   require_once 'PHPUnit/Framework/Assert/Functions.php';
+//
+
+/**
+ * Features context.
+ */
+class FeatureContext extends BehatContext
+{
+    /**
+     * Initializes context.
+     * Every scenario gets it's own context object.
+     *
+     * @param array $parameters context parameters (set them up through behat.yml)
+     */
+    public function __construct(array $parameters)
+    {
+        // Initialize your context here
+    }
+
+//
+// Place your definition and hook methods here:
+//
+//    /**
+//     * @Given /^I have done something with "([^"]*)"$/
+//     */
+//    public function iHaveDoneSomethingWith($argument)
+//    {
+//        doSomethingWith($argument);
+//    }
+//
+}

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);
+    }
 }