shahradelahi / easy-http

examples/websocket/coinmarketcap-ticker.php

Indentation +38 added lines, -38 removed lines

@@ -10,58 +10,58 @@
 $SocketClient = new WebSocket();
 
 $SocketClient->onWhile = function (WebSocket $socket) use ($close_time) {
-	if (time() >= $close_time) {
-		$socket->close();
-	}
+    if (time() >= $close_time) {
+        $socket->close();
+    }
 };
 
 $SocketClient->onOpen = function (WebSocket $socket) {
-	echo sprintf(
-		'<pre><b>%s</b>: Connected to %s</pre><br/>',
-		date('Y-m-d H:i:s'),
-		$socket->getSocketUrl()
-	);
+    echo sprintf(
+        '<pre><b>%s</b>: Connected to %s</pre><br/>',
+        date('Y-m-d H:i:s'),
+        $socket->getSocketUrl()
+    );
 
-	$socket->send(json_encode([
-		'method' => 'subscribe',
-		'id' => 'price',
-		'data' => [
-			'cryptoIds' => [1, 1027, 825, 3408, 1839, 4687, 52, 2010, 5426],
-			'index' => 'detail'
-		]
-	]));
+    $socket->send(json_encode([
+        'method' => 'subscribe',
+        'id' => 'price',
+        'data' => [
+            'cryptoIds' => [1, 1027, 825, 3408, 1839, 4687, 52, 2010, 5426],
+            'index' => 'detail'
+        ]
+    ]));
 };
 
 $SocketClient->onClose = function (WebSocket $socket, int $closeStatus) {
-	echo sprintf(
-		'<pre><b>%s</b>: Disconnected with status: %s</pre><br/>',
-		date('Y-m-d H:i:s'),
-		$closeStatus
-	);
+    echo sprintf(
+        '<pre><b>%s</b>: Disconnected with status: %s</pre><br/>',
+        date('Y-m-d H:i:s'),
+        $closeStatus
+    );
 };
 
 $SocketClient->onMessage = function (WebSocket $socket, string $message) {
-	$data = json_decode($message, true);
-	if (isset($data['id']) && $data['id'] == "price") {
-		echo sprintf(
-			'<pre><b>%s</b>: %s</pre><br/>',
-			date('Y-m-d H:i:s'),
-			$message
-		);
-	}
+    $data = json_decode($message, true);
+    if (isset($data['id']) && $data['id'] == "price") {
+        echo sprintf(
+            '<pre><b>%s</b>: %s</pre><br/>',
+            date('Y-m-d H:i:s'),
+            $message
+        );
+    }
 };
 
 $SocketClient->onError = function (WebSocket $socket, WebSocketException $exception) {
-	echo sprintf(
-		"<pre>%s: Error: %s<br>File: %s:%s<br></pre><br>",
-		date('Y-m-d H:i:s'),
-		$exception->getMessage(),
-		$exception->getFile(),
-		$exception->getLine()
-	);
+    echo sprintf(
+        "<pre>%s: Error: %s<br>File: %s:%s<br></pre><br>",
+        date('Y-m-d H:i:s'),
+        $exception->getMessage(),
+        $exception->getFile(),
+        $exception->getLine()
+    );
 };
 
 $SocketClient->connect(
-	'wss://stream.coinmarketcap.com/price/latest',
-	(new WebSocketConfig())->setFragmentSize(8096)->setTimeout(15)
+    'wss://stream.coinmarketcap.com/price/latest',
+    (new WebSocketConfig())->setFragmentSize(8096)->setTimeout(15)
 );
\ No newline at end of file

Spacing +5 added lines, -5 removed lines

@@ -9,13 +9,13 @@ 
 $close_time = time() + 10;
 $SocketClient = new WebSocket();
 
-$SocketClient->onWhile = function (WebSocket $socket) use ($close_time) {
+$SocketClient->onWhile = function(WebSocket $socket) use ($close_time) {
 	if (time() >= $close_time) {
 		$socket->close();
 	}
 };
 
-$SocketClient->onOpen = function (WebSocket $socket) {
+$SocketClient->onOpen = function(WebSocket $socket) {
 	echo sprintf(
 		'<pre><b>%s</b>: Connected to %s</pre><br/>',
 		date('Y-m-d H:i:s'),
@@ -32,7 +32,7 @@ 
 	]));
 };
 
-$SocketClient->onClose = function (WebSocket $socket, int $closeStatus) {
+$SocketClient->onClose = function(WebSocket $socket, int $closeStatus) {
 	echo sprintf(
 		'<pre><b>%s</b>: Disconnected with status: %s</pre><br/>',
 		date('Y-m-d H:i:s'),
@@ -40,7 +40,7 @@ 
 	);
 };
 
-$SocketClient->onMessage = function (WebSocket $socket, string $message) {
+$SocketClient->onMessage = function(WebSocket $socket, string $message) {
 	$data = json_decode($message, true);
 	if (isset($data['id']) && $data['id'] == "price") {
 		echo sprintf(
@@ -51,7 +51,7 @@ 
 	}
 };
 
-$SocketClient->onError = function (WebSocket $socket, WebSocketException $exception) {
+$SocketClient->onError = function(WebSocket $socket, WebSocketException $exception) {
 	echo sprintf(
 		"<pre>%s: Error: %s<br>File: %s:%s<br></pre><br>",
 		date('Y-m-d H:i:s'),

examples/websocket/anonymous-callable.php

Indentation +5 added lines, -5 removed lines

@@ -4,17 +4,17 @@
 $SocketClient = new \EasyHttp\WebSocket();
 
 $SocketClient->onOpen = function (\EasyHttp\WebSocket $socket) {
-	echo "Connected to server<br>";
-	$socket->send("Hello World");
+    echo "Connected to server<br>";
+    $socket->send("Hello World");
 };
 
 $SocketClient->onMessage = function (\EasyHttp\WebSocket $socket, $message) {
-	echo $message . "<br>";
-	$socket->close();
+    echo $message . "<br>";
+    $socket->close();
 };
 
 $SocketClient->onClose = function (\EasyHttp\WebSocket $socket, int $closeStatus) {
-	echo "Disconnected with status: $closeStatus<br>";
+    echo "Disconnected with status: $closeStatus<br>";
 };
 
 $SocketClient->connect('wss://socket.litehex.com/', new \EasyHttp\WebSocketConfig());
\ No newline at end of file

Spacing +3 added lines, -3 removed lines

@@ -3,17 +3,17 @@
 
 $SocketClient = new \EasyHttp\WebSocket();
 
-$SocketClient->onOpen = function (\EasyHttp\WebSocket $socket) {
+$SocketClient->onOpen = function(\EasyHttp\WebSocket $socket) {
 	echo "Connected to server<br>";
 	$socket->send("Hello World");
 };
 
-$SocketClient->onMessage = function (\EasyHttp\WebSocket $socket, $message) {
+$SocketClient->onMessage = function(\EasyHttp\WebSocket $socket, $message) {
 	echo $message . "<br>";
 	$socket->close();
 };
 
-$SocketClient->onClose = function (\EasyHttp\WebSocket $socket, int $closeStatus) {
+$SocketClient->onClose = function(\EasyHttp\WebSocket $socket, int $closeStatus) {
 	echo "Disconnected with status: $closeStatus<br>";
 };
 

src/Contracts/CommonsContract.php

Indentation +47 added lines, -47 removed lines

@@ -12,58 +12,58 @@
 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;
-	public const CLIENT_CONNECTION_NOT_ESTABLISHED = 113;
+    // 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;
+    public const CLIENT_CONNECTION_NOT_ESTABLISHED = 113;
 
 }
\ No newline at end of file

src/Contracts/WscCommonsContract.php

Indentation +17 added lines, -17 removed lines

@@ -12,25 +12,25 @@
 interface WscCommonsContract
 {
 
-	public const TCP_SCHEME = 'tcp://';
+    public const TCP_SCHEME = 'tcp://';
 
-	public const MAX_BYTES_READ = 65535;
-	public const DEFAULT_TIMEOUT = 5;
-	public const DEFAULT_FRAGMENT_SIZE = 4096;
-	public const DEFAULT_RESPONSE_HEADER = 8192;
-	public const SEC_WEBSOCKET_ACCEPT_PTTRN = '/Sec-WebSocket-Accept:\s(.*)$/mUi';
-	public const SERVER_KEY_ACCEPT = '258EAFA5-E914-47DA-95CA-C5AB0DC85B11';
-	public const PROXY_MATCH_RESP = '/^HTTP\/\d\.\d 200/';
+    public const MAX_BYTES_READ = 65535;
+    public const DEFAULT_TIMEOUT = 5;
+    public const DEFAULT_FRAGMENT_SIZE = 4096;
+    public const DEFAULT_RESPONSE_HEADER = 8192;
+    public const SEC_WEBSOCKET_ACCEPT_PTTRN = '/Sec-WebSocket-Accept:\s(.*)$/mUi';
+    public const SERVER_KEY_ACCEPT = '258EAFA5-E914-47DA-95CA-C5AB0DC85B11';
+    public const PROXY_MATCH_RESP = '/^HTTP\/\d\.\d 200/';
 
-	// 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;
 
-	public const KEY_GEN_LENGTH = 16;
-	public const DEFAULT_PING_INTERVAL = 5;
+    public const KEY_GEN_LENGTH = 16;
+    public const DEFAULT_PING_INTERVAL = 5;
 
 }

src/Contracts/MessageContract.php

Indentation +6 added lines, -6 removed lines

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

src/Contracts/WebSocketContract.php

Indentation +17 added lines, -17 removed lines

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

src/WebSocket.php

Spacing +5 added lines, -5 removed lines

@@ -114,19 +114,19 @@ 
 	{
 		if ($client instanceof SocketClient) {
 
-			$this->onOpen = function ($socket) use ($client) {
+			$this->onOpen = function($socket) use ($client) {
 				$client->onOpen($socket);
 			};
 
-			$this->onClose = function ($socket, int $closeStatus) use ($client) {
+			$this->onClose = function($socket, int $closeStatus) use ($client) {
 				$client->onClose($socket, $closeStatus);
 			};
 
-			$this->onError = function ($socket, WebSocketException $exception) use ($client) {
+			$this->onError = function($socket, WebSocketException $exception) use ($client) {
 				$client->onError($socket, $exception);
 			};
 
-			$this->onMessage = function ($socket, string $message) use ($client) {
+			$this->onMessage = function($socket, string $message) use ($client) {
 				$client->onMessage($socket, $message);
 			};
 		}
@@ -346,7 +346,7 @@ 
 			. implode(
 				"\r\n",
 				array_map(
-					function ($key, $value) {
+					function($key, $value) {
 						return "$key: $value";
 					},
 					array_keys($headers),

Indentation +232 added lines, -232 removed lines

@@ -24,237 +24,237 @@
 class WebSocket implements WscCommonsContract
 {
 
-	use WSClientTrait;
-	use WSConnectionTrait;
-
-	/**
-	 * App version
-	 *
-	 * @var string
-	 */
-	public const VERSION = 'v1.2.0';
-
-	/**
-	 * @var resource|bool
-	 */
-	private $socket;
-
-	/**
-	 * @var string
-	 */
-	private string $lastOpcode;
-
-	/**
-	 * @var float|int
-	 */
-	private float|int $closeStatus;
-
-	/**
-	 * @var string|null
-	 */
-	private ?string $hugePayload;
-
-	/**
-	 * @var WebSocketConfig
-	 */
-	protected WebSocketConfig $config;
-
-	/**
-	 * @var string
-	 */
-	protected string $socketUrl;
-
-	/**
-	 * @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,
-	];
-
-	/**
-	 * Sets parameters for Web Socket Client intercommunication
-	 *
-	 * @param ?SocketClient $client leave it empty if you want to use default socket client
-	 */
-	public function __construct(?SocketClient $client = null)
-	{
-		if ($client instanceof SocketClient) {
-
-			$this->onOpen = function ($socket) use ($client) {
-				$client->onOpen($socket);
-			};
-
-			$this->onClose = function ($socket, int $closeStatus) use ($client) {
-				$client->onClose($socket, $closeStatus);
-			};
-
-			$this->onError = function ($socket, WebSocketException $exception) use ($client) {
-				$client->onError($socket, $exception);
-			};
-
-			$this->onMessage = function ($socket, string $message) use ($client) {
-				$client->onMessage($socket, $message);
-			};
-		}
-
-		$this->config = $config ?? new WebSocketConfig();
-	}
-
-	/**
-	 * 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 = $urlParts['path'] ?? '/';
-		$query = $urlParts['query'] ?? '';
-		$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";
-	}
-
-	/**
-	 * @param int $timeout
-	 * @param null $microSecs
-	 *
-	 * @return void
-	 */
-	public function setTimeout(int $timeout, $microSecs = null): void
-	{
-		$this->config->setTimeout($timeout);
-		if ($this->socket && get_resource_type($this->socket) === 'stream') {
-			stream_set_timeout($this->socket, $timeout, $microSecs);
-		}
-	}
-
-	/**
-	 * @param string $name
-	 * @param array $arguments
-	 *
-	 * @return mixed
-	 * @throws \Exception
-	 */
-	public function __call(string $name, array $arguments): mixed
-	{
-		if (property_exists($this, $name)) {
-			return $this->$name;
-		}
-
-		if (method_exists($this, $name)) {
-			return call_user_func_array([$this, $name], $arguments);
-		}
-
-		if (str_starts_with($name, 'get')) {
-			$property = lcfirst(substr($name, 3));
-
-			if (property_exists($this, $property)) {
-				return $this->{$property};
-			}
-		}
-
-		if (str_starts_with($name, 'set')) {
-			$property = lcfirst(substr($name, 3));
-			if (property_exists($this, $property)) {
-				$this->{$property} = $arguments[0];
-				return $this;
-			}
-		}
-
-		throw new \Exception(sprintf("Method '%s' does not exist.", $name));
-	}
+    use WSClientTrait;
+    use WSConnectionTrait;
+
+    /**
+     * App version
+     *
+     * @var string
+     */
+    public const VERSION = 'v1.2.0';
+
+    /**
+     * @var resource|bool
+     */
+    private $socket;
+
+    /**
+     * @var string
+     */
+    private string $lastOpcode;
+
+    /**
+     * @var float|int
+     */
+    private float|int $closeStatus;
+
+    /**
+     * @var string|null
+     */
+    private ?string $hugePayload;
+
+    /**
+     * @var WebSocketConfig
+     */
+    protected WebSocketConfig $config;
+
+    /**
+     * @var string
+     */
+    protected string $socketUrl;
+
+    /**
+     * @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,
+    ];
+
+    /**
+     * Sets parameters for Web Socket Client intercommunication
+     *
+     * @param ?SocketClient $client leave it empty if you want to use default socket client
+     */
+    public function __construct(?SocketClient $client = null)
+    {
+        if ($client instanceof SocketClient) {
+
+            $this->onOpen = function ($socket) use ($client) {
+                $client->onOpen($socket);
+            };
+
+            $this->onClose = function ($socket, int $closeStatus) use ($client) {
+                $client->onClose($socket, $closeStatus);
+            };
+
+            $this->onError = function ($socket, WebSocketException $exception) use ($client) {
+                $client->onError($socket, $exception);
+            };
+
+            $this->onMessage = function ($socket, string $message) use ($client) {
+                $client->onMessage($socket, $message);
+            };
+        }
+
+        $this->config = $config ?? new WebSocketConfig();
+    }
+
+    /**
+     * 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 = $urlParts['path'] ?? '/';
+        $query = $urlParts['query'] ?? '';
+        $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";
+    }
+
+    /**
+     * @param int $timeout
+     * @param null $microSecs
+     *
+     * @return void
+     */
+    public function setTimeout(int $timeout, $microSecs = null): void
+    {
+        $this->config->setTimeout($timeout);
+        if ($this->socket && get_resource_type($this->socket) === 'stream') {
+            stream_set_timeout($this->socket, $timeout, $microSecs);
+        }
+    }
+
+    /**
+     * @param string $name
+     * @param array $arguments
+     *
+     * @return mixed
+     * @throws \Exception
+     */
+    public function __call(string $name, array $arguments): mixed
+    {
+        if (property_exists($this, $name)) {
+            return $this->$name;
+        }
+
+        if (method_exists($this, $name)) {
+            return call_user_func_array([$this, $name], $arguments);
+        }
+
+        if (str_starts_with($name, 'get')) {
+            $property = lcfirst(substr($name, 3));
+
+            if (property_exists($this, $property)) {
+                return $this->{$property};
+            }
+        }
+
+        if (str_starts_with($name, 'set')) {
+            $property = lcfirst(substr($name, 3));
+            if (property_exists($this, $property)) {
+                $this->{$property} = $arguments[0];
+                return $this;
+            }
+        }
+
+        throw new \Exception(sprintf("Method '%s' does not exist.", $name));
+    }
 
 }
\ No newline at end of file

src/Traits/WSClientTrait.php

Spacing +6 added lines, -6 removed lines

@@ -72,7 +72,7 @@ 
 	 */
 	private function getPayloadLength(string $data): float|int
 	{
-		$payloadLength = (int)ord($data[1]) & self::MASK_127; // Bits 1-7 in byte 1
+		$payloadLength = (int) ord($data[1]) & self::MASK_127; // Bits 1-7 in byte 1
 		if ($payloadLength > self::MASK_125) {
 			if ($payloadLength === self::MASK_126) {
 				$data = $this->read(2); // 126: Payload is a 16-bit unsigned int
@@ -94,7 +94,7 @@ 
 	private function getPayloadData(string $data, int $payloadLength): string
 	{
 		// Masking?
-		$mask = (bool)(ord($data[1]) >> 7);  // Bit 0 in byte 1
+		$mask = (bool) (ord($data[1]) >> 7); // Bit 0 in byte 1
 		$payload = '';
 		$maskingKey = '';
 
@@ -110,7 +110,7 @@ 
 			if ($mask) {
 				// Unmask payload.
 				for ($i = 0; $i < $payloadLength; $i++) {
-					$payload .= ($data[$i] ^ $maskingKey[$i % 4]);
+					$payload .= ($data[$i]^$maskingKey[$i % 4]);
 				}
 			} else {
 				$payload = $data;
@@ -131,7 +131,7 @@ 
 			return null;
 		}
 
-		$final = (bool)(ord($data[0]) & 1 << 7);
+		$final = (bool) (ord($data[0]) & 1 << 7);
 
 		$opcodeInt = ord($data[0]) & 31;
 		$opcodeInts = array_flip(self::$opcodes);
@@ -198,7 +198,7 @@ 
 		// Binary string for header.
 		$frameHeadBin = '';
 		// Write FIN, final fragment bit.
-		$frameHeadBin .= (bool)$final ? '1' : '0';
+		$frameHeadBin .= (bool) $final ? '1' : '0';
 		// RSV 1, 2, & 3 false and unused.
 		$frameHeadBin .= '000';
 		// Opcode rest of the byte.
@@ -236,7 +236,7 @@ 
 
 		// Append payload to frame:
 		for ($i = 0; $i < $payloadLen; $i++) {
-			$frame .= ($masked === true) ? $payload[$i] ^ $mask[$i % 4] : $payload[$i];
+			$frame .= ($masked === true) ? $payload[$i]^$mask[$i % 4] : $payload[$i];
 		}
 
 		$this->write($frame);

Indentation +266 added lines, -266 removed lines

@@ -19,271 +19,271 @@
 trait WSClientTrait
 {
 
-	/**
-	 * Validates whether server sent valid upgrade response
-	 *
-	 * @param WebSocketConfig $config
-	 * @param string $pathWithQuery
-	 * @param string $key
-	 * @throws ConnectionException
-	 */
-	private function validateResponse(WebSocketConfig $config, string $pathWithQuery, string $key): void
-	{
-		$response = stream_get_line($this->socket, self::DEFAULT_RESPONSE_HEADER, "\r\n\r\n");
-		if (!preg_match(self::SEC_WEBSOCKET_ACCEPT_PTTRN, $response, $matches)) {
-			$address = $config->getScheme() . '://' . $config->getHost() . ':' . $config->getPort() . $pathWithQuery;
-			throw new ConnectionException(
-				"Connection to '{$address}' failed: Server sent invalid upgrade response:\n"
-				. $response, CommonsContract::CLIENT_INVALID_UPGRADE_RESPONSE
-			);
-		}
-
-		$keyAccept = trim($matches[1]);
-		$expectedResponse = base64_encode(pack('H*', sha1($key . self::SERVER_KEY_ACCEPT)));
-		if ($keyAccept !== $expectedResponse) {
-			throw new ConnectionException(
-				'Server sent bad upgrade response.',
-				CommonsContract::CLIENT_INVALID_UPGRADE_RESPONSE
-			);
-		}
-	}
-
-	/**
-	 *  Gets host uri based on protocol
-	 *
-	 * @param WebSocketConfig $config
-	 * @return string
-	 * @throws BadUriException
-	 */
-	private function getHostUri(WebSocketConfig $config): string
-	{
-		if (in_array($config->getScheme(), ['ws', 'wss'], true) === false) {
-			throw new BadUriException(
-				"Url should have scheme ws or wss, not '{$config->getScheme()}' from URI '$this->socketUrl' .",
-				CommonsContract::CLIENT_INCORRECT_SCHEME
-			);
-		}
-
-		return ($config->getScheme() === 'wss' ? 'ssl' : 'tcp') . '://' . $config->getHost();
-	}
-
-	/**
-	 * @param string $data
-	 * @return float|int
-	 * @throws ConnectionException
-	 */
-	private function getPayloadLength(string $data): float|int
-	{
-		$payloadLength = (int)ord($data[1]) & self::MASK_127; // Bits 1-7 in byte 1
-		if ($payloadLength > self::MASK_125) {
-			if ($payloadLength === self::MASK_126) {
-				$data = $this->read(2); // 126: Payload is a 16-bit unsigned int
-			} else {
-				$data = $this->read(8); // 127: Payload is a 64-bit unsigned int
-			}
-			$payloadLength = bindec(Toolkit::sprintB($data));
-		}
-
-		return $payloadLength;
-	}
-
-	/**
-	 * @param string $data
-	 * @param int $payloadLength
-	 * @return string
-	 * @throws ConnectionException
-	 */
-	private function getPayloadData(string $data, int $payloadLength): string
-	{
-		// Masking?
-		$mask = (bool)(ord($data[1]) >> 7);  // Bit 0 in byte 1
-		$payload = '';
-		$maskingKey = '';
-
-		// Get masking key.
-		if ($mask) {
-			$maskingKey = $this->read(4);
-		}
-
-		// Get the actual payload, if any (might not be for e.g. close frames.
-		if ($payloadLength > 0) {
-			$data = $this->read($payloadLength);
-
-			if ($mask) {
-				// Unmask payload.
-				for ($i = 0; $i < $payloadLength; $i++) {
-					$payload .= ($data[$i] ^ $maskingKey[$i % 4]);
-				}
-			} else {
-				$payload = $data;
-			}
-		}
-
-		return $payload;
-	}
-
-	/**
-	 * @return string|null
-	 * @throws \Exception
-	 */
-	protected function receiveFragment(): string|null
-	{
-		$data = $this->read(2);
-		if (is_string($data) === false) {
-			return null;
-		}
-
-		$final = (bool)(ord($data[0]) & 1 << 7);
-
-		$opcodeInt = ord($data[0]) & 31;
-		$opcodeInts = array_flip(self::$opcodes);
-		if (!array_key_exists($opcodeInt, $opcodeInts)) {
-			throw new ConnectionException(
-				"Bad opcode in websocket frame: $opcodeInt",
-				CommonsContract::CLIENT_BAD_OPCODE
-			);
-		}
-
-		$opcode = $opcodeInts[$opcodeInt];
-
-		if ($opcode !== 'continuation') {
-			$this->lastOpcode = $opcode;
-		}
-
-		$payloadLength = $this->getPayloadLength($data);
-		$payload = $this->getPayloadData($data, $payloadLength);
-
-		if ($opcode === CommonsContract::EVENT_TYPE_CLOSE) {
-			if ($payloadLength >= 2) {
-				$statusBin = $payload[0] . $payload[1];
-				$status = bindec(sprintf('%08b%08b', ord($payload[0]), ord($payload[1])));
-				$this->closeStatus = $status;
-				$payload = substr($payload, 2);
-
-				if (!$this->isClosing) {
-					$this->send($statusBin . 'Close acknowledged: ' . $status,
-						CommonsContract::EVENT_TYPE_CLOSE); // Respond.
-				}
-			}
-
-			if ($this->isClosing) {
-				$this->isClosing = false; // A close response, all done.
-			}
-
-			fclose($this->socket);
-			$this->isConnected = false;
-		}
-
-		if (!$final) {
-			$this->hugePayload .= $payload;
-
-			return null;
-		}
-
-		if ($this->hugePayload) {
-			$payload = $this->hugePayload .= $payload;
-			$this->hugePayload = null;
-		}
-
-		return $payload;
-	}
-
-	/**
-	 * @param $final
-	 * @param $payload
-	 * @param $opcode
-	 * @param $masked
-	 * @throws \Exception
-	 */
-	protected function sendFragment($final, $payload, $opcode, $masked): void
-	{
-		// Binary string for header.
-		$frameHeadBin = '';
-		// Write FIN, final fragment bit.
-		$frameHeadBin .= (bool)$final ? '1' : '0';
-		// RSV 1, 2, & 3 false and unused.
-		$frameHeadBin .= '000';
-		// Opcode rest of the byte.
-		$frameHeadBin .= sprintf('%04b', self::$opcodes[$opcode]);
-		// Use masking?
-		$frameHeadBin .= $masked ? '1' : '0';
-
-		// 7 bits of payload length...
-		$payloadLen = strlen($payload);
-		if ($payloadLen > self::MAX_BYTES_READ) {
-			$frameHeadBin .= decbin(self::MASK_127);
-			$frameHeadBin .= sprintf('%064b', $payloadLen);
-		} else if ($payloadLen > self::MASK_125) {
-			$frameHeadBin .= decbin(self::MASK_126);
-			$frameHeadBin .= sprintf('%016b', $payloadLen);
-		} else {
-			$frameHeadBin .= sprintf('%07b', $payloadLen);
-		}
-
-		$frame = '';
-
-		// Write frame head to frame.
-		foreach (str_split($frameHeadBin, 8) as $binstr) {
-			$frame .= chr(bindec($binstr));
-		}
-		// Handle masking
-		if ($masked) {
-			// generate a random mask:
-			$mask = '';
-			for ($i = 0; $i < 4; $i++) {
-				$mask .= chr(random_int(0, 255));
-			}
-			$frame .= $mask;
-		}
-
-		// Append payload to frame:
-		for ($i = 0; $i < $payloadLen; $i++) {
-			$frame .= ($masked === true) ? $payload[$i] ^ $mask[$i % 4] : $payload[$i];
-		}
-
-		$this->write($frame);
-	}
-
-	/**
-	 * Sec-WebSocket-Key generator
-	 *
-	 * @return string   the 16 character length key
-	 * @throws \Exception
-	 */
-	private function generateKey(): string
-	{
-		$chars = 'abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ!"$&/()=[]{}0123456789';
-		$key = '';
-		$chLen = strlen($chars);
-		for ($i = 0; $i < self::KEY_GEN_LENGTH; $i++) {
-			$key .= $chars[random_int(0, $chLen - 1)];
-		}
-
-		return base64_encode($key);
-	}
-
-	/**
-	 * @param int $len
-	 * @return string|null
-	 * @throws ConnectionException
-	 */
-	protected function read(int $len): string|null
-	{
-		if ($this->socket && $this->isConnected()) {
-			return Middleware::stream_read($this->socket, $len);
-		}
-
-		return null;
-	}
-
-	/**
-	 * @param string $data
-	 * @return void
-	 * @throws ConnectionException
-	 */
-	protected function write(string $data): void
-	{
-		Middleware::stream_write($this->socket, $data);
-	}
+    /**
+     * Validates whether server sent valid upgrade response
+     *
+     * @param WebSocketConfig $config
+     * @param string $pathWithQuery
+     * @param string $key
+     * @throws ConnectionException
+     */
+    private function validateResponse(WebSocketConfig $config, string $pathWithQuery, string $key): void
+    {
+        $response = stream_get_line($this->socket, self::DEFAULT_RESPONSE_HEADER, "\r\n\r\n");
+        if (!preg_match(self::SEC_WEBSOCKET_ACCEPT_PTTRN, $response, $matches)) {
+            $address = $config->getScheme() . '://' . $config->getHost() . ':' . $config->getPort() . $pathWithQuery;
+            throw new ConnectionException(
+                "Connection to '{$address}' failed: Server sent invalid upgrade response:\n"
+                . $response, CommonsContract::CLIENT_INVALID_UPGRADE_RESPONSE
+            );
+        }
+
+        $keyAccept = trim($matches[1]);
+        $expectedResponse = base64_encode(pack('H*', sha1($key . self::SERVER_KEY_ACCEPT)));
+        if ($keyAccept !== $expectedResponse) {
+            throw new ConnectionException(
+                'Server sent bad upgrade response.',
+                CommonsContract::CLIENT_INVALID_UPGRADE_RESPONSE
+            );
+        }
+    }
+
+    /**
+     *  Gets host uri based on protocol
+     *
+     * @param WebSocketConfig $config
+     * @return string
+     * @throws BadUriException
+     */
+    private function getHostUri(WebSocketConfig $config): string
+    {
+        if (in_array($config->getScheme(), ['ws', 'wss'], true) === false) {
+            throw new BadUriException(
+                "Url should have scheme ws or wss, not '{$config->getScheme()}' from URI '$this->socketUrl' .",
+                CommonsContract::CLIENT_INCORRECT_SCHEME
+            );
+        }
+
+        return ($config->getScheme() === 'wss' ? 'ssl' : 'tcp') . '://' . $config->getHost();
+    }
+
+    /**
+     * @param string $data
+     * @return float|int
+     * @throws ConnectionException
+     */
+    private function getPayloadLength(string $data): float|int
+    {
+        $payloadLength = (int)ord($data[1]) & self::MASK_127; // Bits 1-7 in byte 1
+        if ($payloadLength > self::MASK_125) {
+            if ($payloadLength === self::MASK_126) {
+                $data = $this->read(2); // 126: Payload is a 16-bit unsigned int
+            } else {
+                $data = $this->read(8); // 127: Payload is a 64-bit unsigned int
+            }
+            $payloadLength = bindec(Toolkit::sprintB($data));
+        }
+
+        return $payloadLength;
+    }
+
+    /**
+     * @param string $data
+     * @param int $payloadLength
+     * @return string
+     * @throws ConnectionException
+     */
+    private function getPayloadData(string $data, int $payloadLength): string
+    {
+        // Masking?
+        $mask = (bool)(ord($data[1]) >> 7);  // Bit 0 in byte 1
+        $payload = '';
+        $maskingKey = '';
+
+        // Get masking key.
+        if ($mask) {
+            $maskingKey = $this->read(4);
+        }
+
+        // Get the actual payload, if any (might not be for e.g. close frames.
+        if ($payloadLength > 0) {
+            $data = $this->read($payloadLength);
+
+            if ($mask) {
+                // Unmask payload.
+                for ($i = 0; $i < $payloadLength; $i++) {
+                    $payload .= ($data[$i] ^ $maskingKey[$i % 4]);
+                }
+            } else {
+                $payload = $data;
+            }
+        }
+
+        return $payload;
+    }
+
+    /**
+     * @return string|null
+     * @throws \Exception
+     */
+    protected function receiveFragment(): string|null
+    {
+        $data = $this->read(2);
+        if (is_string($data) === false) {
+            return null;
+        }
+
+        $final = (bool)(ord($data[0]) & 1 << 7);
+
+        $opcodeInt = ord($data[0]) & 31;
+        $opcodeInts = array_flip(self::$opcodes);
+        if (!array_key_exists($opcodeInt, $opcodeInts)) {
+            throw new ConnectionException(
+                "Bad opcode in websocket frame: $opcodeInt",
+                CommonsContract::CLIENT_BAD_OPCODE
+            );
+        }
+
+        $opcode = $opcodeInts[$opcodeInt];
+
+        if ($opcode !== 'continuation') {
+            $this->lastOpcode = $opcode;
+        }
+
+        $payloadLength = $this->getPayloadLength($data);
+        $payload = $this->getPayloadData($data, $payloadLength);
+
+        if ($opcode === CommonsContract::EVENT_TYPE_CLOSE) {
+            if ($payloadLength >= 2) {
+                $statusBin = $payload[0] . $payload[1];
+                $status = bindec(sprintf('%08b%08b', ord($payload[0]), ord($payload[1])));
+                $this->closeStatus = $status;
+                $payload = substr($payload, 2);
+
+                if (!$this->isClosing) {
+                    $this->send($statusBin . 'Close acknowledged: ' . $status,
+                        CommonsContract::EVENT_TYPE_CLOSE); // Respond.
+                }
+            }
+
+            if ($this->isClosing) {
+                $this->isClosing = false; // A close response, all done.
+            }
+
+            fclose($this->socket);
+            $this->isConnected = false;
+        }
+
+        if (!$final) {
+            $this->hugePayload .= $payload;
+
+            return null;
+        }
+
+        if ($this->hugePayload) {
+            $payload = $this->hugePayload .= $payload;
+            $this->hugePayload = null;
+        }
+
+        return $payload;
+    }
+
+    /**
+     * @param $final
+     * @param $payload
+     * @param $opcode
+     * @param $masked
+     * @throws \Exception
+     */
+    protected function sendFragment($final, $payload, $opcode, $masked): void
+    {
+        // Binary string for header.
+        $frameHeadBin = '';
+        // Write FIN, final fragment bit.
+        $frameHeadBin .= (bool)$final ? '1' : '0';
+        // RSV 1, 2, & 3 false and unused.
+        $frameHeadBin .= '000';
+        // Opcode rest of the byte.
+        $frameHeadBin .= sprintf('%04b', self::$opcodes[$opcode]);
+        // Use masking?
+        $frameHeadBin .= $masked ? '1' : '0';
+
+        // 7 bits of payload length...
+        $payloadLen = strlen($payload);
+        if ($payloadLen > self::MAX_BYTES_READ) {
+            $frameHeadBin .= decbin(self::MASK_127);
+            $frameHeadBin .= sprintf('%064b', $payloadLen);
+        } else if ($payloadLen > self::MASK_125) {
+            $frameHeadBin .= decbin(self::MASK_126);
+            $frameHeadBin .= sprintf('%016b', $payloadLen);
+        } else {
+            $frameHeadBin .= sprintf('%07b', $payloadLen);
+        }
+
+        $frame = '';
+
+        // Write frame head to frame.
+        foreach (str_split($frameHeadBin, 8) as $binstr) {
+            $frame .= chr(bindec($binstr));
+        }
+        // Handle masking
+        if ($masked) {
+            // generate a random mask:
+            $mask = '';
+            for ($i = 0; $i < 4; $i++) {
+                $mask .= chr(random_int(0, 255));
+            }
+            $frame .= $mask;
+        }
+
+        // Append payload to frame:
+        for ($i = 0; $i < $payloadLen; $i++) {
+            $frame .= ($masked === true) ? $payload[$i] ^ $mask[$i % 4] : $payload[$i];
+        }
+
+        $this->write($frame);
+    }
+
+    /**
+     * Sec-WebSocket-Key generator
+     *
+     * @return string   the 16 character length key
+     * @throws \Exception
+     */
+    private function generateKey(): string
+    {
+        $chars = 'abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ!"$&/()=[]{}0123456789';
+        $key = '';
+        $chLen = strlen($chars);
+        for ($i = 0; $i < self::KEY_GEN_LENGTH; $i++) {
+            $key .= $chars[random_int(0, $chLen - 1)];
+        }
+
+        return base64_encode($key);
+    }
+
+    /**
+     * @param int $len
+     * @return string|null
+     * @throws ConnectionException
+     */
+    protected function read(int $len): string|null
+    {
+        if ($this->socket && $this->isConnected()) {
+            return Middleware::stream_read($this->socket, $len);
+        }
+
+        return null;
+    }
+
+    /**
+     * @param string $data
+     * @return void
+     * @throws ConnectionException
+     */
+    protected function write(string $data): void
+    {
+        Middleware::stream_write($this->socket, $data);
+    }
 
 }
\ No newline at end of file

src/WebSocketConfig.php

Indentation +331 added lines, -331 removed lines

@@ -14,336 +14,336 @@
 class WebSocketConfig
 {
 
-	/**
-	 * @var string
-	 */
-	private string $scheme;
-
-	/**
-	 * @var string
-	 */
-	private string $host;
-
-	/**
-	 * @var string
-	 */
-	private string $user;
-
-	/**
-	 * @var string
-	 */
-	private string $password;
-
-	/**
-	 * @var string
-	 */
-	private string $port;
-
-	/**
-	 * @var int
-	 */
-	private int $timeout = WscCommonsContract::DEFAULT_TIMEOUT;
-
-	/**
-	 * @var array
-	 */
-	private array $headers = [];
-
-	/**
-	 * @var int
-	 */
-	private int $fragmentSize = WscCommonsContract::DEFAULT_FRAGMENT_SIZE;
-
-	/**
-	 * @var null|resource
-	 */
-	private $context;
-
-	/**
-	 * @var bool
-	 */
-	private bool $hasProxy = false;
-
-	/**
-	 * @var string
-	 */
-	private string $proxyIp;
-
-	/**
-	 * @var string
-	 */
-	private string $proxyPort;
-
-	/**
-	 * @var string|null
-	 */
-	private ?string $proxyAuth;
-
-	/**
-	 * @var array
-	 */
-	private array $contextOptions = [];
-
-	/**
-	 * @var int
-	 */
-	private int $pingInterval = WscCommonsContract::DEFAULT_PING_INTERVAL;
-
-	/**
-	 * @return int
-	 */
-	public function getTimeout(): int
-	{
-		return $this->timeout;
-	}
-
-	/**
-	 * @param int $timeout
-	 * @return WebSocketConfig
-	 */
-	public function setTimeout(int $timeout): WebSocketConfig
-	{
-		$this->timeout = $timeout;
-		return $this;
-	}
-
-	/**
-	 * @param int $int
-	 * @return $this
-	 */
-	public function setPingInterval(int $int): WebSocketConfig
-	{
-		$this->pingInterval = $int;
-		return $this;
-	}
-
-	/**
-	 * @return int
-	 */
-	public function getPingInterval(): int
-	{
-		return $this->pingInterval;
-	}
-
-	/**
-	 * @return array
-	 */
-	public function getHeaders(): array
-	{
-		return $this->headers;
-	}
-
-	/**
-	 * @param array $headers
-	 * @return WebSocketConfig
-	 */
-	public function setHeaders(array $headers): WebSocketConfig
-	{
-		$this->headers = $headers;
-		return $this;
-	}
-
-	/**
-	 * @return int
-	 */
-	public function getFragmentSize(): int
-	{
-		return $this->fragmentSize;
-	}
-
-	/**
-	 * @param int $fragmentSize
-	 * @return WebSocketConfig
-	 */
-	public function setFragmentSize(int $fragmentSize): WebSocketConfig
-	{
-		$this->fragmentSize = $fragmentSize;
-		return $this;
-	}
-
-	/**
-	 * @return mixed
-	 */
-	public function getContext(): mixed
-	{
-		return $this->context;
-	}
-
-	/**
-	 * @param mixed $context
-	 * @return WebSocketConfig
-	 */
-	public function setContext(mixed $context): WebSocketConfig
-	{
-		$this->context = $context;
-		return $this;
-	}
-
-	/**
-	 * @return mixed
-	 */
-	public function getScheme(): string
-	{
-		return $this->scheme;
-	}
-
-	/**
-	 * @param string $scheme
-	 * @return WebSocketConfig
-	 */
-	public function setScheme(string $scheme): WebSocketConfig
-	{
-		$this->scheme = $scheme;
-		return $this;
-	}
-
-	/**
-	 * @return string
-	 */
-	public function getHost(): string
-	{
-		return $this->host;
-	}
-
-	/**
-	 * @param string $host
-	 * @return WebSocketConfig
-	 */
-	public function setHost(string $host): WebSocketConfig
-	{
-		$this->host = $host;
-		return $this;
-	}
-
-	/**
-	 * @return string
-	 */
-	public function getUser(): string
-	{
-		return $this->user;
-	}
-
-	/**
-	 * @param array $urlParts
-	 * @return WebSocketConfig
-	 */
-	public function setUser(array $urlParts): WebSocketConfig
-	{
-		$this->user = $urlParts['user'] ?? '';
-		return $this;
-	}
-
-	/**
-	 * @return string
-	 */
-	public function getPassword(): string
-	{
-		return $this->password;
-	}
-
-	/**
-	 * @param array $urlParts
-	 * @return WebSocketConfig
-	 */
-	public function setPassword(array $urlParts): WebSocketConfig
-	{
-		$this->password = $urlParts['pass'] ?? '';
-		return $this;
-	}
-
-	/**
-	 * @return string
-	 */
-	public function getPort(): string
-	{
-		return $this->port;
-	}
-
-	/**
-	 * @param array $urlParts
-	 * @return WebSocketConfig
-	 */
-	public function setPort(array $urlParts): WebSocketConfig
-	{
-		$this->port = $urlParts['port'] ?? ($this->scheme === 'wss' ? '443' : '80');
-		return $this;
-	}
-
-	/**
-	 * @return array
-	 */
-	public function getContextOptions(): array
-	{
-		return $this->contextOptions;
-	}
-
-	/**
-	 * @param array $contextOptions
-	 * @return WebSocketConfig
-	 */
-	public function setContextOptions(array $contextOptions): WebSocketConfig
-	{
-		$this->contextOptions = $contextOptions;
-		return $this;
-	}
-
-	/**
-	 * @param string $ip
-	 * @param string $port
-	 * @return WebSocketConfig
-	 */
-	public function setProxy(string $ip, string $port): WebSocketConfig
-	{
-		$this->hasProxy = true;
-		$this->proxyIp = $ip;
-		$this->proxyPort = $port;
-
-		return $this;
-	}
-
-	/**
-	 * Sets auth for proxy
-	 *
-	 * @param string $userName
-	 * @param string $password
-	 * @return WebSocketConfig
-	 */
-	public function setProxyAuth(string $userName, string $password): WebSocketConfig
-	{
-		$this->proxyAuth = (empty($userName) === false && empty($password) === false) ? base64_encode($userName . ':' . $password) : null;
-		return $this;
-	}
-
-	/**
-	 * @return bool
-	 */
-	public function hasProxy(): bool
-	{
-		return $this->hasProxy;
-	}
-
-	/**
-	 * @return string|null
-	 */
-	public function getProxyIp(): ?string
-	{
-		return $this->proxyIp;
-	}
-
-	/**
-	 * @return string|null
-	 */
-	public function getProxyPort(): ?string
-	{
-		return $this->proxyPort;
-	}
-
-	/**
-	 * @return string|null
-	 */
-	public function getProxyAuth(): ?string
-	{
-		return $this->proxyAuth;
-	}
+    /**
+     * @var string
+     */
+    private string $scheme;
+
+    /**
+     * @var string
+     */
+    private string $host;
+
+    /**
+     * @var string
+     */
+    private string $user;
+
+    /**
+     * @var string
+     */
+    private string $password;
+
+    /**
+     * @var string
+     */
+    private string $port;
+
+    /**
+     * @var int
+     */
+    private int $timeout = WscCommonsContract::DEFAULT_TIMEOUT;
+
+    /**
+     * @var array
+     */
+    private array $headers = [];
+
+    /**
+     * @var int
+     */
+    private int $fragmentSize = WscCommonsContract::DEFAULT_FRAGMENT_SIZE;
+
+    /**
+     * @var null|resource
+     */
+    private $context;
+
+    /**
+     * @var bool
+     */
+    private bool $hasProxy = false;
+
+    /**
+     * @var string
+     */
+    private string $proxyIp;
+
+    /**
+     * @var string
+     */
+    private string $proxyPort;
+
+    /**
+     * @var string|null
+     */
+    private ?string $proxyAuth;
+
+    /**
+     * @var array
+     */
+    private array $contextOptions = [];
+
+    /**
+     * @var int
+     */
+    private int $pingInterval = WscCommonsContract::DEFAULT_PING_INTERVAL;
+
+    /**
+     * @return int
+     */
+    public function getTimeout(): int
+    {
+        return $this->timeout;
+    }
+
+    /**
+     * @param int $timeout
+     * @return WebSocketConfig
+     */
+    public function setTimeout(int $timeout): WebSocketConfig
+    {
+        $this->timeout = $timeout;
+        return $this;
+    }
+
+    /**
+     * @param int $int
+     * @return $this
+     */
+    public function setPingInterval(int $int): WebSocketConfig
+    {
+        $this->pingInterval = $int;
+        return $this;
+    }
+
+    /**
+     * @return int
+     */
+    public function getPingInterval(): int
+    {
+        return $this->pingInterval;
+    }
+
+    /**
+     * @return array
+     */
+    public function getHeaders(): array
+    {
+        return $this->headers;
+    }
+
+    /**
+     * @param array $headers
+     * @return WebSocketConfig
+     */
+    public function setHeaders(array $headers): WebSocketConfig
+    {
+        $this->headers = $headers;
+        return $this;
+    }
+
+    /**
+     * @return int
+     */
+    public function getFragmentSize(): int
+    {
+        return $this->fragmentSize;
+    }
+
+    /**
+     * @param int $fragmentSize
+     * @return WebSocketConfig
+     */
+    public function setFragmentSize(int $fragmentSize): WebSocketConfig
+    {
+        $this->fragmentSize = $fragmentSize;
+        return $this;
+    }
+
+    /**
+     * @return mixed
+     */
+    public function getContext(): mixed
+    {
+        return $this->context;
+    }
+
+    /**
+     * @param mixed $context
+     * @return WebSocketConfig
+     */
+    public function setContext(mixed $context): WebSocketConfig
+    {
+        $this->context = $context;
+        return $this;
+    }
+
+    /**
+     * @return mixed
+     */
+    public function getScheme(): string
+    {
+        return $this->scheme;
+    }
+
+    /**
+     * @param string $scheme
+     * @return WebSocketConfig
+     */
+    public function setScheme(string $scheme): WebSocketConfig
+    {
+        $this->scheme = $scheme;
+        return $this;
+    }
+
+    /**
+     * @return string
+     */
+    public function getHost(): string
+    {
+        return $this->host;
+    }
+
+    /**
+     * @param string $host
+     * @return WebSocketConfig
+     */
+    public function setHost(string $host): WebSocketConfig
+    {
+        $this->host = $host;
+        return $this;
+    }
+
+    /**
+     * @return string
+     */
+    public function getUser(): string
+    {
+        return $this->user;
+    }
+
+    /**
+     * @param array $urlParts
+     * @return WebSocketConfig
+     */
+    public function setUser(array $urlParts): WebSocketConfig
+    {
+        $this->user = $urlParts['user'] ?? '';
+        return $this;
+    }
+
+    /**
+     * @return string
+     */
+    public function getPassword(): string
+    {
+        return $this->password;
+    }
+
+    /**
+     * @param array $urlParts
+     * @return WebSocketConfig
+     */
+    public function setPassword(array $urlParts): WebSocketConfig
+    {
+        $this->password = $urlParts['pass'] ?? '';
+        return $this;
+    }
+
+    /**
+     * @return string
+     */
+    public function getPort(): string
+    {
+        return $this->port;
+    }
+
+    /**
+     * @param array $urlParts
+     * @return WebSocketConfig
+     */
+    public function setPort(array $urlParts): WebSocketConfig
+    {
+        $this->port = $urlParts['port'] ?? ($this->scheme === 'wss' ? '443' : '80');
+        return $this;
+    }
+
+    /**
+     * @return array
+     */
+    public function getContextOptions(): array
+    {
+        return $this->contextOptions;
+    }
+
+    /**
+     * @param array $contextOptions
+     * @return WebSocketConfig
+     */
+    public function setContextOptions(array $contextOptions): WebSocketConfig
+    {
+        $this->contextOptions = $contextOptions;
+        return $this;
+    }
+
+    /**
+     * @param string $ip
+     * @param string $port
+     * @return WebSocketConfig
+     */
+    public function setProxy(string $ip, string $port): WebSocketConfig
+    {
+        $this->hasProxy = true;
+        $this->proxyIp = $ip;
+        $this->proxyPort = $port;
+
+        return $this;
+    }
+
+    /**
+     * Sets auth for proxy
+     *
+     * @param string $userName
+     * @param string $password
+     * @return WebSocketConfig
+     */
+    public function setProxyAuth(string $userName, string $password): WebSocketConfig
+    {
+        $this->proxyAuth = (empty($userName) === false && empty($password) === false) ? base64_encode($userName . ':' . $password) : null;
+        return $this;
+    }
+
+    /**
+     * @return bool
+     */
+    public function hasProxy(): bool
+    {
+        return $this->hasProxy;
+    }
+
+    /**
+     * @return string|null
+     */
+    public function getProxyIp(): ?string
+    {
+        return $this->proxyIp;
+    }
+
+    /**
+     * @return string|null
+     */
+    public function getProxyPort(): ?string
+    {
+        return $this->proxyPort;
+    }
+
+    /**
+     * @return string|null
+     */
+    public function getProxyAuth(): ?string
+    {
+        return $this->proxyAuth;
+    }
 
 }