1. TcpConnection add properties websocketOrigin & websocketClientProtocol

2. Protocols/Ws::onConnect init websocketOrigin & websocketClientProtocol
3. Protocols/Websocket::input init websocketOrigin & websocketClientProtocol

Author: chaz6chez

src/Connection/TcpConnection.php

@@ -61,6 +61,8 @@
 /**
  * TcpConnection.
  * @property string $websocketType
+ * @property string|null websocketClientProtocol
+ * @property string|null websocketOrigin
  */
 class TcpConnection extends ConnectionInterface implements JsonSerializable
 {

src/Protocols/Websocket.php

@@ -84,6 +84,8 @@ class Websocket
      */
     public static function input(string $buffer, TcpConnection $connection): int
     {
+        $connection->websocketOrigin = $connection->websocketOrigin ?? null;
+        $connection->websocketClientProtocol = $connection->websocketClientProtocol ?? null;
         // Receive length.
         $recvLen = strlen($buffer);
         // We need more data.

src/Protocols/Ws.php

@@ -323,6 +323,8 @@ public static function decode(string $bytes, AsyncTcpConnection $connection): st
      */
     public static function onConnect(AsyncTcpConnection $connection): void
     {
+        $connection->websocketOrigin = $connection->websocketOrigin ?? null;
+        $connection->websocketClientProtocol = $connection->websocketClientProtocol ?? null;
         static::sendHandshake($connection);
     }
 
@@ -372,8 +374,8 @@ public static function sendHandshake(AsyncTcpConnection $connection): void
             (!preg_match("/\nHost:/i", $userHeaderStr) ? "Host: $host\r\n" : '') .
             "Connection: Upgrade\r\n" .
             "Upgrade: websocket\r\n" .
-            (isset($connection->websocketOrigin) ? "Origin: " . $connection->websocketOrigin . "\r\n" : '') .
-            (isset($connection->websocketClientProtocol) ? "Sec-WebSocket-Protocol: " . $connection->websocketClientProtocol . "\r\n" : '') .
+            ($connection?->websocketOrigin ? "Origin: " . $connection->websocketOrigin . "\r\n" : '') .
+            ($connection?->websocketClientProtocol ? "Sec-WebSocket-Protocol: " . $connection->websocketClientProtocol . "\r\n" : '') .
             "Sec-WebSocket-Version: 13\r\n" .
             "Sec-WebSocket-Key: " . $connection->context->websocketSecKey . $userHeaderStr . "\r\n\r\n";
         $connection->send($header, true);