| 199 |
lars |
1 |
<?php namespace Clockwork\DataSource;
|
|
|
2 |
|
|
|
3 |
use Clockwork\DataSource\DataSource;
|
|
|
4 |
use Clockwork\Helpers\Serializer;
|
|
|
5 |
use Clockwork\Request\Request;
|
|
|
6 |
|
|
|
7 |
use Psr\Http\Message\ServerRequestInterface as PsrRequest;
|
|
|
8 |
use Psr\Http\Message\ResponseInterface as PsrResponse;
|
|
|
9 |
|
|
|
10 |
// Data source providing data obtainable from the PSR-7 request and response interfaces
|
|
|
11 |
class PsrMessageDataSource extends DataSource
|
|
|
12 |
{
|
|
|
13 |
// PSR Messages
|
|
|
14 |
protected $psrRequest;
|
|
|
15 |
protected $psrResponse;
|
|
|
16 |
|
|
|
17 |
// Create a new data source, takes PSR-7 request and response as arguments
|
|
|
18 |
public function __construct(PsrRequest $psrRequest = null, PsrResponse $psrResponse = null)
|
|
|
19 |
{
|
|
|
20 |
$this->psrRequest = $psrRequest;
|
|
|
21 |
$this->psrResponse = $psrResponse;
|
|
|
22 |
}
|
|
|
23 |
|
|
|
24 |
// Adds request and response information to the request
|
|
|
25 |
public function resolve(Request $request)
|
|
|
26 |
{
|
|
|
27 |
if ($this->psrRequest) {
|
|
|
28 |
$request->method = $this->psrRequest->getMethod();
|
|
|
29 |
$request->uri = $this->getRequestUri();
|
|
|
30 |
$request->headers = $this->getRequestHeaders();
|
|
|
31 |
$request->getData = $this->sanitize($this->psrRequest->getQueryParams());
|
|
|
32 |
$request->postData = $this->sanitize($this->psrRequest->getParsedBody());
|
|
|
33 |
$request->cookies = $this->sanitize($this->psrRequest->getCookieParams());
|
|
|
34 |
$request->time = $this->getRequestTime();
|
|
|
35 |
}
|
|
|
36 |
|
|
|
37 |
if ($this->psrResponse !== null) {
|
|
|
38 |
$request->responseStatus = $this->psrResponse->getStatusCode();
|
|
|
39 |
$request->responseTime = $this->getResponseTime();
|
|
|
40 |
}
|
|
|
41 |
|
|
|
42 |
return $request;
|
|
|
43 |
}
|
|
|
44 |
|
|
|
45 |
// Normalize items in the array and remove passwords
|
|
|
46 |
protected function sanitize($data)
|
|
|
47 |
{
|
|
|
48 |
return is_array($data) ? $this->removePasswords((new Serializer)->normalizeEach($data)) : $data;
|
|
|
49 |
}
|
|
|
50 |
|
|
|
51 |
// Get the response time, fetching it from ServerParams
|
|
|
52 |
protected function getRequestTime()
|
|
|
53 |
{
|
|
|
54 |
$env = $this->psrRequest->getServerParams();
|
|
|
55 |
|
|
|
56 |
if (isset($env['REQUEST_TIME_FLOAT'])) {
|
|
|
57 |
return $env['REQUEST_TIME_FLOAT'];
|
|
|
58 |
}
|
|
|
59 |
}
|
|
|
60 |
|
|
|
61 |
// Get the response time (current time, assuming most of the application code has already run at this point)
|
|
|
62 |
protected function getResponseTime()
|
|
|
63 |
{
|
|
|
64 |
return microtime(true);
|
|
|
65 |
}
|
|
|
66 |
|
|
|
67 |
// Get the request headers
|
|
|
68 |
protected function getRequestHeaders()
|
|
|
69 |
{
|
|
|
70 |
$headers = [];
|
|
|
71 |
|
|
|
72 |
foreach ($this->psrRequest->getHeaders() as $header => $values) {
|
|
|
73 |
if (strtoupper(substr($header, 0, 5)) === 'HTTP_') {
|
|
|
74 |
$header = substr($header, 5);
|
|
|
75 |
}
|
|
|
76 |
|
|
|
77 |
$header = str_replace('_', ' ', $header);
|
|
|
78 |
$header = ucwords(strtolower($header));
|
|
|
79 |
$header = str_replace(' ', '-', $header);
|
|
|
80 |
|
|
|
81 |
$headers[$header] = $values;
|
|
|
82 |
}
|
|
|
83 |
|
|
|
84 |
ksort($headers);
|
|
|
85 |
|
|
|
86 |
return $headers;
|
|
|
87 |
}
|
|
|
88 |
|
|
|
89 |
// Get the request URI
|
|
|
90 |
protected function getRequestUri()
|
|
|
91 |
{
|
|
|
92 |
$uri = $this->psrRequest->getUri();
|
|
|
93 |
|
|
|
94 |
return $uri->getPath() . ($uri->getQuery() ? '?' . $uri->getQuery() : '');
|
|
|
95 |
}
|
|
|
96 |
}
|