From cfc0f60042d60869a986e3e1e4cb0ce031e227a0 Mon Sep 17 00:00:00 2001
From: Eric Lippmann <eric.lippmann@netways.de>
Date: Thu, 1 Sep 2016 10:47:06 +0200
Subject: [PATCH] Add RestRequest class

refs #11398
---
 .../Monitoring/Web/Rest/RestRequest.php       | 269 ++++++++++++++++++
 1 file changed, 269 insertions(+)
 create mode 100644 modules/monitoring/library/Monitoring/Web/Rest/RestRequest.php

diff --git a/modules/monitoring/library/Monitoring/Web/Rest/RestRequest.php b/modules/monitoring/library/Monitoring/Web/Rest/RestRequest.php
new file mode 100644
index 000000000..7506f6418
--- /dev/null
+++ b/modules/monitoring/library/Monitoring/Web/Rest/RestRequest.php
@@ -0,0 +1,269 @@
+<?php
+/* Icinga Web 2 | (c) 2016 Icinga Development Team | GPLv2+ */
+
+namespace Icinga\Module\Monitoring\Web\Rest;
+
+use Exception;
+
+/**
+ * REST Request
+ */
+class RestRequest
+{
+    /**
+     * Request URI
+     *
+     * @var string
+     */
+    protected $uri;
+
+    /**
+     * Request method
+     *
+     * @var string
+     */
+    protected $method;
+
+    /**
+     * Request content type
+     *
+     * @var string
+     */
+    protected $contentType;
+
+    /**
+     * Whether to authenticate with basic auth
+     *
+     * @var bool
+     */
+    protected $hasBasicAuth;
+
+    /**
+     * Auth username
+     *
+     * @var string
+     */
+    protected $username;
+
+    /**
+     * Auth password
+     *
+     * @var string
+     */
+    protected $password;
+
+    /**
+     * Request payload
+     *
+     * @var mixed
+     */
+    protected $payload;
+
+    /**
+     * Whether strict SSL is enabled
+     *
+     * @var bool
+     */
+    protected $strictSsl = true;
+
+    /**
+     * Request timeout
+     *
+     * @var int
+     */
+    protected $timeout = 30;
+
+    /**
+     * Create a POST REST request
+     *
+     * @param   string  $uri
+     *
+     * @return  static
+     */
+    public static function post($uri)
+    {
+        $request = new static;
+        $request->uri = $uri;
+        $request->method = 'POST';
+        return $request;
+    }
+
+    /**
+     * Send content type JSON
+     *
+     * @return $this
+     */
+    public function sendJson()
+    {
+        $this->contentType = 'application/json';
+
+        return $this;
+    }
+
+    /**
+     * Set basic auth credentials
+     *
+     * @param   string  $username
+     * @param   string  $password
+     *
+     * @return  $this
+     */
+    public function authenticateWith($username, $password)
+    {
+        $this->hasBasicAuth = true;
+        $this->username = $username;
+        $this->password = $password;
+
+        return $this;
+    }
+
+    /**
+     * Set request payload
+     *
+     * @param   mixed   $payload
+     *
+     * @return  $this
+     */
+    public function setPayload($payload)
+    {
+        $this->payload = $payload;
+
+        return $this;
+    }
+
+    /**
+     * Disable strict SSL
+     *
+     * @return $this
+     */
+    public function noStrictSsl()
+    {
+        $this->strictSsl = false;
+
+        return $this;
+    }
+
+    /**
+     * Serialize payload according to content type
+     *
+     * @param   mixed   $payload
+     * @param   string  $contentType
+     *
+     * @return  string
+     */
+    public function serializePayload($payload, $contentType)
+    {
+        switch ($contentType) {
+            case 'application/json':
+                $payload = json_encode($payload);
+                break;
+        }
+
+        return $payload;
+    }
+
+    /**
+     * Send the request
+     *
+     * @return  mixed
+     *
+     * @throws  Exception
+     */
+    public function send()
+    {
+        $defaults = array(
+            'host'  => 'localhost',
+            'path'  => '/'
+        );
+
+        $url = array_merge($defaults, parse_url($this->uri));
+
+        if (isset($url['port'])) {
+            $url['host'] .= sprintf(':%u', $url['port']);
+        }
+
+        if (isset($url['query'])) {
+            $url['path'] .= sprintf('?%s', $url['query']);
+        }
+
+        $headers = array(
+            "{$this->method} {$url['path']} HTTP/1.1",
+            "Host: {$url['host']}",
+            "Content-Type: {$this->contentType}",
+            'Accept: application/json',
+            // Bypass "Expect: 100-continue" timeouts
+            'Expect:'
+        );
+
+        $ch = curl_init();
+
+        $options = array(
+            CURLOPT_URL     => $this->uri,
+            CURLOPT_TIMEOUT => $this->timeout,
+            // Ignore proxy settings
+            CURLOPT_PROXY           => '',
+            CURLOPT_CUSTOMREQUEST   => $this->method,
+            CURLOPT_RETURNTRANSFER  => true
+        );
+
+        if ($this->strictSsl) {
+            $options[CURLOPT_SSL_VERIFYHOST] = 2;
+            $options[CURLOPT_SSL_VERIFYPEER] = true;
+        } else {
+            $options[CURLOPT_SSL_VERIFYHOST] = false;
+            $options[CURLOPT_SSL_VERIFYPEER] = false;
+        }
+
+        if ($this->hasBasicAuth) {
+            $options[CURLOPT_USERPWD] = sprintf('%s:%s', $this->username, $this->password);
+        }
+
+        if (! empty($this->payload)) {
+            $payload = $this->serializePayload($this->payload, $this->contentType);
+            $options[CURLOPT_POSTFIELDS] = $payload;
+        }
+
+        $options[CURLOPT_HTTPHEADER] = $headers;
+
+        curl_setopt_array($ch, $options);
+
+        $result = curl_exec($ch);
+
+        if ($result === false) {
+            throw new Exception(curl_error($ch));
+        }
+
+        curl_close($ch);
+
+        $response = @json_decode($result, true);
+
+        if ($response === null) {
+            if (version_compare(PHP_VERSION, '5.5.0', '>=')) {
+                throw new Exception(json_last_error_msg());
+            } else {
+                switch (json_last_error()) {
+                    case JSON_ERROR_DEPTH:
+                        $msg = 'The maximum stack depth has been exceeded';
+                        break;
+                    case JSON_ERROR_CTRL_CHAR:
+                        $msg = 'Control character error, possibly incorrectly encoded';
+                        break;
+                    case JSON_ERROR_STATE_MISMATCH:
+                        $msg = 'Invalid or malformed JSON';
+                        break;
+                    case JSON_ERROR_SYNTAX:
+                        $msg = 'Syntax error';
+                        break;
+                    case JSON_ERROR_UTF8:
+                        $msg = 'Malformed UTF-8 characters, possibly incorrectly encoded';
+                        break;
+                    default:
+                        $msg = 'An error occured when parsing a JSON string';
+                }
+                throw new Exception($msg);
+            }
+        }
+
+        return $response;
+    }
+}