| Index: test/web_socket_test.dart
|
| diff --git a/test/web_socket_test.dart b/test/web_socket_test.dart
|
| deleted file mode 100644
|
| index 53aa5be41563542ef04aefd21c0c9c52a503ce52..0000000000000000000000000000000000000000
|
| --- a/test/web_socket_test.dart
|
| +++ /dev/null
|
| @@ -1,183 +0,0 @@
|
| -// 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.
|
| -
|
| -@TestOn('vm')
|
| -
|
| -import 'dart:io';
|
| -
|
| -import 'package:http_parser/http_parser.dart';
|
| -import 'package:stream_channel/stream_channel.dart';
|
| -import 'package:test/test.dart';
|
| -
|
| -void main() {
|
| - group("using WebSocketChannel", () {
|
| - test("a client can communicate with a WebSocket server", () async {
|
| - var server = await HttpServer.bind("localhost", 0);
|
| - server.transform(new WebSocketTransformer()).listen((webSocket) {
|
| - webSocket.add("hello!");
|
| - webSocket.listen((request) {
|
| - expect(request, equals("ping"));
|
| - webSocket.add("pong");
|
| - webSocket.close();
|
| - });
|
| - });
|
| -
|
| - var client = new HttpClient();
|
| - var request = await client.openUrl(
|
| - "GET", Uri.parse("http://localhost:${server.port}"));
|
| - request.headers
|
| - ..set("Connection", "Upgrade")
|
| - ..set("Upgrade", "websocket")
|
| - ..set("Sec-WebSocket-Key", "x3JJHMbDL1EzLkh9GBhXDw==")
|
| - ..set("Sec-WebSocket-Version", "13");
|
| -
|
| - var response = await request.close();
|
| - var socket = await response.detachSocket();
|
| - var innerChannel = new StreamChannel(socket, socket);
|
| - var webSocket = new WebSocketChannel(innerChannel, serverSide: false);
|
| -
|
| - var n = 0;
|
| - await webSocket.stream.listen((message) {
|
| - if (n == 0) {
|
| - expect(message, equals("hello!"));
|
| - webSocket.sink.add("ping");
|
| - } else if (n == 1) {
|
| - expect(message, equals("pong"));
|
| - webSocket.sink.close();
|
| - server.close();
|
| - } else {
|
| - fail("Only expected two messages.");
|
| - }
|
| - n++;
|
| - }).asFuture();
|
| - });
|
| -
|
| - test("a server can communicate with a WebSocket client", () async {
|
| - var server = await HttpServer.bind("localhost", 0);
|
| - server.listen((request) async {
|
| - var response = request.response;
|
| - response.statusCode = 101;
|
| - response.headers
|
| - ..set("Connection", "Upgrade")
|
| - ..set("Upgrade", "websocket")
|
| - ..set("Sec-WebSocket-Accept", CompatibleWebSocket
|
| - .signKey(request.headers.value('Sec-WebSocket-Key')));
|
| - response.contentLength = 0;
|
| -
|
| - var socket = await response.detachSocket();
|
| - var innerChannel = new StreamChannel(socket, socket);
|
| - var webSocket = new WebSocketChannel(innerChannel);
|
| - webSocket.sink.add("hello!");
|
| -
|
| - var message = await webSocket.stream.first;
|
| - expect(message, equals("ping"));
|
| - webSocket.sink.add("pong");
|
| - webSocket.sink.close();
|
| - });
|
| -
|
| - var webSocket = await WebSocket.connect('ws://localhost:${server.port}');
|
| - var n = 0;
|
| - await webSocket.listen((message) {
|
| - if (n == 0) {
|
| - expect(message, equals("hello!"));
|
| - webSocket.add("ping");
|
| - } else if (n == 1) {
|
| - expect(message, equals("pong"));
|
| - webSocket.close();
|
| - server.close();
|
| - } else {
|
| - fail("Only expected two messages.");
|
| - }
|
| - n++;
|
| - }).asFuture();
|
| - });
|
| - });
|
| -
|
| - group("using CompatibleWebSocket", () {
|
| - test("a client can communicate with a WebSocket server", () {
|
| - return HttpServer.bind("localhost", 0).then((server) {
|
| - server.transform(new WebSocketTransformer()).listen((webSocket) {
|
| - webSocket.add("hello!");
|
| - webSocket.listen((request) {
|
| - expect(request, equals("ping"));
|
| - webSocket.add("pong");
|
| - webSocket.close();
|
| - });
|
| - });
|
| -
|
| - var client = new HttpClient();
|
| - return client
|
| - .openUrl("GET", Uri.parse("http://localhost:${server.port}"))
|
| - .then((request) {
|
| - request.headers
|
| - ..set("Connection", "Upgrade")
|
| - ..set("Upgrade", "websocket")
|
| - ..set("Sec-WebSocket-Key", "x3JJHMbDL1EzLkh9GBhXDw==")
|
| - ..set("Sec-WebSocket-Version", "13");
|
| - return request.close();
|
| - }).then((response) => response.detachSocket()).then((socket) {
|
| - var webSocket = new CompatibleWebSocket(socket, serverSide: false);
|
| -
|
| - var n = 0;
|
| - return webSocket.listen((message) {
|
| - if (n == 0) {
|
| - expect(message, equals("hello!"));
|
| - webSocket.add("ping");
|
| - } else if (n == 1) {
|
| - expect(message, equals("pong"));
|
| - webSocket.close();
|
| - server.close();
|
| - } else {
|
| - fail("Only expected two messages.");
|
| - }
|
| - n++;
|
| - }).asFuture();
|
| - });
|
| - });
|
| - });
|
| -
|
| - test("a server can communicate with a WebSocket client", () {
|
| - return HttpServer.bind("localhost", 0).then((server) {
|
| - server.listen((request) {
|
| - var response = request.response;
|
| - response.statusCode = 101;
|
| - response.headers
|
| - ..set("Connection", "Upgrade")
|
| - ..set("Upgrade", "websocket")
|
| - ..set("Sec-WebSocket-Accept", CompatibleWebSocket
|
| - .signKey(request.headers.value('Sec-WebSocket-Key')));
|
| - response.contentLength = 0;
|
| - response.detachSocket().then((socket) {
|
| - var webSocket = new CompatibleWebSocket(socket);
|
| - webSocket.add("hello!");
|
| - webSocket.first.then((request) {
|
| - expect(request, equals("ping"));
|
| - webSocket.add("pong");
|
| - webSocket.close();
|
| - });
|
| - });
|
| - });
|
| -
|
| - return WebSocket
|
| - .connect('ws://localhost:${server.port}')
|
| - .then((webSocket) {
|
| - var n = 0;
|
| - return webSocket.listen((message) {
|
| - if (n == 0) {
|
| - expect(message, equals("hello!"));
|
| - webSocket.add("ping");
|
| - } else if (n == 1) {
|
| - expect(message, equals("pong"));
|
| - webSocket.close();
|
| - server.close();
|
| - } else {
|
| - fail("Only expected two messages.");
|
| - }
|
| - n++;
|
| - }).asFuture();
|
| - });
|
| - });
|
| - });
|
| - });
|
| -}
|
|
|