Some new stuff, need to figure out logic loop of base64 stuffs....

Author: dcarbone

README.md

@@ -45,6 +45,7 @@ var_dump($kv_list);
 - [Agent](./docs/AGENT.md)
 - [Catalog](./docs/CATALOG.md)
 - [Status](./docs/STATUS.md)
+- [Event](./docs/EVENT.md)
 
 More will be added as time goes on!
 

docs/EVENT.md

@@ -0,0 +1,23 @@
+# PHP Consul API Event
+
+All interactions with the [`v1/event`](https://www.consul.io/docs/agent/http/event.html) endpoint
+are done via the [EventClient](./src/Event/EventClient.php) class.
+
+If you have constructed a [Client](./src/Client.php) object, this is done as so:
+
+```php
+$event = $client->Event();
+```
+
+## Actions
+
+### Fire an Event
+
+In order to fire an event, you must first create an [UserEvent](./src/Event/UserEvent.php)
+object.
+
+Below is a quick example:
+
+```php
+$event = new
+```

docs/STATUS.md

@@ -0,0 +1,32 @@
+# PHP Consul API Status
+
+All interactions with the [`v1/status`](https://www.consul.io/docs/agent/http/status.html) endpoint
+are done via the [StatusClient](./src/Status/StatusClient.php) class.
+
+If you have constructed a [Client](./src/Client.php) object, this is done as so:
+
+```php
+$status = $client->Status();
+```
+
+## Actions
+
+### Leader
+
+```php
+list($addrses, $err) = $client->Status()->leader();
+if (null !== $err)
+    die($err);
+
+var_dump($address);
+```
+
+### Peers
+
+```php
+list($peers, $err) = $client->Status()->peers();
+if (null !== $err)
+    die($err);
+
+var_dump($peers);
+```

src/AbstractConsulClient.php

@@ -39,7 +39,7 @@ public function __construct(Config $config)
      * @return array(
      *  @type int query duration in microseconds
      *  @type HttpResponse|null response object
-     *  @type Error|null error, if any
+     *  @type \DCarbone\PHPConsulAPI\Error|null error, if any
      * )
      */
     protected function requireOK(array $requestResult)
@@ -72,7 +72,7 @@ protected function requireOK(array $requestResult)
      * @return array(
      *  @type int duration in microseconds
      *  @type HttpResponse|null http response
-     *  @type Error|null any seen errors
+     *  @type \DCarbone\PHPConsulAPI\Error|null any seen errors
      * )
      */
     protected function doRequest(Request $r)
@@ -131,7 +131,7 @@ protected function buildWriteMeta($duration)
      * @param HttpResponse $response
      * @return array(
      *  @type array|string|bool|int|float decoded response
-     *  @type Error|null error, if any
+     *  @type \DCarbone\PHPConsulAPI\Error|null error, if any
      * )
      */
     protected function decodeBody(HttpResponse $response)

src/Agent/AgentClient.php

@@ -17,7 +17,6 @@
 */
 
 use DCarbone\PHPConsulAPI\AbstractConsulClient;
-use DCarbone\PHPConsulAPI\QueryMeta;
 use DCarbone\PHPConsulAPI\Request;
 
 /**
@@ -32,7 +31,7 @@ class AgentClient extends AbstractConsulClient
     /**
      * @return array(
      * @type AgentSelf|null agent info or null on error
-     * @type QueryMeta query metadata
+     * @type \DCarbone\PHPConsulAPI\QueryMeta query metadata
      * @type \DCarbone\PHPConsulAPI\Error|null error, if any
      * )
      */

src/Catalog/CatalogClient.php

@@ -89,7 +89,7 @@ public function datacenters()
      * @param QueryOptions|null $queryOptions
      * @return array(
      *  @type CatalogNode[]|null array of catalog nodes or null on error
-     *  @type QueryMeta query metadata
+     *  @type \DCarbone\PHPConsulAPI\QueryMeta query metadata
      *  @type \DCarbone\PHPConsulAPI\Error|null error, if any
      * )
      */
@@ -123,7 +123,7 @@ public function nodes(QueryOptions $queryOptions = null)
      * @param QueryOptions|null $queryOptions
      * @return array(
      * @type string[]|null list of services or null on error
-     * @type QueryMeta query metadata
+     * @type \DCarbone\PHPConsulAPI\QueryMeta query metadata
      * @type \DCarbone\PHPConsulAPI\Error|null error, if any
      * )
      */
@@ -149,7 +149,7 @@ public function services(QueryOptions $queryOptions = null)
      * @param QueryOptions|null $queryOptions
      * @return array(
      *  @type CatalogService[]|null array of services or null on error
-     *  @type QueryMeta query metadata
+     *  @type \DCarbone\PHPConsulAPI\QueryMeta query metadata
      *  @type \DCarbone\PHPConsulAPI\Error|null error, if any
      * )
      */
@@ -186,7 +186,7 @@ public function service($service, $tag = '', QueryOptions $queryOptions = null)
      * @param QueryOptions|null $queryOptions
      * @return array(
      *  @type CatalogNode node or null on error
-     *  @type QueryMeta query metadata
+     *  @type \DCarbone\PHPConsulAPI\QueryMeta query metadata
      *  @type \DCarbone\PHPConsulAPI\Error|null error, if any
      * )
      */

src/Client.php

@@ -18,6 +18,7 @@
 
 use DCarbone\PHPConsulAPI\Agent\AgentClient;
 use DCarbone\PHPConsulAPI\Catalog\CatalogClient;
+use DCarbone\PHPConsulAPI\Event\EventClient;
 use DCarbone\PHPConsulAPI\KV\KVClient;
 use DCarbone\PHPConsulAPI\Status\StatusClient;
 
@@ -35,6 +36,8 @@ class Client
     private $_Catalog;
     /** @var StatusClient */
     private $_Status;
+    /** @var EventClient */
+    private $_Event;
 
     /**
      * Client constructor.
@@ -61,6 +64,7 @@ public function __construct(Config $config = null)
         $this->_Agent = new AgentClient($config);
         $this->_Catalog = new CatalogClient($config);
         $this->_Status = new StatusClient($config);
+        $this->_Event = new EventClient($config);
     }
 
     /**
@@ -95,4 +99,11 @@ public function Status()
         return $this->_Status;
     }
 
+    /**
+     * @return EventClient
+     */
+    public function Event()
+    {
+        return $this->_Event;
+    }
 }

src/Error.php

@@ -33,7 +33,6 @@ class Error implements \JsonSerializable
     /**
      * Error constructor.
      * @param string $message
-     * @internal param string $level
      */
     public function __construct($message)
     {

src/Event/EventClient.php

@@ -0,0 +1,103 @@
+<?php namespace DCarbone\PHPConsulAPI\Event;
+
+/*
+   Copyright 2016 Daniel Carbone ([email protected])
+
+   Licensed under the Apache License, Version 2.0 (the "License");
+   you may not use this file except in compliance with the License.
+   You may obtain a copy of the License at
+
+       http://www.apache.org/licenses/LICENSE-2.0
+
+   Unless required by applicable law or agreed to in writing, software
+   distributed under the License is distributed on an "AS IS" BASIS,
+   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+   See the License for the specific language governing permissions and
+   limitations under the License.
+*/
+
+use DCarbone\PHPConsulAPI\AbstractConsulClient;
+use DCarbone\PHPConsulAPI\QueryOptions;
+use DCarbone\PHPConsulAPI\Request;
+use DCarbone\PHPConsulAPI\WriteOptions;
+
+/**
+ * Class EventClient
+ * @package DCarbone\PHPConsulAPI
+ */
+class EventClient extends AbstractConsulClient
+{
+    /**
+     * @param UserEvent $event
+     * @param WriteOptions|null $writeOptions
+     * @return array(
+     *  @type UserEvent|null user event that was fired or null on error
+     *  @type \DCarbone\PHPConsulAPI\WriteMeta write metadata
+     *  @type \DCarbone\PHPConsulAPI\Error error, if any
+     * )
+     */
+    public function fire(UserEvent $event, WriteOptions $writeOptions = null)
+    {
+        $r = new Request('put', sprintf('v1/event/fire/%s', rawurlencode($event->getName())), $this->_Config);
+        $r->setWriteOptions($writeOptions);
+
+        if ('' !== ($nf = $event->getNodeFilter()))
+            $r->params()->set('node', $nf);
+        if ('' !== ($sf = $event->getServiceFilter()))
+            $r->params()->set('service', $sf);
+        if ('' !== ($tf = $event->getTagFilter()))
+            $r->params()->set('tag', $tf);
+        if ('' !== ($payload = $event->getPayload()))
+            $r->setBody($payload);
+
+        var_dump($payload);exit;
+
+        list($duration, $response, $err) = $this->requireOK($this->doRequest($r));
+        $wm = $this->buildWriteMeta($duration);
+
+        if (null !== $err)
+            return [null, $wm, $err];
+
+        list($data, $err) = $this->decodeBody($response);
+        if ($err !== null)
+            return [null, $wm, $err];
+
+        return [new UserEvent($data), $wm, null];
+    }
+    
+    /**
+     * @param string $name
+     * @param QueryOptions|null $queryOptions
+     * @return array(
+     *  @type UserEvent[] list of user events or null on error
+     *  @type \DCarbone\PHPConsulAPI\QueryMeta query metadata
+     *  @type \DCarbone\PHPConsulAPI\Error error, if any
+     * )
+     */
+    public function eventList($name = '', QueryOptions $queryOptions = null)
+    {
+        $r = new Request('get', 'v1/event/list', $this->_Config);
+        if ('' !== (string)$name)
+            $r->params()->set('name', $name);
+        $r->setQueryOptions($queryOptions);
+
+        list($duration, $response, $err) = $this->requireOK($this->doRequest($r));
+        $qm = $this->buildQueryMeta($duration, $response);
+
+        if (null !== $err)
+            return [null, $qm, $err];
+
+        list($data, $err) = $this->decodeBody($response);
+
+        if (null !== $err)
+            return [null, $qm, $err];
+
+        $events = array();
+        foreach($data as $event)
+        {
+            $events[] = new UserEvent($event);
+        }
+
+        return [$events, $qm, null];
+    }
+}