Chromium Code Reviews| OLD | NEW |
|---|---|
| 1 // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS d.file | 1 // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS d.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 pub_tests; | 5 library pub_tests; |
| 6 | 6 |
| 7 import 'dart:async'; | 7 import 'dart:async'; |
| 8 import 'dart:io'; | 8 import 'dart:io'; |
| 9 | 9 |
| 10 import 'package:http/http.dart' as http; | 10 import 'package:http/http.dart' as http; |
| 11 import 'package:scheduled_test/scheduled_process.dart'; | 11 import 'package:scheduled_test/scheduled_process.dart'; |
| 12 import 'package:scheduled_test/scheduled_test.dart'; | 12 import 'package:scheduled_test/scheduled_test.dart'; |
| 13 | 13 |
| 14 import '../descriptor.dart' as d; | 14 import '../descriptor.dart' as d; |
| 15 import '../test_pub.dart'; | 15 import '../test_pub.dart'; |
| 16 | 16 |
| 17 /// The pub process running "pub serve". | 17 /// The pub process running "pub serve". |
| 18 ScheduledProcess _pubServer; | 18 ScheduledProcess _pubServer; |
| 19 | 19 |
| 20 /// The ephemeral port assigned to the running server. | 20 /// The ephemeral port assigned to the running server. |
| 21 int _port; | 21 int _port; |
| 22 | 22 |
| 23 /// Schedules starting the "pub serve" process. | 23 /// Schedules starting the "pub serve" process. |
| 24 void startPubServe() { | 24 /// |
| 25 /// If [shouldInstallFirst] is `true`, then validates that pub install is run | |
|
nweiz
2013/07/30 19:34:36
Nit: remove "then"
Bob Nystrom
2013/07/30 21:35:32
Done.
| |
| 26 /// first. | |
| 27 void startPubServe({bool shouldInstallFirst: false}) { | |
| 25 // Use port 0 to get an ephemeral port. | 28 // Use port 0 to get an ephemeral port. |
| 26 _pubServer = startPub(args: ["serve", "--port=0"]); | 29 _pubServer = startPub(args: ["serve", "--port=0"]); |
| 27 | 30 |
| 28 expect(_pubServer.nextLine().then((line) { | 31 if (shouldInstallFirst) { |
| 29 var match = new RegExp(r"localhost:(\d+)").firstMatch(line); | 32 schedule(() { |
| 30 assert(match != null); | 33 return _pubServer.nextLine().then((line1) { |
| 31 _port = int.parse(match[1]); | 34 expect(line1, startsWith("Dependencies have changed")); |
| 32 }), completes); | 35 return _pubServer.nextLine(); |
| 36 }).then((line2) { | |
| 37 expect(line2, startsWith("Resolving dependencies...")); | |
| 38 return _pubServer.nextLine(); | |
| 39 }).then((line3) { | |
| 40 expect(line3, equals("Dependencies installed!")); | |
| 41 return _pubServer.nextLine(); | |
| 42 }).then((line4) { | |
| 43 _parsePort(line4); | |
| 44 }); | |
| 45 }); | |
|
nweiz
2013/07/30 19:34:36
Since [nextLine] is scheduled internally, you can
Bob Nystrom
2013/07/30 21:35:32
Done.
| |
| 46 | |
| 47 return; | |
| 48 } | |
| 49 | |
| 50 expect(_pubServer.nextLine().then(_parsePort), completes); | |
| 51 } | |
| 52 | |
| 53 /// Parses the port number from the "Serving blah on localhost:1234" line | |
| 54 /// printed by pub serve. | |
| 55 void _parsePort(String line) { | |
| 56 var match = new RegExp(r"localhost:(\d+)").firstMatch(line); | |
| 57 assert(match != null); | |
| 58 _port = int.parse(match[1]); | |
| 33 } | 59 } |
| 34 | 60 |
| 35 void endPubServe() { | 61 void endPubServe() { |
| 36 _pubServer.kill(); | 62 _pubServer.kill(); |
| 37 } | 63 } |
| 38 | 64 |
| 39 /// Schedules an HTTP request to the running pub server with [urlPath] and | 65 /// Schedules an HTTP request to the running pub server with [urlPath] and |
| 40 /// verifies that it responds with [expected]. | 66 /// verifies that it responds with [expected]. |
| 41 void requestShouldSucceed(String urlPath, String expected) { | 67 void requestShouldSucceed(String urlPath, String expected) { |
| 42 schedule(() { | 68 schedule(() { |
| 43 return http.get("http://localhost:$_port/$urlPath").then((response) { | 69 return http.get("http://localhost:$_port/$urlPath").then((response) { |
| 44 expect(response.body, equals(expected)); | 70 expect(response.body, equals(expected)); |
| 45 }); | 71 }); |
| 46 }, "request $urlPath"); | 72 }, "request $urlPath"); |
| 47 } | 73 } |
| 48 | 74 |
| 49 /// Schedules an HTTP request to the running pub server with [urlPath] and | 75 /// Schedules an HTTP request to the running pub server with [urlPath] and |
| 50 /// verifies that it responds with a 404. | 76 /// verifies that it responds with a 404. |
| 51 void requestShould404(String urlPath) { | 77 void requestShould404(String urlPath) { |
| 52 schedule(() { | 78 schedule(() { |
| 53 return http.get("http://localhost:$_port/$urlPath").then((response) { | 79 return http.get("http://localhost:$_port/$urlPath").then((response) { |
| 54 expect(response.statusCode, equals(404)); | 80 expect(response.statusCode, equals(404)); |
| 55 }); | 81 }); |
| 56 }, "request $urlPath"); | 82 }, "request $urlPath"); |
| 57 } | 83 } |
| OLD | NEW |