742 lines
23 KiB
JavaScript
742 lines
23 KiB
JavaScript
|
// importScripts('sockjs.js');
|
||
|
|
// import { getToken } from '@/utils/auth';
|
||
|
|
// import SockJS from 'sockjs-client';
|
||
|
|
|
||
|
|
// const websocketUrl = 'ws://test.joylink.club/jlcloud/joylink-websocket?token=';
|
||
|
|
// const websocketUrl = `http://192.168.3.6:9000/joylink-websocket?token=`;
|
||
|
|
let websocketUrl = null;
|
||
|
|
let token = null;
|
||
|
|
var StompClient = function (headers, token) {
|
||
|
|
const scope = this;
|
||
|
|
this.url = websocketUrl + token;
|
||
|
|
this.headers = headers || {};
|
||
|
|
this.connect();
|
||
|
|
};
|
||
|
|
|
||
|
|
StompClient.prototype = {
|
||
|
|
socket: null,
|
||
|
|
|
||
|
|
clientIns: null,
|
||
|
|
|
||
|
|
subscribeMap: null,
|
||
|
|
|
||
|
|
url: '',
|
||
|
|
|
||
|
|
status: false,
|
||
|
|
|
||
|
|
sockStatus: 0,
|
||
|
|
|
||
|
|
headers: {
|
||
|
|
// 'X-Token': getToken()
|
||
|
|
},
|
||
|
|
|
||
|
|
count: 0,
|
||
|
|
|
||
|
|
topic: '',
|
||
|
|
|
||
|
|
onmessage: null,
|
||
|
|
|
||
|
|
checkTimer: null,
|
||
|
|
|
||
|
|
// 连接服务端
|
||
|
|
connect() {
|
||
|
|
return new Promise((resolve, reject) => {
|
||
|
|
try {
|
||
|
|
// 断开已有连接
|
||
|
|
if (this.clientIns && this.clientIns.connected) {
|
||
|
|
this.clientIns.disconnect();
|
||
|
|
this.clientIns = null;
|
||
|
|
}
|
||
|
|
|
||
|
|
// // 建立连接对象（还未发起连接）
|
||
|
|
// this.socket = new SockJS(websocketUrl + token);
|
||
|
|
//
|
||
|
|
// // 获取 STOMP 子协议的客户端对象
|
||
|
|
// this.clientIns = Stomp.over(this.socket);
|
||
|
|
|
||
|
|
this.websocket = new WebSocket(this.url.replace(/https/, 'wss').replace(/http/, 'ws'));
|
||
|
|
|
||
|
|
this.clientIns = Stomp.over(this.websocket);
|
||
|
|
|
||
|
|
this.closeStompDebug();
|
||
|
|
|
||
|
|
// 向服务器发起websocket连接并发送CONNECT帧
|
||
|
|
this.clientIns.connect({ 'X-Token': token }, () => {
|
||
|
|
console.info('连接成功.');
|
||
|
|
this.count = 0;
|
||
|
|
this.status = true;
|
||
|
|
|
||
|
|
// 恢复订阅
|
||
|
|
if (this.topic && this.onmessage) {
|
||
|
|
this.unsubscribe(this.topic);
|
||
|
|
this.subscribe(this.topic, this.onmessage, this.headers);
|
||
|
|
}
|
||
|
|
|
||
|
|
resolve(this);
|
||
|
|
}, () => {
|
||
|
|
if (this.checkTimer) {
|
||
|
|
clearInterval(this.checkTimer);
|
||
|
|
this.checkTimer = null;
|
||
|
|
}
|
||
|
|
|
||
|
|
});
|
||
|
|
} catch (err) {
|
||
|
|
reject(err);
|
||
|
|
}
|
||
|
|
});
|
||
|
|
|
||
|
|
},
|
||
|
|
logOut(err) {
|
||
|
|
if (err.code == 50008 || err.code == 50014) {
|
||
|
|
this.url = websocketUrl + token;
|
||
|
|
this.status = false;
|
||
|
|
this.count++;
|
||
|
|
this.reconnect(this.count);
|
||
|
|
}
|
||
|
|
},
|
||
|
|
// 恢复链接
|
||
|
|
reconnect(count) {
|
||
|
|
console.info(`尝试第${count || 1}次连接.`);
|
||
|
|
this.connect().then(() => { }).catch(() => {
|
||
|
|
this.count++;
|
||
|
|
this.reconnect(this.count);
|
||
|
|
});
|
||
|
|
},
|
||
|
|
|
||
|
|
closeStompDebug() {
|
||
|
|
if (this.clientIns) {
|
||
|
|
this.clientIns.debug = undefined;
|
||
|
|
|
||
|
|
}
|
||
|
|
},
|
||
|
|
|
||
|
|
// 订阅指定的topic
|
||
|
|
subscribe(topic, onmessage, headers) {
|
||
|
|
this.topic = topic;
|
||
|
|
this.onmessage = onmessage;
|
||
|
|
this.headers = headers;
|
||
|
|
if (this.status) {
|
||
|
|
if (!this.subscribeMap) {
|
||
|
|
this.subscribeMap = new Map();
|
||
|
|
}
|
||
|
|
|
||
|
|
try {
|
||
|
|
var subscription = this.subscribeMap.get(topic);
|
||
|
|
if (!subscription) {
|
||
|
|
subscription = this.clientIns.subscribe(topic, onmessage, headers); // 接收消息通过 subscribe() 方法实现
|
||
|
|
this.subscribeMap.set(topic, subscription);
|
||
|
|
}
|
||
|
|
} catch (err) {
|
||
|
|
setTimeout(() => {
|
||
|
|
this.subscribe(topic, onmessage, headers);
|
||
|
|
}, 300);
|
||
|
|
}
|
||
|
|
|
||
|
|
} else {
|
||
|
|
setTimeout(() => {
|
||
|
|
this.subscribe(topic, onmessage, headers);
|
||
|
|
}, 300);
|
||
|
|
}
|
||
|
|
},
|
||
|
|
|
||
|
|
unsubscribe(topic) {
|
||
|
|
if (this.subscribeMap) {
|
||
|
|
const subscription = this.subscribeMap.get(topic);
|
||
|
|
if (subscription) {
|
||
|
|
subscription.unsubscribe();
|
||
|
|
this.subscribeMap.delete(topic);
|
||
|
|
console.log('取消订阅');
|
||
|
|
}
|
||
|
|
}
|
||
|
|
},
|
||
|
|
|
||
|
|
// 发送消息
|
||
|
|
send(url, msg) {
|
||
|
|
if (this.status) {
|
||
|
|
if (msg) {
|
||
|
|
msg = JSON.stringify(msg);
|
||
|
|
}
|
||
|
|
try {
|
||
|
|
this.clientIns.send(url, {}, msg);
|
||
|
|
} catch (err) {
|
||
|
|
this.status = false;
|
||
|
|
this.send(url, msg);
|
||
|
|
}
|
||
|
|
} else {
|
||
|
|
setTimeout(() => {
|
||
|
|
this.send(url, msg);
|
||
|
|
}, 300);
|
||
|
|
}
|
||
|
|
},
|
||
|
|
|
||
|
|
disconnect() {
|
||
|
|
if (this.checkTimer) {
|
||
|
|
clearInterval(this.checkTimer);
|
||
|
|
this.checkTimer = null;
|
||
|
|
}
|
||
|
|
|
||
|
|
if (this.clientIns && this.clientIns.connected) {
|
||
|
|
this.clientIns.disconnect();
|
||
|
|
this.clientIns = null;
|
||
|
|
}
|
||
|
|
this.status = false;
|
||
|
|
console.log('断开连接');
|
||
|
|
}
|
||
|
|
|
||
|
|
};
|
||
|
|
|
||
|
|
var Byte; var Client; var Frame; var Stomp;
|
||
|
|
var __hasProp = {}.hasOwnProperty;
|
||
|
|
var __slice = [].slice;
|
||
|
|
|
||
|
|
Byte = {
|
||
|
|
LF: '\x0A',
|
||
|
|
NULL: '\x00'
|
||
|
|
};
|
||
|
|
|
||
|
|
Frame = (function() {
|
||
|
|
var unmarshallSingle;
|
||
|
|
|
||
|
|
function Frame(command, headers, body) {
|
||
|
|
this.command = command;
|
||
|
|
this.headers = headers != null ? headers : {};
|
||
|
|
this.body = body != null ? body : '';
|
||
|
|
}
|
||
|
|
|
||
|
|
Frame.prototype.toString = function() {
|
||
|
|
var lines, name, skipContentLength, value, _ref;
|
||
|
|
lines = [this.command];
|
||
|
|
skipContentLength = this.headers['content-length'] === false;
|
||
|
|
if (skipContentLength) {
|
||
|
|
delete this.headers['content-length'];
|
||
|
|
}
|
||
|
|
_ref = this.headers;
|
||
|
|
for (name in _ref) {
|
||
|
|
if (!__hasProp.call(_ref, name)) continue;
|
||
|
|
value = _ref[name];
|
||
|
|
lines.push('' + name + ':' + value);
|
||
|
|
}
|
||
|
|
if (this.body && !skipContentLength) {
|
||
|
|
lines.push('content-length:' + (Frame.sizeOfUTF8(this.body)));
|
||
|
|
}
|
||
|
|
lines.push(Byte.LF + this.body);
|
||
|
|
return lines.join(Byte.LF);
|
||
|
|
};
|
||
|
|
|
||
|
|
Frame.sizeOfUTF8 = function(s) {
|
||
|
|
if (s) {
|
||
|
|
return encodeURI(s).match(/%..|./g).length;
|
||
|
|
} else {
|
||
|
|
return 0;
|
||
|
|
}
|
||
|
|
};
|
||
|
|
|
||
|
|
unmarshallSingle = function(data) {
|
||
|
|
var body, chr, command, divider, headerLines, headers, i, idx, len, line, start, trim, _i, _j, _len, _ref, _ref1;
|
||
|
|
divider = data.search(RegExp('' + Byte.LF + Byte.LF));
|
||
|
|
headerLines = data.substring(0, divider).split(Byte.LF);
|
||
|
|
command = headerLines.shift();
|
||
|
|
headers = {};
|
||
|
|
trim = function(str) {
|
||
|
|
return str.replace(/^\s+|\s+$/g, '');
|
||
|
|
};
|
||
|
|
_ref = headerLines.reverse();
|
||
|
|
for (_i = 0, _len = _ref.length; _i < _len; _i++) {
|
||
|
|
line = _ref[_i];
|
||
|
|
idx = line.indexOf(':');
|
||
|
|
headers[trim(line.substring(0, idx))] = trim(line.substring(idx + 1));
|
||
|
|
}
|
||
|
|
body = '';
|
||
|
|
start = divider + 2;
|
||
|
|
if (headers['content-length']) {
|
||
|
|
len = parseInt(headers['content-length']);
|
||
|
|
body = ('' + data).substring(start, start + len);
|
||
|
|
} else {
|
||
|
|
chr = null;
|
||
|
|
for (i = _j = start, _ref1 = data.length; start <= _ref1 ? _j < _ref1 : _j > _ref1; i = start <= _ref1 ? ++_j : --_j) {
|
||
|
|
chr = data.charAt(i);
|
||
|
|
if (chr === Byte.NULL) {
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
body += chr;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
return new Frame(command, headers, body);
|
||
|
|
};
|
||
|
|
|
||
|
|
Frame.unmarshall = function(datas) {
|
||
|
|
var data;
|
||
|
|
return (function() {
|
||
|
|
var _i, _len, _ref, _results;
|
||
|
|
_ref = datas.split(RegExp('' + Byte.NULL + Byte.LF + '*'));
|
||
|
|
_results = [];
|
||
|
|
for (_i = 0, _len = _ref.length; _i < _len; _i++) {
|
||
|
|
data = _ref[_i];
|
||
|
|
if ((data != null ? data.length : void 0) > 0) {
|
||
|
|
_results.push(unmarshallSingle(data));
|
||
|
|
}
|
||
|
|
}
|
||
|
|
return _results;
|
||
|
|
})();
|
||
|
|
};
|
||
|
|
|
||
|
|
Frame.marshall = function(command, headers, body) {
|
||
|
|
var frame;
|
||
|
|
frame = new Frame(command, headers, body);
|
||
|
|
return frame.toString() + Byte.NULL;
|
||
|
|
};
|
||
|
|
|
||
|
|
return Frame;
|
||
|
|
|
||
|
|
})();
|
||
|
|
|
||
|
|
Client = (function() {
|
||
|
|
var now;
|
||
|
|
|
||
|
|
function Client(ws) {
|
||
|
|
this.ws = ws;
|
||
|
|
this.ws.binaryType = 'arraybuffer';
|
||
|
|
this.counter = 0;
|
||
|
|
this.connected = false;
|
||
|
|
this.heartbeat = {
|
||
|
|
outgoing: 10000,
|
||
|
|
incoming: 10000
|
||
|
|
};
|
||
|
|
this.maxWebSocketFrameSize = 16 * 1024;
|
||
|
|
this.subscriptions = {};
|
||
|
|
}
|
||
|
|
|
||
|
|
Client.prototype.debug = function(message) {
|
||
|
|
var _ref;
|
||
|
|
return typeof window !== 'undefined' && window !== null ? (_ref = window.console) != null ? _ref.log(message) : void 0 : void 0;
|
||
|
|
};
|
||
|
|
|
||
|
|
now = function() {
|
||
|
|
if (Date.now) {
|
||
|
|
return Date.now();
|
||
|
|
} else {
|
||
|
|
return new Date().valueOf;
|
||
|
|
}
|
||
|
|
};
|
||
|
|
|
||
|
|
Client.prototype._transmit = function(command, headers, body) {
|
||
|
|
var out;
|
||
|
|
out = Frame.marshall(command, headers, body);
|
||
|
|
if (typeof this.debug === 'function') {
|
||
|
|
this.debug('>>> ' + out);
|
||
|
|
}
|
||
|
|
while (true) {
|
||
|
|
if (out.length > this.maxWebSocketFrameSize) {
|
||
|
|
this.ws.send(out.substring(0, this.maxWebSocketFrameSize));
|
||
|
|
out = out.substring(this.maxWebSocketFrameSize);
|
||
|
|
if (typeof this.debug === 'function') {
|
||
|
|
this.debug('remaining = ' + out.length);
|
||
|
|
}
|
||
|
|
} else {
|
||
|
|
return this.ws.send(out);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
};
|
||
|
|
|
||
|
|
Client.prototype._setupHeartbeat = function(headers) {
|
||
|
|
var serverIncoming, serverOutgoing, ttl, v, _ref, _ref1;
|
||
|
|
if ((_ref = headers.version) !== Stomp.VERSIONS.V1_1 && _ref !== Stomp.VERSIONS.V1_2) {
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
_ref1 = (function() {
|
||
|
|
var _i, _len, _ref1, _results;
|
||
|
|
_ref1 = headers['heart-beat'].split(',');
|
||
|
|
_results = [];
|
||
|
|
for (_i = 0, _len = _ref1.length; _i < _len; _i++) {
|
||
|
|
v = _ref1[_i];
|
||
|
|
_results.push(parseInt(v));
|
||
|
|
}
|
||
|
|
return _results;
|
||
|
|
})(), serverOutgoing = _ref1[0], serverIncoming = _ref1[1];
|
||
|
|
if (!(this.heartbeat.outgoing === 0 || serverIncoming === 0)) {
|
||
|
|
ttl = Math.max(this.heartbeat.outgoing, serverIncoming);
|
||
|
|
if (typeof this.debug === 'function') {
|
||
|
|
this.debug('send PING every ' + ttl + 'ms');
|
||
|
|
}
|
||
|
|
this.pinger = Stomp.setInterval(ttl, (function(_this) {
|
||
|
|
return function() {
|
||
|
|
_this.ws.send(Byte.LF);
|
||
|
|
return typeof _this.debug === 'function' ? _this.debug('>>> PING') : void 0;
|
||
|
|
};
|
||
|
|
})(this));
|
||
|
|
}
|
||
|
|
if (!(this.heartbeat.incoming === 0 || serverOutgoing === 0)) {
|
||
|
|
ttl = Math.max(this.heartbeat.incoming, serverOutgoing);
|
||
|
|
if (typeof this.debug === 'function') {
|
||
|
|
this.debug('check PONG every ' + ttl + 'ms');
|
||
|
|
}
|
||
|
|
return this.ponger = Stomp.setInterval(ttl, (function(_this) {
|
||
|
|
return function() {
|
||
|
|
var delta;
|
||
|
|
delta = now() - _this.serverActivity;
|
||
|
|
if (delta > ttl * 2) {
|
||
|
|
if (typeof _this.debug === 'function') {
|
||
|
|
_this.debug('did not receive server activity for the last ' + delta + 'ms');
|
||
|
|
}
|
||
|
|
return _this.ws.close();
|
||
|
|
}
|
||
|
|
};
|
||
|
|
})(this));
|
||
|
|
}
|
||
|
|
};
|
||
|
|
|
||
|
|
Client.prototype._parseConnect = function() {
|
||
|
|
var args, connectCallback, errorCallback, headers;
|
||
|
|
args = arguments.length >= 1 ? __slice.call(arguments, 0) : [];
|
||
|
|
headers = {};
|
||
|
|
switch (args.length) {
|
||
|
|
case 2:
|
||
|
|
headers = args[0], connectCallback = args[1];
|
||
|
|
break;
|
||
|
|
case 3:
|
||
|
|
if (args[1] instanceof Function) {
|
||
|
|
headers = args[0], connectCallback = args[1], errorCallback = args[2];
|
||
|
|
} else {
|
||
|
|
headers.login = args[0], headers.passcode = args[1], connectCallback = args[2];
|
||
|
|
}
|
||
|
|
break;
|
||
|
|
case 4:
|
||
|
|
headers.login = args[0], headers.passcode = args[1], connectCallback = args[2], errorCallback = args[3];
|
||
|
|
break;
|
||
|
|
default:
|
||
|
|
headers.login = args[0], headers.passcode = args[1], connectCallback = args[2], errorCallback = args[3], headers.host = args[4];
|
||
|
|
}
|
||
|
|
return [headers, connectCallback, errorCallback];
|
||
|
|
};
|
||
|
|
|
||
|
|
Client.prototype.connect = function() {
|
||
|
|
var args, errorCallback, headers, out;
|
||
|
|
args = arguments.length >= 1 ? __slice.call(arguments, 0) : [];
|
||
|
|
out = this._parseConnect.apply(this, args);
|
||
|
|
headers = out[0], this.connectCallback = out[1], errorCallback = out[2];
|
||
|
|
if (typeof this.debug === 'function') {
|
||
|
|
this.debug('Opening Web Socket...');
|
||
|
|
}
|
||
|
|
this.ws.onmessage = (function(_this) {
|
||
|
|
return function(evt) {
|
||
|
|
var arr, c, client, data, frame, messageID, onreceive, subscription, _i, _len, _ref, _results;
|
||
|
|
data = typeof ArrayBuffer !== 'undefined' && evt.data instanceof ArrayBuffer ? (arr = new Uint8Array(evt.data), typeof _this.debug === 'function' ? _this.debug('--- got data length: ' + arr.length) : void 0, ((function() {
|
||
|
|
var _i, _len, _results;
|
||
|
|
_results = [];
|
||
|
|
for (_i = 0, _len = arr.length; _i < _len; _i++) {
|
||
|
|
c = arr[_i];
|
||
|
|
_results.push(String.fromCharCode(c));
|
||
|
|
}
|
||
|
|
return _results;
|
||
|
|
})()).join('')) : evt.data;
|
||
|
|
_this.serverActivity = now();
|
||
|
|
if (data === Byte.LF) {
|
||
|
|
if (typeof _this.debug === 'function') {
|
||
|
|
_this.debug('<<< PONG');
|
||
|
|
}
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
if (typeof _this.debug === 'function') {
|
||
|
|
_this.debug('<<< ' + data);
|
||
|
|
}
|
||
|
|
_ref = Frame.unmarshall(data);
|
||
|
|
_results = [];
|
||
|
|
for (_i = 0, _len = _ref.length; _i < _len; _i++) {
|
||
|
|
frame = _ref[_i];
|
||
|
|
switch (frame.command) {
|
||
|
|
case 'CONNECTED':
|
||
|
|
if (typeof _this.debug === 'function') {
|
||
|
|
_this.debug('connected to server ' + frame.headers.server);
|
||
|
|
}
|
||
|
|
_this.connected = true;
|
||
|
|
_this._setupHeartbeat(frame.headers);
|
||
|
|
_results.push(typeof _this.connectCallback === 'function' ? _this.connectCallback(frame) : void 0);
|
||
|
|
break;
|
||
|
|
case 'MESSAGE':
|
||
|
|
subscription = frame.headers.subscription;
|
||
|
|
onreceive = _this.subscriptions[subscription] || _this.onreceive;
|
||
|
|
if (onreceive) {
|
||
|
|
client = _this;
|
||
|
|
messageID = frame.headers['message-id'];
|
||
|
|
frame.ack = function(headers) {
|
||
|
|
if (headers == null) {
|
||
|
|
headers = {};
|
||
|
|
}
|
||
|
|
return client.ack(messageID, subscription, headers);
|
||
|
|
};
|
||
|
|
frame.nack = function(headers) {
|
||
|
|
if (headers == null) {
|
||
|
|
headers = {};
|
||
|
|
}
|
||
|
|
return client.nack(messageID, subscription, headers);
|
||
|
|
};
|
||
|
|
_results.push(onreceive(frame));
|
||
|
|
} else {
|
||
|
|
_results.push(typeof _this.debug === 'function' ? _this.debug('Unhandled received MESSAGE: ' + frame) : void 0);
|
||
|
|
}
|
||
|
|
break;
|
||
|
|
case 'RECEIPT':
|
||
|
|
_results.push(typeof _this.onreceipt === 'function' ? _this.onreceipt(frame) : void 0);
|
||
|
|
break;
|
||
|
|
case 'ERROR':
|
||
|
|
_results.push(typeof errorCallback === 'function' ? errorCallback(frame) : void 0);
|
||
|
|
break;
|
||
|
|
default:
|
||
|
|
_results.push(typeof _this.debug === 'function' ? _this.debug('Unhandled frame: ' + frame) : void 0);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
return _results;
|
||
|
|
};
|
||
|
|
})(this);
|
||
|
|
this.ws.onclose = (function(_this) {
|
||
|
|
return function() {
|
||
|
|
var msg;
|
||
|
|
msg = 'Whoops! Lost connection to ' + _this.ws.url;
|
||
|
|
if (typeof _this.debug === 'function') {
|
||
|
|
_this.debug(msg);
|
||
|
|
}
|
||
|
|
_this._cleanUp();
|
||
|
|
return typeof errorCallback === 'function' ? errorCallback(msg) : void 0;
|
||
|
|
};
|
||
|
|
})(this);
|
||
|
|
return this.ws.onopen = (function(_this) {
|
||
|
|
return function() {
|
||
|
|
if (typeof _this.debug === 'function') {
|
||
|
|
_this.debug('Web Socket Opened...');
|
||
|
|
}
|
||
|
|
headers['accept-version'] = Stomp.VERSIONS.supportedVersions();
|
||
|
|
headers['heart-beat'] = [_this.heartbeat.outgoing, _this.heartbeat.incoming].join(',');
|
||
|
|
return _this._transmit('CONNECT', headers);
|
||
|
|
};
|
||
|
|
})(this);
|
||
|
|
};
|
||
|
|
|
||
|
|
Client.prototype.disconnect = function(disconnectCallback, headers) {
|
||
|
|
if (headers == null) {
|
||
|
|
headers = {};
|
||
|
|
}
|
||
|
|
this._transmit('DISCONNECT', headers);
|
||
|
|
this.ws.onclose = null;
|
||
|
|
this.ws.close();
|
||
|
|
this._cleanUp();
|
||
|
|
return typeof disconnectCallback === 'function' ? disconnectCallback() : void 0;
|
||
|
|
};
|
||
|
|
|
||
|
|
Client.prototype._cleanUp = function() {
|
||
|
|
this.connected = false;
|
||
|
|
if (this.pinger) {
|
||
|
|
Stomp.clearInterval(this.pinger);
|
||
|
|
}
|
||
|
|
if (this.ponger) {
|
||
|
|
return Stomp.clearInterval(this.ponger);
|
||
|
|
}
|
||
|
|
};
|
||
|
|
|
||
|
|
Client.prototype.send = function(destination, headers, body) {
|
||
|
|
if (headers == null) {
|
||
|
|
headers = {};
|
||
|
|
}
|
||
|
|
if (body == null) {
|
||
|
|
body = '';
|
||
|
|
}
|
||
|
|
headers.destination = destination;
|
||
|
|
return this._transmit('SEND', headers, body);
|
||
|
|
};
|
||
|
|
|
||
|
|
Client.prototype.subscribe = function(destination, callback, headers) {
|
||
|
|
var client;
|
||
|
|
if (headers == null) {
|
||
|
|
headers = {};
|
||
|
|
}
|
||
|
|
if (!headers.id) {
|
||
|
|
headers.id = 'sub-' + this.counter++;
|
||
|
|
}
|
||
|
|
headers.destination = destination;
|
||
|
|
this.subscriptions[headers.id] = callback;
|
||
|
|
this._transmit('SUBSCRIBE', headers);
|
||
|
|
client = this;
|
||
|
|
return {
|
||
|
|
id: headers.id,
|
||
|
|
unsubscribe: function() {
|
||
|
|
return client.unsubscribe(headers.id);
|
||
|
|
}
|
||
|
|
};
|
||
|
|
};
|
||
|
|
|
||
|
|
Client.prototype.unsubscribe = function(id) {
|
||
|
|
delete this.subscriptions[id];
|
||
|
|
return this._transmit('UNSUBSCRIBE', {
|
||
|
|
id: id
|
||
|
|
});
|
||
|
|
};
|
||
|
|
|
||
|
|
Client.prototype.begin = function(transaction) {
|
||
|
|
var client, txid;
|
||
|
|
txid = transaction || 'tx-' + this.counter++;
|
||
|
|
this._transmit('BEGIN', {
|
||
|
|
transaction: txid
|
||
|
|
});
|
||
|
|
client = this;
|
||
|
|
return {
|
||
|
|
id: txid,
|
||
|
|
commit: function() {
|
||
|
|
return client.commit(txid);
|
||
|
|
},
|
||
|
|
abort: function() {
|
||
|
|
return client.abort(txid);
|
||
|
|
}
|
||
|
|
};
|
||
|
|
};
|
||
|
|
|
||
|
|
Client.prototype.commit = function(transaction) {
|
||
|
|
return this._transmit('COMMIT', {
|
||
|
|
transaction: transaction
|
||
|
|
});
|
||
|
|
};
|
||
|
|
|
||
|
|
Client.prototype.abort = function(transaction) {
|
||
|
|
return this._transmit('ABORT', {
|
||
|
|
transaction: transaction
|
||
|
|
});
|
||
|
|
};
|
||
|
|
|
||
|
|
Client.prototype.ack = function(messageID, subscription, headers) {
|
||
|
|
if (headers == null) {
|
||
|
|
headers = {};
|
||
|
|
}
|
||
|
|
headers['message-id'] = messageID;
|
||
|
|
headers.subscription = subscription;
|
||
|
|
return this._transmit('ACK', headers);
|
||
|
|
};
|
||
|
|
|
||
|
|
Client.prototype.nack = function(messageID, subscription, headers) {
|
||
|
|
if (headers == null) {
|
||
|
|
headers = {};
|
||
|
|
}
|
||
|
|
headers['message-id'] = messageID;
|
||
|
|
headers.subscription = subscription;
|
||
|
|
return this._transmit('NACK', headers);
|
||
|
|
};
|
||
|
|
|
||
|
|
return Client;
|
||
|
|
|
||
|
|
})();
|
||
|
|
|
||
|
|
Stomp = {
|
||
|
|
VERSIONS: {
|
||
|
|
V1_0: '1.0',
|
||
|
|
V1_1: '1.1',
|
||
|
|
V1_2: '1.2',
|
||
|
|
supportedVersions: function() {
|
||
|
|
return '1.1,1.0';
|
||
|
|
}
|
||
|
|
},
|
||
|
|
client: function(url, protocols) {
|
||
|
|
var klass, ws;
|
||
|
|
if (protocols == null) {
|
||
|
|
protocols = ['v10.stomp', 'v11.stomp'];
|
||
|
|
}
|
||
|
|
klass = Stomp.WebSocketClass || WebSocket;
|
||
|
|
ws = new klass(url, protocols);
|
||
|
|
return new Client(ws);
|
||
|
|
},
|
||
|
|
over: function(ws) {
|
||
|
|
return new Client(ws);
|
||
|
|
},
|
||
|
|
Frame: Frame
|
||
|
|
};
|
||
|
|
|
||
|
|
if (typeof exports !== 'undefined' && exports !== null) {
|
||
|
|
exports.Stomp = Stomp;
|
||
|
|
}
|
||
|
|
Stomp.setInterval = function(interval, f) {
|
||
|
|
return setInterval(f, interval);
|
||
|
|
};
|
||
|
|
Stomp.clearInterval = function(id) {
|
||
|
|
return clearInterval(id);
|
||
|
|
};
|
||
|
|
|
||
|
|
let data = null;
|
||
|
|
|
||
|
|
let topic = null;
|
||
|
|
let header = null;
|
||
|
|
let teststomp = null;
|
||
|
|
function timedCount() {
|
||
|
|
|
||
|
|
onmessage = (e) => {
|
||
|
|
|
||
|
|
if (e.data.type == 'init') {
|
||
|
|
topic = e.data.topic;
|
||
|
|
header = {'X-Token': e.data.token };
|
||
|
|
token = e.data.token;
|
||
|
|
websocketUrl = e.data.baseurl + '/joylink-websocket?token=';
|
||
|
|
|
||
|
|
}
|
||
|
|
|
||
|
|
if (e.data == 'connect') {
|
||
|
|
teststomp = new StompClient(header, token);
|
||
|
|
teststomp.subscribe(topic, callback, header);
|
||
|
|
}
|
||
|
|
|
||
|
|
if (e.data == 'off') {
|
||
|
|
teststomp.unsubscribe(topic);
|
||
|
|
}
|
||
|
|
|
||
|
|
};
|
||
|
|
function callback(Response) {
|
||
|
|
|
||
|
|
data = JSON.parse(Response.body);
|
||
|
|
|
||
|
|
console.log(data);
|
||
|
|
|
||
|
|
if(data.trainPosList){
|
||
|
|
postMessage(data);
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
|
||
|
|
if(data.type == "Train_Position_3D"){
|
||
|
|
postMessage(data);
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
if(data.type == "Train_Hmi_3D"){
|
||
|
|
|
||
|
|
postMessage(data);
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
|
||
|
|
if(data.type == 'TDT_3D'){
|
||
|
|
postMessage(data);
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
|
||
|
|
if(data.type == "DeviceCtrl_3D"){
|
||
|
|
if (data.body.type== 'SIGNAL') {
|
||
|
|
postMessage(data);
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
|
||
|
|
if (data.body.type== "PSD") {
|
||
|
|
postMessage(data);
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
if (data.body.type == "SWITCH") {
|
||
|
|
postMessage(data);
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
if (data.body.type == 'TRAIN_DOOR') {
|
||
|
|
postMessage(data);
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
if(data.type == "Device_Load_Destroy_3D"){
|
||
|
|
postMessage(data);
|
||
|
|
|
||
|
|
}
|
||
|
|
|
||
|
|
}
|
||
|
|
|
||
|
|
}
|
||
|
|
|
||
|
|
timedCount();
|