diff options
author | 2017-09-01 11:57:47 +0800 | |
---|---|---|
committer | 2017-09-01 11:57:58 +0800 | |
commit | 57dbba269d19bc59fad89160200bb2dbcccb9003 (patch) | |
tree | d466041ceffa2161124ca79a48b3e077777c74b8 /usecaseui-common/src/main/webapp/app/fusion/scripts/socket/peerBroadcast.js | |
parent | 4ff32341a0af1972b44a7410e76e9b231131e7ab (diff) |
Upload Monitor function code
Change-Id: I33ad76221b4cb771a298ff240245fc24be664efb
Issue-Id: USECASEUI-6
Signed-off-by: shentao <shentao@chinamobile.com>
Diffstat (limited to 'usecaseui-common/src/main/webapp/app/fusion/scripts/socket/peerBroadcast.js')
-rw-r--r-- | usecaseui-common/src/main/webapp/app/fusion/scripts/socket/peerBroadcast.js | 103 |
1 files changed, 103 insertions, 0 deletions
diff --git a/usecaseui-common/src/main/webapp/app/fusion/scripts/socket/peerBroadcast.js b/usecaseui-common/src/main/webapp/app/fusion/scripts/socket/peerBroadcast.js new file mode 100644 index 00000000..d056ce48 --- /dev/null +++ b/usecaseui-common/src/main/webapp/app/fusion/scripts/socket/peerBroadcast.js @@ -0,0 +1,103 @@ + +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); +} |