aurorahttp / aurora / 6

pending completion

Build # 6

Build Type

push

travis-ci

Committed by

panlatent

Commit Message

<a href="https://github.com/aurorahttp/aurora/commit/<a class=hub.com/aurorahttp/aurora/commit/<a class="double-link" href="https://git"><a class=hub.com/aurorahttp/aurora/commit/<a class="double-link" href="https://git"><a class=hub.com/aurorahttp/aurora/commit/<a class="double-link" href="https://git"><a class=hub.com/aurorahttp/aurora/commit/ca330346f8bc173178283703065ae1fc9125eb4b">ca330346f">&lt;a href=&quot;https://github.com/aurorahttp/aurora/commit/</a><a class="double-link" href="https://github.com/aurorahttp/aurora/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/aurorahttp/aurora/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/aurorahttp/aurora/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/aurorahttp/aurora/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/aurorahttp/aurora/commit/ca330346f8bc173178283703065ae1fc9125eb4b">ca330346f</a><a href="https://github.com/aurorahttp/aurora/commit/ca330346f8bc173178283703065ae1fc9125eb4b">&quot;&gt;&amp;lt;a href=&amp;quot;https://github.com/aurorahttp/aurora/commit/&lt;/a&gt;&lt;a class=&quot;double-link&quot; href=&quot;https://github.com/aurorahttp/aurora/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/aurorahttp/aurora/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/aurorahttp/aurora/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/aurorahttp/aurora/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/aurorahttp/aurora/commit/ca330346f8bc173178283703065ae1fc9125eb4b&quot;&gt;ca330346f&lt;/a&gt;&lt;a href=&quot;https://github.com/aurorahttp/aurora/commit/ca330346f8bc173178283703065ae1fc9125eb4b&quot;&gt;&amp;quot;&amp;gt;&amp;amp;lt;a href=&amp;amp;quot;https://github.com/aurorahttp/aurora/commit/&amp;lt;/a&amp;gt;&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://github.com/aurorahttp/aurora/commit/&amp;amp;lt;a ... (continued)

Run Details

76 of 76 new or added lines in 1 file covered. (100.0%)

193 of 1760 relevant lines covered (10.97%)

0.62 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/src/Http/Session/Session.php

<?php

namespace Aurora\Http\Session;

use Aurora\Event\SafeClosureEvent;
use Aurora\Http\Connection\ClientConnection;
use Aurora\Http\Handler\ClosureHandler;
use Aurora;
use Ev;
use Aurora\Http\Client\LengthRequiredException;
use Aurora\Http\Codec\Decoder;
use Aurora\Http\Codec\Decoder\Stream;
use Aurora\Http\Codec\Encoder;
use Aurora\Http\Transaction\Transaction;
use EvIo;
use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface;

class Session
{
    const EVENT_TRANSACTION_BEFORE = 'connection.transaction::before';
    const EVENT_TRANSACTION_HANDLE_BEFORE = 'connection.transaction_handle::before';
    const EVENT_TRANSACTION_HANDLE_AFTER = 'connection.transaction_handle::after';

    /**
     * @var ClientConnection
     */
    protected $connection;
    /**
     * @var \EvTimer
     */
    protected $waitTimeoutEvent;
    /**
     * @var EvIo
     */
    protected $socketReadEvent;
    /**
     * @var EvIo
     */
    protected $socketWriteEvent;
    /**
     * @var Stream
     */
    protected $decodeStream;

    /**
     * Connection constructor.
     *
     * @param ClientConnection $connection
     */
    public function __construct(ClientConnection $connection)
    {
        $this->connection = $connection;
        stream_set_blocking($connection->getSocket(), 0);
        Aurora::debug("connection created from {$connection->getAddress()}:{$connection->getPort()}");

        $this->socketReadEvent = new EvIo($connection->getSocket(), Ev::READ, new SafeClosureEvent(function () {
            $this->onRead();
        }));

        $this->decodeStream = new Stream();
        $this->decodeStream->getContext()->setHeaderReady([$this, 'afterRequestHeader']);
        $this->decodeStream->getContext()->setBodyReady([$this, 'afterRequestBody']);
    }

    /**
     * Stop all watchers and close client socket.
     */
    public function close()
    {
        $this->socketReadEvent and $this->socketReadEvent->stop();
        $this->socketWriteEvent and $this->socketWriteEvent->stop();
        $this->waitTimeoutEvent and $this->waitTimeoutEvent->stop();
        $this->connection->close();
        Aurora::debug("connection close from {$this->connection->getAddress()}:{$this->connection->getPort()}");
    }

    /**
     * Read socket and write buffer.
     */
    public function onRead()
    {
        $part = $this->connection->read(1024);
        $length = 0;
        for (; $length != strlen($part);) {
            $length += $successLength = $this->decodeStream->write(substr($part, $length));
        }
    }

    /**
     * Event
     *
     * @throws LengthRequiredException
     */
    public function afterRequestHeader()
    {
        $codec = new Decoder();
        $codec->setAdapter(new GuzzleDecodeAdapter());
        $request = $codec->decode($this->decodeStream);

        $uri = $this->decodeStream->getUri();
        Aurora::access("{$request->getMethod()} {$uri} HTTP/{$request->getProtocolVersion()}");

        if ($request->getMethod() == 'CONNECT') {
            Aurora::debug('not supported client create tunnel');
            // $tunnel = new Tunnel($uri->getHost(), $uri->getPort());
            $this->socketReadEvent->stop();
            $this->close();

            return;
        } elseif ($request->getMethod() == 'POST') {
            if (! $request->hasHeader('Content-Length')) {
                throw new LengthRequiredException();
            }
            /*
             * If Content-Length is zero, can't read socket.
             */
            if ($request->getHeaderLine('Content-Length') == 0) {
                $this->transaction($request);
            }

            return;
        }
        $this->transaction($request);
    }

    /**
     * Event
     */
    public function afterRequestBody()
    {
        // empty
    }

    /**
     * Run a HTTP transaction.
     *
     * @param ServerRequestInterface $request
     */
    public function transaction(ServerRequestInterface $request)
    {
        Aurora::event(static::EVENT_TRANSACTION_BEFORE);
        $transaction = new Transaction($request);
        $transaction->getMiddlewares()->insert(new GuzzleBridgeMiddleware());
        $transaction->getFilters()->insert(new ResponseFixed());
        $transaction->setRequestHandler(new RequestHandler());
        $event = new TransactionEvent($transaction);
        Aurora::event(static::EVENT_TRANSACTION_HANDLE_BEFORE, $event);
        $response = $transaction->handle($request, ClosureHandler::create(function() {}));
        Aurora::event(static::EVENT_TRANSACTION_HANDLE_AFTER, $event);
        $this->sendResponse($response);
    }

    /**
     * Send a response to client socket.
     *
     * @param ResponseInterface $response
     */
    public function sendResponse(ResponseInterface $response)
    {
        $this->socketReadEvent->stop();
        $encoder = new Encoder();
        $stream = $encoder->encode($response);
        $buffer = $stream->getContents();
        $this->socketWriteEvent = new EvIo($this->connection->getSocket(), Ev::WRITE, function () use (&$buffer) {
            echo $length = $this->connection->write($buffer, strlen($buffer));
            Aurora::debug('write => size ' . $length . " bytes");
            if ($length === false) {
                Aurora::error('socket error');

                return;
            }
            $buffer = substr($buffer, $length);
            if (empty($buffer)) {
                $this->close();
            }
        });
    }
}

1	<?php
2
3	namespace Aurora\Http\Session;
4
5	use Aurora\Event\SafeClosureEvent;
6	use Aurora\Http\Connection\ClientConnection;
7	use Aurora\Http\Handler\ClosureHandler;
8	use Aurora;
9	use Ev;
10	use Aurora\Http\Client\LengthRequiredException;
11	use Aurora\Http\Codec\Decoder;
12	use Aurora\Http\Codec\Decoder\Stream;
13	use Aurora\Http\Codec\Encoder;
14	use Aurora\Http\Transaction\Transaction;
15	use EvIo;
16	use Psr\Http\Message\ResponseInterface;
17	use Psr\Http\Message\ServerRequestInterface;
18
19	class Session
20	{
21	const EVENT_TRANSACTION_BEFORE = 'connection.transaction::before';
22	const EVENT_TRANSACTION_HANDLE_BEFORE = 'connection.transaction_handle::before';
23	const EVENT_TRANSACTION_HANDLE_AFTER = 'connection.transaction_handle::after';
24
25	/**
26	* @var ClientConnection
27	*/
28	protected $connection;
29	/**
30	* @var \EvTimer
31	*/
32	protected $waitTimeoutEvent;
33	/**
34	* @var EvIo
35	*/
36	protected $socketReadEvent;
37	/**
38	* @var EvIo
39	*/
40	protected $socketWriteEvent;
41	/**
42	* @var Stream
43	*/
44	protected $decodeStream;
45
46	/**
47	* Connection constructor.
48	*
49	* @param ClientConnection $connection
50	*/
51	public function __construct(ClientConnection $connection)
52	{	×
53	$this->connection = $connection;	×
54	stream_set_blocking($connection->getSocket(), 0);	×
55	Aurora::debug("connection created from {$connection->getAddress()}:{$connection->getPort()}");	×
56
57	$this->socketReadEvent = new EvIo($connection->getSocket(), Ev::READ, new SafeClosureEvent(function () {
58	$this->onRead();	×
59	}));	×
60
61	$this->decodeStream = new Stream();	×
62	$this->decodeStream->getContext()->setHeaderReady([$this, 'afterRequestHeader']);	×
63	$this->decodeStream->getContext()->setBodyReady([$this, 'afterRequestBody']);	×
64	}	×
65
66	/**
67	* Stop all watchers and close client socket.
68	*/
69	public function close()
70	{	×
71	$this->socketReadEvent and $this->socketReadEvent->stop();	×
72	$this->socketWriteEvent and $this->socketWriteEvent->stop();	×
73	$this->waitTimeoutEvent and $this->waitTimeoutEvent->stop();	×
74	$this->connection->close();	×
75	Aurora::debug("connection close from {$this->connection->getAddress()}:{$this->connection->getPort()}");	×
76	}	×
77
78	/**
79	* Read socket and write buffer.
80	*/
81	public function onRead()
82	{	×
83	$part = $this->connection->read(1024);	×
84	$length = 0;	×
85	for (; $length != strlen($part);) {	×
86	$length += $successLength = $this->decodeStream->write(substr($part, $length));	×
87	}	×
88	}	×
89
90	/**
91	* Event
92	*
93	* @throws LengthRequiredException
94	*/
95	public function afterRequestHeader()
96	{	×
97	$codec = new Decoder();	×
98	$codec->setAdapter(new GuzzleDecodeAdapter());	×
99	$request = $codec->decode($this->decodeStream);	×
100
101	$uri = $this->decodeStream->getUri();	×
102	Aurora::access("{$request->getMethod()} {$uri} HTTP/{$request->getProtocolVersion()}");	×
103
104	if ($request->getMethod() == 'CONNECT') {	×
105	Aurora::debug('not supported client create tunnel');	×
106	// $tunnel = new Tunnel($uri->getHost(), $uri->getPort());
107	$this->socketReadEvent->stop();	×
108	$this->close();	×
109
110	return;	×
111	} elseif ($request->getMethod() == 'POST') {	×
112	if (! $request->hasHeader('Content-Length')) {	×
113	throw new LengthRequiredException();	×
114	}	×
115	/*
116	* If Content-Length is zero, can't read socket.
117	*/
118	if ($request->getHeaderLine('Content-Length') == 0) {	×
119	$this->transaction($request);	×
120	}	×
121
122	return;	×
123	}	×
124	$this->transaction($request);	×
125	}	×
126
127	/**
128	* Event
129	*/
130	public function afterRequestBody()
131	{	×
132	// empty
133	}	×
134
135	/**
136	* Run a HTTP transaction.
137	*
138	* @param ServerRequestInterface $request
139	*/
140	public function transaction(ServerRequestInterface $request)
141	{	×
142	Aurora::event(static::EVENT_TRANSACTION_BEFORE);	×
143	$transaction = new Transaction($request);	×
144	$transaction->getMiddlewares()->insert(new GuzzleBridgeMiddleware());	×
145	$transaction->getFilters()->insert(new ResponseFixed());	×
146	$transaction->setRequestHandler(new RequestHandler());	×
147	$event = new TransactionEvent($transaction);	×
148	Aurora::event(static::EVENT_TRANSACTION_HANDLE_BEFORE, $event);	×
149	$response = $transaction->handle($request, ClosureHandler::create(function() {}));
150	Aurora::event(static::EVENT_TRANSACTION_HANDLE_AFTER, $event);	×
151	$this->sendResponse($response);	×
152	}	×
153
154	/**
155	* Send a response to client socket.
156	*
157	* @param ResponseInterface $response
158	*/
159	public function sendResponse(ResponseInterface $response)
160	{	×
161	$this->socketReadEvent->stop();	×
162	$encoder = new Encoder();	×
163	$stream = $encoder->encode($response);	×
164	$buffer = $stream->getContents();	×
165	$this->socketWriteEvent = new EvIo($this->connection->getSocket(), Ev::WRITE, function () use (&$buffer) {
166	echo $length = $this->connection->write($buffer, strlen($buffer));	×
167	Aurora::debug('write => size ' . $length . " bytes");	×
168	if ($length === false) {	×
169	Aurora::error('socket error');	×
170
171	return;	×
172	}	×
173	$buffer = substr($buffer, $length);	×
174	if (empty($buffer)) {	×
175	$this->close();	×
176	}	×
177	});	×
178	}	×
179	}

aurorahttp / aurora / 6

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous