Merge pull request repejota#106 from repejota/feature/connectionInfo

Feature/connection info

Author: repejota

examples/simpleclient/main.php

@@ -3,26 +3,9 @@
 
 use Nats\Connection as NatsClient;
 
-$client = new NatsClient();
-$client->connect();
+$nc = new NatsClient();
+$nc->connect();
 
-printf('Connected to NATS.'.PHP_EOL);
+printf('Connected to NATS at %s'.PHP_EOL, $nc->connectedServerId());
 
-// Simple Subscriber.
-$client->subscribe(
-    'foo',
-    function ($message) {
-        printf("Data: %s\r\n".PHP_EOL, $message->getBody());
-    }
-);
-printf('Subscribed to "foo" messages.'.PHP_EOL);
-
-// Wait for messages.
-printf('Wait for messages on %s subscriptions'.PHP_EOL, $client->subscriptionsCount());
-while (true) {
-    $client->wait();
-
-    printf('Reconnecting ...'.PHP_EOL);
-    $client->reconnect();
-    printf('Reconnected %s subscriptions'.PHP_EOL, $client->subscriptionsCount());
-}
+$nc->wait();

src/Nats/Connection.php

@@ -237,6 +237,36 @@ function () {
         return $fp;
     }
 
+    /**
+     * Server information.
+     *
+     * @var mixed
+     */
+    private $serverInfo;
+
+
+    /**
+     * Process information returned by the server after connection.
+     *
+     * @param string $connectionResponse INFO message.
+     *
+     * @return void
+     */
+    private function processServerInfo($connectionResponse)
+    {
+        $this->serverInfo = new ServerInfo($connectionResponse);
+    }
+
+    /**
+     * Returns current connected server ID.
+     *
+     * @return string Server ID.
+     */
+    public function connectedServerID()
+    {
+        return $this->serverInfo->getServerID();
+    }
+
     /**
      * Constructor.
      *
@@ -390,11 +420,12 @@ public function connect($timeout = null)
 
         $msg = 'CONNECT '.$this->options;
         $this->send($msg);
-        // $infoResponse = $this->receive();
         $connectResponse = $this->receive();
 
         if ($this->isErrorResponse($connectResponse) === true) {
             throw Exception::forFailedConnection($connectResponse);
+        } else {
+            $this->processServerInfo($connectResponse);
         }
 
         $this->ping();