Skip to content

Commit 467cdba

Browse files
committed
trim
1 parent 0ddefd1 commit 467cdba

File tree

2 files changed

+27
-21
lines changed

2 files changed

+27
-21
lines changed

main.js

Lines changed: 25 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -4,30 +4,35 @@ import * as scheme from './scheme.min.js';
44
import * as x86asm from './x86asm.min.js';
55
import * as dockerfile from './dockerfile.min.js';
66

7-
let socket = new WebSocket("ws://localhost:8001/ws", "echo");
8-
socket.onopen = (ev) => {
9-
console.log("connected", ev);
10-
window.addEventListener('beforeunload', () => {
11-
console.log('closing', ev);
7+
function ws_connect() {
8+
const socket = new WebSocket("ws://localhost:8001/ws", "echo");
9+
socket.onopen = (ev) => {
10+
console.log("connected", ev);
11+
window.addEventListener('beforeunload', () => {
12+
console.log('closing', ev);
13+
socket.close();
14+
});
15+
}
16+
socket.onmessage = function(ev) {
17+
console.log('reloading', ev);
1218
socket.close();
13-
});
14-
}
15-
socket.onmessage = function(ev) {
16-
console.log('reloading', ev);
17-
socket.close();
18-
location.reload();
19-
}
20-
socket.onclose = function() {
21-
// TODO: Reconnect?
22-
console.log('closed');
19+
location.reload();
20+
}
21+
socket.onclose = function() {
22+
// TODO: Reconnect?
23+
console.log('closed');
24+
// Retry.
25+
setTimeout(connect, 2000);
26+
}
27+
socket.onerror = function(ev) {
28+
console.log('error', ev);
29+
}
2330
}
24-
socket.onerror = function(ev) {
25-
console.log('error', ev);
31+
32+
if (!location.origin.includes("github")) {
33+
ws_connect();
2634
}
2735

28-
// hljs.configure({
29-
// ignoreUnescapedHTML: true,
30-
// });
3136
hljs.registerLanguage("cmake", cmake.default);
3237
hljs.registerLanguage("scheme", scheme.default);
3338
hljs.registerLanguage("x86asm", x86asm.default);

src/main.rs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@ use std::{
1414
path::{Path, PathBuf},
1515
process::Command,
1616
thread,
17-
time::Instant,
17+
time::{Duration, Instant},
1818
};
1919

2020
use std::io::Write;
@@ -1423,6 +1423,7 @@ fn main() {
14231423
loop {
14241424
if let Ok(_) = erx.recv() {
14251425
println!("ws event");
1426+
thread::sleep(Duration::from_millis(200));
14261427
ws.send_text("reload").unwrap();
14271428
println!("ws event sent");
14281429
}

0 commit comments

Comments
 (0)