gubes mirror. how does this work
covid
+42
-26
+16
-15
core/connection.ts
+16
-15
core/connection.ts
···
294
294
return this.nickname;
295
295
}
296
296
297
-
try_and_reconnect = false;
298
297
retry_interval = 0;
299
298
retry_count = 0;
300
299
$recovering = signal(false);
301
300
302
301
protected async recover_connection() {
303
-
if (!this.try_and_reconnect) {
304
-
return;
305
-
}
306
-
if (this.retry_count > 5) {
307
-
this.try_and_reconnect = false;
302
+
console.log("Recovering connection");
303
+
this.$recovering.value = true;
304
+
try {
305
+
await this.connect().catch(x => {});
306
+
} catch {}
307
+
308
+
if (this.retry_count > 5
309
+
|| this.$state.value == ConnectionState.Connected
310
+
) {
308
311
this.$recovering.value = false;
309
312
this.retry_count = 0;
310
313
this.retry_interval = 0;
311
-
312
-
return;
314
+
} else {
315
+
this.retry_interval += 10000;
316
+
this.retry_count += 1;
317
+
318
+
console.log(`Reconnection failed, trying again in ${this.retry_interval}ms`)
319
+
320
+
setTimeout(() => this.recover_connection(), this.retry_interval);
313
321
}
314
-
315
-
setTimeout(() => {
316
-
this.$recovering.value = true;
317
-
318
-
this.connect();
319
-
this.retry_interval += 10000;
320
-
}, this.retry_interval);
321
322
}
322
323
323
324
/**
+9
-2
core/queue.ts
+9
-2
core/queue.ts
···
76
76
77
77
export class Deferred<T = void, E = void> {
78
78
promise: Promise<T>;
79
+
done = false;
79
80
resolve!: (message: T) => void;
80
81
reject!: (message: E) => void;
81
82
82
83
constructor() {
83
84
this.promise = new Promise((resolve, reject) => {
84
-
this.resolve = resolve;
85
-
this.reject = reject;
85
+
this.resolve = (x) => {
86
+
resolve(x);
87
+
this.done = true;
88
+
};
89
+
this.reject = (x) => {
90
+
reject(x);
91
+
this.done = true;
92
+
};
86
93
})
87
94
}
88
95
}
+12
-6
core/ws/connection.ts
+12
-6
core/ws/connection.ts
···
40
40
this.ws.onopen = () => { this.#register(resolver) };
41
41
this.ws.onmessage = (ev) => this.handle_incoming(ev.data as string);
42
42
this.ws.onclose = () => this.handle_disconnect();
43
-
this.ws.onerror = () => this.socket_error();
43
+
this.ws.onerror = () => {
44
+
if (!resolver.done) resolver.reject();
45
+
this.socket_error();
46
+
}
44
47
45
48
return resolver.promise;
46
49
}
···
117
120
}
118
121
119
122
private socket_error() {
120
-
console.log("hi")
123
+
console.log("Socket Error Moment!!!!")
124
+
125
+
let reconnect = this.$state.value == ConnectionState.Connected;
121
126
122
-
this.$state.value = ConnectionState.Failed;
123
127
this.$error.value = [ConnectionErrorCode.SocketError];
124
-
125
-
// this.try_and_reconnect = true;
126
-
// this.recover_connection();
128
+
this.disconnect(ConnectionState.Failed);
129
+
130
+
if (reconnect) {
131
+
this.recover_connection();
132
+
}
127
133
}
128
134
129
135
async disconnect(target_state: ConnectionState = ConnectionState.Disconnected) {
+1
-1
neo/package.json
+1
-1
neo/package.json
+1
neo/src/buffer/view.tsx
+1
neo/src/buffer/view.tsx
-1
neo/src/chat/adapters.ts
-1
neo/src/chat/adapters.ts