hfw / socket

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.");
         }

src/WebSocket/FrameReader.php

Spacing +6 added lines, -6 removed lines

@@ -46,14 +46,14 @@ 
      */
     protected $maxLength = 10 * 1024 * 1024;
 
-    public function __construct (WebSocketClient $client) {
+    public function __construct(WebSocketClient $client) {
         $this->client = $client;
     }
 
     /**
      * @return Frame|null
      */
-    protected function getFrame () {
+    protected function getFrame() {
         if (!$this->head) {
             if (preg_match(self::REGEXP, $this->buffer, $head)) {
                 [, $op, $len] = unpack('C2', $head[0]);
@@ -95,7 +95,7 @@ 
      *
      * @return Generator|Frame[]
      */
-    public function getFrames () {
+    public function getFrames() {
         $this->buffer .= $this->client->recvAll();
         while ($frame = $this->getFrame()) {
             yield $frame;
@@ -105,7 +105,7 @@ 
     /**
      * @return int
      */
-    public function getMaxLength (): int {
+    public function getMaxLength(): int {
         return $this->maxLength;
     }
 
@@ -113,7 +113,7 @@ 
      * @param int $bytes
      * @return $this
      */
-    public function setMaxLength (int $bytes) {
+    public function setMaxLength(int $bytes) {
         if ($bytes < self::MAX_LENGTH_RANGE[0] or $bytes > self::MAX_LENGTH_RANGE[1]) {
             throw new InvalidArgumentException('Max length must be within range [125,2^63-1]');
         }
@@ -126,7 +126,7 @@ 
      *
      * @throws WebSocketError
      */
-    protected function validate (): void {
+    protected function validate(): void {
         if ($this->head['length'] > $this->maxLength) {
             throw new WebSocketError(Frame::CLOSE_TOO_LARGE, "Payload would exceed {$this->maxLength} bytes");
         }

src/AbstractServer.php

Spacing +2 added lines, -2 removed lines

@@ -18,7 +18,7 @@ 
      *
      * @return string
      */
-    public function __toString () {
+    public function __toString() {
         try {
             return implode(':', $this->getSockName());
         }
@@ -40,7 +40,7 @@ 
      * @return $this
      * @throws SocketError
      */
-    public function bind (string $address, int $port = 0) {
+    public function bind(string $address, int $port = 0) {
         if (!@socket_bind($this->resource, $address, $port)) {
             throw new SocketError($this->resource, SOCKET_EOPNOTSUPP);
         }

src/StreamServer.php

Spacing +4 added lines, -4 removed lines

@@ -12,7 +12,7 @@ 
      *
      * @return int
      */
-    final public static function getType (): int {
+    final public static function getType(): int {
         return SOCK_STREAM;
     }
 
@@ -25,7 +25,7 @@ 
      * @return StreamClient
      * @throws SocketError
      */
-    public function accept () {
+    public function accept() {
         if (!$resource = @socket_accept($this->resource)) {
             throw new SocketError($this->resource); // reliable errno
         }
@@ -45,7 +45,7 @@ 
      * @return $this
      * @throws SocketError
      */
-    public function listen (int $backlog = 0) {
+    public function listen(int $backlog = 0) {
         if (!@socket_listen($this->resource, $backlog)) {
             throw new SocketError($this->resource); // reliable errno
         }
@@ -58,7 +58,7 @@ 
      * @param resource $resource The accepted connection.
      * @return StreamClient
      */
-    protected function newClient ($resource) {
+    protected function newClient($resource) {
         return new StreamClient($resource);
     }
 

src/DatagramServer.php

Spacing +3 added lines, -3 removed lines

@@ -12,7 +12,7 @@ 
      *
      * @return int
      */
-    final public static function getType (): int {
+    final public static function getType(): int {
         return SOCK_DGRAM;
     }
 
@@ -28,12 +28,12 @@ 
      * @return string
      * @throws SocketError
      */
-    public function recv (int $length, int $flags = 0, string &$name = null, int &$port = 0): string {
+    public function recv(int $length, int $flags = 0, string &$name = null, int &$port = 0): string {
         $count = @socket_recvfrom($this->resource, $data, $length, $flags, $name, $port);
         if ($count === false) {
             throw new SocketError($this->resource, SOCKET_EOPNOTSUPP);
         }
-        return (string)$data; // cast needed, will be null if 0 bytes are read
+        return (string) $data; // cast needed, will be null if 0 bytes are read
     }
 
 }
\ No newline at end of file

src/Reactor.php

Spacing +7 added lines, -7 removed lines

@@ -28,12 +28,12 @@ 
      * @return int
      * @throws SocketError
      */
-    public static function select (array &$read, array &$write, array &$except, ?float $timeout = null): int {
+    public static function select(array &$read, array &$write, array &$except, ?float $timeout = null): int {
         $rwe = [$read, $write, $except];
         array_walk_recursive($rwe, function(SocketInterface &$each) {
             $each = $each->getResource();
         });
-        $uSec = (int)(fmod($timeout, 1) * 1000000); // ignored if timeout is null
+        $uSec = (int) (fmod($timeout, 1) * 1000000); // ignored if timeout is null
         $count = @socket_select($rwe[0], $rwe[1], $rwe[2], $timeout, $uSec); // keys are preserved
         if ($count === false) {
             $read = $write = $except = [];
@@ -51,7 +51,7 @@ 
      * @param ReactiveInterface $socket
      * @return $this
      */
-    public function add (ReactiveInterface $socket) {
+    public function add(ReactiveInterface $socket) {
         $this->sockets[$socket->getId()] = $socket;
         return $this;
     }
@@ -61,14 +61,14 @@ 
      *
      * @return int
      */
-    public function count () {
+    public function count() {
         return count($this->sockets);
     }
 
     /**
      * @return SocketInterface[]
      */
-    public function getSockets () {
+    public function getSockets() {
         return $this->sockets;
     }
 
@@ -82,7 +82,7 @@ 
      * @param float|null $timeout Maximum seconds to block. `NULL` blocks forever.
      * @return int Number of sockets selected.
      */
-    public function react (?float $timeout = null): int {
+    public function react(?float $timeout = null): int {
         /** @var ReactiveInterface[][] $rwe */
         $rwe = [$this->sockets, [], $this->sockets];
         $count = static::select($rwe[0], $rwe[1], $rwe[2], $timeout);
@@ -110,7 +110,7 @@ 
      * @param int|ReactiveInterface $id
      * @return $this
      */
-    public function remove ($id) {
+    public function remove($id) {
         unset($this->sockets[$id instanceof ReactiveInterface ? $id->getId() : $id]);
         return $this;
     }

src/StreamClient.php

Spacing +6 added lines, -6 removed lines

@@ -12,7 +12,7 @@ 
      *
      * @return int
      */
-    final public static function getType (): int {
+    final public static function getType(): int {
         return SOCK_STREAM;
     }
 
@@ -26,7 +26,7 @@ 
      * @return static[] Two instances at indices `0` and `1`.
      * @throws SocketError
      */
-    public static function newUnixPair (...$extra) {
+    public static function newUnixPair(...$extra) {
         if (!@socket_create_pair(AF_UNIX, SOCK_STREAM, 0, $fd)) {
             throw new SocketError; // reliable errno
         }
@@ -45,7 +45,7 @@ 
      * @return string
      * @throws SocketError The partially read data is attached.
      */
-    public function read (int $length): string {
+    public function read(int $length): string {
         try {
             $data = '';
             do {
@@ -72,11 +72,11 @@ 
      * @return string
      * @throws SocketError
      */
-    public function recv (int $maxLength, int $msgFlags = 0): string {
+    public function recv(int $maxLength, int $msgFlags = 0): string {
         if (false === @socket_recv($this->resource, $data, $maxLength, $msgFlags)) {
             throw new SocketError($this->resource, SOCKET_EINVAL);
         }
-        return (string)$data; // cast needed, will be null if 0 bytes are read.
+        return (string) $data; // cast needed, will be null if 0 bytes are read.
     }
 
     /**
@@ -86,7 +86,7 @@ 
      * @return string
      * @throws SocketError
      */
-    public function recvAll (int $msgFlags = 0): string {
+    public function recvAll(int $msgFlags = 0): string {
         $msgFlags = ($msgFlags & ~MSG_WAITALL) | MSG_DONTWAIT;
         $length = $this->getOption(SO_RCVBUF);
         try {

src/AbstractSocket.php

Spacing +29 added lines, -29 removed lines

@@ -14,7 +14,7 @@ 
      *
      * @return int
      */
-    abstract public static function getType (): int;
+    abstract public static function getType(): int;
 
     /**
      * The underlying PHP resource.
@@ -33,7 +33,7 @@ 
      * @return static
      * @throws SocketError
      */
-    public static function create (int $domain = AF_INET, ...$extra) {
+    public static function create(int $domain = AF_INET, ...$extra) {
         if (!$resource = @socket_create($domain, static::getType(), 0)) { // auto-protocol
             throw new SocketError; // reliable errno
         }
@@ -49,12 +49,12 @@ 
      * @throws InvalidArgumentException Not a socket resource, or the socket is of the wrong type.
      * @throws SocketError Slippage of an existing error on the resource.
      */
-    public function __construct ($resource) {
+    public function __construct($resource) {
         if (!is_resource($resource) or get_resource_type($resource) !== 'Socket') {
             throw new InvalidArgumentException('Expected an open socket resource.', SOCKET_EBADF);
         }
         elseif (socket_get_option($resource, SOL_SOCKET, SO_TYPE) !== static::getType()) {
-            throw new InvalidArgumentException('Invalid socket type for ' . static::class, SOCKET_ESOCKTNOSUPPORT);
+            throw new InvalidArgumentException('Invalid socket type for '.static::class, SOCKET_ESOCKTNOSUPPORT);
         }
         elseif ($errno = SocketError::getLast($resource)) {
             // "File descriptor in bad state"
@@ -68,7 +68,7 @@ 
      *
      * @see close()
      */
-    public function __destruct () {
+    public function __destruct() {
         if ($this->isOpen()) {
             $this->close();
         }
@@ -85,7 +85,7 @@ 
      * @return $this
      * @throws SocketError
      */
-    public function await (int $channel) {
+    public function await(int $channel) {
         $rwe = [$channel => [$this->resource]];
         if (!@socket_select($rwe[0], $rwe[1], $rwe[2], null)) {
             throw new SocketError($this->resource);
@@ -98,7 +98,7 @@ 
      *
      * @return $this
      */
-    final public function awaitOutOfBand () {
+    final public function awaitOutOfBand() {
         return $this->await(self::CH_EXCEPT);
     }
 
@@ -107,7 +107,7 @@ 
      *
      * @return $this
      */
-    final public function awaitReadable () {
+    final public function awaitReadable() {
         return $this->await(self::CH_READ);
     }
 
@@ -116,7 +116,7 @@ 
      *
      * @return $this
      */
-    final public function awaitWritable () {
+    final public function awaitWritable() {
         return $this->await(self::CH_WRITE);
     }
 
@@ -127,7 +127,7 @@ 
      *
      * @return $this
      */
-    public function close () {
+    public function close() {
         socket_close($this->resource); // never errors
         return $this;
     }
@@ -137,15 +137,15 @@ 
      *
      * @return int
      */
-    final public function getDomain (): int {
+    final public function getDomain(): int {
         return $this->getOption(39); // SO_DOMAIN is not exposed by PHP
     }
 
     /**
      * @inheritDoc
      */
-    final public function getId (): int {
-        return (int)$this->resource;
+    final public function getId(): int {
+        return (int) $this->resource;
     }
 
     /**
@@ -157,7 +157,7 @@ 
      * @return mixed The option's value. This is never `false`.
      * @throws SocketError
      */
-    public function getOption (int $option) {
+    public function getOption(int $option) {
         $value = @socket_get_option($this->resource, SOL_SOCKET, $option);
         if ($value === false) {
             throw new SocketError($this->resource, SOCKET_EINVAL);
@@ -168,7 +168,7 @@ 
     /**
      * @inheritDoc
      */
-    final public function getResource () {
+    final public function getResource() {
         return $this->resource;
     }
 
@@ -180,7 +180,7 @@ 
      * @return array `[ 0 => address, 1 => port ]`
      * @throws SocketError
      */
-    public function getSockName (): array {
+    public function getSockName(): array {
         if (!@socket_getsockname($this->resource, $addr, $port)) {
             throw new SocketError($this->resource, SOCKET_EOPNOTSUPP);
         }
@@ -190,7 +190,7 @@ 
     /**
      * @inheritDoc
      */
-    public function isOpen (): bool {
+    public function isOpen(): bool {
         return is_resource($this->resource);
     }
 
@@ -201,7 +201,7 @@ 
      *
      * @return bool
      */
-    final public function isOutOfBand (): bool {
+    final public function isOutOfBand(): bool {
         return $this->isReady(self::CH_EXCEPT);
     }
 
@@ -212,7 +212,7 @@ 
      *
      * @return bool
      */
-    final public function isReadable (): bool {
+    final public function isReadable(): bool {
         return $this->isReady(self::CH_READ);
     }
 
@@ -226,15 +226,15 @@ 
      * @return bool
      * @throws SocketError
      */
-    public function isReady (int $channel, ?float $timeout = 0): bool {
+    public function isReady(int $channel, ?float $timeout = 0): bool {
         $rwe = [$channel => [$this->resource]];
         // core casts non-null timeout to int.
         // usec is ignored if timeout is null.
-        $usec = (int)(fmod($timeout, 1) * 1000000);
+        $usec = (int) (fmod($timeout, 1) * 1000000);
         if (false === $count = @socket_select($rwe[0], $rwe[1], $rwe[2], $timeout, $usec)) {
             throw new SocketError($this->resource);
         }
-        return (bool)$count;
+        return (bool) $count;
     }
 
     /**
@@ -244,7 +244,7 @@ 
      *
      * @return bool
      */
-    final public function isWritable (): bool {
+    final public function isWritable(): bool {
         return $this->isReady(self::CH_WRITE);
     }
 
@@ -266,7 +266,7 @@ 
      * @return $this
      * @throws SocketError
      */
-    public function setBlocking (bool $blocking) {
+    public function setBlocking(bool $blocking) {
         if ($blocking ? @socket_set_block($this->resource) : @socket_set_nonblock($this->resource)) {
             return $this;
         }
@@ -283,7 +283,7 @@ 
      * @return $this
      * @throws SocketError
      */
-    public function setOption (int $option, $value) {
+    public function setOption(int $option, $value) {
         if (!@socket_set_option($this->resource, SOL_SOCKET, $option, $value)) {
             throw new SocketError($this->resource, SOCKET_EINVAL);
         }
@@ -296,10 +296,10 @@ 
      * @param float $timeout Zero means "no timeout" (block forever).
      * @return $this
      */
-    public function setTimeout (float $timeout) {
+    public function setTimeout(float $timeout) {
         $tv = [
-            'sec' => (int)$timeout,
-            'usec' => (int)(fmod($timeout, 1) * 1000000)
+            'sec' => (int) $timeout,
+            'usec' => (int) (fmod($timeout, 1) * 1000000)
         ];
         $this->setOption(SO_RCVTIMEO, $tv);
         $this->setOption(SO_SNDTIMEO, $tv);
@@ -329,7 +329,7 @@ 
      * @return $this
      * @throws SocketError
      */
-    public function shutdown (int $channel) {
+    public function shutdown(int $channel) {
         if (!@socket_shutdown($this->resource, $channel)) {
             throw new SocketError($this->resource); // reliable errno
         }

src/WebSocket/Frame.php

Spacing +33 added lines, -33 removed lines

@@ -41,15 +41,15 @@ 
         0x0f => 'RESERVED CONTROL 0x0f',
     ];
 
-    const CLOSE_NORMAL = 1000;              // mutual closure
-    const CLOSE_INTERRUPT = 1001;           // abrupt closure due to hangups, reboots, "going away"
-    const CLOSE_PROTOCOL_ERROR = 1002;      // invalid behavior / framing
-    const CLOSE_UNHANDLED_DATA = 1003;      // message handler doesn't want the payload
-    const CLOSE_BAD_DATA = 1007;            // message handler can't understand the payload
-    const CLOSE_POLICY_VIOLATION = 1008;    // generic "access denied"
-    const CLOSE_TOO_LARGE = 1009;           // unacceptable payload size
-    const CLOSE_EXPECTATION = 1010;         // peer closed because it wants extensions (listed in the reason)
-    const CLOSE_INTERNAL_ERROR = 1011;      // like http 500
+    const CLOSE_NORMAL = 1000; // mutual closure
+    const CLOSE_INTERRUPT = 1001; // abrupt closure due to hangups, reboots, "going away"
+    const CLOSE_PROTOCOL_ERROR = 1002; // invalid behavior / framing
+    const CLOSE_UNHANDLED_DATA = 1003; // message handler doesn't want the payload
+    const CLOSE_BAD_DATA = 1007; // message handler can't understand the payload
+    const CLOSE_POLICY_VIOLATION = 1008; // generic "access denied"
+    const CLOSE_TOO_LARGE = 1009; // unacceptable payload size
+    const CLOSE_EXPECTATION = 1010; // peer closed because it wants extensions (listed in the reason)
+    const CLOSE_INTERNAL_ERROR = 1011; // like http 500
 
     /**
      * @var bool
@@ -79,7 +79,7 @@ 
      * @param int $opCode
      * @param string $payload
      */
-    public function __construct (bool $final, int $rsv, int $opCode, string $payload) {
+    public function __construct(bool $final, int $rsv, int $opCode, string $payload) {
         $this->final = $final;
         $this->rsv = $rsv;
         $this->opCode = $opCode;
@@ -91,7 +91,7 @@ 
      *
      * @return string
      */
-    public function __toString () {
+    public function __toString() {
         if ($this->isClose()) {
             return $this->getCloseReason();
         }
@@ -105,7 +105,7 @@ 
      *
      * @return int
      */
-    final public function getCloseCode (): int {
+    final public function getCloseCode(): int {
         $code = substr($this->payload, 0, 2);
         return isset($code[1]) ? unpack('n', $code)[1] : self::CLOSE_NORMAL;
     }
@@ -117,126 +117,126 @@ 
      *
      * @return string
      */
-    final public function getCloseReason (): string {
+    final public function getCloseReason(): string {
         return substr($this->payload, 2);
     }
 
     /**
      * @return int
      */
-    final public function getLength (): int {
+    final public function getLength(): int {
         return strlen($this->payload);
     }
 
     /**
      * @return string
      */
-    public function getName (): string {
+    public function getName(): string {
         return self::NAMES[$this->opCode];
     }
 
     /**
      * @return int
      */
-    final public function getOpCode (): int {
+    final public function getOpCode(): int {
         return $this->opCode;
     }
 
     /**
      * @return string
      */
-    final public function getPayload (): string {
+    final public function getPayload(): string {
         return $this->payload;
     }
 
     /**
      * @return int
      */
-    final public function getRsv (): int {
+    final public function getRsv(): int {
         return $this->rsv;
     }
 
     /**
      * @return bool
      */
-    final public function hasRsv1 (): bool {
-        return (bool)($this->rsv & self::RSV1);
+    final public function hasRsv1(): bool {
+        return (bool) ($this->rsv & self::RSV1);
     }
 
     /**
      * @return bool
      */
-    final public function hasRsv2 (): bool {
-        return (bool)($this->rsv & self::RSV2);
+    final public function hasRsv2(): bool {
+        return (bool) ($this->rsv & self::RSV2);
     }
 
     /**
      * @return bool
      */
-    final public function hasRsv3 (): bool {
-        return (bool)($this->rsv & self::RSV3);
+    final public function hasRsv3(): bool {
+        return (bool) ($this->rsv & self::RSV3);
     }
 
     /**
      * @return bool
      */
-    final public function isBinary (): bool {
+    final public function isBinary(): bool {
         return $this->opCode === self::OP_BINARY;
     }
 
     /**
      * @return bool
      */
-    final public function isClose (): bool {
+    final public function isClose(): bool {
         return $this->opCode === self::OP_CLOSE;
     }
 
     /**
      * @return bool
      */
-    final public function isContinue (): bool {
+    final public function isContinue(): bool {
         return $this->opCode === self::OP_CONTINUE;
     }
 
     /**
      * @return bool
      */
-    final public function isControl (): bool {
+    final public function isControl(): bool {
         return $this->opCode >= self::OP_CLOSE;
     }
 
     /**
      * @return bool
      */
-    final public function isData (): bool {
+    final public function isData(): bool {
         return $this->opCode < self::OP_CLOSE;
     }
 
     /**
      * @return bool
      */
-    final public function isFinal (): bool {
+    final public function isFinal(): bool {
         return $this->final;
     }
 
     /**
      * @return bool
      */
-    final public function isPing (): bool {
+    final public function isPing(): bool {
         return $this->opCode === self::OP_PING;
     }
 
     /**
      * @return bool
      */
-    final public function isPong (): bool {
+    final public function isPong(): bool {
         return $this->opCode === self::OP_PONG;
     }
 
     /**
      * @return bool
      */
-    final public function isText (): bool {
+    final public function isText(): bool {
         return $this->opCode === self::OP_TEXT;
     }