-
-
Notifications
You must be signed in to change notification settings - Fork 146
/
Server.php
63 lines (50 loc) · 1.99 KB
/
Server.php
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
<?php
namespace React\Http;
use Evenement\EventEmitter;
use React\Socket\ServerInterface as SocketServerInterface;
use React\Socket\ConnectionInterface;
/** @event request */
class Server extends EventEmitter implements ServerInterface
{
private $io;
public function __construct(SocketServerInterface $io)
{
$this->io = $io;
$this->io->on('connection', function (ConnectionInterface $conn) {
// TODO: http 1.1 keep-alive
// TODO: chunked transfer encoding (also for outgoing data)
// TODO: multipart parsing
$parser = new RequestHeaderParser();
$parser->on('headers', function (Request $request, $bodyBuffer) use ($conn, $parser) {
// attach remote ip to the request as metadata
$request->remoteAddress = $conn->getRemoteAddress();
$this->handleRequest($conn, $request, $bodyBuffer);
$conn->removeListener('data', array($parser, 'feed'));
$conn->on('end', function () use ($request) {
$request->emit('end');
});
$conn->on('data', function ($data) use ($request) {
$request->emit('data', array($data));
});
$request->on('pause', function () use ($conn) {
$conn->emit('pause');
});
$request->on('resume', function () use ($conn) {
$conn->emit('resume');
});
});
$conn->on('data', array($parser, 'feed'));
});
}
public function handleRequest(ConnectionInterface $conn, Request $request, $bodyBuffer)
{
$response = new Response($conn);
$response->on('close', array($request, 'close'));
if (!$this->listeners('request')) {
$response->end();
return;
}
$this->emit('request', array($request, $response));
$request->emit('data', array($bodyBuffer));
}
}