diff options
author | Timoney, Dan (dt5972) <dtimoney@att.com> | 2018-11-06 14:15:05 -0500 |
---|---|---|
committer | Timoney, Dan (dt5972) <dtimoney@att.com> | 2018-11-06 14:16:18 -0500 |
commit | d9642fafddbaa28789339e1989c4583af003a193 (patch) | |
tree | 0442af1ba4e793433fac5871dd8e69c98a056446 /dgbuilder/public/red/comms.js | |
parent | 33d814f236d4c3e4246851c810bdbbab5090abbb (diff) |
Fix license issues
Fix license definition in package.json files
Remove obsolete dgbuilder from SDNC (dgbuilder now in CCSDK)
Change-Id: Iee0bf9468f081c5957eae2e873efbea6fb6be354
Issue-ID: SDNC-489
Signed-off-by: Timoney, Dan (dt5972) <dtimoney@att.com>
Former-commit-id: 4e104ac4183dd46124753c4571939e765a124508
Diffstat (limited to 'dgbuilder/public/red/comms.js')
-rw-r--r-- | dgbuilder/public/red/comms.js | 93 |
1 files changed, 0 insertions, 93 deletions
diff --git a/dgbuilder/public/red/comms.js b/dgbuilder/public/red/comms.js deleted file mode 100644 index 64912476..00000000 --- a/dgbuilder/public/red/comms.js +++ /dev/null @@ -1,93 +0,0 @@ -/** - * Copyright 2014 IBM Corp. - * - * 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. - **/ - -RED.comms = (function() { - - var errornotification = null; - var subscriptions = {}; - var ws; - function connectWS() { - var path = location.hostname+":"+location.port+document.location.pathname; - path = path+(path.slice(-1) == "/"?"":"/")+"comms"; - path = "ws"+(document.location.protocol=="https:"?"s":"")+"://"+path; - ws = new WebSocket(path); - ws.onopen = function() { - if (errornotification) { - errornotification.close(); - errornotification = null; - } - for (var t in subscriptions) { - if (subscriptions.hasOwnProperty(t)) { - ws.send(JSON.stringify({subscribe:t})); - } - } - } - ws.onmessage = function(event) { - var msg = JSON.parse(event.data); - if (msg.topic) { - for (var t in subscriptions) { - if (subscriptions.hasOwnProperty(t)) { - var re = new RegExp("^"+t.replace(/([\[\]\?\(\)\\\\$\^\*\.|])/g,"\\$1").replace(/\+/g,"[^/]+").replace(/\/#$/,"(\/.*)?")+"$"); - if (re.test(msg.topic)) { - var subscribers = subscriptions[t]; - if (subscribers) { - for (var i=0;i<subscribers.length;i++) { - subscribers[i](msg.topic,msg.data); - } - } - } - } - } - } - }; - ws.onclose = function() { - if (errornotification == null) { - errornotification = RED.notify("<b>Error</b>: Lost connection to server","error",true); - } - setTimeout(connectWS,1000); - } - } - - function subscribe(topic,callback) { - if (subscriptions[topic] == null) { - subscriptions[topic] = []; - } - subscriptions[topic].push(callback); - if (ws && ws.readyState == 1) { - ws.send(JSON.stringify({subscribe:topic})); - } - } - - function unsubscribe(topic,callback) { - if (subscriptions.topic) { - for (var i=0;i<subscriptions.topic.length;i++) { - if (subscriptions.topic[i] === callback) { - subscriptions.topic.splice(i,1); - break; - } - } - if (subscriptions.topic.length === 0) { - delete subscriptions.topic; - } - } - } - - return { - connect: connectWS, - subscribe: subscribe, - unsubscribe:unsubscribe - } -})(); |