1:   2:   3:   4:   5:   6:   7:   8:   9:  10:  11:  12:  13:  14:  15:  16:  17:  18:  19:  20:  21:  22:  23:  24:  25:  26:  27:  28:  29:  30:  31:  32:  33:  34:  35:  36:  37:  38:  39:  40:  41:  42:  43:  44:  45:  46:  47:  48:  49:  50:  51:  52:  53:  54:  55:  56:  57:  58:  59:  60:  61:  62:  63:  64:  65:  66:  67:  68:  69:  70:  71:  72:  73:  74:  75:  76:  77:  78:  79:  80:  81:  82:  83:  84:  85:  86:  87:  88:  89:  90:  91:  92:  93:  94:  95:  96:  97:  98:  99: 100: 101: 102: 103: 104: 105: 106: 107: 108: 109: 110: 111: 112: 113: 114: 115: 116: 117: 118: 119: 120: 121: 122: 123: 

<?php

/**
 * ManyChat API PHP library
 *
 * @copyright 2019 ManyChat, Inc.
 * @license https://opensource.org/licenses/MIT The MIT License
 */

namespace ManyChat\Utils;

use ManyChat\Exception\HTTPNotFoundException;
use ManyChat\Exception\RequestCURLException;

/**
 * CURL-request wrapper
 * @package ManyChat\Utils
 */
class Request
{
    /** @var integer HTTP method GET */
    public const GET = 1;

    /** @var integer HTTP method POST */
    public const POST = 2;

    /** @var integer HTTP Not Found status code */
    public const HTTP_NOTFOUND_CODE = 404;

    /** @var resource|false $curl CURL session object */
    private $curl;

    /** @var array $defaultHeaders Default request headers */
    private $defaultHeaders;

    /** @var array $defaultCURLOptions Default CURL options */
    private $defaultCURLOptions;

    public function __construct($defaultHeaders = [], $defaultCURLOptions = [])
    {
        $this->curl = curl_init();
        $this->defaultHeaders = $defaultHeaders;
        $this->defaultCURLOptions = $defaultCURLOptions;
    }

    /**
     * Makes CURL request with given CURL options
     *
     * @param array $curlOptions CURL options
     *
     * @return string Request's response
     * @throws RequestCURLException If the request didn't succeed
     * @throws HTTPNotFoundException If the server's reply is HTTP Not Found code (404)
     */
    public function request(array $curlOptions): string
    {
        if (!empty($this->defaultHeaders)) {
            if (!isset($curlOptions[CURLOPT_HTTPHEADER])) {
                $curlOptions[CURLOPT_HTTPHEADER] = [];
            }
            $curlOptions[CURLOPT_HTTPHEADER] = $this->defaultHeaders + $curlOptions[CURLOPT_HTTPHEADER];
        }

        $options = $this->defaultCURLOptions + $curlOptions;
        curl_setopt_array($this->curl, $options);

        $result = curl_exec($this->curl);
        if ($result === false) {
            throw new RequestCURLException(curl_error($this->curl), curl_errno($this->curl));
        }

        $responseCode = curl_getinfo($this->curl, CURLINFO_RESPONSE_CODE);
        if ($responseCode === self::HTTP_NOTFOUND_CODE) {
            throw new HTTPNotFoundException("404 Not Found: {$options[CURLOPT_URL]}");
        }

        return $result;
    }

    /**
     * Makes CURL GET-request to the $url with parameters $data
     *
     * @param string $url URL
     * @param array|null $data GET-request parameters
     *
     * @return string Request's response
     * @throws RequestCURLException If the request didn't succeed
     */
    public function get(string $url, ?array $data = []): string
    {
        if (!empty($data)) {
            $url = $url.'?'.http_build_query($data);
        }

        $options = [
            CURLOPT_URL => $url,
        ];

        return $this->request($options);
    }

    /**
     * Makes CURL POST-request to the $url with parameters $data
     *
     * @param string $url URL
     * @param string $data POST-request parameters
     *
     * @return string Request's response
     * @throws RequestCURLException If the request didn't succeed
     */
    public function post(string $url, string $data)
    {
        $options = [
            CURLOPT_URL => $url,
            CURLOPT_POST => true,
            CURLOPT_POSTFIELDS => $data,
        ];

        return $this->request($options);
    }

}