mirror of
https://github.com/p1neappleXpress/OpenFlux.git
synced 2026-10-21 06:20:22 +08:00
p1neappleXpress
d3d67eff8b
The exit is a small PHP program on an ordinary web hosting, reached through cups.online or Mail.ru. See the PR for the list.
31 lines
1.6 KiB
PHP
31 lines
1.6 KiB
PHP
<?php
|
|
// WsClient against a server that splits, fragments and closes (see wsserver.php):
|
|
// php test/ws_test.php
|
|
require __DIR__ . '/../lib/ws.php';
|
|
$port = random_int(44000, 44999);
|
|
$p = proc_open([PHP_BINARY, __DIR__ . '/wsserver.php', (string)$port], [1 => ['pipe', 'w'], 2 => ['file', '/dev/null', 'w']], $pipes);
|
|
fgets($pipes[1]);
|
|
$ws = new WsClient();
|
|
$ok = true;
|
|
$check = function (string $name, bool $pass) use (&$ok) { printf("%-58s %s\n", $name, $pass ? 'OK' : 'FAIL'); $ok = $ok && $pass; };
|
|
$check('upgrade', $ws->connect("ws://127.0.0.1:$port/", 'http://x', ''));
|
|
|
|
$got = [];
|
|
$until = microtime(true) + 12;
|
|
while (microtime(true) < $until && !$ws->closed) {
|
|
do {
|
|
$m = $ws->readFrame(0.2); // 0.2 s: shorter than the server's pauses inside one frame
|
|
if ($m !== null && $m !== '') { $got[] = $m; }
|
|
} while ($ws->pending());
|
|
}
|
|
$check('two messages in one TCP chunk come out separately', ($got[0] ?? '') === 'first' && ($got[1] ?? '') === 'second');
|
|
$check('a 60 KB message delivered slowly arrives whole', ($got[2] ?? '') === str_repeat('0123456789abcdef', 3840));
|
|
$check('a fragmented message is reassembled (ping in between)', ($got[3] ?? '') === 'frag-ment-ed');
|
|
$check('a header split across writes is handled', ($got[4] ?? '') === 'split-header');
|
|
$check('nothing extra or corrupt came out', count($got) === 5);
|
|
$check('a close frame sets $closed and drops the socket', $ws->closed && $ws->sock === null);
|
|
$check('readFrame after close returns null (no spin)', $ws->readFrame(0.05) === null);
|
|
proc_terminate($p);
|
|
echo $ok ? "WS TEST PASS\n" : "WS TEST FAIL\n";
|
|
exit($ok ? 0 : 1);
|