Viewing file:  RoadRunnerClient.php (3.16 KB) -rw-r--r--
Select action/file-type:
 (+) |  (+) |  (+) | Code (+) | Session (+) |  (+) | SDB (+) |  (+) |  (+) |  (+) |  (+) |  (+) |
<?php
namespace Laravel\Octane\RoadRunner;
use Generator;
use Illuminate\Foundation\Application;
use Illuminate\Http\Request;
use Laravel\Octane\Contracts\Client;
use Laravel\Octane\Contracts\StoppableClient;
use Laravel\Octane\MarshalsPsr7RequestsAndResponses;
use Laravel\Octane\Octane;
use Laravel\Octane\OctaneResponse;
use Laravel\Octane\RequestContext;
use ReflectionFunction;
use Spiral\RoadRunner\Http\PSR7Worker;
use Symfony\Component\HttpFoundation\BinaryFileResponse;
use Symfony\Component\HttpFoundation\StreamedResponse;
use Throwable;
class RoadRunnerClient implements Client, StoppableClient
{
use MarshalsPsr7RequestsAndResponses;
public function __construct(protected PSR7Worker $client)
{
}
/**
* Marshal the given request context into an Illuminate request.
*/
public function marshalRequest(RequestContext $context): array
{
return [
$this->toHttpFoundationRequest($context->psr7Request),
$context,
];
}
/**
* Send the response to the server.
*/
public function respond(RequestContext $context, OctaneResponse $octaneResponse): void
{
if ($octaneResponse->outputBuffer &&
! $octaneResponse->response instanceof StreamedResponse &&
! $octaneResponse->response instanceof BinaryFileResponse) {
$octaneResponse->response->setContent(
$octaneResponse->outputBuffer.$octaneResponse->response->getContent()
);
}
if (($octaneResponse->response instanceof StreamedResponse) &&
! is_null($responseCallback = static::resolveStreamResponseCallback($octaneResponse->response))) {
$this->client->getHttpWorker()->respond(
$octaneResponse->response->getStatusCode(),
$responseCallback(),
$this->toPsr7Response($octaneResponse->response)->getHeaders(),
);
return;
}
$this->client->respond($this->toPsr7Response($octaneResponse->response));
}
/**
* Resolve the stream response callback from the given response.
*
* @param \Symfony\Component\HttpFoundation\StreamedResponse $response
* @return \Closure|null
*/
public static function resolveStreamResponseCallback(StreamedResponse $response)
{
if (is_null($responseCallback = $response->getCallback())) {
return null;
}
$reflection = new ReflectionFunction($responseCallback);
if ($reflection->hasReturnType() === true &&
in_array($reflection->getReturnType()?->getName(), [Generator::class, 'string'])) {
return $responseCallback;
}
return null;
}
/**
* Send an error message to the server.
*/
public function error(Throwable $e, Application $app, Request $request, RequestContext $context): void
{
$this->client->getWorker()->error(Octane::formatExceptionForClient(
$e,
$app->make('config')->get('app.debug')
));
}
/**
* Stop the underlying server / worker.
*/
public function stop(): void
{
$this->client->getWorker()->stop();
}
}
|