Local Aerys Redirect

local_redir.php

<?php

$dispatcher = new class implements \Aerys\Middleware {
    public function __invoke(\Aerys\Request $req, \Aerys\Response $res) {
        /* dispatch */
        if (/* $local_request === */ true) {
            $started = false;
            $oldireq = $req->getLocalVar("cgihandler.ireq");
            $ireq = clone $oldireq;
            $ireq->locals = [];
            /* manipulate URI here */
            $ireq->uri = "{$ireq->protocol}://{$ireq->uriHost}:{$ireq->uriPort}/filterstream";
            $ireq->uriPath = "/filterstream";
            $ireq->uriQuery = "";
            try {
                $filters = $ireq->client->httpDriver->filters($ireq);
                $filters = array_merge([function() use (&$started) {
                    $headers = yield;
                    $started = true;
                    return $headers;
                }], $filters);
                $filter = \Aerys\responseFilter($filters, $ireq);
                $filter->current(); // initialize filters
                $codec = \Aerys\responseCodec($filter, $ireq);
                $ireq->response = new \Aerys\StandardResponse($codec);

                $gen = $ireq->vhost->getApplication()(new \Aerys\StandardRequest($ireq), $ireq->response);
                if ($gen instanceof \Generator) {
                    yield from $gen;
                }
                // prevent any writes for this response...
                $oldireq->responseWriter = (function() { while (1) yield; })();
            } catch (\Throwable $e) {
                if ($started) {
                    // force append
                    $res->stream("");
                }
                throw $e;
            }
        }
    }

    public function do(\Aerys\InternalRequest $ireq) {
        $ireq->locals["cgihandler.ireq"] = $ireq;
    }
};