shahradelahi / easy-http

examples/bulk-request/breakdown-large-request.php

Indentation +124 added lines, -124 removed lines

@@ -17,117 +17,117 @@ 
 $client = new \EasyHttp\Client();
 $endpoint = 'https://scanner.tradingview.com/america/scan';
 $post = [
-	'filter' => [
-		[
-			'left' => "exchange",
-			'operation' => "in_range",
-			'right' => [
-				'AMEX',
-				'NASDAQ',
-				'NYSE'
-			],
-		],
-		[
-			'left' => "is_primary",
-			'operation' => "equal",
-			'right' => true,
-		],
-		[
-			'left' => "change",
-			'operation' => "nempty",
-		]
-	],
-	'options' => [
-		'lang' => "en",
-		'active_symbols_only' => true,
-	],
-	'markets' => [
-		"america"
-	],
-	'columns' => [
-		"logoid",
-		"name",
-		"change|1",
-		"change|5",
-		"change|15",
-		"change|60",
-		"change|240",
-		"change",
-		"change|1W",
-		"change|1M",
-		"Perf.3M",
-		"Perf.6M",
-		"Perf.YTD",
-		"Perf.Y",
-		"Volatility.D",
-		"description",
-		"type",
-		"subtype",
-		"update_mode",
-		"currency",
-		"fundamental_currency_code",
-		"Recommend.All",
-		"RSI",
-		"RSI[1]",
-		"Stoch.K",
-		"Stoch.D",
-		"Stoch.K[1]",
-		"Stoch.D[1]",
-		"CCI20",
-		"CCI20[1]",
-		"AO",
-		"AO[1]",
-		"AO[2]",
-		"Mom",
-		"Mom[1]",
-		"MACD.macd",
-		"MACD.signal",
-		"Rec.Stoch.RSI",
-		"Stoch.RSI.K",
-		"Rec.WR",
-		"W.R",
-		"Rec.BBPower",
-		"BBPower",
-		"Rec.UO",
-		"UO",
-		"EMA10",
-		"close",
-		"SMA10",
-		"EMA20",
-		"SMA20",
-		"EMA30",
-		"SMA30",
-		"EMA50",
-		"SMA50",
-		"EMA100",
-		"SMA100",
-		"EMA200",
-		"SMA200",
-		"Rec.Ichimoku",
-		"Ichimoku.BLine",
-		"Rec.VWMA",
-		"VWMA",
-		"Rec.HullMA9",
-		"HullMA9"
-	],
-	'sort' => [
-		'sortBy' => "change",
-		'sortOrder' => "desc"
-	]
+    'filter' => [
+        [
+            'left' => "exchange",
+            'operation' => "in_range",
+            'right' => [
+                'AMEX',
+                'NASDAQ',
+                'NYSE'
+            ],
+        ],
+        [
+            'left' => "is_primary",
+            'operation' => "equal",
+            'right' => true,
+        ],
+        [
+            'left' => "change",
+            'operation' => "nempty",
+        ]
+    ],
+    'options' => [
+        'lang' => "en",
+        'active_symbols_only' => true,
+    ],
+    'markets' => [
+        "america"
+    ],
+    'columns' => [
+        "logoid",
+        "name",
+        "change|1",
+        "change|5",
+        "change|15",
+        "change|60",
+        "change|240",
+        "change",
+        "change|1W",
+        "change|1M",
+        "Perf.3M",
+        "Perf.6M",
+        "Perf.YTD",
+        "Perf.Y",
+        "Volatility.D",
+        "description",
+        "type",
+        "subtype",
+        "update_mode",
+        "currency",
+        "fundamental_currency_code",
+        "Recommend.All",
+        "RSI",
+        "RSI[1]",
+        "Stoch.K",
+        "Stoch.D",
+        "Stoch.K[1]",
+        "Stoch.D[1]",
+        "CCI20",
+        "CCI20[1]",
+        "AO",
+        "AO[1]",
+        "AO[2]",
+        "Mom",
+        "Mom[1]",
+        "MACD.macd",
+        "MACD.signal",
+        "Rec.Stoch.RSI",
+        "Stoch.RSI.K",
+        "Rec.WR",
+        "W.R",
+        "Rec.BBPower",
+        "BBPower",
+        "Rec.UO",
+        "UO",
+        "EMA10",
+        "close",
+        "SMA10",
+        "EMA20",
+        "SMA20",
+        "EMA30",
+        "SMA30",
+        "EMA50",
+        "SMA50",
+        "EMA100",
+        "SMA100",
+        "EMA200",
+        "SMA200",
+        "Rec.Ichimoku",
+        "Ichimoku.BLine",
+        "Rec.VWMA",
+        "VWMA",
+        "Rec.HullMA9",
+        "HullMA9"
+    ],
+    'sort' => [
+        'sortBy' => "change",
+        'sortOrder' => "desc"
+    ]
 ];
 
 $start = microtime(true);
 $Response = $client->post($endpoint, [
-	'headers' => [
-		'Content-Type' => 'application/json',
-		'Accept' => 'application/json',
-	],
-	'body' => array_merge($post, [
-		'range' => [
-			0,
-			2000
-		]
-	]),
+    'headers' => [
+        'Content-Type' => 'application/json',
+        'Accept' => 'application/json',
+    ],
+    'body' => array_merge($post, [
+        'range' => [
+            0,
+            2000
+        ]
+    ]),
 ]);
 $Data = json_decode($Response->getBody(), true);
 $Memory = \EasyHttp\Utils\Toolkit::bytesToHuman(memory_get_usage());
@@ -139,22 +139,22 @@ 
 // Initializes the request
 $requests = [];
 for ($i = 0; $i < 2000; $i += 500) {
-	$requests[] = [
-		'method' => 'POST',
-		'uri' => $endpoint,
-		'options' => [
-			'headers' => [
-				'Content-Type' => 'application/json',
-				'Accept' => 'application/json',
-			],
-			'body' => array_merge($post, [
-				'range' => [
-					$i,
-					$i + 500
-				]
-			]),
-		]
-	];
+    $requests[] = [
+        'method' => 'POST',
+        'uri' => $endpoint,
+        'options' => [
+            'headers' => [
+                'Content-Type' => 'application/json',
+                'Accept' => 'application/json',
+            ],
+            'body' => array_merge($post, [
+                'range' => [
+                    $i,
+                    $i + 500
+                ]
+            ]),
+        ]
+    ];
 }
 
 // --------------------- ====== --------------------- //
@@ -162,7 +162,7 @@ 
 $start = microtime(true);
 $responses = $client->bulk($requests);
 foreach ($responses as $response) {
-	$Data = json_decode($response->getBody(), true);
+    $Data = json_decode($response->getBody(), true);
 }
 $Memory = \EasyHttp\Utils\Toolkit::bytesToHuman(memory_get_usage());
 echo '<pre>' . "Bulk Request - Total time: " . (microtime(true) - $start) . " - Memory: $Memory" . '</pre>';
\ No newline at end of file

examples/download/download-large-file.php

Indentation +2 added lines, -2 removed lines

@@ -13,7 +13,7 @@
 
 
 if ($Result->save(__DIR__ . '/uploads/google.png')) {
-	echo 'File saved successfully';
+    echo 'File saved successfully';
 } else {
-	echo 'File not saved';
+    echo 'File not saved';
 }
\ No newline at end of file

examples/upload/josh_sean.php

Indentation +9 added lines, -9 removed lines

@@ -2,15 +2,15 @@
 
 function generateUpToDateMimeArray(string $url): array
 {
-	$s = array();
-	foreach (@explode("\n", @file_get_contents($url)) as $x) {
-		if (isset($x[0]) && $x[0] !== '#' && preg_match_all('#([^\s]+)#', $x, $out) && isset($out[1]) && ($c = count($out[1])) > 1) {
-			for ($i = 1; $i < $c; $i++) {
-				$s[$out[1][$i]] = $out[1][0];
-			}
-		}
-	}
-	return $s;
+    $s = array();
+    foreach (@explode("\n", @file_get_contents($url)) as $x) {
+        if (isset($x[0]) && $x[0] !== '#' && preg_match_all('#([^\s]+)#', $x, $out) && isset($out[1]) && ($c = count($out[1])) > 1) {
+            for ($i = 1; $i < $c; $i++) {
+                $s[$out[1][$i]] = $out[1][0];
+            }
+        }
+    }
+    return $s;
 }
 
 $data = generateUpToDateMimeArray('https://svn.apache.org/repos/asf/httpd/httpd/trunk/docs/conf/mime.types');

examples/upload/send-file-to-telegram.php

Indentation +7 added lines, -7 removed lines

@@ -8,13 +8,13 @@
 $chat_id = '259760855';
 
 $response = (new \EasyHttp\Client())->post('https://api.telegram.org/bot' . $your_token . '/sendPhoto', [
-	'query' => [
-		'chat_id' => $chat_id,
-		'caption' => 'Привет!',
-	],
-	'multipart' => \EasyHttp\FormData::create([
-		'photo' => getcwd() . '/../docs/uploads/download.png'
-	])
+    'query' => [
+        'chat_id' => $chat_id,
+        'caption' => 'Привет!',
+    ],
+    'multipart' => \EasyHttp\FormData::create([
+        'photo' => getcwd() . '/../docs/uploads/download.png'
+    ])
 ]);
 
 

examples/upload/upload-multiple-files.php

Indentation +2 added lines, -2 removed lines

@@ -5,8 +5,8 @@
 // =============================== ***** =============================== //
 
 $result = (new \EasyHttp\Client())->upload('https://httpbin.org/post', [
-	'photo1' => getcwd() . '/../docs/uploads/result-of-breakdown-example.png',
-	'photo2' => getcwd() . '/../docs/uploads/download.png',
+    'photo1' => getcwd() . '/../docs/uploads/result-of-breakdown-example.png',
+    'photo2' => getcwd() . '/../docs/uploads/download.png',
 ]);
 
 echo '<pre>' . \EasyHttp\Utils\Toolkit::prettyJson($result->getBody()) . '</pre>';

src/Client.php

Indentation +327 added lines, -327 removed lines

@@ -21,332 +21,332 @@
 class Client
 {
 
-	use ClientTrait;
-
-	/**
-	 * The temp directory to download files - default is $_SERVER['TEMP']
-	 *
-	 * @var ?string
-	 */
-	private ?string $tempDir;
-
-	/**
-	 * The Max count of chunk to download file
-	 *
-	 * @var int
-	 */
-	public int $maxChunkCount = 10;
-
-	/**
-	 * The constructor of the client
-	 */
-	public function __construct()
-	{
-		$this->tempDir = $_SERVER['TEMP'] ?? null;
-		$this->setHasSelfSignedCertificate(true);
-	}
-
-	/**
-	 * Set has self-signed certificate
-	 *
-	 * This is used to set the curl option CURLOPT_SSL_VERIFYPEER
-	 * and CURLOPT_SSL_VERIFYHOST to false. This is useful when you are
-	 * in local environment, or you have self-signed certificate.
-	 *
-	 * @param bool $has
-	 *
-	 * @return void
-	 */
-	public function setHasSelfSignedCertificate(bool $has): void
-	{
-		putenv('HAS_SELF_SIGNED_CERT=' . ($has ? 'true' : 'false'));
-	}
-
-	/**
-	 * Set the temporary directory path to save the downloaded files
-	 *
-	 * @param string $path
-	 *
-	 * @return void
-	 */
-	public function setTempPath(string $path): void
-	{
-		if (!file_exists($path)) {
-			throw new InvalidArgumentException(
-				sprintf('The path "%s" does not exist', $path)
-			);
-		}
-		$this->tempDir = $path;
-	}
-
-	/**
-	 * This method is used to send a http request to a given url.
-	 *
-	 * @param string $method
-	 * @param string $uri
-	 * @param array|HttpOptions $options
-	 *
-	 * @return HttpResponse
-	 */
-	public function request(string $method, string $uri, array|HttpOptions $options = []): HttpResponse
-	{
-		$CurlHandle = Middleware::create_curl_handler($method, $uri, $options);
-		if (!$CurlHandle) {
-			throw new RuntimeException('An error occurred while creating the curl handler');
-		}
-
-		$result = new HttpResponse();
-		$result->setCurlHandle($CurlHandle);
-
-		$response = curl_exec($CurlHandle);
-		if (curl_errno($CurlHandle) || !$response) {
-			$result->setErrorCode(curl_errno($CurlHandle));
-			$result->setErrorMessage(curl_error($CurlHandle) ?? ErrorCode::getMessage(curl_errno($CurlHandle)));
-			return $result;
-		}
-
-		$result->setStatusCode(curl_getinfo($CurlHandle, CURLINFO_HTTP_CODE));
-		$result->setHeaderSize(curl_getinfo($CurlHandle, CURLINFO_HEADER_SIZE));
-		$result->setHeaders(substr((string)$response, 0, $result->getHeaderSize()));
-		$result->setBody(substr((string)$response, $result->getHeaderSize()));
-
-		curl_close($CurlHandle);
-
-		return $result;
-	}
-
-	/**
-	 * Send multiple requests to a given url.
-	 *
-	 * @param array $requests [{method, uri, options}, ...]
-	 *
-	 * @return array<HttpResponse>
-	 */
-	public function bulk(array $requests): array
-	{
-		$result = [];
-		$handlers = [];
-		$multi_handler = curl_multi_init();
-		foreach ($requests as $request) {
-
-			$CurlHandle = Middleware::create_curl_handler(
-				$request['method'] ?? null,
-				$request['uri'],
-				$request['options'] ?? []
-			);
-			if (!$CurlHandle) {
-				throw new RuntimeException(
-					'An error occurred while creating the curl handler'
-				);
-			}
-			$handlers[] = $CurlHandle;
-			curl_multi_add_handle($multi_handler, $CurlHandle);
-
-		}
-
-		$active = null;
-		do {
-			$mrc = curl_multi_exec($multi_handler, $active);
-		} while ($mrc == CURLM_CALL_MULTI_PERFORM);
-
-		while ($active && $mrc == CURLM_OK) {
-			if (curl_multi_select($multi_handler) != -1) {
-				do {
-					$mrc = curl_multi_exec($multi_handler, $active);
-				} while ($mrc == CURLM_CALL_MULTI_PERFORM);
-			}
-		}
-
-		foreach ($handlers as $handler) {
-			curl_multi_remove_handle($multi_handler, $handler);
-		}
-		curl_multi_close($multi_handler);
-
-		foreach ($handlers as $handler) {
-			$content = curl_multi_getcontent($handler);
-			$response = new HttpResponse();
-
-			if (curl_errno($handler)) {
-				$response->setErrorCode(curl_errno($handler));
-				$response->setErrorMessage(
-					curl_error($handler) ??
-					ErrorCode::getMessage(curl_errno($handler))
-				);
-			}
-
-			$response->setCurlHandle($handler);
-			$response->setStatusCode(curl_getinfo($handler, CURLINFO_HTTP_CODE));
-			$response->setHeaderSize(curl_getinfo($handler, CURLINFO_HEADER_SIZE));
-			$response->setHeaders(substr($content, 0, $response->getHeaderSize()));
-			$response->setBody(substr($content, $response->getHeaderSize()));
-
-			$result[] = $response;
-		}
-
-		return $result;
-	}
-
-	/**
-	 * Download large files.
-	 *
-	 * This method is used to download large files with creating multiple requests.
-	 *
-	 * Change `max_chunk_count` variable to change the number of chunks. (default: 10)
-	 *
-	 * @param string $url The direct url to the file.
-	 * @param array|HttpOptions $options The options to use.
-	 *
-	 * @return DownloadResult
-	 */
-	public function download(string $url, array|HttpOptions $options = []): DownloadResult
-	{
-		if (empty($this->tempDir)) {
-			throw new RuntimeException(
-				'The temp directory is not set. Please set the temp directory using the `setTempDir` method.'
-			);
-		}
-
-		if (!file_exists($this->tempDir)) {
-			if (mkdir($this->tempDir, 0777, true) === false) {
-				throw new RuntimeException(
-					'The temp directory is not writable. Please set the temp directory using the `setTempDir` method.'
-				);
-			}
-		}
-
-		if (gettype($options) === 'array') {
-			$options = new HttpOptions($options);
-		}
-
-		$fileSize = $this->get_file_size($url);
-		$chunkSize = $this->get_chunk_size($fileSize);
-
-		$result = new DownloadResult();
-
-		$result->id = uniqid();
-		$result->chunksPath = $this->tempDir . '/' . $result->id . '/';
-		mkdir($result->chunksPath, 0777, true);
-
-		$result->fileSize = $fileSize;
-		$result->chunkSize = $chunkSize;
-		$result->chunks = ceil($fileSize / $chunkSize);
-
-		$result->startTime = time();
-
-		$requests = [];
-		for ($i = 0; $i < $result->chunks; $i++) {
-			$range = $i * $chunkSize . '-' . ($i + 1) * $chunkSize;
-			if ($i + 1 === $result->chunks) {
-				$range = $i * $chunkSize . '-' . $fileSize;
-			}
-			$requests[] = [
-				'method' => 'GET',
-				'uri' => $url,
-				'options' => array_merge($options->toArray(), [
-					'CurlOptions' => [
-						CURLOPT_RANGE => $range
-					],
-				])
-			];
-		}
-
-		foreach ($this->bulk($requests) as $response) {
-			$result->addChunk(
-				Toolkit::randomString(16),
-				$response->getBody(),
-				$response->getInfoFromCurl()->TOTAL_TIME
-			);
-		}
-
-		$result->endTime = time();
-
-		return $result;
-	}
-
-	/**
-	 * Upload single or multiple files
-	 *
-	 * This method is sending file with request method of POST and
-	 * Content-Type of multipart/form-data.
-	 *
-	 * @param string $url The direct url to the file.
-	 * @param array $filePath The path to the file.
-	 * @param array|HttpOptions $options The options to use.
-	 *
-	 * @return HttpResponse
-	 */
-	public function upload(string $url, array $filePath, array|HttpOptions $options = []): HttpResponse
-	{
-		if (gettype($options) === 'array') {
-			$options = new HttpOptions($options);
-		}
-
-		$multipart = [];
-
-		foreach ($filePath as $key => $file) {
-			$multipart[$key] = new \CURLFile(
-				realpath($file),
-				$this->get_file_type($file)
-			);
-		}
-
-		$options->setMultipart($multipart);
-		return $this->post($url, $options);
-	}
-
-	/**
-	 * Get filetype with the extension.
-	 *
-	 * @param string $filename The absolute path to the file.
-	 * @return string eg. image/jpeg
-	 */
-	public static function get_file_type(string $filename): string
-	{
-		return MimeType::TYPES[pathinfo($filename, PATHINFO_EXTENSION)] ?? 'application/octet-stream';
-	}
-
-	/**
-	 * Get file size.
-	 *
-	 * @param string $url The direct url to the file.
-	 * @return int
-	 */
-	public function get_file_size(string $url): int
-	{
-		if (file_exists($url)) {
-			return filesize($url);
-		}
-
-		$response = $this->get($url, [
-			'headers' => [
-				'User-Agent' => 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/74.0.3729.169 Safari/537.36',
-			],
-			'CurlOptions' => [
-				CURLOPT_NOBODY => true,
-			]
-		]);
-
-		return (int)$response->getHeaderLine('Content-Length') ?? 0;
-	}
-
-	/**
-	 * Get the size of each chunk.
-	 *
-	 * For default, we're dividing filesize to 10 as max size of each chunk.
-	 * If the file size was smaller than 2MB, we'll use the filesize as single chunk.
-	 *
-	 * @param int $fileSize The file size.
-	 * @return int
-	 */
-	private function get_chunk_size(int $fileSize): int
-	{
-		$maxChunkSize = $fileSize / $this->maxChunkCount;
-
-		if ($fileSize <= 2 * 1024 * 1024) {
-			return $fileSize;
-		}
-
-		return min($maxChunkSize, $fileSize);
-	}
+    use ClientTrait;
+
+    /**
+     * The temp directory to download files - default is $_SERVER['TEMP']
+     *
+     * @var ?string
+     */
+    private ?string $tempDir;
+
+    /**
+     * The Max count of chunk to download file
+     *
+     * @var int
+     */
+    public int $maxChunkCount = 10;
+
+    /**
+     * The constructor of the client
+     */
+    public function __construct()
+    {
+        $this->tempDir = $_SERVER['TEMP'] ?? null;
+        $this->setHasSelfSignedCertificate(true);
+    }
+
+    /**
+     * Set has self-signed certificate
+     *
+     * This is used to set the curl option CURLOPT_SSL_VERIFYPEER
+     * and CURLOPT_SSL_VERIFYHOST to false. This is useful when you are
+     * in local environment, or you have self-signed certificate.
+     *
+     * @param bool $has
+     *
+     * @return void
+     */
+    public function setHasSelfSignedCertificate(bool $has): void
+    {
+        putenv('HAS_SELF_SIGNED_CERT=' . ($has ? 'true' : 'false'));
+    }
+
+    /**
+     * Set the temporary directory path to save the downloaded files
+     *
+     * @param string $path
+     *
+     * @return void
+     */
+    public function setTempPath(string $path): void
+    {
+        if (!file_exists($path)) {
+            throw new InvalidArgumentException(
+                sprintf('The path "%s" does not exist', $path)
+            );
+        }
+        $this->tempDir = $path;
+    }
+
+    /**
+     * This method is used to send a http request to a given url.
+     *
+     * @param string $method
+     * @param string $uri
+     * @param array|HttpOptions $options
+     *
+     * @return HttpResponse
+     */
+    public function request(string $method, string $uri, array|HttpOptions $options = []): HttpResponse
+    {
+        $CurlHandle = Middleware::create_curl_handler($method, $uri, $options);
+        if (!$CurlHandle) {
+            throw new RuntimeException('An error occurred while creating the curl handler');
+        }
+
+        $result = new HttpResponse();
+        $result->setCurlHandle($CurlHandle);
+
+        $response = curl_exec($CurlHandle);
+        if (curl_errno($CurlHandle) || !$response) {
+            $result->setErrorCode(curl_errno($CurlHandle));
+            $result->setErrorMessage(curl_error($CurlHandle) ?? ErrorCode::getMessage(curl_errno($CurlHandle)));
+            return $result;
+        }
+
+        $result->setStatusCode(curl_getinfo($CurlHandle, CURLINFO_HTTP_CODE));
+        $result->setHeaderSize(curl_getinfo($CurlHandle, CURLINFO_HEADER_SIZE));
+        $result->setHeaders(substr((string)$response, 0, $result->getHeaderSize()));
+        $result->setBody(substr((string)$response, $result->getHeaderSize()));
+
+        curl_close($CurlHandle);
+
+        return $result;
+    }
+
+    /**
+     * Send multiple requests to a given url.
+     *
+     * @param array $requests [{method, uri, options}, ...]
+     *
+     * @return array<HttpResponse>
+     */
+    public function bulk(array $requests): array
+    {
+        $result = [];
+        $handlers = [];
+        $multi_handler = curl_multi_init();
+        foreach ($requests as $request) {
+
+            $CurlHandle = Middleware::create_curl_handler(
+                $request['method'] ?? null,
+                $request['uri'],
+                $request['options'] ?? []
+            );
+            if (!$CurlHandle) {
+                throw new RuntimeException(
+                    'An error occurred while creating the curl handler'
+                );
+            }
+            $handlers[] = $CurlHandle;
+            curl_multi_add_handle($multi_handler, $CurlHandle);
+
+        }
+
+        $active = null;
+        do {
+            $mrc = curl_multi_exec($multi_handler, $active);
+        } while ($mrc == CURLM_CALL_MULTI_PERFORM);
+
+        while ($active && $mrc == CURLM_OK) {
+            if (curl_multi_select($multi_handler) != -1) {
+                do {
+                    $mrc = curl_multi_exec($multi_handler, $active);
+                } while ($mrc == CURLM_CALL_MULTI_PERFORM);
+            }
+        }
+
+        foreach ($handlers as $handler) {
+            curl_multi_remove_handle($multi_handler, $handler);
+        }
+        curl_multi_close($multi_handler);
+
+        foreach ($handlers as $handler) {
+            $content = curl_multi_getcontent($handler);
+            $response = new HttpResponse();
+
+            if (curl_errno($handler)) {
+                $response->setErrorCode(curl_errno($handler));
+                $response->setErrorMessage(
+                    curl_error($handler) ??
+                    ErrorCode::getMessage(curl_errno($handler))
+                );
+            }
+
+            $response->setCurlHandle($handler);
+            $response->setStatusCode(curl_getinfo($handler, CURLINFO_HTTP_CODE));
+            $response->setHeaderSize(curl_getinfo($handler, CURLINFO_HEADER_SIZE));
+            $response->setHeaders(substr($content, 0, $response->getHeaderSize()));
+            $response->setBody(substr($content, $response->getHeaderSize()));
+
+            $result[] = $response;
+        }
+
+        return $result;
+    }
+
+    /**
+     * Download large files.
+     *
+     * This method is used to download large files with creating multiple requests.
+     *
+     * Change `max_chunk_count` variable to change the number of chunks. (default: 10)
+     *
+     * @param string $url The direct url to the file.
+     * @param array|HttpOptions $options The options to use.
+     *
+     * @return DownloadResult
+     */
+    public function download(string $url, array|HttpOptions $options = []): DownloadResult
+    {
+        if (empty($this->tempDir)) {
+            throw new RuntimeException(
+                'The temp directory is not set. Please set the temp directory using the `setTempDir` method.'
+            );
+        }
+
+        if (!file_exists($this->tempDir)) {
+            if (mkdir($this->tempDir, 0777, true) === false) {
+                throw new RuntimeException(
+                    'The temp directory is not writable. Please set the temp directory using the `setTempDir` method.'
+                );
+            }
+        }
+
+        if (gettype($options) === 'array') {
+            $options = new HttpOptions($options);
+        }
+
+        $fileSize = $this->get_file_size($url);
+        $chunkSize = $this->get_chunk_size($fileSize);
+
+        $result = new DownloadResult();
+
+        $result->id = uniqid();
+        $result->chunksPath = $this->tempDir . '/' . $result->id . '/';
+        mkdir($result->chunksPath, 0777, true);
+
+        $result->fileSize = $fileSize;
+        $result->chunkSize = $chunkSize;
+        $result->chunks = ceil($fileSize / $chunkSize);
+
+        $result->startTime = time();
+
+        $requests = [];
+        for ($i = 0; $i < $result->chunks; $i++) {
+            $range = $i * $chunkSize . '-' . ($i + 1) * $chunkSize;
+            if ($i + 1 === $result->chunks) {
+                $range = $i * $chunkSize . '-' . $fileSize;
+            }
+            $requests[] = [
+                'method' => 'GET',
+                'uri' => $url,
+                'options' => array_merge($options->toArray(), [
+                    'CurlOptions' => [
+                        CURLOPT_RANGE => $range
+                    ],
+                ])
+            ];
+        }
+
+        foreach ($this->bulk($requests) as $response) {
+            $result->addChunk(
+                Toolkit::randomString(16),
+                $response->getBody(),
+                $response->getInfoFromCurl()->TOTAL_TIME
+            );
+        }
+
+        $result->endTime = time();
+
+        return $result;
+    }
+
+    /**
+     * Upload single or multiple files
+     *
+     * This method is sending file with request method of POST and
+     * Content-Type of multipart/form-data.
+     *
+     * @param string $url The direct url to the file.
+     * @param array $filePath The path to the file.
+     * @param array|HttpOptions $options The options to use.
+     *
+     * @return HttpResponse
+     */
+    public function upload(string $url, array $filePath, array|HttpOptions $options = []): HttpResponse
+    {
+        if (gettype($options) === 'array') {
+            $options = new HttpOptions($options);
+        }
+
+        $multipart = [];
+
+        foreach ($filePath as $key => $file) {
+            $multipart[$key] = new \CURLFile(
+                realpath($file),
+                $this->get_file_type($file)
+            );
+        }
+
+        $options->setMultipart($multipart);
+        return $this->post($url, $options);
+    }
+
+    /**
+     * Get filetype with the extension.
+     *
+     * @param string $filename The absolute path to the file.
+     * @return string eg. image/jpeg
+     */
+    public static function get_file_type(string $filename): string
+    {
+        return MimeType::TYPES[pathinfo($filename, PATHINFO_EXTENSION)] ?? 'application/octet-stream';
+    }
+
+    /**
+     * Get file size.
+     *
+     * @param string $url The direct url to the file.
+     * @return int
+     */
+    public function get_file_size(string $url): int
+    {
+        if (file_exists($url)) {
+            return filesize($url);
+        }
+
+        $response = $this->get($url, [
+            'headers' => [
+                'User-Agent' => 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/74.0.3729.169 Safari/537.36',
+            ],
+            'CurlOptions' => [
+                CURLOPT_NOBODY => true,
+            ]
+        ]);
+
+        return (int)$response->getHeaderLine('Content-Length') ?? 0;
+    }
+
+    /**
+     * Get the size of each chunk.
+     *
+     * For default, we're dividing filesize to 10 as max size of each chunk.
+     * If the file size was smaller than 2MB, we'll use the filesize as single chunk.
+     *
+     * @param int $fileSize The file size.
+     * @return int
+     */
+    private function get_chunk_size(int $fileSize): int
+    {
+        $maxChunkSize = $fileSize / $this->maxChunkCount;
+
+        if ($fileSize <= 2 * 1024 * 1024) {
+            return $fileSize;
+        }
+
+        return min($maxChunkSize, $fileSize);
+    }
 
 }
\ No newline at end of file

Spacing +3 added lines, -3 removed lines

@@ -107,8 +107,8 @@ 
 
 		$result->setStatusCode(curl_getinfo($CurlHandle, CURLINFO_HTTP_CODE));
 		$result->setHeaderSize(curl_getinfo($CurlHandle, CURLINFO_HEADER_SIZE));
-		$result->setHeaders(substr((string)$response, 0, $result->getHeaderSize()));
-		$result->setBody(substr((string)$response, $result->getHeaderSize()));
+		$result->setHeaders(substr((string) $response, 0, $result->getHeaderSize()));
+		$result->setBody(substr((string) $response, $result->getHeaderSize()));
 
 		curl_close($CurlHandle);
 
@@ -326,7 +326,7 @@ 
 			]
 		]);
 
-		return (int)$response->getHeaderLine('Content-Length') ?? 0;
+		return (int) $response->getHeaderLine('Content-Length') ?? 0;
 	}
 
 	/**

src/Contracts/ConnectionContract.php

Indentation +6 added lines, -6 removed lines

@@ -12,16 +12,16 @@
 interface ConnectionContract
 {
 
-	public function send(string $data): void;
+    public function send(string $data): void;
 
-	public function close(): void;
+    public function close(): void;
 
-	public function getUniqueSocketId(): int;
+    public function getUniqueSocketId(): int;
 
-	public function getPeerName(): string;
+    public function getPeerName(): string;
 
-	public function broadCast(string $data): void;
+    public function broadCast(string $data): void;
 
-	public function broadCastMany(array $data, int $delay): void;
+    public function broadCastMany(array $data, int $delay): void;
 
 }

src/Enums/CurlInfo.php

Indentation +210 added lines, -210 removed lines

@@ -12,215 +12,215 @@
 class CurlInfo
 {
 
-	/**
-	 * @var string
-	 */
-	public string $URL;
-
-	/**
-	 * @var string
-	 */
-	public string $CONTENT_TYPE;
-
-	/**
-	 * @var int
-	 */
-	public int $HTTP_CODE;
-
-	/**
-	 * @var int
-	 */
-	public int $HEADER_SIZE;
-
-	/**
-	 * @var int
-	 */
-	public int $REQUEST_SIZE;
-
-	/**
-	 * @var int
-	 */
-	public int $FILETIME;
-
-	/**
-	 * @var int
-	 */
-	public int $SSL_VERIFY_RESULT;
-
-	/**
-	 * @var int
-	 */
-	public int $REDIRECT_COUNT;
-
-	/**
-	 * @var float
-	 */
-	public float $TOTAL_TIME;
-
-	/**
-	 * @var float
-	 */
-	public float $NAMELOOKUP_TIME;
-
-	/**
-	 * @var float
-	 */
-	public float $CONNECT_TIME;
-
-	/**
-	 * @var float
-	 */
-	public float $PRETRANSFER_TIME;
-
-	/**
-	 * @var int
-	 */
-	public int $SIZE_UPLOAD;
-
-	/**
-	 * @var int
-	 */
-	public int $SIZE_DOWNLOAD;
-
-	/**
-	 * @var int
-	 */
-	public int $SPEED_DOWNLOAD;
-
-	/**
-	 * @var int
-	 */
-	public int $SPEED_UPLOAD;
-
-	/**
-	 * @var int
-	 */
-	public int $DOWNLOAD_CONTENT_LENGTH;
-
-	/**
-	 * @var int
-	 */
-	public int $UPLOAD_CONTENT_LENGTH;
-
-	/**
-	 * @var float
-	 */
-	public float $STARTTRANSFER_TIME;
-
-	/**
-	 * @var int
-	 */
-	public int $REDIRECT_TIME;
-
-	/**
-	 * @var string
-	 */
-	public string $REDIRECT_URL;
-
-	/**
-	 * @var string
-	 */
-	public string $PRIMARY_IP;
-
-	/**
-	 * @var array
-	 */
-	public array $CERTINFO;
-
-	/**
-	 * @var int
-	 */
-	public int $PRIMARY_PORT;
-
-	/**
-	 * @var string
-	 */
-	public string $LOCAL_IP;
-
-	/**
-	 * @var int
-	 */
-	public int $LOCAL_PORT;
-
-	/**
-	 * @var int
-	 */
-	public int $HTTP_VERSION;
-
-	/**
-	 * @var int
-	 */
-	public int $PROTOCOL;
-
-	/**
-	 * @var int
-	 */
-	public int $SSL_VERIFYRESULT;
-
-	/**
-	 * @var string
-	 */
-	public string $SCHEME;
-
-	/**
-	 * @var int
-	 */
-	public int $APPCONNECT_TIME_US;
-
-	/**
-	 * @var int
-	 */
-	public int $CONNECT_TIME_US;
-
-	/**
-	 * @var int
-	 */
-	public int $NAMELOOKUP_TIME_US;
-
-	/**
-	 * @var int
-	 */
-	public int $PRETRANSFER_TIME_US;
-
-	/**
-	 * @var int
-	 */
-	public int $REDIRECT_TIME_US;
-
-	/**
-	 * @var int
-	 */
-	public int $STARTTRANSFER_TIME_US;
-
-	/**
-	 * @var int
-	 */
-	public int $TOTAL_TIME_US;
-
-	/**
-	 * The Constructor
-	 *
-	 * @param array $curlInfo
-	 * @return void
-	 */
-	public function __construct(array $curlInfo = [])
-	{
-		$this->set($curlInfo);
-	}
-
-	/**
-	 * Set CurlInfo
-	 *
-	 * @param array $curlInfo
-	 * @return void
-	 */
-	public function set(array $curlInfo): void
-	{
-		foreach ($curlInfo as $key => $value) {
-			if (property_exists($this, strtoupper($key))) {
-				$this->{strtoupper($key)} = $value;
-			}
-		}
-	}
+    /**
+     * @var string
+     */
+    public string $URL;
+
+    /**
+     * @var string
+     */
+    public string $CONTENT_TYPE;
+
+    /**
+     * @var int
+     */
+    public int $HTTP_CODE;
+
+    /**
+     * @var int
+     */
+    public int $HEADER_SIZE;
+
+    /**
+     * @var int
+     */
+    public int $REQUEST_SIZE;
+
+    /**
+     * @var int
+     */
+    public int $FILETIME;
+
+    /**
+     * @var int
+     */
+    public int $SSL_VERIFY_RESULT;
+
+    /**
+     * @var int
+     */
+    public int $REDIRECT_COUNT;
+
+    /**
+     * @var float
+     */
+    public float $TOTAL_TIME;
+
+    /**
+     * @var float
+     */
+    public float $NAMELOOKUP_TIME;
+
+    /**
+     * @var float
+     */
+    public float $CONNECT_TIME;
+
+    /**
+     * @var float
+     */
+    public float $PRETRANSFER_TIME;
+
+    /**
+     * @var int
+     */
+    public int $SIZE_UPLOAD;
+
+    /**
+     * @var int
+     */
+    public int $SIZE_DOWNLOAD;
+
+    /**
+     * @var int
+     */
+    public int $SPEED_DOWNLOAD;
+
+    /**
+     * @var int
+     */
+    public int $SPEED_UPLOAD;
+
+    /**
+     * @var int
+     */
+    public int $DOWNLOAD_CONTENT_LENGTH;
+
+    /**
+     * @var int
+     */
+    public int $UPLOAD_CONTENT_LENGTH;
+
+    /**
+     * @var float
+     */
+    public float $STARTTRANSFER_TIME;
+
+    /**
+     * @var int
+     */
+    public int $REDIRECT_TIME;
+
+    /**
+     * @var string
+     */
+    public string $REDIRECT_URL;
+
+    /**
+     * @var string
+     */
+    public string $PRIMARY_IP;
+
+    /**
+     * @var array
+     */
+    public array $CERTINFO;
+
+    /**
+     * @var int
+     */
+    public int $PRIMARY_PORT;
+
+    /**
+     * @var string
+     */
+    public string $LOCAL_IP;
+
+    /**
+     * @var int
+     */
+    public int $LOCAL_PORT;
+
+    /**
+     * @var int
+     */
+    public int $HTTP_VERSION;
+
+    /**
+     * @var int
+     */
+    public int $PROTOCOL;
+
+    /**
+     * @var int
+     */
+    public int $SSL_VERIFYRESULT;
+
+    /**
+     * @var string
+     */
+    public string $SCHEME;
+
+    /**
+     * @var int
+     */
+    public int $APPCONNECT_TIME_US;
+
+    /**
+     * @var int
+     */
+    public int $CONNECT_TIME_US;
+
+    /**
+     * @var int
+     */
+    public int $NAMELOOKUP_TIME_US;
+
+    /**
+     * @var int
+     */
+    public int $PRETRANSFER_TIME_US;
+
+    /**
+     * @var int
+     */
+    public int $REDIRECT_TIME_US;
+
+    /**
+     * @var int
+     */
+    public int $STARTTRANSFER_TIME_US;
+
+    /**
+     * @var int
+     */
+    public int $TOTAL_TIME_US;
+
+    /**
+     * The Constructor
+     *
+     * @param array $curlInfo
+     * @return void
+     */
+    public function __construct(array $curlInfo = [])
+    {
+        $this->set($curlInfo);
+    }
+
+    /**
+     * Set CurlInfo
+     *
+     * @param array $curlInfo
+     * @return void
+     */
+    public function set(array $curlInfo): void
+    {
+        foreach ($curlInfo as $key => $value) {
+            if (property_exists($this, strtoupper($key))) {
+                $this->{strtoupper($key)} = $value;
+            }
+        }
+    }
 
 }
\ No newline at end of file

src/Middleware.php

Spacing +1 added lines, -1 removed lines

@@ -100,7 +100,7 @@
 		curl_setopt($cHandler, CURLOPT_TIMEOUT, $options->getTimeout());
 
 		# If self-signed certs are allowed, set it.
-		if ((bool)getenv('HAS_SELF_SIGNED_CERT') === true) {
+		if ((bool) getenv('HAS_SELF_SIGNED_CERT') === true) {
 			curl_setopt($cHandler, CURLOPT_SSL_VERIFYPEER, false);
 			curl_setopt($cHandler, CURLOPT_SSL_VERIFYHOST, false);
 		}

Braces +3 added lines, -1 removed lines

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

Indentation +187 added lines, -187 removed lines

@@ -17,192 +17,192 @@
 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
-	 */
+    /**
+     * 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
+     */
 
 }
\ No newline at end of file