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>';

examples/websoket/coinmarketcap-ticker.php

Indentation +29 added lines, -29 removed lines

@@ -13,41 +13,41 @@
  */
 function startTicker(array $ids, callable $callback): void
 {
-	try {
-
-		$close_time = time() + 10;
-		$ClientConfig = (new WSConfig())->setFragmentSize(8096)->setTimeout(15);
-		$WebSocketClient = new WebSocket('wss://stream.coinmarketcap.com/price/latest', $ClientConfig);
-
-		$WebSocketClient->send(json_encode([
-			'method' => 'subscribe',
-			'id' => 'price',
-			'data' => [
-				'cryptoIds' => $ids,
-				'index' => 'detail'
-			]
-		]));
-
-		while ($close_time > time()) {
-			if (($message = $WebSocketClient->receive()) != "") {
-				$json_response = json_decode($message, true);
-
-				if ($json_response['id'] == "price") {
-					$callback($json_response);
-				}
-			}
-		}
-
-	} catch (Exception $e) {
-		echo "<b>Error</b>: " . $e->getMessage();
-	}
+    try {
+
+        $close_time = time() + 10;
+        $ClientConfig = (new WSConfig())->setFragmentSize(8096)->setTimeout(15);
+        $WebSocketClient = new WebSocket('wss://stream.coinmarketcap.com/price/latest', $ClientConfig);
+
+        $WebSocketClient->send(json_encode([
+            'method' => 'subscribe',
+            'id' => 'price',
+            'data' => [
+                'cryptoIds' => $ids,
+                'index' => 'detail'
+            ]
+        ]));
+
+        while ($close_time > time()) {
+            if (($message = $WebSocketClient->receive()) != "") {
+                $json_response = json_decode($message, true);
+
+                if ($json_response['id'] == "price") {
+                    $callback($json_response);
+                }
+            }
+        }
+
+    } catch (Exception $e) {
+        echo "<b>Error</b>: " . $e->getMessage();
+    }
 }
 
 echo "<pre>Start Tome: " . date('Y-m-d H:i:s') . "</pre><br/>";
 
 $responses = [];
 startTicker([1, 1027, 825, 3408, 1839, 4687, 52, 2010, 5426], function ($data) use (&$responses) {
-	$responses[] = $data;
+    $responses[] = $data;
 });
 
 echo "<pre>" . json_encode($responses, JSON_PRETTY_PRINT) . "</pre><br/>";

Spacing +1 added lines, -1 removed lines

@@ -46,7 +46,7 @@
 echo "<pre>Start Tome: " . date('Y-m-d H:i:s') . "</pre><br/>";
 
 $responses = [];
-startTicker([1, 1027, 825, 3408, 1839, 4687, 52, 2010, 5426], function ($data) use (&$responses) {
+startTicker([1, 1027, 825, 3408, 1839, 4687, 52, 2010, 5426], function($data) use (&$responses) {
 	$responses[] = $data;
 });
 

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/CommonsContract.php

Indentation +46 added lines, -46 removed lines

@@ -12,57 +12,57 @@
 interface CommonsContract
 {
 
-	// DADA types
-	public const EVENT_TYPE_PING = 'ping';
-	public const EVENT_TYPE_PONG = 'pong';
-	public const EVENT_TYPE_TEXT = 'text';
-	public const EVENT_TYPE_CLOSE = 'close';
-	public const EVENT_TYPE_BINARY = 'binary';
-	public const EVENT_TYPE_CONTINUATION = 'continuation';
+    // DADA types
+    public const EVENT_TYPE_PING = 'ping';
+    public const EVENT_TYPE_PONG = 'pong';
+    public const EVENT_TYPE_TEXT = 'text';
+    public const EVENT_TYPE_CLOSE = 'close';
+    public const EVENT_TYPE_BINARY = 'binary';
+    public const EVENT_TYPE_CONTINUATION = 'continuation';
 
-	public const MAP_EVENT_TYPE_TO_METHODS = [
-		self::EVENT_TYPE_TEXT => 'onMessage',
-		self::EVENT_TYPE_PING => 'onPing',
-		self::EVENT_TYPE_PONG => 'onPong',
-	];
+    public const MAP_EVENT_TYPE_TO_METHODS = [
+        self::EVENT_TYPE_TEXT => 'onMessage',
+        self::EVENT_TYPE_PING => 'onPing',
+        self::EVENT_TYPE_PONG => 'onPong',
+    ];
 
-	// DECODE FRAMES
-	public const DECODE_TEXT = 1;
-	public const DECODE_BINARY = 2;
-	public const DECODE_CLOSE = 8;
-	public const DECODE_PING = 9;
-	public const DECODE_PONG = 10;
+    // DECODE FRAMES
+    public const DECODE_TEXT = 1;
+    public const DECODE_BINARY = 2;
+    public const DECODE_CLOSE = 8;
+    public const DECODE_PING = 9;
+    public const DECODE_PONG = 10;
 
-	// ENCODE FRAMES
-	public const ENCODE_TEXT = 129;
-	public const ENCODE_CLOSE = 136;
-	public const ENCODE_PING = 137;
-	public const ENCODE_PONG = 138;
+    // ENCODE FRAMES
+    public const ENCODE_TEXT = 129;
+    public const ENCODE_CLOSE = 136;
+    public const ENCODE_PING = 137;
+    public const ENCODE_PONG = 138;
 
-	// MASKS
-	public const MASK_125 = 125;
-	public const MASK_126 = 126;
-	public const MASK_127 = 127;
-	public const MASK_128 = 128;
-	public const MASK_254 = 254;
-	public const MASK_255 = 255;
+    // MASKS
+    public const MASK_125 = 125;
+    public const MASK_126 = 126;
+    public const MASK_127 = 127;
+    public const MASK_128 = 128;
+    public const MASK_254 = 254;
+    public const MASK_255 = 255;
 
-	// PAYLOADS
-	public const PAYLOAD_CHUNK = 8;
-	public const PAYLOAD_MAX_BITS = 65535;
+    // PAYLOADS
+    public const PAYLOAD_CHUNK = 8;
+    public const PAYLOAD_MAX_BITS = 65535;
 
-	// transfer protocol-level errors
-	public const SERVER_COULD_NOT_BIND_TO_SOCKET = 101;
-	public const SERVER_SELECT_ERROR = 102;
-	public const SERVER_HEADERS_NOT_SET = 103;
-	public const CLIENT_COULD_NOT_OPEN_SOCKET = 104;
-	public const CLIENT_INCORRECT_SCHEME = 105;
-	public const CLIENT_INVALID_UPGRADE_RESPONSE = 106;
-	public const CLIENT_INVALID_STREAM_CONTEXT = 107;
-	public const CLIENT_BAD_OPCODE = 108;
-	public const CLIENT_COULD_ONLY_WRITE_LESS = 109;
-	public const CLIENT_BROKEN_FRAME = 110;
-	public const CLIENT_EMPTY_READ = 111;
-	public const SERVER_INVALID_STREAM_CONTEXT = 112;
+    // transfer protocol-level errors
+    public const SERVER_COULD_NOT_BIND_TO_SOCKET = 101;
+    public const SERVER_SELECT_ERROR = 102;
+    public const SERVER_HEADERS_NOT_SET = 103;
+    public const CLIENT_COULD_NOT_OPEN_SOCKET = 104;
+    public const CLIENT_INCORRECT_SCHEME = 105;
+    public const CLIENT_INVALID_UPGRADE_RESPONSE = 106;
+    public const CLIENT_INVALID_STREAM_CONTEXT = 107;
+    public const CLIENT_BAD_OPCODE = 108;
+    public const CLIENT_COULD_ONLY_WRITE_LESS = 109;
+    public const CLIENT_BROKEN_FRAME = 110;
+    public const CLIENT_EMPTY_READ = 111;
+    public const SERVER_INVALID_STREAM_CONTEXT = 112;
 
 }
\ No newline at end of file

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;
 
 }