Experimental ws support

Author: mpociot

app/Connections/HttpConnection.php

@@ -30,4 +30,9 @@ public function close()
 
         $this->socket->close();
     }
+
+    public function getConnection(): ConnectionInterface
+    {
+        return $this->socket;
+    }
 }

app/Http/Controllers/TunnelMessageController.php

@@ -90,13 +90,17 @@ protected function sendRequestToClient(Request $request, ControlConnection $cont
 
         $httpConnection = $this->connectionManager->storeHttpConnection($httpConnection, $requestId);
 
-        transform($this->passRequestThroughModifiers($request, $httpConnection), function (Request $request) use ($controlConnection, $requestId) {
-            $controlConnection->once('proxy_ready_'.$requestId, function (ConnectionInterface $proxy) use ($request) {
+        transform($this->passRequestThroughModifiers($request, $httpConnection), function (Request $request) use ($httpConnection, $controlConnection, $requestId) {
+            $controlConnection->once('proxy_ready_'.$requestId, function (ConnectionInterface $proxy) use ($httpConnection, $request) {
                 // Convert the Laravel request into a PSR7 request
                 $psr17Factory = new Psr17Factory();
                 $psrHttpFactory = new PsrHttpFactory($psr17Factory, $psr17Factory, $psr17Factory, $psr17Factory);
                 $request = $psrHttpFactory->createRequest($request);
 
+                $httpConnection->getConnection()->on('data', function($d) use ($proxy) {
+                    $proxy->send(new Frame($d, true, Frame::OP_BINARY));
+                });
+
                 $binaryMsg = new Frame(Message::toString($request), true, Frame::OP_BINARY);
                 $proxy->send($binaryMsg);
             });

composer.json

@@ -37,7 +37,7 @@
         "nyholm/psr7": "^1.3",
         "ratchet/pawl": "dev-master",
         "symfony/expression-language": "^5.2",
-        "react/http": "^1.1.0",
+        "react/http": "dev-websocket-support",
         "react/socket": "^1.6",
         "react/stream": "^1.1.1",
         "clue/reactphp-sqlite": "^1.7.0",
@@ -86,6 +86,10 @@
             "type": "vcs",
             "url": "https://github.com/exposedev/expose"
         },
+        {
+            "type": "vcs",
+            "url": "https://github.com/exposedev/http"
+        },
         {
             "type": "vcs",
             "url": "https://github.com/beyondcode/RFC6455",