| OLD | NEW |
| 1 // Copyright (c) 2014, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2014, the Dart project authors. Please see the AUTHORS file |
| 2 // for details. All rights reserved. Use of this source code is governed by a | 2 // for details. All rights reserved. Use of this source code is governed by a |
| 3 // BSD-style license that can be found in the LICENSE file. | 3 // BSD-style license that can be found in the LICENSE file. |
| 4 | 4 |
| 5 library shelf.message_test; | 5 library shelf.message_test; |
| 6 | 6 |
| 7 import 'dart:async'; | 7 import 'dart:async'; |
| 8 import 'dart:convert'; | 8 import 'dart:convert'; |
| 9 | 9 |
| 10 import 'package:shelf/src/message.dart'; | 10 import 'package:shelf/src/message.dart'; |
| 11 import 'package:unittest/unittest.dart'; | 11 import 'package:unittest/unittest.dart'; |
| 12 | 12 |
| 13 import 'test_util.dart'; |
| 14 |
| 13 class _TestMessage extends Message { | 15 class _TestMessage extends Message { |
| 14 _TestMessage(Map<String, String> headers, Map<String, Object> context, | 16 _TestMessage(Map<String, String> headers, Map<String, Object> context, |
| 15 Stream<List<int>> body) | 17 Stream<List<int>> body) |
| 16 : super(body, headers: headers, context: context); | 18 : super(body, headers: headers, context: context); |
| 19 |
| 20 Message change({Map<String, String> headers, Map<String, Object> context}) { |
| 21 throw new UnimplementedError(); |
| 22 } |
| 17 } | 23 } |
| 18 | 24 |
| 19 Message _createMessage({Map<String, String> headers, | 25 Message _createMessage({Map<String, String> headers, |
| 20 Map<String, Object> context, Stream<List<int>> body}) { | 26 Map<String, Object> context, Stream<List<int>> body}) { |
| 21 if (body == null) body = new Stream.fromIterable([]); | 27 if (body == null) body = new Stream.fromIterable([]); |
| 22 return new _TestMessage(headers, context, body); | 28 return new _TestMessage(headers, context, body); |
| 23 } | 29 } |
| 24 | 30 |
| 25 void main() { | 31 void main() { |
| 26 group('headers', () { | 32 group('headers', () { |
| (...skipping 42 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 69 test("supports a null body", () { | 75 test("supports a null body", () { |
| 70 var request = _createMessage(); | 76 var request = _createMessage(); |
| 71 expect(request.readAsString(), completion(equals(""))); | 77 expect(request.readAsString(), completion(equals(""))); |
| 72 }); | 78 }); |
| 73 | 79 |
| 74 test("supports a Stream<List<int>> body", () { | 80 test("supports a Stream<List<int>> body", () { |
| 75 var controller = new StreamController(); | 81 var controller = new StreamController(); |
| 76 var request = _createMessage(body: controller.stream); | 82 var request = _createMessage(body: controller.stream); |
| 77 expect(request.readAsString(), completion(equals("hello, world"))); | 83 expect(request.readAsString(), completion(equals("hello, world"))); |
| 78 | 84 |
| 79 controller.add([104, 101, 108, 108, 111, 44]); | 85 controller.add(HELLO_BYTES); |
| 80 return new Future(() { | 86 return new Future(() { |
| 81 controller | 87 controller |
| 82 ..add([32, 119, 111, 114, 108, 100]) | 88 ..add(WORLD_BYTES) |
| 83 ..close(); | 89 ..close(); |
| 84 }); | 90 }); |
| 85 }); | 91 }); |
| 86 | 92 |
| 87 test("defaults to UTF-8", () { | 93 test("defaults to UTF-8", () { |
| 88 var request = _createMessage(body: new Stream.fromIterable([[195, 168]])); | 94 var request = _createMessage(body: new Stream.fromIterable([[195, 168]])); |
| 89 expect(request.readAsString(), completion(equals("è"))); | 95 expect(request.readAsString(), completion(equals("è"))); |
| 90 }); | 96 }); |
| 91 | 97 |
| 92 test("the content-type header overrides the default", () { | 98 test("the content-type header overrides the default", () { |
| (...skipping 14 matching lines...) Expand all Loading... |
| 107 group("read", () { | 113 group("read", () { |
| 108 test("supports a null body", () { | 114 test("supports a null body", () { |
| 109 var request = _createMessage(); | 115 var request = _createMessage(); |
| 110 expect(request.read().toList(), completion(isEmpty)); | 116 expect(request.read().toList(), completion(isEmpty)); |
| 111 }); | 117 }); |
| 112 | 118 |
| 113 test("supports a Stream<List<int>> body", () { | 119 test("supports a Stream<List<int>> body", () { |
| 114 var controller = new StreamController(); | 120 var controller = new StreamController(); |
| 115 var request = _createMessage(body: controller.stream); | 121 var request = _createMessage(body: controller.stream); |
| 116 expect(request.read().toList(), completion(equals([ | 122 expect(request.read().toList(), completion(equals([ |
| 117 [104, 101, 108, 108, 111, 44], | 123 HELLO_BYTES, |
| 118 [32, 119, 111, 114, 108, 100] | 124 WORLD_BYTES |
| 119 ]))); | 125 ]))); |
| 120 | 126 |
| 121 controller.add([104, 101, 108, 108, 111, 44]); | 127 controller.add(HELLO_BYTES); |
| 122 return new Future(() { | 128 return new Future(() { |
| 123 controller | 129 controller |
| 124 ..add([32, 119, 111, 114, 108, 100]) | 130 ..add(WORLD_BYTES) |
| 125 ..close(); | 131 ..close(); |
| 126 }); | 132 }); |
| 127 }); | 133 }); |
| 128 }); | 134 }); |
| 129 | 135 |
| 130 group("contentLength", () { | 136 group("contentLength", () { |
| 131 test("is null without a content-length header", () { | 137 test("is null without a content-length header", () { |
| 132 var request = _createMessage(); | 138 var request = _createMessage(); |
| 133 expect(request.contentLength, isNull); | 139 expect(request.contentLength, isNull); |
| 134 }); | 140 }); |
| (...skipping 41 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 176 }).encoding, isNull); | 182 }).encoding, isNull); |
| 177 }); | 183 }); |
| 178 | 184 |
| 179 test("comes from the content-type charset parameter", () { | 185 test("comes from the content-type charset parameter", () { |
| 180 expect(_createMessage(headers: { | 186 expect(_createMessage(headers: { |
| 181 'content-type': 'text/plain; charset=iso-8859-1' | 187 'content-type': 'text/plain; charset=iso-8859-1' |
| 182 }).encoding, equals(LATIN1)); | 188 }).encoding, equals(LATIN1)); |
| 183 }); | 189 }); |
| 184 }); | 190 }); |
| 185 } | 191 } |
| OLD | NEW |