unittests added

Author: inkrement

lib/Messenger/src/peers/peer.dart

@@ -1,5 +1,10 @@
 part of messenger;
 
+/**
+ * @todo: 
+ *  * ready Status enum instead of string
+ */
+
 abstract class Peer{
   ///logging object
   final Logger log;
@@ -14,34 +19,37 @@ abstract class Peer{
   String name;
 
   ///new message event stream
-  StreamController<NewMessageEvent> newMessageController = new StreamController<NewMessageEvent>.broadcast();
+  StreamController<NewMessageEvent> newMessageController;
 
   ///ready State of connection
   ///todo: generalize and add to connections to support multiple states
   String readyState;
 
   ///ready State event stream component
   ///todo: generalize and add to connections to support multiple states
-  StreamController readyStateEvent;
+  StreamController<String> readyStateEvent;
 
   /**
    * constuctor
    */
-  Peer([String name="", Level logLevel=Level.FINE]): log = new Logger('Peer'), readyState="none"{
+  Peer([String name="", Level logLevel=Level.FINE]):log = new Logger('Peer'){
+    ///increment number of peers
+    num++;
+    
     log.info("new peer! " + num.toString());
-    _connections = new List<Peer>();
 
-    ///set name of this peer instance
-    this.name = (name.length < 1)?"peer" + num.toString():name;
+    ///init
+    readyStateEvent = new StreamController<String>.broadcast();
+    newMessageController = new StreamController<NewMessageEvent>.broadcast(); 
+    this.name = (name.length < 1)?"peer" + num.toString():name; //set name of this peer instance
+    _connections = new List<Peer>();
+    readyState="none";
 
     ///setup logging library
     Logger.root.level = logLevel;
     Logger.root.onRecord.listen((LogRecord rec) {
       print('${rec.level.name}: ${this.name}: ${rec.message}');
     });
-    
-    ///increment number of peers
-    num++;
   }
 
   /**

tests/helloworld.dart

@@ -1,6 +1,8 @@
-part of unittest;
+library unittest.helloworld;
 
-void helloworld() {
+import 'package:unittest/unittest.dart';
+
+main() {
 
   /**
    * hello world

tests/jsrtcpeer.dart

@@ -1,9 +1,9 @@
-part of unittest;
+library unittest.jsrtcpeer;
 
-jsrtcpeer() {
-  
-  /// setup html environment 
-  useHtmlConfiguration();
+import 'package:unittest/unittest.dart';
+import 'package:webrtc/Messenger/messenger.dart';
+
+void main() {
 
   /**
    * expect to construct new Object without catching a exception
@@ -44,45 +44,21 @@ jsrtcpeer() {
     alice.connect(bob);
   });
 
-  test('webrtc datachannel', (){
-    
-  });
-  
-  
-  
-  
-  /*
-  test('Webrtc types datachannel',(){
-    JsWebRtcPeer alice = new JsWebRtcPeer();
-    
-    InstanceMirror myClassInstanceMirror = reflect(alice);
-    //String type = myClassInstanceMirror.type;
-    //logMessage();
+  /**
+   * test status opens
+   */
+  test('webrtc datachannel open', (){
+    JsWebRtcPeer alice = new JsWebRtcPeer("alice");
+    JsWebRtcPeer bob = new JsWebRtcPeer("bob");
 
+    alice.readyStateEvent.stream.listen((String status){
+      if(status == "open")
+          expectAsync0((){});
+    });
 
-    //expect("", myClassInstanceMirror.type);
-  });
-  
-  test('Webrtc has icecandidates',(){
-    JsWebRtcPeer alice = new JsWebRtcPeer();
-    JsWebRtcPeer bob = new JsWebRtcPeer();
+    alice.connect(bob);
 
-    //expect(alice.connect(bob), completes);
-   
   });
 
 
-  test("testing a future", () {
-    Compute compute = new Compute();    
-    Future<Map> future = compute.sumIt([1, 2, 3]);
-    expect(future, completion(equals({"value" : 6})));
-  });
-  */
-  
-  
-  //test connect
-  
-
-  
-  
 }

tests/messagepassingpeer.dart

@@ -1,6 +1,9 @@
-part of unittest;
+library unittest.messagepassing;
 
-messagepassingpeer() {
+import 'package:unittest/unittest.dart';
+import 'package:webrtc/Messenger/messenger.dart';
+
+main() {
   test('SendAndReceive', (){
     MessagePassingPeer alice = new MessagePassingPeer();
     MessagePassingPeer bob = new MessagePassingPeer();

tests/unittests.dart

@@ -1,31 +1,32 @@
 
 library unittest;
 
-import 'package:unittest/unittest.dart';
-import 'package:webrtc/Messenger/messenger.dart';
+
+
 import 'package:unittest/html_config.dart';
 //import 'dart:mirrors';
 //import 'dart:async';
 
-part 'helloworld.dart';
-part 'webrtcpeer.dart';
-part 'jsrtcpeer.dart';
-part 'messagepassingpeer.dart';
-
+import 'helloworld.dart' as hello;
+import 'jsrtcpeer.dart' as js_rtc;
+import 'webrtcpeer.dart' as native_rtc;
+import 'messagepassingpeer.dart' as messagepassing;
 
 void main() {
 
   /// setup html environment 
   useHtmlConfiguration();
 
+  
+  
   /// run hello world tests
-  helloworld();
+  //helloworld();
 
   /// webrtc Peer tests
   //webrtcpeer();
 
   /// tests for JS Wrapper
-  jsrtcpeer();
+  js_rtc.main();
 
   /// messagepassing peer test
   //messagepassingpeer();

tests/webrtcpeer.dart

@@ -1,6 +1,9 @@
-part of unittest;
+library unittest.webrtcpeer;
 
-webrtcpeer() {
+import 'package:unittest/unittest.dart';
+import 'package:webrtc/Messenger/messenger.dart';
+
+void main() {
 
 
   /**