shahradelahi / easy-http

examples/websoket/coinmarketcap-ticker.php

Indentation +29 added lines, -29 removed lines

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

Spacing +1 added lines, -1 removed lines

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

src/Contracts/CommonsContract.php

Indentation +46 added lines, -46 removed lines

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

src/Contracts/ConnectionContract.php

Indentation +6 added lines, -6 removed lines

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

src/Contracts/WscCommonsContract.php

Indentation +16 added lines, -16 removed lines

@@ -12,24 +12,24 @@
 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 KEY_GEN_LENGTH = 16;
 
 }

src/Contracts/MessageContract.php

Indentation +7 added lines, -7 removed lines

@@ -14,12 +14,12 @@
 interface MessageContract
 {
 
-	/**
-	 * @param ConnectionContract $recv
-	 * @param mixed $msg
-	 * @return mixed
-	 * @throws WebSocketException
-	 */
-	public function onMessage(ConnectionContract $recv, mixed $msg): mixed;
+    /**
+     * @param ConnectionContract $recv
+     * @param mixed $msg
+     * @return mixed
+     * @throws WebSocketException
+     */
+    public function onMessage(ConnectionContract $recv, mixed $msg): mixed;
 
 }

src/Contracts/WebSocketContract.php

Indentation +17 added lines, -17 removed lines

@@ -14,24 +14,24 @@
 interface WebSocketContract
 {
 
-	/**
-	 * @param ConnectionContract $conn
-	 * @return mixed
-	 */
-	public function onOpen(ConnectionContract $conn): mixed;
+    /**
+     * @param ConnectionContract $conn
+     * @return mixed
+     */
+    public function onOpen(ConnectionContract $conn): mixed;
 
-	/**
-	 * @param ConnectionContract $conn
-	 * @return mixed
-	 * @throws WebSocketException
-	 */
-	public function onClose(ConnectionContract $conn): mixed;
+    /**
+     * @param ConnectionContract $conn
+     * @return mixed
+     * @throws WebSocketException
+     */
+    public function onClose(ConnectionContract $conn): mixed;
 
-	/**
-	 * @param ConnectionContract $conn
-	 * @param WebSocketException $ex
-	 * @return mixed
-	 */
-	public function onError(ConnectionContract $conn, WebSocketException $ex): mixed;
+    /**
+     * @param ConnectionContract $conn
+     * @param WebSocketException $ex
+     * @return mixed
+     */
+    public function onError(ConnectionContract $conn, WebSocketException $ex): mixed;
 
 }

src/WebSocket.php

Indentation +12 added lines, -12 removed lines

@@ -16,17 +16,17 @@
 class WebSocket extends WscMain
 {
 
-	/**
-	 * Sets parameters for Web Socket Client intercommunication
-	 *
-	 * @param string $url string representation of a socket utf, ex.: tcp://www.example.com:8000 or udp://example.com:13
-	 * @param WSConfig $config Client configuration settings e.g.: connection - timeout, ssl options, fragment message size to send etc.
-	 * @throws Exception
-	 */
-	public function __construct(string $url, WSConfig $config)
-	{
-		$this->socketUrl = $url;
-		$this->connect($config);
-	}
+    /**
+     * Sets parameters for Web Socket Client intercommunication
+     *
+     * @param string $url string representation of a socket utf, ex.: tcp://www.example.com:8000 or udp://example.com:13
+     * @param WSConfig $config Client configuration settings e.g.: connection - timeout, ssl options, fragment message size to send etc.
+     * @throws Exception
+     */
+    public function __construct(string $url, WSConfig $config)
+    {
+        $this->socketUrl = $url;
+        $this->connect($config);
+    }
 
 }

src/Utils/WSConfig.php

Indentation +308 added lines, -308 removed lines

@@ -14,313 +14,313 @@
 class WSConfig
 {
 
-	/**
-	 * @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 = [];
-
-	/**
-	 * @return int
-	 */
-	public function getTimeout(): int
-	{
-		return $this->timeout;
-	}
-
-	/**
-	 * @param int $timeout
-	 * @return WSConfig
-	 */
-	public function setTimeout(int $timeout): WSConfig
-	{
-		$this->timeout = $timeout;
-		return $this;
-	}
-
-	/**
-	 * @return array
-	 */
-	public function getHeaders(): array
-	{
-		return $this->headers;
-	}
-
-	/**
-	 * @param array $headers
-	 * @return WSConfig
-	 */
-	public function setHeaders(array $headers): WSConfig
-	{
-		$this->headers = $headers;
-		return $this;
-	}
-
-	/**
-	 * @return int
-	 */
-	public function getFragmentSize(): int
-	{
-		return $this->fragmentSize;
-	}
-
-	/**
-	 * @param int $fragmentSize
-	 * @return WSConfig
-	 */
-	public function setFragmentSize(int $fragmentSize): WSConfig
-	{
-		$this->fragmentSize = $fragmentSize;
-		return $this;
-	}
-
-	/**
-	 * @return mixed
-	 */
-	public function getContext(): mixed
-	{
-		return $this->context;
-	}
-
-	/**
-	 * @param mixed $context
-	 * @return WSConfig
-	 */
-	public function setContext(mixed $context): WSConfig
-	{
-		$this->context = $context;
-		return $this;
-	}
-
-	/**
-	 * @return mixed
-	 */
-	public function getScheme(): string
-	{
-		return $this->scheme;
-	}
-
-	/**
-	 * @param string $scheme
-	 * @return WSConfig
-	 */
-	public function setScheme(string $scheme): WSConfig
-	{
-		$this->scheme = $scheme;
-		return $this;
-	}
-
-	/**
-	 * @return string
-	 */
-	public function getHost(): string
-	{
-		return $this->host;
-	}
-
-	/**
-	 * @param string $host
-	 * @return WSConfig
-	 */
-	public function setHost(string $host): WSConfig
-	{
-		$this->host = $host;
-		return $this;
-	}
-
-	/**
-	 * @return string
-	 */
-	public function getUser(): string
-	{
-		return $this->user;
-	}
-
-	/**
-	 * @param array $urlParts
-	 * @return WSConfig
-	 */
-	public function setUser(array $urlParts): WSConfig
-	{
-		$this->user = $urlParts['user'] ?? '';
-		return $this;
-	}
-
-	/**
-	 * @return string
-	 */
-	public function getPassword(): string
-	{
-		return $this->password;
-	}
-
-	/**
-	 * @param array $urlParts
-	 * @return WSConfig
-	 */
-	public function setPassword(array $urlParts): WSConfig
-	{
-		$this->password = $urlParts['pass'] ?? '';
-		return $this;
-	}
-
-	/**
-	 * @return string
-	 */
-	public function getPort(): string
-	{
-		return $this->port;
-	}
-
-	/**
-	 * @param array $urlParts
-	 * @return WSConfig
-	 */
-	public function setPort(array $urlParts): WSConfig
-	{
-		$this->port = $urlParts['port'] ?? ($this->scheme === 'wss' ? '443' : '80');
-		return $this;
-	}
-
-	/**
-	 * @return array
-	 */
-	public function getContextOptions(): array
-	{
-		return $this->contextOptions;
-	}
-
-	/**
-	 * @param array $contextOptions
-	 * @return WSConfig
-	 */
-	public function setContextOptions(array $contextOptions): WSConfig
-	{
-		$this->contextOptions = $contextOptions;
-		return $this;
-	}
-
-	/**
-	 * @param string $ip
-	 * @param string $port
-	 * @return WSConfig
-	 */
-	public function setProxy(string $ip, string $port): WSConfig
-	{
-		$this->hasProxy = true;
-		$this->proxyIp = $ip;
-		$this->proxyPort = $port;
-
-		return $this;
-	}
-
-	/**
-	 * Sets auth for proxy
-	 *
-	 * @param string $userName
-	 * @param string $password
-	 * @return WSConfig
-	 */
-	public function setProxyAuth(string $userName, string $password): WSConfig
-	{
-		$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 = [];
+
+    /**
+     * @return int
+     */
+    public function getTimeout(): int
+    {
+        return $this->timeout;
+    }
+
+    /**
+     * @param int $timeout
+     * @return WSConfig
+     */
+    public function setTimeout(int $timeout): WSConfig
+    {
+        $this->timeout = $timeout;
+        return $this;
+    }
+
+    /**
+     * @return array
+     */
+    public function getHeaders(): array
+    {
+        return $this->headers;
+    }
+
+    /**
+     * @param array $headers
+     * @return WSConfig
+     */
+    public function setHeaders(array $headers): WSConfig
+    {
+        $this->headers = $headers;
+        return $this;
+    }
+
+    /**
+     * @return int
+     */
+    public function getFragmentSize(): int
+    {
+        return $this->fragmentSize;
+    }
+
+    /**
+     * @param int $fragmentSize
+     * @return WSConfig
+     */
+    public function setFragmentSize(int $fragmentSize): WSConfig
+    {
+        $this->fragmentSize = $fragmentSize;
+        return $this;
+    }
+
+    /**
+     * @return mixed
+     */
+    public function getContext(): mixed
+    {
+        return $this->context;
+    }
+
+    /**
+     * @param mixed $context
+     * @return WSConfig
+     */
+    public function setContext(mixed $context): WSConfig
+    {
+        $this->context = $context;
+        return $this;
+    }
+
+    /**
+     * @return mixed
+     */
+    public function getScheme(): string
+    {
+        return $this->scheme;
+    }
+
+    /**
+     * @param string $scheme
+     * @return WSConfig
+     */
+    public function setScheme(string $scheme): WSConfig
+    {
+        $this->scheme = $scheme;
+        return $this;
+    }
+
+    /**
+     * @return string
+     */
+    public function getHost(): string
+    {
+        return $this->host;
+    }
+
+    /**
+     * @param string $host
+     * @return WSConfig
+     */
+    public function setHost(string $host): WSConfig
+    {
+        $this->host = $host;
+        return $this;
+    }
+
+    /**
+     * @return string
+     */
+    public function getUser(): string
+    {
+        return $this->user;
+    }
+
+    /**
+     * @param array $urlParts
+     * @return WSConfig
+     */
+    public function setUser(array $urlParts): WSConfig
+    {
+        $this->user = $urlParts['user'] ?? '';
+        return $this;
+    }
+
+    /**
+     * @return string
+     */
+    public function getPassword(): string
+    {
+        return $this->password;
+    }
+
+    /**
+     * @param array $urlParts
+     * @return WSConfig
+     */
+    public function setPassword(array $urlParts): WSConfig
+    {
+        $this->password = $urlParts['pass'] ?? '';
+        return $this;
+    }
+
+    /**
+     * @return string
+     */
+    public function getPort(): string
+    {
+        return $this->port;
+    }
+
+    /**
+     * @param array $urlParts
+     * @return WSConfig
+     */
+    public function setPort(array $urlParts): WSConfig
+    {
+        $this->port = $urlParts['port'] ?? ($this->scheme === 'wss' ? '443' : '80');
+        return $this;
+    }
+
+    /**
+     * @return array
+     */
+    public function getContextOptions(): array
+    {
+        return $this->contextOptions;
+    }
+
+    /**
+     * @param array $contextOptions
+     * @return WSConfig
+     */
+    public function setContextOptions(array $contextOptions): WSConfig
+    {
+        $this->contextOptions = $contextOptions;
+        return $this;
+    }
+
+    /**
+     * @param string $ip
+     * @param string $port
+     * @return WSConfig
+     */
+    public function setProxy(string $ip, string $port): WSConfig
+    {
+        $this->hasProxy = true;
+        $this->proxyIp = $ip;
+        $this->proxyPort = $port;
+
+        return $this;
+    }
+
+    /**
+     * Sets auth for proxy
+     *
+     * @param string $userName
+     * @param string $password
+     * @return WSConfig
+     */
+    public function setProxyAuth(string $userName, string $password): WSConfig
+    {
+        $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;
+    }
 
 }

src/Utils/WscMain.php

Indentation +416 added lines, -416 removed lines

@@ -19,421 +19,421 @@
 class WscMain implements WscCommonsContract
 {
 
-	use WSClientTrait;
-
-	/**
-	 * @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 string
-	 */
-	protected string $socketUrl = '';
-
-	/**
-	 * @var WSConfig
-	 */
-	protected WSConfig $config;
-
-	/**
-	 * @param WSConfig $config
-	 * @throws \Exception
-	 */
-	protected function connect(WSConfig $config): void
-	{
-		$this->config = $config;
-		$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' => 'websocket-client-php',
-			'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;
-	}
-
-	/**
-	 * 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 WscMain
-	 */
-	public function setTimeout(int $timeout, $microSecs = null): WscMain
-	{
-		$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(new WSConfig());
-		}
-
-		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 null|string
-	 * @throws \Exception
-	 */
-	public function receive(): ?string
-	{
-		if (!$this->isConnected) {
-			$this->connect(new WSConfig());
-		}
-
-		$this->hugePayload = '';
-
-		$response = null;
-		while ($response === null) {
-			$response = $this->receiveFragment();
-		}
-
-		return $response;
-	}
-
-	/**
-	 * 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
-	{
-		$written = fwrite($this->socket, $data);
-
-		if ($written < strlen($data)) {
-			throw new ConnectionException(
-				"Could only write $written out of " . strlen($data) . ' bytes.',
-				CommonsContract::CLIENT_COULD_ONLY_WRITE_LESS
-			);
-		}
-	}
-
-	/**
-	 * @param int $len
-	 * @return string
-	 * @throws ConnectionException
-	 */
-	protected function read(int $len): string
-	{
-		$data = '';
-		while (($dataLen = strlen($data)) < $len) {
-			$buff = fread($this->socket, $len - $dataLen);
-
-			if ($buff === false) {
-				$metadata = stream_get_meta_data($this->socket);
-				throw new ConnectionException(
-					'Broken frame, read ' . strlen($data) . ' of stated '
-					. $len . ' bytes.  Stream state: '
-					. json_encode($metadata),
-					CommonsContract::CLIENT_BROKEN_FRAME
-				);
-			}
-
-			if ($buff === '') {
-				$metadata = stream_get_meta_data($this->socket);
-				throw new ConnectionException(
-					'Empty read; connection dead?  Stream state: ' . json_encode($metadata),
-					CommonsContract::CLIENT_EMPTY_READ
-				);
-			}
-			$data .= $buff;
-		}
-
-		return $data;
-	}
-
-	/**
-	 * 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;
-	}
-
-	/**
-	 * 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);
-	}
+    use WSClientTrait;
+
+    /**
+     * @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 string
+     */
+    protected string $socketUrl = '';
+
+    /**
+     * @var WSConfig
+     */
+    protected WSConfig $config;
+
+    /**
+     * @param WSConfig $config
+     * @throws \Exception
+     */
+    protected function connect(WSConfig $config): void
+    {
+        $this->config = $config;
+        $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' => 'websocket-client-php',
+            '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;
+    }
+
+    /**
+     * 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 WscMain
+     */
+    public function setTimeout(int $timeout, $microSecs = null): WscMain
+    {
+        $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(new WSConfig());
+        }
+
+        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 null|string
+     * @throws \Exception
+     */
+    public function receive(): ?string
+    {
+        if (!$this->isConnected) {
+            $this->connect(new WSConfig());
+        }
+
+        $this->hugePayload = '';
+
+        $response = null;
+        while ($response === null) {
+            $response = $this->receiveFragment();
+        }
+
+        return $response;
+    }
+
+    /**
+     * 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
+    {
+        $written = fwrite($this->socket, $data);
+
+        if ($written < strlen($data)) {
+            throw new ConnectionException(
+                "Could only write $written out of " . strlen($data) . ' bytes.',
+                CommonsContract::CLIENT_COULD_ONLY_WRITE_LESS
+            );
+        }
+    }
+
+    /**
+     * @param int $len
+     * @return string
+     * @throws ConnectionException
+     */
+    protected function read(int $len): string
+    {
+        $data = '';
+        while (($dataLen = strlen($data)) < $len) {
+            $buff = fread($this->socket, $len - $dataLen);
+
+            if ($buff === false) {
+                $metadata = stream_get_meta_data($this->socket);
+                throw new ConnectionException(
+                    'Broken frame, read ' . strlen($data) . ' of stated '
+                    . $len . ' bytes.  Stream state: '
+                    . json_encode($metadata),
+                    CommonsContract::CLIENT_BROKEN_FRAME
+                );
+            }
+
+            if ($buff === '') {
+                $metadata = stream_get_meta_data($this->socket);
+                throw new ConnectionException(
+                    'Empty read; connection dead?  Stream state: ' . json_encode($metadata),
+                    CommonsContract::CLIENT_EMPTY_READ
+                );
+            }
+            $data .= $buff;
+        }
+
+        return $data;
+    }
+
+    /**
+     * 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;
+    }
+
+    /**
+     * 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);
+    }
 
 }

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),