Added test cases for flutter

Author: loint

README.md

@@ -2,21 +2,33 @@
 
 For Flutter:
 ```dart
-var client = new Client('ws://localhost:3000', 100);
+var client = new FlutterSocketClient('ws://localhost:3000');
+```
+
+For Web:
+```dart
+var client = new WebSocketClient('ws://localhost:3000');
+```
+
+Inspired by Socket.io
+```dart
 client.authenticate({
-      "scope": "Mobile",
-      "version": "v1_0",
-      "platform": "Android",
-      "device": "Sony Xperia Z",
-      "osVersion": "1234",
-      "ipAddress": "127.0.0.1"
+  "scope": "Mobile",
+  "version": "v1_0",
+  "platform": "Android",
+  "device": "Sony Xperia Z",
+  "osVersion": "1234",
+  "ipAddress": "127.0.0.1"
 });
 client.onConnection(() async {
-    client.on("UserAuthSignIn", (Message message) async {
+  client.on("UserAuthSignIn", (Message message) async {
     expect("UserAuthSignIn", equals(message.event));
     expect('{"status": "OK"}', equals(message.message));
-    });
-    await client.emit("UserAuthSignIn", {});
+  });
+  client.onDisconnection(() async {
+  });
+  await client.emit("UserAuthSignIn", {});
+  await client.emit("UserAuthSignIn", {});
 });
 await client.connect();
 ```

lib/flutter_socket_client.dart

@@ -40,8 +40,9 @@ class FlutterSocketClient extends Client implements SocketClient {
     return this;
   }
 
-  Future initialize() async {
+  Future<SocketClient> initialize() async {
     _client = await WebSocket.connect(this.url);
+    return this;
   }
 
   @override

lib/src/client.dart

@@ -56,12 +56,11 @@ abstract class Client {
   }
 
   Future<String> transport(String message) async {
-    print('Transport : ' + message);
     if (message.toString().startsWith('connected')) {
       return socket != null && socket.isConnected() ? '1' : '0';
     }
     if (message.toString().startsWith('ws://')) {
-      socket = await getSocket().connect();
+      socket = await getSocket().initialize();
       if (socket.isConnected()) {
         // Create new stream for new connection
         responseStream = new StreamController.broadcast();
@@ -111,21 +110,19 @@ abstract class Client {
     }
     var callback = eventListeners[message.event];
     if (callback == null) {
-      print('Can not process event ' + message.event);
+      print('Can not handle event : ' + message.event);
       return 0;
     }
     await callback(message);
     return 0;
   }
 
   Future<Message> emit(String eventName, dynamic data) async {
-    print('Emit');
     final isConnected = await transport('connected');
     var connected = '1';
     if (isConnected.toString() != '1') {
       connected = await transport(this.url);
     }
-    print('Connected ' + connected.toString());
     if (connected.toString() == '1') {
       var requestMessage = new Message(eventName, data);
       String responseText = null;

lib/src/socket_client.dart

@@ -27,7 +27,7 @@ library socket.client;
 import 'dart:async';
 
 abstract class SocketClient {
-  Future initialize();
+  Future<SocketClient> initialize();
   Future connect();
   bool isConnected();
   Future add(String message);

lib/web_socket_client.dart

@@ -38,8 +38,9 @@ class WebSocketClient extends Client.Client implements SocketClient {
     return this;
   }
 
-  Future initialize() async {
+  Future<SocketClient> initialize() async {
     _client = new WebSocket(this.url);
+    return this;
   }
 
   @override

pubspec.yaml

@@ -8,3 +8,4 @@ environment:
 
 dev_dependencies:
   test: ^0.12.0
+  browser_unittest: ^0.4.0

test/socket_flutter_test.dart renamed to test/flutter_socket_client_test.dart

@@ -27,7 +27,7 @@ import 'package:socket_client_dart/src/client.dart';
 import 'package:socket_client_dart/flutter_socket_client.dart';
 
 void main() {
-  test("FlutterClient:integration", () async {
+  test("FlutterSocketClient:integration", () async {
     // Client connection is not allowed to retry
     // another connection is connected
     var client = new FlutterSocketClient('ws://localhost:3000');

test/web_socket_client_test.dart

@@ -0,0 +1,56 @@
+// Copyright 2018 Food Tiny Authors. All rights reserved.
+//
+// Redistribution and use in source and binary forms, with or without
+// modification, are permitted provided that the following conditions are met:
+//
+// Redistributions of source code must retain the above copyright
+// notice, this list of conditions and the following disclaimer.
+// Redistributions in binary form must reproduce the above
+// copyright notice, this list of conditions and the following disclaimer
+// in the documentation and/or other materials provided with the
+// distribution.
+//
+// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+// "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+// LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+// A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+// OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+// LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+// DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+// THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+// OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+
+import 'package:unittest/unittest.dart';
+import 'package:unittest/html_config.dart';
+import 'package:socket_client_dart/src/client.dart';
+import 'package:socket_client_dart/web_socket_client.dart';
+
+void main() {
+  useHtmlConfiguration();
+  test("WebSocketClient:integration", () async {
+    // Client connection is not allowed to retry
+    // another connection is connected
+    var client = new WebSocketClient('ws://localhost:3000');
+    client.authenticate({
+      "scope": "Mobile",
+      "version": "v1_0",
+      "platform": "Android",
+      "device": "Sony Xperia Z",
+      "osVersion": "1234",
+      "ipAddress": "127.0.0.1"
+    });
+    client.onConnection(() async {
+      client.on("UserAuthSignIn", (Message message) async {
+        expect("UserAuthSignIn", equals(message.event));
+        expect('{"status": "OK"}', equals(message.message));
+      });
+      client.onDisconnection(() async {
+      });
+      await client.emit("UserAuthSignIn", {});
+      await client.emit("UserAuthSignIn", {});
+    });
+    await client.connect();
+  });
+}