aboutsummaryrefslogtreecommitdiffhomepage
path: root/assets/php/vendor/ratchet/rfc6455/tests/ab/startServer.php
diff options
context:
space:
mode:
authormarvin-borner@live.com2018-04-16 21:09:05 +0200
committermarvin-borner@live.com2018-04-16 21:09:05 +0200
commitcf14306c2b3f82a81f8d56669a71633b4d4b5fce (patch)
tree86700651aa180026e89a66064b0364b1e4346f3f /assets/php/vendor/ratchet/rfc6455/tests/ab/startServer.php
parent619b01b3615458c4ed78bfaeabb6b1a47cc8ad8b (diff)
Main merge to user management system - files are now at /main/public/
Diffstat (limited to 'assets/php/vendor/ratchet/rfc6455/tests/ab/startServer.php')
-rwxr-xr-xassets/php/vendor/ratchet/rfc6455/tests/ab/startServer.php55
1 files changed, 0 insertions, 55 deletions
diff --git a/assets/php/vendor/ratchet/rfc6455/tests/ab/startServer.php b/assets/php/vendor/ratchet/rfc6455/tests/ab/startServer.php
deleted file mode 100755
index b256ec2..0000000
--- a/assets/php/vendor/ratchet/rfc6455/tests/ab/startServer.php
+++ /dev/null
@@ -1,55 +0,0 @@
-<?php
-use Ratchet\RFC6455\Messaging\MessageInterface;
-use Ratchet\RFC6455\Messaging\FrameInterface;
-use Ratchet\RFC6455\Messaging\Frame;
-
-require_once __DIR__ . "/../bootstrap.php";
-
-$loop = \React\EventLoop\Factory::create();
-
-$socket = new \React\Socket\Server($loop);
-$server = new \React\Http\Server($socket);
-
-$closeFrameChecker = new \Ratchet\RFC6455\Messaging\CloseFrameChecker;
-$negotiator = new \Ratchet\RFC6455\Handshake\ServerNegotiator(new \Ratchet\RFC6455\Handshake\RequestVerifier);
-
-$uException = new \UnderflowException;
-
-$server->on('request', function (\React\Http\Request $request, \React\Http\Response $response) use ($negotiator, $closeFrameChecker, $uException) {
- $psrRequest = new \GuzzleHttp\Psr7\Request($request->getMethod(), $request->getPath(), $request->getHeaders());
-
- $negotiatorResponse = $negotiator->handshake($psrRequest);
-
- $response->writeHead(
- $negotiatorResponse->getStatusCode(),
- array_merge(
- $negotiatorResponse->getHeaders(),
- ["Content-Length" => "0"]
- )
- );
-
- if ($negotiatorResponse->getStatusCode() !== 101) {
- $response->end();
- return;
- }
-
- $parser = new \Ratchet\RFC6455\Messaging\MessageBuffer($closeFrameChecker, function(MessageInterface $message) use ($response) {
- $response->write($message->getContents());
- }, function(FrameInterface $frame) use ($response, &$parser) {
- switch ($frame->getOpCode()) {
- case Frame::OP_CLOSE:
- $response->end($frame->getContents());
- break;
- case Frame::OP_PING:
- $response->write($parser->newFrame($frame->getPayload(), true, Frame::OP_PONG)->getContents());
- break;
- }
- }, true, function() use ($uException) {
- return $uException;
- });
-
- $request->on('data', [$parser, 'onData']);
-});
-
-$socket->listen(9001, '0.0.0.0');
-$loop->run();