ad/packmate
1
0
Fork 0
mirror of https://github.com/Av0idD4rk/packmate.git synced 2026-10-23 21:42:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

Исправил таймаут WS

Browse Source
This commit is contained in:
saber-nyan 2019-05-11 00:45:14 +03:00
parent 43591bd269
commit 824bec994c
No known key found for this signature in database
GPG Key ID: 7B069E9C295E6B4A
1 changed files with 28 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

49
src/views/Home.vue
View File

@ -40,29 +40,36 @@ export default {
reloadNavbar() { reloadNavbar() {
this.$refs.navbar.getCtfServices(); this.$refs.navbar.getCtfServices();
}, },
connectWs() {
const wsUrl = this.$store.state.apiUrl + '/ws';
this.socket = new SockJS(wsUrl);
this.socket.onopen = function () {
console.debug('WS connected');
};
this.socket.onclose = function (ev) {
console.debug('WS disconnected', ev.code, ev.reason);
if (ev.code === 1008) {
console.info('Security timeout, reconnecting...');
this.connectWs();
}
};
this.socket.onmessage = ev => {
const parsed = JSON.parse(ev.data);
console.debug('WS got message', parsed);
const currentPort = this.$route.params.servicePort;
if (!(currentPort === undefined || currentPort === parsed.service.port)) {
console.debug('not related port, skipping...');
return;
}
this.$refs.sidebar.onGotNewStream(parsed);
};
this.socket.onerror = function (ev) {
console.warn('WS err', ev);
};
},
}, },
mounted() { mounted() {
const wsUrl = this.$store.state.apiUrl + '/ws'; this.connectWs();
this.socket = new SockJS(wsUrl);
this.socket.onopen = function () {
console.debug('WS connected');
};
this.socket.onclose = function (ev) {
console.debug('WS disconnected', ev.code, ev.reason);
};
this.socket.onmessage = ev => {
const parsed = JSON.parse(ev.data);
console.debug('WS got message', parsed);
const currentPort = this.$route.params.servicePort;
if (!(currentPort === undefined || currentPort === parsed.service.port)) {
console.debug('not related port, skipping...');
return;
}
this.$refs.sidebar.onGotNewStream(parsed);
};
this.socket.onerror = function (ev) {
console.warn('WS err', ev);
};
}, },
beforeDestroy() { beforeDestroy() {
this.socket.close(); this.socket.close();