Formatting READDME

Author: jason-fox

README.md

@@ -327,39 +327,39 @@ var ws = require("ws");
 
 var wss = new ws.Server({
     server: server,
-    path: "/helloworld"
+    path: "/helloworld",
 });
 
-wss.on("connection", function(ws) {
+wss.on("connection", function (ws) {
     var sessionId = null;
     var request = ws.upgradeReq;
     var response = {
-        writeHead: {}
+        writeHead: {},
     };
 
-    sessionHandler(request, response, function(err) {
+    sessionHandler(request, response, function (err) {
         sessionId = request.session.id;
     });
 
-    ws.on("error", error => {
+    ws.on("error", (error) => {
         stop(sessionId);
     });
 
     ws.on("close", () => {
         stop(sessionId);
     });
 
-    ws.on("message", _message => {
+    ws.on("message", (_message) => {
         var message = JSON.parse(_message);
 
         switch (message.id) {
             case "start":
                 sessionId = request.session.id;
-                start(sessionId, ws, message.sdpOffer, function(error, sdpAnswer) {
+                start(sessionId, ws, message.sdpOffer, function (error, sdpAnswer) {
                     ws.send(
                         JSON.stringify({
                             id: "startResponse",
-                            sdpAnswer: sdpAnswer
+                            sdpAnswer: sdpAnswer,
                         })
                     );
                 });
@@ -434,26 +434,26 @@ function start(sessionId, ws, sdpOffer, callback) {
                     }
                 }
                 // Connect it back on itself (i.e. in loopback)
-                connectMediaElements(webRtcEndpoint, error => {
-                    webRtcEndpoint.on("OnIceCandidate", function(event) {
+                connectMediaElements(webRtcEndpoint, (error) => {
+                    webRtcEndpoint.on("OnIceCandidate", function (event) {
                         const candidate = kurento.getComplexType("IceCandidate")(event.candidate);
                         ws.send(
                             JSON.stringify({
                                 id: "iceCandidate",
-                                candidate: candidate
+                                candidate: candidate,
                             })
                         );
                     });
 
                     webRtcEndpoint.processOffer(sdpOffer, (error, sdpAnswer) => {
                         sessions[sessionId] = {
                             pipeline: pipeline,
-                            webRtcEndpoint: webRtcEndpoint
+                            webRtcEndpoint: webRtcEndpoint,
                         };
                         return callback(null, sdpAnswer);
                     });
 
-                    webRtcEndpoint.gatherCandidates(error => {
+                    webRtcEndpoint.gatherCandidates((error) => {
                         if (error) {
                             return callback(error);
                         }
@@ -480,15 +480,12 @@ function createMediaElements(pipeline, ws, callback) {
 
 ```javascript
 function connectMediaElements(webRtcEndpoint, callback) {
-    webRtcEndpoint.connect(
-        webRtcEndpoint,
-        error => {
-            if (error) {
-                return callback(error);
-            }
-            return callback(null);
+    webRtcEndpoint.connect(webRtcEndpoint, (error) => {
+        if (error) {
+            return callback(error);
         }
-    );
+        return callback(null);
+    });
 }
 ```
 
@@ -535,10 +532,10 @@ function start() {
     var options = {
         localVideo: videoInput,
         remoteVideo: videoOutput,
-        onicecandidate: onIceCandidate
+        onicecandidate: onIceCandidate,
     };
 
-    webRtcPeer = kurentoUtils.WebRtcPeer.WebRtcPeerSendrecv(options, function(error) {
+    webRtcPeer = kurentoUtils.WebRtcPeer.WebRtcPeerSendrecv(options, function (error) {
         if (error) return onError(error);
         this.generateOffer(onOffer);
     });
@@ -547,14 +544,14 @@ function start() {
 function onIceCandidate(candidate) {
     sendMessage({
         id: "onIceCandidate",
-        candidate: candidate
+        candidate: candidate,
     });
 }
 
 function onOffer(error, offerSdp) {
     sendMessage({
         id: "start",
-        sdpOffer: offerSdp
+        sdpOffer: offerSdp,
     });
 }
 ```
@@ -563,7 +560,7 @@ Whenever a WebSocket message is received, either starting communication, changin
 an appropriate action is taken.
 
 ```javascript
-ws.onmessage = function(message) {
+ws.onmessage = function (message) {
     var parsedMessage = JSON.parse(message.data);
 
     switch (parsedMessage.id) {
@@ -654,7 +651,7 @@ function createMediaElements(pipeline, ws, callback) {
                 -1.2,
                 1.6,
                 1.6,
-                function(error) {
+                function (error) {
                     if (error) {
                         return callback(error);
                     }
@@ -668,24 +665,18 @@ function createMediaElements(pipeline, ws, callback) {
 
 ```javascript
 function connectMediaElements(webRtcEndpoint, faceOverlayFilter, callback) {
-    webRtcEndpoint.connect(
-        faceOverlayFilter,
-        error => {
+    webRtcEndpoint.connect(faceOverlayFilter, (error) => {
+        if (error) {
+            return callback(error);
+        }
+        faceOverlayFilter.connect(webRtcEndpoint, (error) => {
             if (error) {
                 return callback(error);
             }
-            faceOverlayFilter.connect(
-                webRtcEndpoint,
-                error => {
-                    if (error) {
-                        return callback(error);
-                    }
 
-                    return callback(null);
-                }
-            );
-        }
-    );
+            return callback(null);
+        });
+    });
 }
 ```
 
@@ -816,25 +807,19 @@ function createMediaElements(pipeline, ws, callback) {
 
 ```javascript
 function connectMediaElements(webRtcEndpoint, filter, callback) {
-    webRtcEndpoint.connect(
-        filter,
-        error => {
+    webRtcEndpoint.connect(filter, (error) => {
+        if (error) {
+            return callback(error);
+        }
+
+        filter.connect(webRtcEndpoint, (error) => {
             if (error) {
                 return callback(error);
             }
 
-            filter.connect(
-                webRtcEndpoint,
-                error => {
-                    if (error) {
-                        return callback(error);
-                    }
-
-                    return callback(null);
-                }
-            );
-        }
-    );
+            return callback(null);
+        });
+    });
 }
 ```