blob: 58fbd74f4d20747459c2a28b900429c0086cd871 [file] [log] [blame]
// Copyright (c) 2014, the Dart project authors. Please see the AUTHORS file
// for details. All rights reserved. Use of this source code is governed by a
// BSD-style license that can be found in the LICENSE file.
/// A Shelf adapter for handling [HttpRequest] objects from `dart:io`.
/// One can provide an instance of [HttpServer] as the `requests` parameter in
/// [serveRequests].
/// This adapter supports request hijacking; see [Request.hijack]. It also
/// supports the `""` `Response.context` property. If this
/// property is `true` (the default), streamed responses will be buffered to
/// improve performance; if it's `false`, all chunks will be pushed over the
/// wire as they're received. See [`HttpResponse.bufferOutput`][bufferOutput]
/// for more information.
/// [bufferOutput]:
import 'dart:async';
import 'dart:io';
import 'package:stack_trace/stack_trace.dart';
import 'shelf.dart';
import 'src/util.dart';
export 'src/io_server.dart';
/// Starts an [HttpServer] that listens on the specified [address] and
/// [port] and sends requests to [handler].
/// See the documentation for [HttpServer.bind] for more details on [address],
/// [port], and [backlog].
Future<HttpServer> serve(Handler handler, address, int port, {int backlog}) {
if (backlog == null) backlog = 0;
return HttpServer.bind(address, port, backlog: backlog).then((server) {
serveRequests(server, handler);
return server;
/// Serve a [Stream] of [HttpRequest]s.
/// [HttpServer] implements [Stream<HttpRequest>] so it can be passed directly
/// to [serveRequests].
/// Errors thrown by [handler] while serving a request will be printed to the
/// console and cause a 500 response with no body. Errors thrown asynchronously
/// by [handler] will be printed to the console or, if there's an active error
/// zone, passed to that zone.
void serveRequests(Stream<HttpRequest> requests, Handler handler) {
catchTopLevelErrors(() {
requests.listen((request) => handleRequest(request, handler));
}, (error, stackTrace) {
_logTopLevelError('Asynchronous error\n$error', stackTrace);
/// Uses [handler] to handle [request].
/// Returns a [Future] which completes when the request has been handled.
Future handleRequest(HttpRequest request, Handler handler) async {
var shelfRequest;
try {
shelfRequest = _fromHttpRequest(request);
} catch (error, stackTrace) {
var response = _logTopLevelError(
'Error parsing request.\n$error', stackTrace);
await _writeResponse(response, request.response);
// TODO(nweiz): abstract out hijack handling to make it easier to implement an
// adapter.
var response;
try {
response = await handler(shelfRequest);
} on HijackException catch (error, stackTrace) {
// A HijackException should bypass the response-writing logic entirely.
if (!shelfRequest.canHijack) return;
// If the request wasn't hijacked, we shouldn't be seeing this exception.
response = _logError(
"Caught HijackException, but the request wasn't hijacked.",
} catch (error, stackTrace) {
response = _logError(
shelfRequest, 'Error thrown by handler.\n$error', stackTrace);
if (response == null) {
await _writeResponse(
_logError(shelfRequest, 'null response from handler.'),
} else if (shelfRequest.canHijack) {
await _writeResponse(response, request.response);
var message = new StringBuffer()
..writeln("Got a response for hijacked request "
"${shelfRequest.method} ${shelfRequest.requestedUri}:")
.forEach((key, value) => message.writeln("${key}: ${value}"));
throw new Exception(message.toString().trim());
/// Creates a new [Request] from the provided [HttpRequest].
Request _fromHttpRequest(HttpRequest request) {
var headers = <String, String>{};
request.headers.forEach((k, v) {
// Multiple header values are joined with commas.
// See
headers[k] = v.join(',');
void onHijack(callback) {
.detachSocket(writeHeaders: false)
.then((socket) => callback(socket, socket));
return new Request(request.method, request.requestedUri,
protocolVersion: request.protocolVersion,
headers: headers,
body: request,
onHijack: onHijack);
Future _writeResponse(Response response, HttpResponse httpResponse) {
if (response.context.containsKey("")) {
httpResponse.bufferOutput = response.context[""];
httpResponse.statusCode = response.statusCode;
response.headers.forEach((header, value) {
if (value == null) return;
httpResponse.headers.set(header, value);
if (!response.headers.containsKey(HttpHeaders.SERVER)) {
httpResponse.headers.set(HttpHeaders.SERVER, 'dart:io with Shelf');
if (!response.headers.containsKey(HttpHeaders.DATE)) { = new;
return httpResponse
.then((_) => httpResponse.close());
// TODO(kevmoo) A developer mode is needed to include error info in response
// TODO(kevmoo) Make error output plugable. stderr, logging, etc
Response _logError(Request request, String message, [StackTrace stackTrace]) {
// Add information about the request itself.
var buffer = new StringBuffer();
buffer.write("${request.method} ${request.requestedUri.path}");
if (request.requestedUri.query.isNotEmpty) {
return _logTopLevelError(buffer.toString(), stackTrace);
Response _logTopLevelError(String message, [StackTrace stackTrace]) {
var chain = new Chain.current();
if (stackTrace != null) {
chain = new Chain.forTrace(stackTrace);
chain = chain
.foldFrames((frame) => frame.isCore || frame.package == 'shelf').terse;
stderr.writeln('ERROR - ${new}');
return new Response.internalServerError();