Merge pull request repejota#100 from repejota/feature/auth

Add Token authorization

Author: repejota

examples/connectauthtoken.php

@@ -0,0 +1,8 @@
+<?php
+require_once __DIR__.'/../vendor/autoload.php';
+
+$connectionOptions = new \Nats\ConnectionOptions();
+$connectionOptions->setHost('localhost')->setPort(4222)->setToken('supersecrettoken');
+$c = new Nats\Connection($connectionOptions);
+$c->connect();
+$c->close();

src/Nats/ConnectionOptions.php

@@ -37,6 +37,13 @@ class ConnectionOptions
      */
     private $pass = null;
 
+    /**
+     * Token to connect.
+     *
+     * @var string
+     */
+    private $token = null;
+
     /**
      * Language of this client.
      *
@@ -105,6 +112,10 @@ public function __toString()
             $a['pass'] = $this->pass;
         }
 
+        if (empty($this->token) === false) {
+            $a['auth_token'] = $this->token;
+        }
+
         return json_encode($a);
     }
 
@@ -169,7 +180,7 @@ public function setPort($port)
     public function getUser()
     {
         return $this->user;
-    }//end getUser()
+    }
 
 
     /**
@@ -184,7 +195,7 @@ public function setUser($user)
         $this->user = $user;
 
         return $this;
-    }//end setUser()
+    }
 
 
     /**
@@ -195,8 +206,7 @@ public function setUser($user)
     public function getPass()
     {
         return $this->pass;
-    }//end getPass()
-
+    }
 
     /**
      * Set password.
@@ -212,6 +222,29 @@ public function setPass($pass)
         return $this;
     }
 
+    /**
+     * Get token.
+     *
+     * @return string
+     */
+    public function getToken()
+    {
+        return $this->token;
+    }
+
+    /**
+     * Set token.
+     *
+     * @param string $token Token.
+     *
+     * @return $this
+     */
+    public function setToken($token)
+    {
+        $this->token = $token;
+
+        return $this;
+    }
 
     /**
      * Get language.

test/ConnectionOptionsTest.php

@@ -24,6 +24,29 @@ public function testSettersAndGetters()
         $this->assertEquals(4222, $options->getPort());
         $this->assertEquals('user', $options->getUser());
         $this->assertEquals('password', $options->getPass());
+        $this->assertNull($options->getToken());
+        $this->assertEquals('lang', $options->getLang());
+        $this->assertEquals('version', $options->getVersion());
+        $this->assertTrue($options->isVerbose());
+        $this->assertTrue($options->isPedantic());
+        $this->assertTrue($options->isReconnect());
+    }
+
+    /**
+     * Test Connection Options getters and setters using auth token.
+     *
+     * @return void
+     */
+    public function testAuthToken()
+    {
+        $options = new ConnectionOptions();
+        $options->setHost('host')->setPort(4222)->setToken('token')->setLang('lang')->setVersion('version')->setVerbose(true)->setPedantic(true)->setReconnect(true);
+
+        $this->assertEquals('host', $options->getHost());
+        $this->assertEquals(4222, $options->getPort());
+        $this->assertEquals('token', $options->getToken());
+        $this->assertNull($options->getUser());
+        $this->assertNull($options->getPass());
         $this->assertEquals('lang', $options->getLang());
         $this->assertEquals('version', $options->getVersion());
         $this->assertTrue($options->isVerbose());