Experimenting with logger...will probably change it.

Author: dcarbone

src/AbstractConsulClient.php

@@ -55,7 +55,7 @@ protected function requireOK(array $requestResult)
 
         if (200 !== $response->httpCode)
         {
-            return [$duration, $response, new Error('warn', sprintf(
+            return [$duration, $response, new Error(sprintf(
                 '%s - Error seen while executing "%s".  Response code: %d.  Message: %s',
                 get_class($this),
                 $response->url,
@@ -142,7 +142,7 @@ protected function decodeBody(HttpResponse $response)
         if (JSON_ERROR_NONE === $err)
             return [$data, null];
 
-        return [null, new Error('error', sprintf(
+        return [null, new Error(sprintf(
             '%s - Unable to parse response as JSON.  Message: %s',
             get_class($this),
             PHP_VERSION_ID >= 50500 ? json_last_error_msg() : (string)$err

src/Config.php

@@ -22,6 +22,14 @@
  */
 class Config extends AbstractDefinedStrictCollection
 {
+    /** @var array */
+    private $_logLevels = array(
+        'debug' => 0,
+        'info' => 1,
+        'warn' => 2,
+        'error' => 3,
+    );
+
     /**
      * @return static
      */
@@ -66,6 +74,8 @@ protected function getDefinition()
             'CertFile' => null,
             'KeyFile' => null,
             'InsecureSkipVerify' => null,
+            'LogLevel' => 'warn',
+            'Loggers' => array(),
         );
     }
 
@@ -274,6 +284,80 @@ public function setInsecureSkipVerify($insecureSkipVerify)
         return $this;
     }
 
+    /**
+     * @return ConsulAPILoggerInterface[]
+     */
+    public function getLoggers()
+    {
+        return $this->_storage['Loggers'];
+    }
+
+    /**
+     * @param array $loggers
+     * @return $this
+     */
+    public function setLoggers(array $loggers)
+    {
+        $this->_storage['Loggers'] = array();
+        foreach($loggers as $logger)
+        {
+            if ($logger instanceof ConsulAPILoggerInterface)
+            {
+                $this->_storage['Loggers'][] = $logger;
+            }
+            else
+            {
+                throw new \InvalidArgumentException(sprintf(
+                    '%s - %s is not a valid logger implementation',
+                    get_class($this),
+                    is_object($logger) ? get_class($logger) : gettype($logger)
+                ));
+            }
+        }
+
+        return $this;
+    }
+
+    /**
+     * @param ConsulAPILoggerInterface $logger
+     * @return $this
+     */
+    public function addLogger(ConsulAPILoggerInterface $logger)
+    {
+        $this->_storage['Loggers'][] = $logger;
+
+        return $this;
+    }
+
+    /**
+     * @return string
+     */
+    public function getLogLevel()
+    {
+        return $this->_storage['LogLevel'];
+    }
+
+    /**
+     * @param string $logLevel
+     * @return $this
+     */
+    public function setLogLevel($logLevel)
+    {
+        if (!is_string($logLevel) || '' === ($level = strtolower($logLevel)) || !isset($this->_logLevels[$level]))
+        {
+            throw new \InvalidArgumentException(sprintf(
+                '%s - Log level must be one of the following values: ["%s"].  %s seen.',
+                get_class($this),
+                implode('", "', array_keys($this->_logLevels)),
+                is_string($logLevel) ? $logLevel : gettype($logLevel)
+            ));
+        }
+
+        $this->_storage['LogLevel'] = $level;
+
+        return $this;
+    }
+
     /**
      * @return string
      */
@@ -312,6 +396,22 @@ public function getCurlOptArray()
         return $opts;
     }
 
+    /**
+     * @param string $logLevel
+     * @param string $message
+     */
+    public function log($logLevel, $message)
+    {
+        $level = strtolower($logLevel);
+        if ($this->_logLevels[$this->_storage['LogLevel']] <= $this->_logLevels[strtolower($level)])
+        {
+            foreach($this->_storage['Loggers'] as $logger)
+            {
+                $logger->{$level}($message);
+            }
+        }
+    }
+
     /**
      * @param string $param
      * @return string|bool

src/ConsulAPILoggerInterface.php

@@ -0,0 +1,48 @@
+<?php namespace DCarbone\PHPConsulAPI;
+
+/*
+   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.
+*/
+
+/**
+ * Interface ConsulAPILoggerInterface
+ * @package DCarbone\PHPConsulAPI
+ */
+interface ConsulAPILoggerInterface
+{
+    /**
+     * @param string $message
+     * @return bool
+     */
+    public function error($message);
+
+    /**
+     * @param string $message
+     * @return bool
+     */
+    public function warn($message);
+
+    /**
+     * @param string $message
+     * @return bool
+     */
+    public function info($message);
+
+    /**
+     * @param string $message
+     * @return bool
+     */
+    public function debug($message);
+}

src/DateTime.php

@@ -65,6 +65,14 @@ public function formatDefault()
         return $this->format(self::$_defaultFormat);
     }
 
+    /**
+     * @return string
+     */
+    public static function now()
+    {
+        return date(self::$_defaultFormat);
+    }
+
     /**
      * Specify data which should be serialized to JSON
      * @link http://php.net/manual/en/jsonserializable.jsonserialize.php

src/Error.php

@@ -24,17 +24,6 @@
  */
 class Error implements \JsonSerializable
 {
-    /** @var array */
-    private $_levels = array(
-        'debug',
-        'info',
-        'warn',
-        'error',
-    );
-
-    /** @var string */
-    private $_level;
-
     /** @var DateTime */
     private $_timestamp;
 
@@ -43,22 +32,11 @@ class Error implements \JsonSerializable
 
     /**
      * Error constructor.
-     * @param string $level
      * @param string $message
+     * @internal param string $level
      */
-    public function __construct($level, $message)
+    public function __construct($message)
     {
-        if (!is_string($level) || !in_array($level, $this->_levels, true))
-        {
-            throw new \InvalidArgumentException(sprintf(
-                '%s - "%s" is not valid level.  Available choices: ["%s"]',
-                get_class($this),
-                is_string($level) ? $level : gettype($level),
-                implode('", "', $this->_levels)
-            ));
-        }
-
-        $this->_level = $level;
         $this->_timestamp = new DateTime();
         $this->_message = $message;
     }
@@ -71,7 +49,6 @@ public function __construct($level, $message)
     public function jsonSerialize()
     {
         return array(
-            'level' => $this->_level,
             'message' => $this->_message,
             'timestamp' => $this->_timestamp
         );
@@ -83,8 +60,7 @@ public function jsonSerialize()
     public function __toString()
     {
         return sprintf(
-            '[%s] - %s - %s',
-            $this->_level,
+            '[error] - %s - %s',
             $this->_timestamp,
             $this->_message
         );