Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(852)

Issues Search
    My Issues | Starred     Open | Closed | All

Unified Diff: samples/tests/samples/src/chat/HttpTest.dart

Issue 9488008: Include HTTP library in the standalone VM (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Minor update Created 8 years, 10 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « samples/tests/samples/src/chat/HttpParserTest.dart ('k') | samples/tests/samples/src/chat/UrlEncodingTest.dart » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: samples/tests/samples/src/chat/HttpTest.dart
diff --git a/samples/tests/samples/src/chat/HttpTest.dart b/samples/tests/samples/src/chat/HttpTest.dart
deleted file mode 100644
index 1bd0062b2c47202e478a99132434f722f5a857be..0000000000000000000000000000000000000000
--- a/samples/tests/samples/src/chat/HttpTest.dart
+++ /dev/null
@@ -1,384 +0,0 @@
-// 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.
-
-#library("http_test.dart");
-#import("dart:isolate");
-#import("dart:io");
-#import("../../../../chat/http.dart");
-#import("../../../../chat/chat_server_lib.dart");
-
-
-class TestServerMain {
- TestServerMain()
- : _statusPort = new ReceivePort(),
- _serverPort = null {
- new TestServer().spawn().then((SendPort port) {
- _serverPort = port;
- });
- }
-
- void setServerStartedHandler(void startedCallback(int port)) {
- _startedCallback = startedCallback;
- }
-
- void start() {
- // Handle status messages from the server.
- _statusPort.receive((var status, SendPort replyTo) {
- if (status.isStarted) {
- _startedCallback(status.port);
- }
- });
-
- // Send server start message to the server.
- var command = new TestServerCommand.start();
- _serverPort.send(command, _statusPort.toSendPort());
- }
-
- void shutdown() {
- // Send server stop message to the server.
- _serverPort.send(new TestServerCommand.stop(), _statusPort.toSendPort());
- _statusPort.close();
- }
-
- void chunkedEncoding() {
- // Send chunked encoding message to the server.
- _serverPort.send(
- new TestServerCommand.chunkedEncoding(), _statusPort.toSendPort());
- }
-
- ReceivePort _statusPort; // Port for receiving messages from the server.
- SendPort _serverPort; // Port for sending messages to the server.
- var _startedCallback;
-}
-
-
-class TestServerCommand {
- static final START = 0;
- static final STOP = 1;
- static final CHUNKED_ENCODING = 2;
-
- TestServerCommand.start() : _command = START;
- TestServerCommand.stop() : _command = STOP;
- TestServerCommand.chunkedEncoding() : _command = CHUNKED_ENCODING;
-
- bool get isStart() => _command == START;
- bool get isStop() => _command == STOP;
- bool get isChunkedEncoding() => _command == CHUNKED_ENCODING;
-
- int _command;
-}
-
-
-class TestServerStatus {
- static final STARTED = 0;
- static final STOPPED = 1;
- static final ERROR = 2;
-
- TestServerStatus.started(this._port) : _state = STARTED;
- TestServerStatus.stopped() : _state = STOPPED;
- TestServerStatus.error() : _state = ERROR;
-
- bool get isStarted() => _state == STARTED;
- bool get isStopped() => _state == STOPPED;
- bool get isError() => _state == ERROR;
-
- int get port() => _port;
-
- int _state;
- int _port;
-}
-
-
-class TestServer extends Isolate {
- // Echo the request content back to the response.
- void _echoHandler(HttpRequest request, HttpResponse response) {
- Expect.equals("POST", request.method);
- response.contentLength = request.contentLength;
- request.inputStream.pipe(response.outputStream);
- }
-
- // Echo the request content back to the response.
- void _zeroToTenHandler(HttpRequest request, HttpResponse response) {
- Expect.equals("GET", request.method);
- request.inputStream.dataHandler = () {};
- request.inputStream.closeHandler = () {
- response.writeString("01234567890");
- response.outputStream.close();
- };
- }
-
- // Return a 404.
- void _notFoundHandler(HttpRequest request, HttpResponse response) {
- response.statusCode = HttpStatus.NOT_FOUND;
- response.setHeader("Content-Type", "text/html; charset=UTF-8");
- response.writeString("Page not found");
- response.outputStream.close();
- }
-
- void main() {
- // Setup request handlers.
- _requestHandlers = new Map();
- _requestHandlers["/echo"] = (HttpRequest request, HttpResponse response) {
- _echoHandler(request, response);
- };
- _requestHandlers["/0123456789"] =
- (HttpRequest request, HttpResponse response) {
- _zeroToTenHandler(request, response);
- };
-
- this.port.receive((var message, SendPort replyTo) {
- if (message.isStart) {
- _server = new HttpServer();
- try {
- _server.listen("127.0.0.1", 0);
- _server.requestHandler = (HttpRequest req, HttpResponse rsp) {
- _requestReceivedHandler(req, rsp);
- };
- replyTo.send(new TestServerStatus.started(_server.port), null);
- } catch (var e) {
- replyTo.send(new TestServerStatus.error(), null);
- }
- } else if (message.isStop) {
- _server.close();
- this.port.close();
- replyTo.send(new TestServerStatus.stopped(), null);
- } else if (message.isChunkedEncoding) {
- _chunkedEncoding = true;
- }
- });
- }
-
- void _requestReceivedHandler(HttpRequest request, HttpResponse response) {
- var requestHandler =_requestHandlers[request.path];
- if (requestHandler != null) {
- requestHandler(request, response);
- } else {
- _notFoundHandler(request, response);
- }
- }
-
- HttpServer _server; // HTTP server instance.
- Map _requestHandlers;
- bool _chunkedEncoding = false;
-}
-
-
-void testStartStop() {
- TestServerMain testServerMain = new TestServerMain();
- testServerMain.setServerStartedHandler((int port) {
- testServerMain.shutdown();
- });
- testServerMain.start();
-}
-
-
-void testGET() {
- TestServerMain testServerMain = new TestServerMain();
- testServerMain.setServerStartedHandler((int port) {
- HttpClient httpClient = new HttpClient();
- HttpClientConnection conn =
- httpClient.get("127.0.0.1", port, "/0123456789");
- conn.responseHandler = (HttpClientResponse response) {
- Expect.equals(HttpStatus.OK, response.statusCode);
- StringInputStream stream = new StringInputStream(response.inputStream);
- StringBuffer body = new StringBuffer();
- stream.dataHandler = () => body.add(stream.read());
- stream.closeHandler = () {
- Expect.equals("01234567890", body.toString());
- httpClient.shutdown();
- testServerMain.shutdown();
- };
- };
- });
- testServerMain.start();
-}
-
-
-void testPOST(bool chunkedEncoding) {
- String data = "ABCDEFGHIJKLMONPQRSTUVWXYZ";
- final int kMessageCount = 10;
-
- TestServerMain testServerMain = new TestServerMain();
-
- void runTest(int port) {
- int count = 0;
- HttpClient httpClient = new HttpClient();
- void sendRequest() {
- HttpClientConnection conn =
- httpClient.post("127.0.0.1", port, "/echo");
- conn.requestHandler = (HttpClientRequest request) {
- if (chunkedEncoding) {
- request.writeString(data.substring(0, 10));
- request.writeString(data.substring(10, data.length));
- } else {
- request.contentLength = data.length;
- request.outputStream.write(data.charCodes());
- }
- request.outputStream.close();
- };
- conn.responseHandler = (HttpClientResponse response) {
- Expect.equals(HttpStatus.OK, response.statusCode);
- StringInputStream stream = new StringInputStream(response.inputStream);
- StringBuffer body = new StringBuffer();
- stream.dataHandler = () => body.add(stream.read());
- stream.closeHandler = () {
- Expect.equals(data, body.toString());
- count++;
- if (count < kMessageCount) {
- sendRequest();
- } else {
- httpClient.shutdown();
- testServerMain.shutdown();
- }
- };
- };
- }
-
- sendRequest();
- }
-
- testServerMain.setServerStartedHandler(runTest);
- if (chunkedEncoding) {
- testServerMain.chunkedEncoding();
- }
- testServerMain.start();
-}
-
-
-void testReadInto(bool chunkedEncoding) {
- String data = "ABCDEFGHIJKLMNOPQRSTUVWXYZ";
- final int kMessageCount = 10;
-
- TestServerMain testServerMain = new TestServerMain();
-
- void runTest(int port) {
- int count = 0;
- HttpClient httpClient = new HttpClient();
- void sendRequest() {
- HttpClientConnection conn =
- httpClient.post("127.0.0.1", port, "/echo");
- conn.requestHandler = (HttpClientRequest request) {
- if (chunkedEncoding) {
- request.writeString(data.substring(0, 10));
- request.writeString(data.substring(10, data.length));
- } else {
- request.contentLength = data.length;
- request.outputStream.write(data.charCodes());
- }
- request.outputStream.close();
- };
- conn.responseHandler = (HttpClientResponse response) {
- Expect.equals(HttpStatus.OK, response.statusCode);
- InputStream stream = response.inputStream;
- List<int> body = new List<int>();
- stream.dataHandler = () {
- List tmp = new List(3);
- int bytes = stream.readInto(tmp);
- body.addAll(tmp.getRange(0, bytes));
- };
- stream.closeHandler = () {
- Expect.equals(data, new String.fromCharCodes(body));
- count++;
- if (count < kMessageCount) {
- sendRequest();
- } else {
- httpClient.shutdown();
- testServerMain.shutdown();
- }
- };
- };
- }
-
- sendRequest();
- }
-
- testServerMain.setServerStartedHandler(runTest);
- if (chunkedEncoding) {
- testServerMain.chunkedEncoding();
- }
- testServerMain.start();
-}
-
-
-void testReadShort(bool chunkedEncoding) {
- String data = "ABCDEFGHIJKLMNOPQRSTUVWXYZ";
- final int kMessageCount = 10;
-
- TestServerMain testServerMain = new TestServerMain();
-
- void runTest(int port) {
- int count = 0;
- HttpClient httpClient = new HttpClient();
- void sendRequest() {
- HttpClientConnection conn =
- httpClient.post("127.0.0.1", port, "/echo");
- conn.requestHandler = (HttpClientRequest request) {
- if (chunkedEncoding) {
- request.writeString(data.substring(0, 10));
- request.writeString(data.substring(10, data.length));
- } else {
- request.contentLength = data.length;
- request.outputStream.write(data.charCodes());
- }
- request.outputStream.close();
- };
- conn.responseHandler = (HttpClientResponse response) {
- Expect.equals(HttpStatus.OK, response.statusCode);
- InputStream stream = response.inputStream;
- List<int> body = new List<int>();
- stream.dataHandler = () {
- List tmp = stream.read(2);
- body.addAll(tmp);
- };
- stream.closeHandler = () {
- Expect.equals(data, new String.fromCharCodes(body));
- count++;
- if (count < kMessageCount) {
- sendRequest();
- } else {
- httpClient.shutdown();
- testServerMain.shutdown();
- }
- };
- };
- }
-
- sendRequest();
- }
-
- testServerMain.setServerStartedHandler(runTest);
- if (chunkedEncoding) {
- testServerMain.chunkedEncoding();
- }
- testServerMain.start();
-}
-
-
-void test404() {
- TestServerMain testServerMain = new TestServerMain();
- testServerMain.setServerStartedHandler((int port) {
- HttpClient httpClient = new HttpClient();
- HttpClientConnection conn =
- httpClient.get("127.0.0.1", port, "/thisisnotfound");
- conn.responseHandler = (HttpClientResponse response) {
- Expect.equals(HttpStatus.NOT_FOUND, response.statusCode);
- httpClient.shutdown();
- testServerMain.shutdown();
- };
- });
- testServerMain.start();
-}
-
-
-void main() {
- testStartStop();
- testGET();
- testPOST(true);
- testPOST(false);
- testReadInto(true);
- testReadInto(false);
- testReadShort(true);
- testReadShort(false);
- test404();
-}
« no previous file with comments | « samples/tests/samples/src/chat/HttpParserTest.dart ('k') | samples/tests/samples/src/chat/UrlEncodingTest.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698