Merge pull request repejota#104 from sergeyklay/feature/configurable-connection-options-constructor

Configurable ConnectionOptions ctor

Author: repejota

examples/connect.php

@@ -1,8 +1,13 @@
 <?php
 require_once __DIR__.'/../vendor/autoload.php';
 
-$connectionOptions = new \Nats\ConnectionOptions();
-$connectionOptions->setHost('localhost')->setPort(4222);
+$connectionOptions = new \Nats\ConnectionOptions(
+    [
+     'host' => '127.0.0.1',
+     'port' => 4222,
+    ]
+);
+
 $c = new Nats\Connection($connectionOptions);
 $c->connect();
 $c->close();

src/Nats/ConnectionOptions.php

@@ -1,6 +1,8 @@
 <?php
 namespace Nats;
 
+use Traversable;
+
 /**
  * ConnectionOptions Class.
  *
@@ -79,6 +81,49 @@ class ConnectionOptions
      */
     private $reconnect = true;
 
+    /**
+     * Allows to define parameters which can be set by passing them to the class constructor.
+     *
+     * @var array
+     */
+    private $configurable = [
+                             'host',
+                             'port',
+                             'user',
+                             'pass',
+                             'token',
+                             'lang',
+                             'version',
+                             'verbose',
+                             'pedantic',
+                             'reconnect',
+                            ];
+
+
+    /**
+     * ConnectionOptions constructor.
+     *
+     * <code>
+     * use Nats\ConnectionOptions;
+     *
+     * $options = new ConnectionOptions([
+     *     'host' => '127.0.0.1',
+     *     'port' => 4222,
+     *     'user' => 'nats',
+     *     'pass' => 'nats',
+     *     'lang' => 'php',
+     *      // ...
+     * ]);
+     * </code>
+     *
+     * @param Traversable|array $options The connection options.
+     */
+    public function __construct($options = null)
+    {
+        if (empty($options) === false) {
+            $this->initialize($options);
+        }
+    }
 
     /**
      * Get the URI for a server.
@@ -374,4 +419,31 @@ public function setReconnect($reconnect)
 
         return $this;
     }
+
+    /**
+     * Initialize the parameters.
+     *
+     * @param Traversable|array $options The connection options.
+     *
+     * @throws Exception When $options are an invalid type.
+     * @return void
+     */
+    protected function initialize($options)
+    {
+        if (is_array($options) === false && ($options instanceof Traversable) === false) {
+            throw new Exception('The $options argument must be either an array or Traversable');
+        }
+
+        foreach ($options as $key => $value) {
+            if (in_array($key, $this->configurable, true) === false) {
+                continue;
+            }
+
+            $method = 'set'.ucfirst($key);
+
+            if (method_exists($this, $method) === true) {
+                $this->$method($value);
+            }
+        }
+    }
 }