{

/** @var resource The underlying socket */

private $socket;

public function __construct(StreamInterface $stream)

{

$this->socket = $stream->detach();

}

/**

public function write($data): void

{

$rand = \random_int(0, 28);

$frame = [

'fin' => 1,

'rsv1' => 0,

'rsv2' => 0,

'rsv3' => 0,

'opcode' => 1, // We always send text

'mask' => 1,

'len' => \strlen($data),

'mask_key' => \substr(\md5(\uniqid()), $rand, 4),

'data' => $data,

];

if (1 === $frame['mask']) {

for ($i = 0; $i < $frame['len']; ++$i) {

$frame['data'][$i]

= \chr(\ord($frame['data'][$i]) ^ \ord($frame['mask_key'][$i % 4]));

}

}

if ($frame['len'] > 2 ** 16) {

$len = 127;

} elseif ($frame['len'] > 125) {

$len = 126;

} else {

$len = $frame['len'];

}

$firstByte = ($frame['fin'] << 7) | (($frame['rsv1'] << 7) >> 1) | (($frame['rsv2'] << 7) >> 2) | (($frame['rsv3'] << 7) >> 3) | (($frame['opcode'] << 4) >> 4);

$secondByte = ($frame['mask'] << 7) | (($len << 1) >> 1);

$this->socketWrite(\chr($firstByte));

$this->socketWrite(\chr($secondByte));

if (126 === $len) {

$this->socketWrite(\pack('n', $frame['len']));

} elseif (127 === $len) {

$higher = $frame['len'] >> 32;

$lower = ($frame['len'] << 32) >> 32;

$this->socketWrite(\pack('N', $higher));

$this->socketWrite(\pack('N', $lower));

}

if (1 === $frame['mask']) {

$this->socketWrite($frame['mask_key']);

}

$this->socketWrite($frame['data']);

}

/**

public function read($waitTime = 0, $waitMicroTime = 200000, $getFrame = false)

{

if (!\is_resource($this->socket) || \feof($this->socket)) {

return null;

}

$read = [$this->socket];

$write = null;

$expect = null;

if (0 === \stream_select($read, $write, $expect, $waitTime, $waitMicroTime)) {

return false;

}

$firstByte = $this->socketRead(1);

$frame = [];

$firstByte = \ord($firstByte);

$secondByte = \ord($this->socketRead(1));

// First byte decoding

$frame['fin'] = ($firstByte & 128) >> 7;

$frame['rsv1'] = ($firstByte & 64) >> 6;

$frame['rsv2'] = ($firstByte & 32) >> 5;

$frame['rsv3'] = ($firstByte & 16) >> 4;

$frame['opcode'] = ($firstByte & 15);

// Second byte decoding

$frame['mask'] = ($secondByte & 128) >> 7;

$frame['len'] = ($secondByte & 127);

// Get length of the frame

if (126 === $frame['len']) {

$frame['len'] = \unpack('n', $this->socketRead(2))[1];

} elseif (127 === $frame['len']) {

list($higher, $lower) = \array_values(\unpack('N2', $this->socketRead(8)));

$frame['len'] = ($higher << 32) | $lower;

}

// Get the mask key if needed

if (1 === $frame['mask']) {

$frame['mask_key'] = $this->socketRead(4);

}

$frame['data'] = $this->socketRead($frame['len']);

// Decode data if needed

if (1 === $frame['mask']) {

for ($i = 0; $i < $frame['len']; ++$i) {

$frame['data'][$i] = \chr(\ord($frame['data'][$i]) ^ \ord($frame['mask_key'][$i % 4]));

}

}

if ($getFrame) {

return $frame;

}

return (string) $frame['data'];

}

/**

private function socketRead($length)

{

$read = '';

do {

$read .= \fread($this->socket, $length - \strlen($read));

} while (\strlen($read) < $length && !\feof($this->socket));

return $read;

}

/**

private function socketWrite($data)

{

return \fwrite($this->socket, $data);

}