EasyHttp\Middleware

Complexity

Total Complexity

26

Size/Duplication

Total Lines	185
Duplicated Lines	0 %

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
B	set_curl_options()	0	48	7
A	handle_media()	0	20	5
A	create_curl_handler()	0	23	6
A	stream_write()	0	18	3
A	stream_read()	0	27	5

<?php

namespace EasyHttp;

use EasyHttp\Contracts\CommonsContract;
use EasyHttp\Exceptions\ConnectionException;
use EasyHttp\Model\HttpOptions;
use EasyHttp\Utils\Toolkit;

/**
 * Middleware class
 *
 * @link    https://github.com/shahradelahi/easy-http
 * @author  Shahrad Elahi (https://github.com/shahradelahi)
 * @license https://github.com/shahradelahi/easy-http/blob/master/LICENSE (MIT License)
 */
class Middleware
{

	/**
	 * Create curl handler.
	 *
	 * @param ?string $method
	 * @param string $uri
	 * @param array|HttpOptions $options
	 *
	 * @return \CurlHandle|false
	 */
	public static function create_curl_handler(?string $method, string $uri, array|HttpOptions $options = []): \CurlHandle|false
	{
		$handler = curl_init();
		if (is_resource($handler) || !$handler) {
			return false;
		}

		if (gettype($options) === 'array') {
			$options = new HttpOptions($options);
		}

		if (count($options->getQuery()) > 0) {
			if (!str_contains($uri, '?')) {
				$uri .= '?';
			}
			$uri .= $options->getQueryString();
		}

		curl_setopt($handler, CURLOPT_URL, $uri);

		self::set_curl_options($method, $handler, $options);

		return $handler;
	}

	/**
	 * Setup curl options based on the given method and our options.
	 *
	 * @param \CurlHandle $cHandler
	 * @param ?string $method
	 * @param HttpOptions $options
	 *
	 * @return void
	 */
	public static function set_curl_options(?string $method, \CurlHandle $cHandler, HttpOptions $options): void
	{
		curl_setopt($cHandler, CURLOPT_HEADER, true);
		curl_setopt($cHandler, CURLOPT_CUSTOMREQUEST, $method ?? 'GET');

		# Fetch the header
		$fetchedHeaders = [];
		foreach ($options->getHeaders() as $header => $value) {
			$fetchedHeaders[] = $header . ': ' . $value;
		}

		# Set headers
		curl_setopt($cHandler, CURLOPT_HTTPHEADER, $fetchedHeaders ?? []);

		# Add body if we have one.
		if ($options->getBody()) {
			curl_setopt($cHandler, CURLOPT_CUSTOMREQUEST, $method ?? 'POST');
			curl_setopt($cHandler, CURLOPT_POSTFIELDS, $options->getBody());
			curl_setopt($cHandler, CURLOPT_POST, true);
		}

		# Check for a proxy
		if ($options->getProxy() != null) {
			curl_setopt($cHandler, CURLOPT_PROXY, $options->getProxy()->getHost());
			curl_setopt($cHandler, CURLOPT_PROXYUSERPWD, $options->getProxy()->getAuth());
			if ($options->getProxy()->type !== null) {
				curl_setopt($cHandler, CURLOPT_PROXYTYPE, $options->getProxy()->type);
			}
		}

		curl_setopt($cHandler, CURLOPT_RETURNTRANSFER, true);
		curl_setopt($cHandler, CURLOPT_FOLLOWLOCATION, true);

		# Add and override the custom curl options.
		foreach ($options->getCurlOptions() as $option => $value) {
			curl_setopt($cHandler, $option, $value);
		}

		# if we have a timeout, set it.
		curl_setopt($cHandler, CURLOPT_TIMEOUT, $options->getTimeout());

		# If self-signed certs are allowed, set it.
		if ((bool)getenv('HAS_SELF_SIGNED_CERT') === true) {
			curl_setopt($cHandler, CURLOPT_SSL_VERIFYPEER, false);
			curl_setopt($cHandler, CURLOPT_SSL_VERIFYHOST, false);
		}

		(new Middleware())->handle_media($cHandler, $options);
	}

	/**
	 * Handle the media
	 *
	 * @param \CurlHandle $handler
	 * @param HttpOptions $options
	 * @return void
	 */
	private function handle_media(\CurlHandle $handler, HttpOptions $options): void
	{
		if (count($options->getMultipart()) > 0) {
			curl_setopt($handler, CURLOPT_POST, true);
			curl_setopt($handler, CURLOPT_CUSTOMREQUEST, 'POST');

			$form_data = new FormData();
			foreach ($options->getMultipart() as $key => $value) {
				$form_data->addFile($key, $value);
			}

			$headers = [];
			foreach ($options->getHeaders() as $header => $value) {
				if (Toolkit::insensitiveString($header, 'content-type')) continue;
				$headers[] = $header . ': ' . $value;
			}
			$headers[] = 'Content-Type: multipart/form-data';

			curl_setopt($handler, CURLOPT_HTTPHEADER, $headers);
			curl_setopt($handler, CURLOPT_POSTFIELDS, $form_data->getFiles());
		}
	}

	/**
	 * @param mixed $socket
	 * @param int $len
	 * @return string|null
	 * @throws ConnectionException
	 */
	public static function stream_read(mixed $socket, int $len): string|null
	{
		if (!is_resource($socket)) {
			throw new ConnectionException(sprintf(
				'%s is not a valid resource. Datatype: %s', $socket, gettype($socket)
			));
		}

		$data = '';
		while (($dataLen = strlen($data)) < $len) {
			$buff = fread($socket, $len - $dataLen);

			if ($buff === false) {
				return null;
			}

			if ($buff === '') {
				$metadata = stream_get_meta_data($socket);
				throw new ConnectionException(
					sprintf('Empty read; connection dead?  Stream state: %s', json_encode($metadata)),
					CommonsContract::CLIENT_EMPTY_READ
				);
			}
			$data .= $buff;
		}

		return $data;
	}

	/**
	 * @param mixed $socket
	 * @param string $data
	 * @return bool
	 * @throws ConnectionException
	 */
	public static function stream_write(mixed $socket, string $data): bool
	{
		if (!is_resource($socket)) {
			throw new ConnectionException(sprintf(
				'%s is not a valid resource. Datatype: %s', $socket, gettype($socket)
			));
		}

		$written = fwrite($socket, $data);

		if ($written < strlen($data)) {
			throw new ConnectionException(
				sprintf('Could only write %s out of %s bytes.', $written, strlen($data)),
				CommonsContract::CLIENT_COULD_ONLY_WRITE_LESS
			);
		}

		return true;
	}

	/**
	 * Stream connect
	 */

}