shahradelahi / easy-http

src/Model/DownloadResult.php

Indentation +141 added lines, -141 removed lines

@@ -12,146 +12,146 @@
 class DownloadResult
 {
 
-	/**
-	 * The unique identifier of the download
-	 *
-	 * @var string
-	 */
-	public string $id;
-
-	/**
-	 * The final size of the downloaded file
-	 *
-	 * @var int
-	 */
-	public int $fileSize;
-
-	/**
-	 * The path of the downloaded chunks
-	 *
-	 * @var string
-	 */
-	public string $chunksPath;
-
-	/**
-	 * The size of each chunk
-	 *
-	 * @var int
-	 */
-	public int $chunkSize;
-
-	/**
-	 * The count of chunks
-	 *
-	 * @var int
-	 */
-	public int $chunks;
-
-	/**
-	 * Start time of the download in timestamp.
-	 *
-	 * @var int
-	 */
-	public int $startTime;
-
-	/**
-	 * End time of the download in timestamp.
-	 *
-	 * @var int
-	 */
-	public int $endTime;
-
-	/**
-	 * The downloaded chunks
-	 *
-	 * @var array [{id, size, location, elapsedTime}, ...]
-	 */
-	public array $downloads;
-
-	/**
-	 * Add a chunk to the download result
-	 *
-	 * @param string $id The unique identifier of the chunk
-	 * @param ?string $body The chunk body
-	 * @param float $elapsedTime in microseconds
-	 * @return void
-	 */
-	public function addChunk(string $id, ?string $body, float $elapsedTime): void
-	{
-		$data = [
-			'id' => $id,
-			'location' => null,
-			'size' => 0,
-			'elapsed_time' => $elapsedTime,
-			'status' => 'failed',
-		];
-		if ($body !== null) {
-			$save = $this->saveChunk($id, $body);
-			$data = array_merge($data, [
-				'location' => $save ?? null,
-				'size' => strlen($body),
-				'status' => $save ? 'saved' : 'failed',
-			]);
-		}
-		$this->downloads[] = $data;
-	}
-
-	/**
-	 * Save the chunks to the temp directory
-	 *
-	 * @param string $id The unique identifier of the chunk
-	 * @param string $body The body of the chunk
-	 * @return string|bool
-	 */
-	private function saveChunk(string $id, string $body): string|bool
-	{
-		$path = $this->chunksPath . DIRECTORY_SEPARATOR . $id;
-		return file_put_contents($path, $body) ? $path : false;
-	}
-
-	/**
-	 * Merge the chunks into a single string
-	 *
-	 * @return string
-	 */
-	public function mergeChunks(): string
-	{
-		$result = '';
-		foreach ($this->downloads as $chunk) {
-			$result .= file_get_contents($chunk['location']);
-		}
-		return $result;
-	}
-
-	/**
-	 * Save the merged chunks to a file
-	 *
-	 * @param string $filePath The path/to/file.ext
-	 * @return bool
-	 */
-	public function save(string $filePath): bool
-	{
-		$pathInfo = pathinfo($filePath, PATHINFO_DIRNAME);
-		if (gettype($pathInfo) != "string") $pathInfo = $pathInfo['dirname'];
-		if (!file_exists($pathInfo)) {
-			throw new \InvalidArgumentException('The directory does not exist');
-		}
-		$result = $this->mergeChunks();
-		$this->cleanChunks();
-		return file_put_contents($filePath, $result) !== false;
-	}
-
-	/**
-	 * Clean the directory of the chunks
-	 *
-	 * @return void
-	 */
-	public function cleanChunks(): void
-	{
-		foreach (glob($this->chunksPath . DIRECTORY_SEPARATOR . '*') as $file) {
-			unlink($file);
-		}
-		rmdir($this->chunksPath);
-	}
+    /**
+     * The unique identifier of the download
+     *
+     * @var string
+     */
+    public string $id;
+
+    /**
+     * The final size of the downloaded file
+     *
+     * @var int
+     */
+    public int $fileSize;
+
+    /**
+     * The path of the downloaded chunks
+     *
+     * @var string
+     */
+    public string $chunksPath;
+
+    /**
+     * The size of each chunk
+     *
+     * @var int
+     */
+    public int $chunkSize;
+
+    /**
+     * The count of chunks
+     *
+     * @var int
+     */
+    public int $chunks;
+
+    /**
+     * Start time of the download in timestamp.
+     *
+     * @var int
+     */
+    public int $startTime;
+
+    /**
+     * End time of the download in timestamp.
+     *
+     * @var int
+     */
+    public int $endTime;
+
+    /**
+     * The downloaded chunks
+     *
+     * @var array [{id, size, location, elapsedTime}, ...]
+     */
+    public array $downloads;
+
+    /**
+     * Add a chunk to the download result
+     *
+     * @param string $id The unique identifier of the chunk
+     * @param ?string $body The chunk body
+     * @param float $elapsedTime in microseconds
+     * @return void
+     */
+    public function addChunk(string $id, ?string $body, float $elapsedTime): void
+    {
+        $data = [
+            'id' => $id,
+            'location' => null,
+            'size' => 0,
+            'elapsed_time' => $elapsedTime,
+            'status' => 'failed',
+        ];
+        if ($body !== null) {
+            $save = $this->saveChunk($id, $body);
+            $data = array_merge($data, [
+                'location' => $save ?? null,
+                'size' => strlen($body),
+                'status' => $save ? 'saved' : 'failed',
+            ]);
+        }
+        $this->downloads[] = $data;
+    }
+
+    /**
+     * Save the chunks to the temp directory
+     *
+     * @param string $id The unique identifier of the chunk
+     * @param string $body The body of the chunk
+     * @return string|bool
+     */
+    private function saveChunk(string $id, string $body): string|bool
+    {
+        $path = $this->chunksPath . DIRECTORY_SEPARATOR . $id;
+        return file_put_contents($path, $body) ? $path : false;
+    }
+
+    /**
+     * Merge the chunks into a single string
+     *
+     * @return string
+     */
+    public function mergeChunks(): string
+    {
+        $result = '';
+        foreach ($this->downloads as $chunk) {
+            $result .= file_get_contents($chunk['location']);
+        }
+        return $result;
+    }
+
+    /**
+     * Save the merged chunks to a file
+     *
+     * @param string $filePath The path/to/file.ext
+     * @return bool
+     */
+    public function save(string $filePath): bool
+    {
+        $pathInfo = pathinfo($filePath, PATHINFO_DIRNAME);
+        if (gettype($pathInfo) != "string") $pathInfo = $pathInfo['dirname'];
+        if (!file_exists($pathInfo)) {
+            throw new \InvalidArgumentException('The directory does not exist');
+        }
+        $result = $this->mergeChunks();
+        $this->cleanChunks();
+        return file_put_contents($filePath, $result) !== false;
+    }
+
+    /**
+     * Clean the directory of the chunks
+     *
+     * @return void
+     */
+    public function cleanChunks(): void
+    {
+        foreach (glob($this->chunksPath . DIRECTORY_SEPARATOR . '*') as $file) {
+            unlink($file);
+        }
+        rmdir($this->chunksPath);
+    }
 
 }
\ No newline at end of file

Braces +3 added lines, -1 removed lines

@@ -132,7 +132,9 @@
 	public function save(string $filePath): bool
 	{
 		$pathInfo = pathinfo($filePath, PATHINFO_DIRNAME);
-		if (gettype($pathInfo) != "string") $pathInfo = $pathInfo['dirname'];
+		if (gettype($pathInfo) != "string") {
+		    $pathInfo = $pathInfo['dirname'];
+		}
 		if (!file_exists($pathInfo)) {
 			throw new \InvalidArgumentException('The directory does not exist');
 		}

src/Model/HttpResponse.php

Indentation +76 added lines, -76 removed lines

@@ -35,90 +35,90 @@
 class HttpResponse
 {
 
-	/**
-	 * Set the curl handle
-	 *
-	 * @param \CurlHandle $curlHandle
-	 * @return HttpResponse
-	 */
-	public function setCurlHandle(\CurlHandle $curlHandle): HttpResponse
-	{
-		$this->curlHandle = $curlHandle;
-		return $this;
-	}
+    /**
+     * Set the curl handle
+     *
+     * @param \CurlHandle $curlHandle
+     * @return HttpResponse
+     */
+    public function setCurlHandle(\CurlHandle $curlHandle): HttpResponse
+    {
+        $this->curlHandle = $curlHandle;
+        return $this;
+    }
 
-	/**
-	 * Get info from the curl handle
-	 *
-	 * @return CurlInfo|false
-	 */
-	public function getInfoFromCurl(): CurlInfo|false
-	{
-		if (empty($this->getCurlHandle())) {
-			return false;
-		}
+    /**
+     * Get info from the curl handle
+     *
+     * @return CurlInfo|false
+     */
+    public function getInfoFromCurl(): CurlInfo|false
+    {
+        if (empty($this->getCurlHandle())) {
+            return false;
+        }
 
-		return new CurlInfo(curl_getinfo($this->curlHandle));
-	}
+        return new CurlInfo(curl_getinfo($this->curlHandle));
+    }
 
-	/**
-	 * Set the headers of the response
-	 *
-	 * @param string $headers
-	 * @return HttpResponse
-	 */
-	public function setHeaders(string $headers): HttpResponse
-	{
-		$result = [];
-		$lines = explode("\r\n", $headers);
-		foreach ($lines as $line) {
-			if (str_contains($line, ':')) {
-				$parts = explode(':', $line);
-				$result[trim($parts[0])] = trim($parts[1]);
-			}
-		}
-		$this->headers = $result;
-		return $this;
-	}
+    /**
+     * Set the headers of the response
+     *
+     * @param string $headers
+     * @return HttpResponse
+     */
+    public function setHeaders(string $headers): HttpResponse
+    {
+        $result = [];
+        $lines = explode("\r\n", $headers);
+        foreach ($lines as $line) {
+            if (str_contains($line, ':')) {
+                $parts = explode(':', $line);
+                $result[trim($parts[0])] = trim($parts[1]);
+            }
+        }
+        $this->headers = $result;
+        return $this;
+    }
 
-	/**
-	 * Get a key from the response headers
-	 *
-	 * @param string $key
-	 * @return mixed
-	 */
-	public function getHeaderLine(string $key): mixed
-	{
-		return array_change_key_case($this->headers, CASE_LOWER)[strtolower($key)] ?? null;
-	}
+    /**
+     * Get a key from the response headers
+     *
+     * @param string $key
+     * @return mixed
+     */
+    public function getHeaderLine(string $key): mixed
+    {
+        return array_change_key_case($this->headers, CASE_LOWER)[strtolower($key)] ?? null;
+    }
 
-	/**
-	 * @param string $name
-	 * @param array $arguments
-	 * @return mixed
-	 */
-	public function __call(string $name, array $arguments): mixed
-	{
-		if (property_exists($this, $name)) {
-			return $this->{$name};
-		}
+    /**
+     * @param string $name
+     * @param array $arguments
+     * @return mixed
+     */
+    public function __call(string $name, array $arguments): mixed
+    {
+        if (property_exists($this, $name)) {
+            return $this->{$name};
+        }
 
-		if (method_exists($this, $name)) {
-			return $this->{$name}();
-		}
+        if (method_exists($this, $name)) {
+            return $this->{$name}();
+        }
 
-		if (str_starts_with($name, 'get')) {
-			$property = lcfirst(substr($name, 3));
-			return $this->{$property} ?? null;
-		}
+        if (str_starts_with($name, 'get')) {
+            $property = lcfirst(substr($name, 3));
+            return $this->{$property} ?? null;
+        }
 
-		if (str_starts_with($name, 'set')) {
-			$property = lcfirst(substr($name, 3));
-			$this->{$property} = $arguments[0] ?? null;
-			return $this;
-		}
+        if (str_starts_with($name, 'set')) {
+            $property = lcfirst(substr($name, 3));
+            $this->{$property} = $arguments[0] ?? null;
+            return $this;
+        }
 
-		throw new \BadMethodCallException("Method $name does not exist");
-	}
+        throw new \BadMethodCallException("Method $name does not exist");
+    }
 
 }
\ No newline at end of file

examples/websocket/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 WebSocketConfig())->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 WebSocketConfig())->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/Contracts/MessageContract.php

Indentation +6 added lines, -6 removed lines

@@ -14,11 +14,11 @@
 interface MessageContract
 {
 
-	/**
-	 * @param string $message
-	 * @return void
-	 * @throws WebSocketException
-	 */
-	public function onMessage(string $message): void;
+    /**
+     * @param string $message
+     * @return void
+     * @throws WebSocketException
+     */
+    public function onMessage(string $message): void;
 
 }

src/Contracts/WebSocketContract.php

Indentation +14 added lines, -14 removed lines

@@ -14,21 +14,21 @@
 interface WebSocketContract
 {
 
-	/**
-	 * @return void
-	 */
-	public function onOpen(): void;
+    /**
+     * @return void
+     */
+    public function onOpen(): void;
 
-	/**
-	 * @param int $closeStatus
-	 * @return void
-	 */
-	public function onClose(int $closeStatus): void;
+    /**
+     * @param int $closeStatus
+     * @return void
+     */
+    public function onClose(int $closeStatus): void;
 
-	/**
-	 * @param WebSocketException $exception
-	 * @return void
-	 */
-	public function onError(WebSocketException $exception): void;
+    /**
+     * @param WebSocketException $exception
+     * @return void
+     */
+    public function onError(WebSocketException $exception): void;
 
 }

src/WebSocket.php

Indentation +412 added lines, -412 removed lines

@@ -19,417 +19,417 @@
 class WebSocket implements WscCommonsContract
 {
 
-	use WSClientTrait;
-
-	/**
-	 * App version
-	 *
-	 * @var string
-	 */
-	public const VERSION = 'v1.0.0';
-
-	/**
-	 * @var resource|bool
-	 */
-	private $socket;
-
-	/**
-	 * @var bool
-	 */
-	private bool $isConnected = false;
-
-	/**
-	 * @var bool
-	 */
-	private bool $isClosing = false;
-
-	/**
-	 * @var string
-	 */
-	private string $lastOpcode;
-
-	/**
-	 * @var float|int
-	 */
-	private float|int $closeStatus;
-
-	/**
-	 * @var string|null
-	 */
-	private ?string $hugePayload;
-
-	/**
-	 * @var array|int[]
-	 */
-	private static array $opcodes = [
-		CommonsContract::EVENT_TYPE_CONTINUATION => 0,
-		CommonsContract::EVENT_TYPE_TEXT => 1,
-		CommonsContract::EVENT_TYPE_BINARY => 2,
-		CommonsContract::EVENT_TYPE_CLOSE => 8,
-		CommonsContract::EVENT_TYPE_PING => 9,
-		CommonsContract::EVENT_TYPE_PONG => 10,
-	];
-
-	/**
-	 * @var WebSocketConfig
-	 */
-	protected WebSocketConfig $config;
-
-	/**
-	 * @var string
-	 */
-	protected string $socketUrl;
-
-	/**
-	 * @var ?SocketClient
-	 */
-	protected ?SocketClient $client = null;
-
-	/**
-	 * Sets parameters for Web Socket Client intercommunication
-	 *
-	 * @param SocketClient|string $clientOrUri pass the SocketClient object or the URI of the server
-	 * @param ?WebSocketConfig $config if you're passing the URI, you can pass the config object
-	 */
-	public function __construct(SocketClient|string $clientOrUri, ?WebSocketConfig $config = null)
-	{
-		if ($clientOrUri instanceof SocketClient) {
-			$this->client = $clientOrUri;
-		} else {
-			$this->connect($clientOrUri, $config === null ? new WebSocketConfig() : $config);
-		}
-	}
-
-	/**
-	 * @param string $socketUrl string that represents the URL of the Web Socket server. e.g. ws://localhost:1337 or wss://localhost:1337
-	 * @param WebSocketConfig $config The configuration for the Web Socket client
-	 */
-	public function connect(string $socketUrl, WebSocketConfig $config): void
-	{
-		try {
-			$this->config = $config;
-			$this->socketUrl = $socketUrl;
-			$urlParts = parse_url($this->socketUrl);
-
-			$this->config->setScheme($urlParts['scheme']);
-			$this->config->setHost($urlParts['host']);
-			$this->config->setUser($urlParts);
-			$this->config->setPassword($urlParts);
-			$this->config->setPort($urlParts);
-
-			$pathWithQuery = $this->getPathWithQuery($urlParts);
-			$hostUri = $this->getHostUri($this->config);
-
-			$context = $this->getStreamContext();
-			if ($this->config->hasProxy()) {
-				$this->socket = $this->proxy();
-			} else {
-				$this->socket = @stream_socket_client(
-					$hostUri . ':' . $this->config->getPort(),
-					$errno,
-					$errstr,
-					$this->config->getTimeout(),
-					STREAM_CLIENT_CONNECT,
-					$context
-				);
-			}
-
-			if ($this->socket === false) {
-				throw new ConnectionException(
-					"Could not open socket to \"{$this->config->getHost()}:{$this->config->getPort()}\": $errstr ($errno).",
-					CommonsContract::CLIENT_COULD_NOT_OPEN_SOCKET
-				);
-			}
-
-			stream_set_timeout($this->socket, $this->config->getTimeout());
-
-			$key = $this->generateKey();
-			$headers = [
-				'Host' => $this->config->getHost() . ':' . $this->config->getPort(),
-				'User-Agent' => 'Easy-Http/' . self::VERSION . ' (PHP/' . PHP_VERSION . ')',
-				'Connection' => 'Upgrade',
-				'Upgrade' => 'WebSocket',
-				'Sec-WebSocket-Key' => $key,
-				'Sec-Websocket-Version' => '13',
-			];
-
-			if ($this->config->getUser() || $this->config->getPassword()) {
-				$headers['authorization'] = 'Basic ' . base64_encode($this->config->getUser() . ':' . $this->config->getPassword()) . "\r\n";
-			}
-
-			if (!empty($this->config->getHeaders())) {
-				$headers = array_merge($headers, $this->config->getHeaders());
-			}
-
-			$header = $this->getHeaders($pathWithQuery, $headers);
-
-			$this->write($header);
-
-			$this->validateResponse($this->config, $pathWithQuery, $key);
-			$this->isConnected = true;
-
-			if ($this->client !== null) {
-				$this->client->setConnection($this);
-				$this->client->onOpen();
-				while ($this->isConnected()) {
-					if (is_string(($message = $this->receive()))) {
-						$this->client->onMessage($message);
-					}
-				}
-				$this->client->onClose($this->closeStatus);
-			}
-
-		} catch (\Exception $e) {
-			$this->client->onError(
-				new WebSocketException(
-					$e->getMessage(),
-					$e->getCode(),
-					$e
-				)
-			);
-		}
-	}
-
-	/**
-	 * Init a proxy connection
-	 *
-	 * @return resource|false
-	 * @throws \InvalidArgumentException
-	 * @throws ConnectionException
-	 */
-	private function proxy()
-	{
-		$sock = @stream_socket_client(
-			WscCommonsContract::TCP_SCHEME . $this->config->getProxyIp() . ':' . $this->config->getProxyPort(),
-			$errno,
-			$errstr,
-			$this->config->getTimeout(),
-			STREAM_CLIENT_CONNECT,
-			$this->getStreamContext()
-		);
-		$write = "CONNECT {$this->config->getProxyIp()}:{$this->config->getProxyPort()} HTTP/1.1\r\n";
-		$auth = $this->config->getProxyAuth();
-		if ($auth !== NULL) {
-			$write .= "Proxy-Authorization: Basic {$auth}\r\n";
-		}
-		$write .= "\r\n";
-		fwrite($sock, $write);
-		$resp = fread($sock, 1024);
-
-		if (preg_match(self::PROXY_MATCH_RESP, $resp) === 1) {
-			return $sock;
-		}
-
-		throw new ConnectionException('Failed to connect to the host via proxy');
-	}
-
-	/**
-	 * @return mixed
-	 * @throws \InvalidArgumentException
-	 */
-	private function getStreamContext(): mixed
-	{
-		if ($this->config->getContext() !== null) {
-			// Suppress the error since we'll catch it below
-			if (@get_resource_type($this->config->getContext()) === 'stream-context') {
-				return $this->config->getContext();
-			}
-
-			throw new \InvalidArgumentException(
-				'Stream context is invalid',
-				CommonsContract::CLIENT_INVALID_STREAM_CONTEXT
-			);
-		}
-
-		return stream_context_create($this->config->getContextOptions());
-	}
-
-	/**
-	 * @param mixed $urlParts
-	 * @return string
-	 */
-	private function getPathWithQuery(mixed $urlParts): string
-	{
-		$path = isset($urlParts['path']) ? $urlParts['path'] : '/';
-		$query = isset($urlParts['query']) ? $urlParts['query'] : '';
-		$fragment = isset($urlParts['fragment']) ? $urlParts['fragment'] : '';
-		$pathWithQuery = $path;
-		if (!empty($query)) {
-			$pathWithQuery .= '?' . $query;
-		}
-		if (!empty($fragment)) {
-			$pathWithQuery .= '#' . $fragment;
-		}
-
-		return $pathWithQuery;
-	}
-
-	/**
-	 * @param string $pathWithQuery
-	 * @param array $headers
-	 * @return string
-	 */
-	private function getHeaders(string $pathWithQuery, array $headers): string
-	{
-		return 'GET ' . $pathWithQuery . " HTTP/1.1\r\n"
-			. implode(
-				"\r\n",
-				array_map(
-					function ($key, $value) {
-						return "$key: $value";
-					},
-					array_keys($headers),
-					$headers
-				)
-			)
-			. "\r\n\r\n";
-	}
-
-	/**
-	 * @return string
-	 */
-	public function getLastOpcode(): string
-	{
-		return $this->lastOpcode;
-	}
-
-	/**
-	 * @return int
-	 */
-	public function getCloseStatus(): int
-	{
-		return $this->closeStatus;
-	}
-
-	/**
-	 * @return bool
-	 */
-	public function isConnected(): bool
-	{
-		return $this->isConnected;
-	}
-
-	/**
-	 * @param int $timeout
-	 * @param null $microSecs
-	 * @return WebSocket
-	 */
-	public function setTimeout(int $timeout, $microSecs = null): WebSocket
-	{
-		$this->config->setTimeout($timeout);
-		if ($this->socket && get_resource_type($this->socket) === 'stream') {
-			stream_set_timeout($this->socket, $timeout, $microSecs);
-		}
-
-		return $this;
-	}
-
-	/**
-	 * Sends message to opened socket connection client->server
-	 *
-	 * @param $payload
-	 * @param string $opcode
-	 * @throws \Exception
-	 */
-	public function send($payload, string $opcode = CommonsContract::EVENT_TYPE_TEXT): void
-	{
-		if (!$this->isConnected) {
-			$this->connect($this->socketUrl, new WebSocketConfig());
-		}
-
-		if (array_key_exists($opcode, self::$opcodes) === false) {
-			throw new BadOpcodeException(
-				"Bad opcode '$opcode'.  Try 'text' or 'binary'.",
-				CommonsContract::CLIENT_BAD_OPCODE
-			);
-		}
-
-		$payloadLength = strlen($payload);
-		$fragmentCursor = 0;
-
-		while ($payloadLength > $fragmentCursor) {
-			$subPayload = substr($payload, $fragmentCursor, $this->config->getFragmentSize());
-			$fragmentCursor += $this->config->getFragmentSize();
-			$final = $payloadLength <= $fragmentCursor;
-			$this->sendFragment($final, $subPayload, $opcode, true);
-			$opcode = 'continuation';
-		}
-	}
-
-	/**
-	 * Receives message client<-server
-	 *
-	 * @return string|null
-	 * @throws \Exception
-	 */
-	public function receive(): string|null
-	{
-		if (!$this->isConnected) {
-			$this->connect($this->socketUrl, new WebSocketConfig());
-		}
-
-		$this->hugePayload = '';
-
-		return $this->receiveFragment();
-	}
-
-	/**
-	 * Tell the socket to close.
-	 *
-	 * @param integer $status http://tools.ietf.org/html/rfc6455#section-7.4
-	 * @param string $message A closing message, max 125 bytes.
-	 * @return bool|null|string
-	 * @throws \Exception
-	 */
-	public function close(int $status = 1000, string $message = 'ttfn'): bool|null|string
-	{
-		$statusBin = sprintf('%016b', $status);
-		$statusStr = '';
-
-		foreach (str_split($statusBin, 8) as $binstr) {
-			$statusStr .= chr(bindec($binstr));
-		}
-
-		$this->send($statusStr . $message, CommonsContract::EVENT_TYPE_CLOSE);
-		$this->isClosing = true;
-
-		return $this->receive(); // Receiving a close frame will close the socket now.
-	}
-
-	/**
-	 * @param string $data
-	 * @throws ConnectionException
-	 */
-	protected function write(string $data): void
-	{
-		Middleware::stream_write($this->socket, $data);
-	}
-
-	/**
-	 * @param int $len
-	 * @return string|null
-	 * @throws ConnectionException
-	 */
-	protected function read(int $len): string|null
-	{
-		return Middleware::stream_read($this->socket, $len) ?: false;
-	}
-
-	/**
-	 * Helper to convert a binary to a string of '0' and '1'.
-	 *
-	 * @param string $string
-	 * @return string
-	 */
-	protected static function sprintB(string $string): string
-	{
-		$return = '';
-		$strLen = strlen($string);
-		for ($i = 0; $i < $strLen; $i++) {
-			$return .= sprintf('%08b', ord($string[$i]));
-		}
-
-		return $return;
-	}
+    use WSClientTrait;
+
+    /**
+     * App version
+     *
+     * @var string
+     */
+    public const VERSION = 'v1.0.0';
+
+    /**
+     * @var resource|bool
+     */
+    private $socket;
+
+    /**
+     * @var bool
+     */
+    private bool $isConnected = false;
+
+    /**
+     * @var bool
+     */
+    private bool $isClosing = false;
+
+    /**
+     * @var string
+     */
+    private string $lastOpcode;
+
+    /**
+     * @var float|int
+     */
+    private float|int $closeStatus;
+
+    /**
+     * @var string|null
+     */
+    private ?string $hugePayload;
+
+    /**
+     * @var array|int[]
+     */
+    private static array $opcodes = [
+        CommonsContract::EVENT_TYPE_CONTINUATION => 0,
+        CommonsContract::EVENT_TYPE_TEXT => 1,
+        CommonsContract::EVENT_TYPE_BINARY => 2,
+        CommonsContract::EVENT_TYPE_CLOSE => 8,
+        CommonsContract::EVENT_TYPE_PING => 9,
+        CommonsContract::EVENT_TYPE_PONG => 10,
+    ];
+
+    /**
+     * @var WebSocketConfig
+     */
+    protected WebSocketConfig $config;
+
+    /**
+     * @var string
+     */
+    protected string $socketUrl;
+
+    /**
+     * @var ?SocketClient
+     */
+    protected ?SocketClient $client = null;
+
+    /**
+     * Sets parameters for Web Socket Client intercommunication
+     *
+     * @param SocketClient|string $clientOrUri pass the SocketClient object or the URI of the server
+     * @param ?WebSocketConfig $config if you're passing the URI, you can pass the config object
+     */
+    public function __construct(SocketClient|string $clientOrUri, ?WebSocketConfig $config = null)
+    {
+        if ($clientOrUri instanceof SocketClient) {
+            $this->client = $clientOrUri;
+        } else {
+            $this->connect($clientOrUri, $config === null ? new WebSocketConfig() : $config);
+        }
+    }
+
+    /**
+     * @param string $socketUrl string that represents the URL of the Web Socket server. e.g. ws://localhost:1337 or wss://localhost:1337
+     * @param WebSocketConfig $config The configuration for the Web Socket client
+     */
+    public function connect(string $socketUrl, WebSocketConfig $config): void
+    {
+        try {
+            $this->config = $config;
+            $this->socketUrl = $socketUrl;
+            $urlParts = parse_url($this->socketUrl);
+
+            $this->config->setScheme($urlParts['scheme']);
+            $this->config->setHost($urlParts['host']);
+            $this->config->setUser($urlParts);
+            $this->config->setPassword($urlParts);
+            $this->config->setPort($urlParts);
+
+            $pathWithQuery = $this->getPathWithQuery($urlParts);
+            $hostUri = $this->getHostUri($this->config);
+
+            $context = $this->getStreamContext();
+            if ($this->config->hasProxy()) {
+                $this->socket = $this->proxy();
+            } else {
+                $this->socket = @stream_socket_client(
+                    $hostUri . ':' . $this->config->getPort(),
+                    $errno,
+                    $errstr,
+                    $this->config->getTimeout(),
+                    STREAM_CLIENT_CONNECT,
+                    $context
+                );
+            }
+
+            if ($this->socket === false) {
+                throw new ConnectionException(
+                    "Could not open socket to \"{$this->config->getHost()}:{$this->config->getPort()}\": $errstr ($errno).",
+                    CommonsContract::CLIENT_COULD_NOT_OPEN_SOCKET
+                );
+            }
+
+            stream_set_timeout($this->socket, $this->config->getTimeout());
+
+            $key = $this->generateKey();
+            $headers = [
+                'Host' => $this->config->getHost() . ':' . $this->config->getPort(),
+                'User-Agent' => 'Easy-Http/' . self::VERSION . ' (PHP/' . PHP_VERSION . ')',
+                'Connection' => 'Upgrade',
+                'Upgrade' => 'WebSocket',
+                'Sec-WebSocket-Key' => $key,
+                'Sec-Websocket-Version' => '13',
+            ];
+
+            if ($this->config->getUser() || $this->config->getPassword()) {
+                $headers['authorization'] = 'Basic ' . base64_encode($this->config->getUser() . ':' . $this->config->getPassword()) . "\r\n";
+            }
+
+            if (!empty($this->config->getHeaders())) {
+                $headers = array_merge($headers, $this->config->getHeaders());
+            }
+
+            $header = $this->getHeaders($pathWithQuery, $headers);
+
+            $this->write($header);
+
+            $this->validateResponse($this->config, $pathWithQuery, $key);
+            $this->isConnected = true;
+
+            if ($this->client !== null) {
+                $this->client->setConnection($this);
+                $this->client->onOpen();
+                while ($this->isConnected()) {
+                    if (is_string(($message = $this->receive()))) {
+                        $this->client->onMessage($message);
+                    }
+                }
+                $this->client->onClose($this->closeStatus);
+            }
+
+        } catch (\Exception $e) {
+            $this->client->onError(
+                new WebSocketException(
+                    $e->getMessage(),
+                    $e->getCode(),
+                    $e
+                )
+            );
+        }
+    }
+
+    /**
+     * Init a proxy connection
+     *
+     * @return resource|false
+     * @throws \InvalidArgumentException
+     * @throws ConnectionException
+     */
+    private function proxy()
+    {
+        $sock = @stream_socket_client(
+            WscCommonsContract::TCP_SCHEME . $this->config->getProxyIp() . ':' . $this->config->getProxyPort(),
+            $errno,
+            $errstr,
+            $this->config->getTimeout(),
+            STREAM_CLIENT_CONNECT,
+            $this->getStreamContext()
+        );
+        $write = "CONNECT {$this->config->getProxyIp()}:{$this->config->getProxyPort()} HTTP/1.1\r\n";
+        $auth = $this->config->getProxyAuth();
+        if ($auth !== NULL) {
+            $write .= "Proxy-Authorization: Basic {$auth}\r\n";
+        }
+        $write .= "\r\n";
+        fwrite($sock, $write);
+        $resp = fread($sock, 1024);
+
+        if (preg_match(self::PROXY_MATCH_RESP, $resp) === 1) {
+            return $sock;
+        }
+
+        throw new ConnectionException('Failed to connect to the host via proxy');
+    }
+
+    /**
+     * @return mixed
+     * @throws \InvalidArgumentException
+     */
+    private function getStreamContext(): mixed
+    {
+        if ($this->config->getContext() !== null) {
+            // Suppress the error since we'll catch it below
+            if (@get_resource_type($this->config->getContext()) === 'stream-context') {
+                return $this->config->getContext();
+            }
+
+            throw new \InvalidArgumentException(
+                'Stream context is invalid',
+                CommonsContract::CLIENT_INVALID_STREAM_CONTEXT
+            );
+        }
+
+        return stream_context_create($this->config->getContextOptions());
+    }
+
+    /**
+     * @param mixed $urlParts
+     * @return string
+     */
+    private function getPathWithQuery(mixed $urlParts): string
+    {
+        $path = isset($urlParts['path']) ? $urlParts['path'] : '/';
+        $query = isset($urlParts['query']) ? $urlParts['query'] : '';
+        $fragment = isset($urlParts['fragment']) ? $urlParts['fragment'] : '';
+        $pathWithQuery = $path;
+        if (!empty($query)) {
+            $pathWithQuery .= '?' . $query;
+        }
+        if (!empty($fragment)) {
+            $pathWithQuery .= '#' . $fragment;
+        }
+
+        return $pathWithQuery;
+    }
+
+    /**
+     * @param string $pathWithQuery
+     * @param array $headers
+     * @return string
+     */
+    private function getHeaders(string $pathWithQuery, array $headers): string
+    {
+        return 'GET ' . $pathWithQuery . " HTTP/1.1\r\n"
+            . implode(
+                "\r\n",
+                array_map(
+                    function ($key, $value) {
+                        return "$key: $value";
+                    },
+                    array_keys($headers),
+                    $headers
+                )
+            )
+            . "\r\n\r\n";
+    }
+
+    /**
+     * @return string
+     */
+    public function getLastOpcode(): string
+    {
+        return $this->lastOpcode;
+    }
+
+    /**
+     * @return int
+     */
+    public function getCloseStatus(): int
+    {
+        return $this->closeStatus;
+    }
+
+    /**
+     * @return bool
+     */
+    public function isConnected(): bool
+    {
+        return $this->isConnected;
+    }
+
+    /**
+     * @param int $timeout
+     * @param null $microSecs
+     * @return WebSocket
+     */
+    public function setTimeout(int $timeout, $microSecs = null): WebSocket
+    {
+        $this->config->setTimeout($timeout);
+        if ($this->socket && get_resource_type($this->socket) === 'stream') {
+            stream_set_timeout($this->socket, $timeout, $microSecs);
+        }
+
+        return $this;
+    }
+
+    /**
+     * Sends message to opened socket connection client->server
+     *
+     * @param $payload
+     * @param string $opcode
+     * @throws \Exception
+     */
+    public function send($payload, string $opcode = CommonsContract::EVENT_TYPE_TEXT): void
+    {
+        if (!$this->isConnected) {
+            $this->connect($this->socketUrl, new WebSocketConfig());
+        }
+
+        if (array_key_exists($opcode, self::$opcodes) === false) {
+            throw new BadOpcodeException(
+                "Bad opcode '$opcode'.  Try 'text' or 'binary'.",
+                CommonsContract::CLIENT_BAD_OPCODE
+            );
+        }
+
+        $payloadLength = strlen($payload);
+        $fragmentCursor = 0;
+
+        while ($payloadLength > $fragmentCursor) {
+            $subPayload = substr($payload, $fragmentCursor, $this->config->getFragmentSize());
+            $fragmentCursor += $this->config->getFragmentSize();
+            $final = $payloadLength <= $fragmentCursor;
+            $this->sendFragment($final, $subPayload, $opcode, true);
+            $opcode = 'continuation';
+        }
+    }
+
+    /**
+     * Receives message client<-server
+     *
+     * @return string|null
+     * @throws \Exception
+     */
+    public function receive(): string|null
+    {
+        if (!$this->isConnected) {
+            $this->connect($this->socketUrl, new WebSocketConfig());
+        }
+
+        $this->hugePayload = '';
+
+        return $this->receiveFragment();
+    }
+
+    /**
+     * Tell the socket to close.
+     *
+     * @param integer $status http://tools.ietf.org/html/rfc6455#section-7.4
+     * @param string $message A closing message, max 125 bytes.
+     * @return bool|null|string
+     * @throws \Exception
+     */
+    public function close(int $status = 1000, string $message = 'ttfn'): bool|null|string
+    {
+        $statusBin = sprintf('%016b', $status);
+        $statusStr = '';
+
+        foreach (str_split($statusBin, 8) as $binstr) {
+            $statusStr .= chr(bindec($binstr));
+        }
+
+        $this->send($statusStr . $message, CommonsContract::EVENT_TYPE_CLOSE);
+        $this->isClosing = true;
+
+        return $this->receive(); // Receiving a close frame will close the socket now.
+    }
+
+    /**
+     * @param string $data
+     * @throws ConnectionException
+     */
+    protected function write(string $data): void
+    {
+        Middleware::stream_write($this->socket, $data);
+    }
+
+    /**
+     * @param int $len
+     * @return string|null
+     * @throws ConnectionException
+     */
+    protected function read(int $len): string|null
+    {
+        return Middleware::stream_read($this->socket, $len) ?: false;
+    }
+
+    /**
+     * Helper to convert a binary to a string of '0' and '1'.
+     *
+     * @param string $string
+     * @return string
+     */
+    protected static function sprintB(string $string): string
+    {
+        $return = '';
+        $strLen = strlen($string);
+        for ($i = 0; $i < $strLen; $i++) {
+            $return .= sprintf('%08b', ord($string[$i]));
+        }
+
+        return $return;
+    }
 
 }

Spacing +1 added lines, -1 removed lines

@@ -225,7 +225,7 @@
 			. implode(
 				"\r\n",
 				array_map(
-					function ($key, $value) {
+					function($key, $value) {
 						return "$key: $value";
 					},
 					array_keys($headers),

src/Loop.php

Indentation +29 added lines, -29 removed lines

@@ -14,36 +14,36 @@
 class Loop
 {
 
-	/**
-	 * Whether the loop is running or not
-	 *
-	 * @var bool
-	 */
-	protected static bool $running = false;
+    /**
+     * Whether the loop is running or not
+     *
+     * @var bool
+     */
+    protected static bool $running = false;
 
-	/**
-	 * @param callable $callback
-	 * @param int $interval in milliseconds
-	 * @return void
-	 */
-	public static function run(callable $callback, int $interval = 500): void
-	{
-		static::$running = true;
-		$last_hit = Toolkit::time();
-		while (static::$running) {
-			if (Toolkit::time() - $last_hit > $interval) {
-				$callback();
-				$last_hit = Toolkit::time();
-			}
-		}
-	}
+    /**
+     * @param callable $callback
+     * @param int $interval in milliseconds
+     * @return void
+     */
+    public static function run(callable $callback, int $interval = 500): void
+    {
+        static::$running = true;
+        $last_hit = Toolkit::time();
+        while (static::$running) {
+            if (Toolkit::time() - $last_hit > $interval) {
+                $callback();
+                $last_hit = Toolkit::time();
+            }
+        }
+    }
 
-	/**
-	 * @return void
-	 */
-	public static function stop(): void
-	{
-		static::$running = false;
-	}
+    /**
+     * @return void
+     */
+    public static function stop(): void
+    {
+        static::$running = false;
+    }
 
 }
\ No newline at end of file

src/Utils/Toolkit.php

Indentation +19 added lines, -19 removed lines

@@ -96,25 +96,25 @@
         return (bool)preg_match_all('/' . $value . '/i', $string);
     }
 
-	/**
-	 * Millisecond sleep
-	 *
-	 * @param int $milliseconds The milliseconds
-	 * @return void
-	 */
-	public static function sleep(int $milliseconds): void
-	{
-		usleep($milliseconds * 1000);
-	}
+    /**
+     * Millisecond sleep
+     *
+     * @param int $milliseconds The milliseconds
+     * @return void
+     */
+    public static function sleep(int $milliseconds): void
+    {
+        usleep($milliseconds * 1000);
+    }
 
-	/**
-	 * Get current time in milliseconds
-	 *
-	 * @return int
-	 */
-	public static function time(): int
-	{
-		return (int)(microtime(true) * 1000);
-	}
+    /**
+     * Get current time in milliseconds
+     *
+     * @return int
+     */
+    public static function time(): int
+    {
+        return (int)(microtime(true) * 1000);
+    }
 
 }
\ No newline at end of file

Spacing +2 added lines, -2 removed lines

@@ -93,7 +93,7 @@ 
      */
     public static function insensitiveString(string $string, string $value): bool
     {
-        return (bool)preg_match_all('/' . $value . '/i', $string);
+        return (bool) preg_match_all('/' . $value . '/i', $string);
     }
 
 	/**
@@ -114,7 +114,7 @@ 
 	 */
 	public static function time(): int
 	{
-		return (int)(microtime(true) * 1000);
+		return (int) (microtime(true) * 1000);
 	}
 
 }
\ No newline at end of file

src/SocketClient.php

Indentation +33 added lines, -33 removed lines

@@ -20,38 +20,38 @@
 abstract class SocketClient implements WebSocketContract, MessageContract
 {
 
-	/**
-	 * @var WebSocket
-	 */
-	protected WebSocket $websocket;
-
-	/**
-	 * @param WebSocket $websocket
-	 * @return void
-	 */
-	protected function setConnection(WebSocket $websocket): void
-	{
-		$this->websocket = $websocket;
-	}
-
-	/**
-	 * @param string $name
-	 * @param array $arguments
-	 * @return mixed
-	 */
-	public function __call(string $name, array $arguments): mixed
-	{
-		if (method_exists($this, $name)) {
-			return call_user_func_array([$this, $name], $arguments);
-		}
-
-		if (method_exists($this->websocket, $name)) {
-			return call_user_func_array([$this->websocket, $name], $arguments);
-		}
-
-		throw new \BadMethodCallException(sprintf(
-			'Method `%s` does not exist at `%s`', $name, get_class($this)
-		));
-	}
+    /**
+     * @var WebSocket
+     */
+    protected WebSocket $websocket;
+
+    /**
+     * @param WebSocket $websocket
+     * @return void
+     */
+    protected function setConnection(WebSocket $websocket): void
+    {
+        $this->websocket = $websocket;
+    }
+
+    /**
+     * @param string $name
+     * @param array $arguments
+     * @return mixed
+     */
+    public function __call(string $name, array $arguments): mixed
+    {
+        if (method_exists($this, $name)) {
+            return call_user_func_array([$this, $name], $arguments);
+        }
+
+        if (method_exists($this->websocket, $name)) {
+            return call_user_func_array([$this->websocket, $name], $arguments);
+        }
+
+        throw new \BadMethodCallException(sprintf(
+            'Method `%s` does not exist at `%s`', $name, get_class($this)
+        ));
+    }
 
 }