Feature/on-data

docs/index.html

@@ -491,6 +491,12 @@ <h2>Getting Started</h2>
             </div>
           </div>
         </div>
+        <div class="child " id="peeron-message"><span class="name"><a
+              href="#peeron-message">'message'</a><span class="tag type event">event</span><span
+              class="snippet">peer.on('message', function(message) { ... });</span></span>
+          <p class="description">Emitted when a message is received from the signalling server. <span class='tip'>
+              Messages from peers are also intercepted by this event.</span></p>
+        </div>
       </div>
     </div>
     <div class="toplevel " id="peerdisconnect"><span class="name"><a href="#peerdisconnect">peer.disconnect</a><span

index.d.ts

@@ -79,6 +79,12 @@ declare class Peer {
    * @param cb Callback Function
    */
   on(event: "error", cb: (err: any) => void): void;
+  /**
+   * Emitted when a message is received from the signalling server.
+   * @param event Event name
+   * @param cb Callback Function
+   */
+  on(event: "message", cb: (data: any) => void): void;
   /**
    * Remove event listeners.(EventEmitter3)
    * @param {String} event The event we want to remove.

lib/enums.ts

@@ -18,7 +18,8 @@ export enum PeerEventType {
   Connection = "connection",
   Call = "call",
   Disconnected = "disconnected",
-  Error = "error"
+  Error = "error",
+  Message = "message"
 }
 
 export enum PeerErrorType {

lib/peer.ts

@@ -284,8 +284,9 @@ export class Peer extends EventEmitter {
         break;
       }
       default: {
+        this.emit(PeerEventType.Message, message);
+
         if (!payload) {
-          logger.warn(`You received a malformed message from ${peerId} of type ${type}`);
           return;
         }
 
@@ -298,8 +299,6 @@ export class Peer extends EventEmitter {
         } else if (connectionId) {
           // Store for possible later use
           this._storeMessage(connectionId, message);
-        } else {
-          logger.warn("You received an unrecognized message:", message);
         }
         break;
       }