Index: pkg/analysis_server/test/channel_test.dart |
diff --git a/pkg/analysis_server/test/channel_test.dart b/pkg/analysis_server/test/channel_test.dart |
new file mode 100644 |
index 0000000000000000000000000000000000000000..0c639ad64a3259b0b3aa50e7120c05d5a776d96c |
--- /dev/null |
+++ b/pkg/analysis_server/test/channel_test.dart |
@@ -0,0 +1,105 @@ |
+// 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. |
+ |
+library test.channel; |
+ |
+import 'package:analysis_server/src/protocol.dart'; |
+import 'package:unittest/matcher.dart'; |
+import 'package:unittest/unittest.dart'; |
+import 'package:analysis_server/src/channel.dart'; |
+import 'mocks.dart'; |
+ |
+main() { |
+ group('Channel', () { |
+ test('invalidJsonToClient', ChannelTest.invalidJsonToClient); |
+ test('invalidJsonToServer', ChannelTest.invalidJsonToServer); |
+ test('notification', ChannelTest.notification); |
+ test('request', ChannelTest.request); |
+ test('response', ChannelTest.response); |
+ }); |
+} |
+ |
+class ChannelTest { |
+ |
+ static void invalidJsonToClient() { |
+ InvalidJsonMockSocket mockSocket = new InvalidJsonMockSocket(); |
+ WebSocketClientChannel client = new WebSocketClientChannel(mockSocket); |
+ var responsesReceived = new List(); |
+ var notificationsReceived = new List(); |
+ client.listen((Response response) => responsesReceived.add(response), |
+ (Notification notification) => notificationsReceived.add(notification)); |
+ |
+ mockSocket.addInvalid('"blat"'); |
+ mockSocket.addInvalid('{foo:bar}'); |
+ |
+ expect(responsesReceived.length, equals(0)); |
+ expect(notificationsReceived.length, equals(0)); |
+ expect(mockSocket.responseCount, equals(0)); |
+ } |
+ |
+ static void invalidJsonToServer() { |
+ InvalidJsonMockSocket mockSocket = new InvalidJsonMockSocket(); |
+ WebSocketServerChannel server = new WebSocketServerChannel(mockSocket); |
+ var received = new List(); |
+ server.listen((Request request) => received.add(request)); |
+ |
+ mockSocket.addInvalid('"blat"'); |
+ mockSocket.addInvalid('{foo:bar}'); |
+ |
+ expect(received.length, equals(0)); |
+ expect(mockSocket.responseCount, equals(2)); |
+ } |
+ |
+ static void notification() { |
+ MockSocket mockSocket = new MockSocket(); |
+ WebSocketClientChannel client = new WebSocketClientChannel(mockSocket); |
+ WebSocketServerChannel server = new WebSocketServerChannel(mockSocket); |
+ var responsesReceived = new List(); |
+ var notificationsReceived = new List(); |
+ client.listen((Response response) => responsesReceived.add(response), |
+ (Notification notification) => notificationsReceived.add(notification)); |
+ |
+ server.sendNotification(new Notification('myEvent')); |
+ |
+ expect(responsesReceived.length, equals(0)); |
+ expect(notificationsReceived.length, equals(1)); |
+ expect(notificationsReceived.first.runtimeType, equals(Notification)); |
+ Notification actual = notificationsReceived.first; |
+ expect(actual.event, equals('myEvent')); |
+ } |
+ |
+ static void request() { |
+ MockSocket mockSocket = new MockSocket(); |
+ WebSocketClientChannel client = new WebSocketClientChannel(mockSocket); |
+ WebSocketServerChannel server = new WebSocketServerChannel(mockSocket); |
+ var requestsReceived = new List(); |
+ server.listen((Request request) => requestsReceived.add(request)); |
+ |
+ client.sendRequest(new Request('myId', 'aMethod')); |
+ |
+ expect(requestsReceived.length, equals(1)); |
+ expect(requestsReceived.first.runtimeType, equals(Request)); |
+ Request actual = requestsReceived.first; |
+ expect(actual.id, equals('myId')); |
+ expect(actual.method, equals('aMethod')); |
+ } |
+ |
+ static void response() { |
+ MockSocket mockSocket = new MockSocket(); |
+ WebSocketClientChannel client = new WebSocketClientChannel(mockSocket); |
+ WebSocketServerChannel server = new WebSocketServerChannel(mockSocket); |
+ var responsesReceived = new List(); |
+ var notificationsReceived = new List(); |
+ client.listen((Response response) => responsesReceived.add(response), |
+ (Notification notification) => notificationsReceived.add(notification)); |
+ |
+ server.sendResponse(new Response('myId')); |
+ |
+ expect(responsesReceived.length, equals(1)); |
+ expect(notificationsReceived.length, equals(0)); |
+ expect(responsesReceived.first.runtimeType, equals(Response)); |
+ Response actual = responsesReceived.first; |
+ expect(actual.id, equals('myId')); |
+ } |
+} |