convertRequest function

Future<Request> convertRequest(RequestContext req, ResponseContext res, { String? handlerPath, Map<String, Object>? context, })

Creates a shelf.Request analogous to the input req.

The request's context will contain req.container as angel3_shelf.container, as well as the provided context, if any.

The context will also have the original request available as angel3_shelf.request.

If you want to read the request body, you must set keepRawRequestBuffers to true on your application instance.

Implementation

Future<shelf.Request> convertRequest(RequestContext req, ResponseContext res,
    {String? handlerPath, Map<String, Object>? context}) async {
  var app = req.app;
  var headers = <String, String>{};
  req.headers!.forEach((k, v) {
    headers[k] = v.join(',');
  });

  headers.remove(HttpHeaders.transferEncodingHeader);

  void Function(void Function(StreamChannel<List<int>>)) onHijack;
  String protocolVersion;
  Uri requestedUri;

  protocolVersion = '1.1';
  requestedUri = Uri.parse('http://${req.hostname}');
  requestedUri = requestedUri.replace(path: req.uri!.path);

  onHijack = (void Function(StreamChannel<List<int>> channel) hijack) async {
    try {
      print('a');
      await res.detach();
      print('b');
      var ctrl = StreamChannelController<List<int>>();
      if (req.hasParsedBody) {
        req.body!.listen(ctrl.local.sink.add,
            onError: ctrl.local.sink.addError, onDone: ctrl.local.sink.close);
      } else {
        await ctrl.local.sink.close();
      }
      scheduleMicrotask(() => ctrl.local.stream.pipe(res));
      hijack(ctrl.foreign);
    } catch (e, st) {
      app?.logger
          .severe('An error occurred while hijacking a shelf request', e, st);
    }
  };

  var url = req.uri!;

  if (p.isAbsolute(url.path)) {
    url = url.replace(path: url.path.substring(1));
  }

  return shelf.Request(req.method, requestedUri,
      protocolVersion: protocolVersion,
      headers: headers,
      handlerPath: handlerPath,
      url: url,
      body: req.body,
      context: {'angel3_shelf.request': req}
        ..addAll({'angel3_shelf.container': req.container!})
        ..addAll(context ?? {}),
      onHijack: onHijack);
}