bitinflow/expose
1
0
Fork 0
mirror of https://github.com/bitinflow/expose.git synced 2026-03-13 13:35:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

Apply fixes from StyleCI

Browse Source
This commit is contained in:
Marcel Pociot
2020-09-07 18:52:38 +00:00
committed by StyleCI Bot
parent e857de8498
commit 32fd4ba8ea
3 changed files with 5 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
app/Client/ProxyManager.php
View File

@@ -3,10 +3,10 @@
namespace App\Client; namespace App\Client;
use App\Client\Http\HttpClient; use App\Client\Http\HttpClient;
use React\Socket\Connector;
use function Ratchet\Client\connect; use function Ratchet\Client\connect;
use Ratchet\Client\WebSocket; use Ratchet\Client\WebSocket;
use React\EventLoop\LoopInterface; use React\EventLoop\LoopInterface;
use React\Socket\Connector;
class ProxyManager class ProxyManager
{ {
@@ -59,7 +59,7 @@ class ProxyManager
$proxyConnection->send($data); $proxyConnection->send($data);
}); });
$proxyConnection->on('message', function ($message) use ($proxyConnection, $connection) { $proxyConnection->on('message', function ($message) use ($connection) {
$connection->write($message); $connection->write($message);
}); });
}); });

6
app/Server/Connections/TcpControlConnection.php
View File

@@ -2,7 +2,6 @@
namespace App\Server\Connections; namespace App\Server\Connections;
use Evenement\EventEmitterTrait;
use Ratchet\ConnectionInterface; use Ratchet\ConnectionInterface;
use React\Socket\Server; use React\Socket\Server;
@@ -80,14 +79,13 @@ class TcpControlConnection extends ControlConnection
{ {
$requestId = uniqid(); $requestId = uniqid();
$sharedServer->on('connection', function(\React\Socket\ConnectionInterface $connection) use ($requestId) { $sharedServer->on('connection', function (\React\Socket\ConnectionInterface $connection) use ($requestId) {
$this->proxyConnection = $connection; $this->proxyConnection = $connection;
$this->once('tcp_proxy_ready_'.$requestId, function (ConnectionInterface $proxy) use ($connection) { $this->once('tcp_proxy_ready_'.$requestId, function (ConnectionInterface $proxy) use ($connection) {
$this->proxy = $proxy; $this->proxy = $proxy;
$connection->on('data', function($data) use ($proxy) { $connection->on('data', function ($data) use ($proxy) {
$proxy->send($data); $proxy->send($data);
}); });

2
app/Server/Http/Controllers/ControlMessageController.php
View File

@@ -83,7 +83,7 @@ class ControlMessageController implements MessageComponentInterface
->then(function ($user) use ($connection, $data) { ->then(function ($user) use ($connection, $data) {
if ($data->type === 'http') { if ($data->type === 'http') {
$this->handleHttpConnection($connection, $data, $user); $this->handleHttpConnection($connection, $data, $user);
} elseif($data->type === 'tcp') { } elseif ($data->type === 'tcp') {
$this->handleTcpConnection($connection, $data, $user); $this->handleTcpConnection($connection, $data, $user);
} }
}, function () use ($connection) { }, function () use ($connection) {