| // Copyright (c) 2012, 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. |
| |
| import 'dart:async'; |
| import 'dart:convert'; |
| import 'dart:typed_data'; |
| |
| import 'package:http_parser/http_parser.dart'; |
| |
| import 'base_request.dart'; |
| import 'base_response.dart'; |
| import 'streamed_response.dart'; |
| import 'utils.dart'; |
| |
| /// An HTTP response where the entire response body is known in advance. |
| class Response extends BaseResponse { |
| /// The bytes comprising the body of this response. |
| final Uint8List bodyBytes; |
| |
| /// The body of the response as a string. This is converted from [bodyBytes] |
| /// using the `charset` parameter of the `Content-Type` header field, if |
| /// available. If it's unavailable or if the encoding name is unknown, |
| /// [latin1] is used by default, as per [RFC 2616][]. |
| /// |
| /// [RFC 2616]: http://www.w3.org/Protocols/rfc2616/rfc2616-sec3.html |
| String get body => _encodingForHeaders(headers).decode(bodyBytes); |
| |
| /// Creates a new HTTP response with a string body. |
| Response(String body, int statusCode, |
| {BaseRequest request, |
| Map<String, String> headers = const {}, |
| bool isRedirect = false, |
| bool persistentConnection = true, |
| String reasonPhrase}) |
| : this.bytes(_encodingForHeaders(headers).encode(body), statusCode, |
| request: request, |
| headers: headers, |
| isRedirect: isRedirect, |
| persistentConnection: persistentConnection, |
| reasonPhrase: reasonPhrase); |
| |
| /// Create a new HTTP response with a byte array body. |
| Response.bytes(List<int> bodyBytes, int statusCode, |
| {BaseRequest request, |
| Map<String, String> headers = const {}, |
| bool isRedirect = false, |
| bool persistentConnection = true, |
| String reasonPhrase}) |
| : bodyBytes = toUint8List(bodyBytes), |
| super(statusCode, |
| contentLength: bodyBytes.length, |
| request: request, |
| headers: headers, |
| isRedirect: isRedirect, |
| persistentConnection: persistentConnection, |
| reasonPhrase: reasonPhrase); |
| |
| /// Creates a new HTTP response by waiting for the full body to become |
| /// available from a [StreamedResponse]. |
| static Future<Response> fromStream(StreamedResponse response) { |
| return response.stream.toBytes().then((body) { |
| return Response.bytes(body, response.statusCode, |
| request: response.request, |
| headers: response.headers, |
| isRedirect: response.isRedirect, |
| persistentConnection: response.persistentConnection, |
| reasonPhrase: response.reasonPhrase); |
| }); |
| } |
| } |
| |
| /// Returns the encoding to use for a response with the given headers. This |
| /// defaults to [latin1] if the headers don't specify a charset or |
| /// if that charset is unknown. |
| Encoding _encodingForHeaders(Map<String, String> headers) => |
| encodingForCharset(_contentTypeForHeaders(headers).parameters['charset']); |
| |
| /// Returns the [MediaType] object for the given headers's content-type. |
| /// |
| /// Defaults to `application/octet-stream`. |
| MediaType _contentTypeForHeaders(Map<String, String> headers) { |
| var contentType = headers['content-type']; |
| if (contentType != null) return MediaType.parse(contentType); |
| return MediaType("application", "octet-stream"); |
| } |