hfw / socket

src/DatagramClient.php

Spacing +1 added lines, -1 removed lines

@@ -12,7 +12,7 @@
      *
      * @return int
      */
-    final public static function getType (): int {
+    final public static function getType(): int {
         return SOCK_DGRAM;
     }
 

src/ReactiveInterface.php

Spacing +2 added lines, -2 removed lines

@@ -14,13 +14,13 @@
      *
      * @return void
      */
-    public function onOutOfBand (): void;
+    public function onOutOfBand(): void;
 
     /**
      * Called by the reactor when the socket has readable data.
      *
      * @return void
      */
-    public function onReadable (): void;
+    public function onReadable(): void;
 
 }
\ No newline at end of file

src/WebSocket/HandShake.php

Spacing +9 added lines, -9 removed lines

@@ -45,32 +45,32 @@ 
      */
     protected $sizeLimit = 4096;
 
-    public function __construct (WebSocketClient $client) {
+    public function __construct(WebSocketClient $client) {
         $this->client = $client;
     }
 
     /**
      * @return string[]
      */
-    public function getHeaders () {
+    public function getHeaders() {
         return $this->headers;
     }
 
     /**
      * @return string
      */
-    public function getMethod (): string {
+    public function getMethod(): string {
         return $this->method;
     }
 
     /**
      * @return int
      */
-    public function getRsv (): int {
+    public function getRsv(): int {
         return $this->rsv;
     }
 
-    public function negotiate (): bool {
+    public function negotiate(): bool {
         $this->buffer .= $this->client->recvAll();
         try {
             if (strlen($this->buffer) > $this->sizeLimit) {
@@ -90,7 +90,7 @@ 
                 $key = strtolower(trim($key));
                 $value = trim($value);
                 if (isset($this->headers[$key])) {
-                    $this->headers[$key] .= ', ' . $value;
+                    $this->headers[$key] .= ', '.$value;
                 }
                 else {
                     $this->headers[$key] = $value;
@@ -108,19 +108,19 @@ 
         }
     }
 
-    protected function upgrade (): void {
+    protected function upgrade(): void {
         $this->client->write(implode("\r\n", [
             "HTTP/1.1 101 Switching Protocols",
             "Connection: Upgrade",
             "Upgrade: websocket",
-            "Sec-WebSocket-Accept: " . base64_encode(sha1($this->headers['sec-websocket-key'] . self::RFC_GUID, true)),
+            "Sec-WebSocket-Accept: ".base64_encode(sha1($this->headers['sec-websocket-key'].self::RFC_GUID, true)),
         ]));
     }
 
     /**
      * Validates the received HTTP handshake headers, or throws.
      */
-    protected function validate (): void {
+    protected function validate(): void {
         if (!(
             $check = 'method = http 1.1'
             and preg_match('/HTTP\/1\.1$/i', $this->method)

src/WebSocket/WebSocketError.php

Spacing +4 added lines, -4 removed lines

@@ -25,7 +25,7 @@ 
      */
     protected $frame;
 
-    public function __construct (int $code, string $message = '', Frame $frame = null, Throwable $previous = null) {
+    public function __construct(int $code, string $message = '', Frame $frame = null, Throwable $previous = null) {
         parent::__construct($message, $code, $previous);
         $this->frame = $frame;
     }
@@ -33,14 +33,14 @@ 
     /**
      * @return mixed
      */
-    public function getExtra () {
+    public function getExtra() {
         return $this->extra;
     }
 
     /**
      * @return Frame|null
      */
-    public function getFrame () {
+    public function getFrame() {
         return $this->frame;
     }
 
@@ -48,7 +48,7 @@ 
      * @param mixed $extra
      * @return $this
      */
-    public function setExtra ($extra) {
+    public function setExtra($extra) {
         $this->extra = $extra;
         return $this;
     }

src/AbstractClient.php

Spacing +5 added lines, -5 removed lines

@@ -18,7 +18,7 @@ 
      *
      * @return string
      */
-    public function __toString () {
+    public function __toString() {
         try {
             return implode(':', $this->getPeerName());
         }
@@ -41,7 +41,7 @@ 
      * @return $this
      * @throws SocketError
      */
-    public function connect (string $address, int $port = 0) {
+    public function connect(string $address, int $port = 0) {
         if (!@socket_connect($this->resource, $address, $port)) {
             // ignore expected errors for non-blocking connections
             $errno = SocketError::getLast($this->resource);
@@ -61,7 +61,7 @@ 
      * @return array `[ 0 => address, 1 => port ]`
      * @throws SocketError
      */
-    public function getPeerName (): array {
+    public function getPeerName(): array {
         if ($this->getDomain() === AF_UNIX) {
             return [$this->getOption(17), 0]; // SO_PEERCRED is not exposed by PHP
         }
@@ -81,7 +81,7 @@ 
      * @return int Total bytes sent.
      * @throws SocketError
      */
-    public function send (string $data, int $flags = 0): int {
+    public function send(string $data, int $flags = 0): int {
         $count = @socket_send($this->resource, $data, strlen($data), $flags);
         if ($count === false) {
             throw new SocketError($this->resource); // reliable errno
@@ -96,7 +96,7 @@ 
      * @return $this
      * @throws SocketError `int` total bytes sent is set as the extra data.
      */
-    public function write (string $data) {
+    public function write(string $data) {
         $length = strlen($data);
         $total = 0;
         while ($total < $length) {

src/SocketInterface.php

Spacing +3 added lines, -3 removed lines

@@ -27,20 +27,20 @@
      *
      * @return int
      */
-    public function getId (): int;
+    public function getId(): int;
 
     /**
      * Returns the underlying socket resource.
      *
      * @return resource
      */
-    public function getResource ();
+    public function getResource();
 
     /**
      * Whether the underlying resource is usable.
      *
      * @return bool
      */
-    public function isOpen (): bool;
+    public function isOpen(): bool;
 
 }
\ No newline at end of file

src/SocketError.php

Spacing +4 added lines, -4 removed lines

@@ -29,7 +29,7 @@ 
      * @param resource $resource PHP socket resource, or `null` for the global error.
      * @return int If the resource is closed or not a socket, `SOCKET_EBADF` is returned.
      */
-    public static function getLast ($resource = null) {
+    public static function getLast($resource = null) {
         if (isset($resource)) {
             if (@get_resource_type($resource) !== 'Socket') {
                 return SOCKET_EBADF; // Bad file descriptor
@@ -62,7 +62,7 @@ 
      * @param int $fallback Code to assume if one can't be found via the subject.
      * @param SocketError|null $previous Slippage of a prior error.
      */
-    public function __construct ($subject = null, $fallback = 0, SocketError $previous = null) {
+    public function __construct($subject = null, $fallback = 0, SocketError $previous = null) {
         if ($errno = is_int($subject) ? $subject : static::getLast($subject)) {
             $message = socket_strerror($errno);
         }
@@ -77,7 +77,7 @@ 
     /**
      * @return mixed
      */
-    public function getExtra () {
+    public function getExtra() {
         return $this->extra;
     }
 
@@ -85,7 +85,7 @@ 
      * @param mixed $extra
      * @return $this
      */
-    public function setExtra ($extra) {
+    public function setExtra($extra) {
         $this->extra = $extra;
         return $this;
     }

src/WebSocket/WebSocketClient.php

Spacing +15 added lines, -15 removed lines

@@ -51,7 +51,7 @@ 
      * @param $resource
      * @param WebSocketServer $server
      */
-    public function __construct ($resource, WebSocketServer $server) {
+    public function __construct($resource, WebSocketServer $server) {
         parent::__construct($resource);
         $this->server = $server;
     }
@@ -74,7 +74,7 @@ 
      * @param string $reason
      * @return StreamClient|void
      */
-    public function close (int $code = null, string $reason = '') {
+    public function close(int $code = null, string $reason = '') {
         try {
             if ($code >= 1000 and $this->state === self::STATE_OK) {
                 $this->getFrameHandler()->writeClose($code, $reason);
@@ -91,49 +91,49 @@ 
     /**
      * @return FrameHandler
      */
-    public function getFrameHandler () {
+    public function getFrameHandler() {
         return $this->frameHandler ?? $this->frameHandler = new FrameHandler($this);
     }
 
     /**
      * @return FrameReader
      */
-    public function getFrameReader () {
+    public function getFrameReader() {
         return $this->frameReader ?? $this->frameReader = new FrameReader($this);
     }
 
     /**
      * @return HandShake
      */
-    public function getHandshake () {
+    public function getHandshake() {
         return $this->handshake ?? $this->handshake = new HandShake($this);
     }
 
     /**
      * @return MessageHandler
      */
-    public function getMessageHandler () {
+    public function getMessageHandler() {
         return $this->messageHandler ?? $this->messageHandler = new MessageHandler($this);
     }
 
     /**
      * @return WebSocketServer
      */
-    public function getServer () {
+    public function getServer() {
         return $this->server;
     }
 
     /**
      * @return int
      */
-    public function getState (): int {
+    public function getState(): int {
         return $this->state;
     }
 
     /**
      * @return bool
      */
-    final public function isOk (): bool {
+    final public function isOk(): bool {
         return $this->state === self::STATE_OK;
     }
 
@@ -142,7 +142,7 @@ 
      *
      * The RFC says the connection must be dropped if any unsupported activity occurs.
      */
-    final public function onOutOfBand (): void {
+    final public function onOutOfBand(): void {
         $this->close(Frame::CLOSE_PROTOCOL_ERROR, "Received out-of-band data.");
     }
 
@@ -151,7 +151,7 @@ 
      *
      * @throws Exception
      */
-    public function onReadable (): void {
+    public function onReadable(): void {
         if (!strlen($this->recv(1, MSG_PEEK))) { // peer has shut down writing, or closed.
             $this->close();
             return;
@@ -187,7 +187,7 @@ 
     /**
      * Stub.
      */
-    protected function onStateOk (): void {
+    protected function onStateOk(): void {
 
     }
 
@@ -195,7 +195,7 @@ 
      * @param FrameHandler $frameHandler
      * @return $this
      */
-    public function setFrameHandler (FrameHandler $frameHandler) {
+    public function setFrameHandler(FrameHandler $frameHandler) {
         $this->frameHandler = $frameHandler;
         return $this;
     }
@@ -204,7 +204,7 @@ 
      * @param FrameReader $frameReader
      * @return $this
      */
-    public function setFrameReader (FrameReader $frameReader) {
+    public function setFrameReader(FrameReader $frameReader) {
         $this->frameReader = $frameReader;
         return $this;
     }
@@ -213,7 +213,7 @@ 
      * @param MessageHandler $messageHandler
      * @return $this
      */
-    public function setMessageHandler (MessageHandler $messageHandler) {
+    public function setMessageHandler(MessageHandler $messageHandler) {
         $this->messageHandler = $messageHandler;
         return $this;
     }

src/WebSocket/MessageHandler.php

Spacing +4 added lines, -4 removed lines

@@ -12,14 +12,14 @@ 
     /**
      * @param WebSocketClient $client
      */
-    public function __construct (WebSocketClient $client) {
+    public function __construct(WebSocketClient $client) {
         $this->client = $client;
     }
 
     /**
      * @param string $binary
      */
-    public function onBinary (string $binary): void {
+    public function onBinary(string $binary): void {
         unset($binary);
         throw new WebSocketError(Frame::CLOSE_UNHANDLED_DATA, "I don't handle binary data.");
     }
@@ -27,7 +27,7 @@ 
     /**
      * @param string $text
      */
-    public function onText (string $text): void {
+    public function onText(string $text): void {
         $this->onText_CheckUtf8($text);
         throw new WebSocketError(Frame::CLOSE_UNHANDLED_DATA, "I don't handle text.");
     }
@@ -37,7 +37,7 @@ 
      *
      * @param string $text
      */
-    protected function onText_CheckUtf8 (string $text): void {
+    protected function onText_CheckUtf8(string $text): void {
         if (!mb_detect_encoding($text, 'UTF-8', true)) {
             throw new WebSocketError(Frame::CLOSE_BAD_DATA, "Received TEXT is not UTF-8.");
         }