1 files changed, 122 insertions, 0 deletions
diff --git a/ecomp-sdk-app/src/main/webapp/app/fusion/scripts/socket/peerBroadcast.js b/ecomp-sdk-app/src/main/webapp/app/fusion/scripts/socket/peerBroadcast.js
new file mode 100644
index 000000000..46fa5c923
--- /dev/null
+++ b/ecomp-sdk-app/src/main/webapp/app/fusion/scripts/socket/peerBroadcast.js
@@ -0,0 +1,122 @@
+/*-
+ * ================================================================================
+ * eCOMP Portal SDK
+ * ================================================================================
+ * Copyright (C) 2017 AT&T Intellectual Property
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ================================================================================
+ */
+
+var output = $('#peerBroadcastSection');
+var websocket = '';
+var currentUser = '';
+var remoteUser = '';
+var f = '';
+var popupService;
+
+function setPopupService(_popupService) {
+	 popupService = _popupService;
+}
+
+function socketSetup(initialPageVisit,_currentUser, _remoteUser, _f) {
+	
+
+
+	if( true) {
+		  
+		var href = window.location.href;
+	    var hostPatt = new RegExp(window.location.host +"/[^/]*");
+	    var res = hostPatt.exec(href);
+	    var protocol = window.location.protocol.replace("http","ws");
+	    
+	    var signalingServerPath = protocol + "//" + res + "/contact";
+		  var wsUri = signalingServerPath;
+		  console.log("Connecting to " + wsUri);
+		  websocket = new WebSocket(wsUri);
+		  //localStorage.notifySocket = JSON.stringify(websocket);
+		  //window.top.notifySocket = websocket;
+		  
+		  currentUser = _currentUser;
+		  remoteUser = _remoteUser;
+		  f = socketSend;
+		 
+		  
+	}
+	
+	//var websocket = JSON.parse(localStorage.notifySocket || "{}") ;
+	if( websocket != null) {
+		websocket.onopen = function(evt) { onOpen(evt); };
+		websocket.onmessage = function(evt) { onMessage(evt); };
+		websocket.onerror = function(evt) { onError(evt); };
+	
+	}
+	
+	//if(f != undefined)
+	 // f();
+	
+	//window.top.notifySocket.send("");
+}
+
+
+function socketSend(currentUser, remoteUser) {
+	
+
+
+	 websocket.send(JSON.stringify({
+         from: currentUser,
+         to: remoteUser
+     }));
+	
+	//window.top.notifySocket.send("");
+}
+
+
+
+
+function onOpen(evt) {
+    console.log("onOpen");
+    //writeToScreen("CONNECTED");
+    
+    if(f != undefined)
+		f(currentUser, remoteUser);
+    
+}
+
+function onMessage(evt) {
+    if (typeof evt.data == "string") {
+        writeToScreen("RECEIVED (text): " + evt.data);
+        
+        if(popupService != undefined) {
+        	popupService.showMessage("Call Request","You are being contacted by " + JSON.parse(evt.data).from + ". Please click on the online icon and then click view");
+        	
+        }
+        //if (confirm("You are being contacted by " + JSON.parse(evt.data).from )) {
+           
+	    //}
+        
+    } else {
+        writeToScreen("RECEIVED (binary): " + evt.data);
+    }
+}
+
+function onError(evt) {
+    writeToScreen('<span style="color: red;">ERROR:</span> ' + evt.data);
+}
+
+function writeToScreen(message) {
+    var pre = document.createElement("p");
+    pre.style.wordWrap = "break-word";
+    pre.innerHTML = message;
+    output.append(pre);
+}