<?php


namespace Kiri;


use Closure;
use CurlHandle;

defined('SPLIT_URL') or define('SPLIT_URL', '/(http[s]?:\/\/)?(([\w\-_]+\.)+\w+(:\d+)?)((\/[a-zA-Z0-9\-]+)+[\/]?(\?[a-zA-Z]+=.*)?)?/');


/**
 * Class ClientAbstracts
 * @package Http\Handler\Client
 */
abstract class ClientAbstracts implements IClient
{

    const string POST    = 'post';
    const string UPLOAD  = 'upload';
    const string GET     = 'get';
    const string DELETE  = 'delete';
    const string OPTIONS = 'options';
    const string HEAD    = 'head';
    const string PUT     = 'put';

    private string $host            = '';
    private array  $header          = [];
    private int    $timeout         = 0;
    private string $method          = 'get';
    private bool   $isSSL           = FALSE;
    private string $agent           = '';
    private string $ssl_cert_file   = '';
    private string $ssl_key_file    = '';
    private string $ca              = '';
    private int    $port            = 80;
    protected int  $num             = 0;
    private ?array $_responseHeader = [];
    private int    $statusCode      = 200;
    protected int  $retryNum        = 0;
    protected int  $retryTimeout    = 0;
    private bool   $verifyPeer      = TRUE;
    private string $proxyHost       = '';
    private int    $proxyPort       = 0;


    /**
     * @var string|null
     */
    protected ?string $body;


    private string|array|null $_data = NULL;

    private int $connect_timeout = 1;


    /**
     * @var resource|\Swoole\Coroutine\Http\Client|\Swoole\Client|CurlHandle
     */
    protected mixed $client;


    /**
     * @param int $retryNum
     * @return $this
     */
    public function withRetryNum(int $retryNum): static
    {
        $this->retryNum = $retryNum;
        return $this;
    }


    /**
     * @return string
     */
    public function getProxyHost(): string
    {
        return $this->proxyHost;
    }


    /**
     * @return string
     */
    public function getProxyPort(): string
    {
        return $this->proxyPort;
    }


    /**
     * @param string $proxy
     * @return ClientAbstracts
     */
    public function withProxyHost(string $proxy): static
    {
        $this->proxyHost = $proxy;
        return $this;
    }


    /**
     * @param int $proxy
     * @return ClientAbstracts
     */
    public function withProxyPort(int $proxy): static
    {
        $this->proxyPort = $proxy;
        return $this;
    }


    /**
     * @param int $retryTimeout
     * @return $this
     */
    public function withRetryTimeout(int $retryTimeout): static
    {
        $this->retryTimeout = $retryTimeout;
        return $this;
    }


    /**
     * @return int
     */
    public function getRetryNum(): int
    {
        return $this->retryNum;
    }


    /**
     * @return int
     */
    public function getRetryTimeout(): int
    {
        return $this->retryTimeout;
    }


    /**
     * @param bool $bool
     * @return $this
     */
    public function withVerifyPeer(bool $bool): static
    {
        $this->verifyPeer = $bool;
        return $this;
    }


    /**
     * @return bool
     */
    public function getVerifyPeer(): bool
    {
        return $this->verifyPeer;
    }


    /**
     * @return int
     */
    public function getStatusCode(): int
    {
        return $this->statusCode;
    }


    /**
     * @return array
     */
    public function getResponseHeaders(): array
    {
        return $this->_responseHeader;
    }


    /**
     * @param string $key
     * @return string|int|null
     */
    public function getResponseHeader(string $key): null|string|int
    {
        return $this->_responseHeader[$key] ?? NULL;
    }


    /**
     * @param null|array $responseHeader
     */
    public function setResponseHeader(?array $responseHeader): void
    {
        $this->_responseHeader = $responseHeader;
    }


    /**
     * @param int $statusCode
     */
    public function setStatusCode(int $statusCode): void
    {
        $this->statusCode = $statusCode;
    }


    /**
     * @return string|null
     */
    public function getBody(): string|null
    {
        return $this->body;
    }


    /**
     * @param ?string $body
     */
    public function setBody(?string $body): void
    {
        $this->body = $body;
    }


    /**
     * @param string $host
     * @param int $port
     * @param false $isSSL
     */
    public function __construct(string $host, int $port, bool $isSSL = FALSE)
    {
        $this->withHost($host)->withPort($port)->withIsSSL($isSSL);
    }


    /**
     * @param string $path
     * @param array|string $params
     */
    public function post(string $path, array|string $params = []): void
    {
        $this->request(self::POST, $path, $params);
    }


    /**
     * @param string $path
     * @param array|string $params
     */
    public function put(string $path, array|string $params = []): void
    {
        $this->request(self::PUT, $path, $params);
    }


    /**
     * @param string $contentType
     * @return ClientAbstracts
     */
    public function withContentType(string $contentType): static
    {
        $this->header['Content-Type'] = $contentType;
        return $this;
    }


    /**
     * @param string $path
     * @param array|string $params
     */
    public function head(string $path, array|string $params = []): void
    {
        $this->request(self::HEAD, $path, $params);
    }


    /**
     * @param string $path
     * @param array|string $params
     */
    public function get(string $path, array|string $params = []): void
    {
        if (is_array($params)) {
            $params = http_build_query($params);
        }
        $this->request(self::GET, $path, $params);
    }

    /**
     * @param string $path
     * @param array|string $params
     */
    public function option(string $path, array|string $params = []): void
    {
        $this->request(self::OPTIONS, $path, $params);
    }

    /**
     * @param string $path
     * @param array|string $params
     */
    public function delete(string $path, array|string $params = []): void
    {
        $this->request(self::DELETE, $path, $params);
    }

    /**
     * @param string $path
     * @param array|string $params
     */
    public function options(string $path, array|string $params = []): void
    {
        $this->request(self::OPTIONS, $path, $params);

    }

    /**
     * @param string $path
     * @param array|string $params
     */
    public function upload(string $path, array|string $params = []): void
    {
        $this->request(self::UPLOAD, $path, $params);
    }


    /**
     * @return string
     */
    public function getHost(): string
    {
        return $this->host;
    }

    /**
     * @return int
     */
    protected function getHostPort(): int
    {
        if (!empty($this->getPort())) {
            return $this->getPort();
        }
        $port = 80;
        if ($this->isSSL()) $port = 443;
        return $port;
    }


    /**
     * @param string $host
     * @return ClientAbstracts
     */
    protected function withHost(string $host): static
    {
        $this->host = $host;
        return $this;
    }

    /**
     * @return array
     */
    public function getHeader(): array
    {
        return $this->header;
    }


    /**
     * @return mixed|null
     */
    public function getContentType(): ?string
    {
        return $this->header['Content-Type'] ?? $this->header['content-type'] ?? NULL;
    }


    /**
     * @param array $header
     * @return ClientAbstracts
     */
    public function withHeader(array $header): static
    {
        $this->header = $header;
        return $this;
    }


    /**
     * @param array $header
     * @return ClientAbstracts
     */
    public function withHeaders(array $header): static
    {
        if (empty($header)) {
            return $this;
        }
        foreach ($header as $key => $val) {
            $this->header[$key] = $val;
        }
        return $this;
    }

    /**
     * @param string $key
     * @param string|array $value
     * @return ClientAbstracts
     */
    public function withAddedHeader(string $key, string|array $value): static
    {
        $this->header[$key] = $value;
        return $this;
    }

    /**
     * @return int
     */
    public function getTimeout(): int
    {
        return $this->timeout;
    }

    /**
     * @param int $value
     * @return ClientAbstracts
     */
    public function withTimeout(int $value): static
    {
        $this->timeout = $value;
        return $this;
    }


    /**
     * @param Closure|null $value
     * @return ClientAbstracts
     */
    public function withCallback(?Closure $value): static
    {
        return $this;
    }

    /**
     * @return string
     */
    public function getMethod(): string
    {
        return $this->method;
    }

    /**
     * @param string $value
     * @return static
     */
    public function withMethod(string $value): static
    {
        $this->method = $value;
        return $this;
    }

    /**
     * @return bool
     */
    public function isSSL(): bool
    {
        return $this->isSSL;
    }

    /**
     * @param bool $isSSL
     * @return ClientAbstracts
     */
    public function withIsSSL(bool $isSSL): static
    {
        $this->isSSL = $isSSL;
        return $this;
    }

    /**
     * @return string
     */
    public function getAgent(): string
    {
        return $this->agent;
    }

    /**
     * @param string $agent
     * @return ClientAbstracts
     */
    public function withAgent(string $agent): static
    {
        $this->agent = $agent;
        return $this;
    }


    /**
     * @return string
     */
    public function getSslCertFile(): string
    {
        return $this->ssl_cert_file;
    }

    /**
     * @param string $ssl_cert_file
     * @return ClientAbstracts
     */
    public function withSslCertFile(string $ssl_cert_file): static
    {
        $this->ssl_cert_file = $ssl_cert_file;
        return $this;
    }

    /**
     * @return string
     */
    public function getSslKeyFile(): string
    {
        return $this->ssl_key_file;
    }

    /**
     * @param string $ssl_key_file
     * @return ClientAbstracts
     */
    public function withSslKeyFile(string $ssl_key_file): static
    {
        $this->ssl_key_file = $ssl_key_file;
        return $this;
    }

    /**
     * @return string
     */
    public function getCa(): string
    {
        return $this->ca;
    }

    /**
     * @param string $ssl_key_file
     * @return static
     */
    public function withCa(string $ssl_key_file): static
    {
        $this->ca = $ssl_key_file;
        return $this;
    }

    /**
     * @return int
     */
    public function getPort(): int
    {
        if ($this->isSSL()) {
            return 443;
        }
        if (empty($this->port)) {
            return 80;
        }
        return $this->port;
    }

    /**
     * @param int $port
     * @return ClientAbstracts
     */
    private function withPort(int $port): static
    {
        $this->port = $port;
        return $this;
    }


    /**
     * @return string|null
     */
    public function getData(): ?string
    {
        return $this->_data;
    }

    /**
     * @param string|null $data
     * @return ClientAbstracts
     */
    public function withBody(?string $data): static
    {
        $this->_data = $data;
        return $this;
    }

    /**
     * @return int
     */
    public function getConnectTimeout(): int
    {
        return $this->connect_timeout;
    }

    /**
     * @param int $connect_timeout
     * @return ClientAbstracts
     */
    public function withConnectTimeout(int $connect_timeout): static
    {
        $this->connect_timeout = $connect_timeout;
        return $this;
    }


    /**
     * @param string $host
     * @return string|string[]
     */
    protected function replaceHost(string $host): array|string
    {
        if ($this->isHttp($host)) {
            return str_replace('http://', '', $host);
        }
        if ($this->isHttps($host)) {
            return str_replace('https://', '', $host);
        }
        return $host;
    }


    /**
     * @param string $url
     * @return false|int
     */
    protected function checkIsIp(string $url): bool|int
    {
        return preg_match('/\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}/', $url);
    }

    /**
     * @param string $url
     * @return bool
     */
    protected function isHttp(string $url): bool
    {
        return str_starts_with($url, 'http://');
    }

    /**
     * @param string $url
     * @return bool
     */
    protected function isHttps(string $url): bool
    {
        return str_starts_with($url, 'https://');
    }


    /**
     * @param array|string $newData
     * @return string|null
     */
    protected function mergeParams(array|string $newData): ?string
    {
        if (is_array($newData)) {
            return json_encode($newData, JSON_UNESCAPED_UNICODE);
        }
        return $newData;
    }


    /**
     * @return bool
     * check isPost Request
     */
    protected function isPost(): bool
    {
        return strtolower($this->method) === self::POST;
    }

    /**
     * @return bool
     * check isPost Request
     */
    protected function isUpload(): bool
    {
        return strtolower($this->method) === self::UPLOAD;
    }


    /**
     * @return bool
     *
     * check isGet Request
     */
    protected function isGet(): bool
    {
        return strtolower($this->method) === self::GET;
    }

    /**
     * @param array|string $arr
     *
     * @return array|string
     * 将请求参数进行编码
     */
    protected function paramEncode(array|string $arr): array|string
    {
        if (!is_array($arr)) {
            return $arr;
        }
        $_tmp = [];
        foreach ($arr as $Key => $val) {
            $_tmp[$Key] = $val;
        }
        if ($this->isGet()) {
            return http_build_query($_tmp);
        }
        return $_tmp;
    }


    /**
     * @param string $string
     * @return array
     */
    protected function matchHost(string $string): array
    {
        return [$this->host, $this->isSSL(), $string];
    }


    /**
     * @param string $path
     * @param array|string $params
     * @return string
     */
    protected function joinGetParams(string $path, array|string $params): string
    {
        if (empty($params)) {
            return $path;
        }
        if (!is_string($params)) {
            $params = http_build_query($params);
        }
        if (str_contains($path, '?')) {
            [$path, $getParams] = explode('?', $path);
        }
        if (empty($getParams)) {
            return $path . '?' . $params;
        }
        return $path . '?' . $params . '&' . $getParams;
    }

}