adam.goldsmith/PrinterStatus
2
0
Fork 0
mirror of https://github.com/ad1217/PrinterStatus synced 2024-11-24 08:23:48 -05:00
Code Issues 1 Releases Wiki Activity

server: Actively check for loss of connection to octoprint websocket

Browse Source 
Periodically `ping` the server, and check for returning `pong`s
This commit is contained in:
Adam Goldsmith 2021-10-28 02:34:28 -04:00
parent 51d3cbf41e
commit 009612898a
1 changed files with 46 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

76
server/server.ts
View File

@ -13,6 +13,10 @@ import * as octoprint from '../types/octoprint';
const PORT = process.env.PORT || 1234;
const PING_TIME = 10000;
type Timeout = ReturnType<typeof setTimeout>;
type configuration = {
printers: {
[key: string]: { address: string; apikey: string };
@ -69,9 +73,6 @@ class PrinterStatus {
webcamURL?: URL;
name?: string;
session_key?: string;
websocket?: WebSocket;
lastStatus?: messages.ExtendedMessage;
constructor(slug: string, address: string, apikey: string) {
@ -79,42 +80,43 @@ class PrinterStatus {
this.address = address;
this.apikey = apikey;
// async init
this.try_connect_websocket();
}
try_connect_websocket() {
this.connect_websocket().catch((e) => {
console.error('Failed to initialize "${this.slug}"');
throw e;
console.error(
`Failed to connect to "${this.slug}", attempting reconnection in 5 seconds`
);
console.error(e);
setTimeout(() => this.try_connect_websocket(), 5000);
});
}
async connect_websocket() {
// initial setup
if (!this.session_key) {
try {
const settings = await this.api_get('settings');
this.webcamURL = new URL(settings.webcam.streamUrl, this.address);
this.name = settings.appearance.name;
const settings = await this.api_get('settings');
this.webcamURL = new URL(settings.webcam.streamUrl, this.address);
this.name = settings.appearance.name;
// do passive login to get a session key from the API key
const login: octoprint.LoginResponse = await this.api_post('login', {
passive: 'true',
});
this.session_key = login.name + ':' + login.session;
} catch {
console.log(
`Failed to connect to "${this.slug}" attempting reconnection in 5 seconds`
);
setTimeout(() => this.connect_websocket(), 5000);
return;
}
}
// do passive login to get a session key from the API key
const login: octoprint.LoginResponse = await this.api_post('login', {
passive: 'true',
});
const session_key = login.name + ':' + login.session;
let pingSender: ReturnType<typeof setInterval>;
let pongTimeout: Timeout;
const url = new URL('/sockjs/websocket', this.address);
url.protocol = 'ws';
this.websocket = new WebSocket(url.toString());
this.websocket
let websocket = new WebSocket(url.toString());
websocket
.on('open', () => {
pingSender = setInterval(() => websocket.ping(), PING_TIME);
pongTimeout = this.heartbeat(websocket, pongTimeout);
console.log(`Connected to "${this.slug}"`);
this.websocket!.send(JSON.stringify({ auth: this.session_key }));
websocket.send(JSON.stringify({ auth: session_key }));
})
.on('message', (data: WebSocket.Data) => {
const event: octoprint.Message = JSON.parse(data as string);
@ -130,14 +132,28 @@ class PrinterStatus {
this.lastStatus = ext_event;
}
})
.on('pong', () => {
pongTimeout = this.heartbeat(websocket, pongTimeout);
})
.on('close', () => {
clearInterval(pingSender);
clearTimeout(pongTimeout);
console.log(
`Lost connection to "${this.slug}" attempting reconnection in 5 seconds`
`Lost connection to "${this.slug}", attempting reconnection in 5 seconds`
);
setTimeout(() => this.connect_websocket(), 5000);
setTimeout(() => this.try_connect_websocket(), 5000);
});
}
heartbeat(websocket: WebSocket, pongTimeout: Timeout): Timeout {
clearTimeout(pongTimeout);
return setTimeout(() => {
console.log(`Missed 2 heartbeats for "${this.slug}", disconnecting`);
websocket.terminate();
}, PING_TIME * 2);
}
async api_get(endpoint: string): Promise<any> {
const r = await fetch(new URL('/api/' + endpoint, this.address), {
headers: { 'X-Api-Key': this.apikey },