jeirmeister/Cockatrice
1
0
Fork 0
mirror of https://github.com/Cockatrice/Cockatrice.git synced 2026-04-27 07:48:01 -07:00
Code Issues Projects Releases Packages Wiki Activity Actions

cleanup testing utilities, documentation, and AI commentary

Browse source
This commit is contained in:
seavor 2026-04-18 15:32:50 -05:00
parent bd2382c94e
commit ef6cea6f6c
150 changed files with 891 additions and 1233 deletions
Download patch file Download diff file Expand all files Collapse all files

17
webclient/src/websocket/services/WebSocketService.ts
View file

@ -1,9 +1,9 @@
import { Subject } from 'rxjs';
import { StatusEnum } from '../interfaces/StatusEnum';
import { StatusEnum } from '../types/StatusEnum';
import { KeepAliveService } from './KeepAliveService';
import { CLIENT_OPTIONS } from '../config';
import type { ConnectTarget } from '../interfaces/WebClientConfig';
import type { ConnectTarget } from '../types/WebClientConfig';
export interface WebSocketServiceConfig {
keepAliveFn: (pingReceived: () => void) => void;
@ -16,7 +16,7 @@ export class WebSocketService {
private config: WebSocketServiceConfig;
private keepAliveService: KeepAliveService;
private errorFired = false;
private hasReportedError = false;
public message$: Subject<MessageEvent> = new Subject();
@ -68,7 +68,7 @@ export class WebSocketService {
socket.onopen = () => {
clearTimeout(connectionTimer);
this.errorFired = false;
this.hasReportedError = false;
this.config.onStatusChange(StatusEnum.CONNECTED, 'Connected');
this.keepAliveService.startPingLoop(this.keepalive, (pingReceived: () => void) => {
@ -77,16 +77,17 @@ export class WebSocketService {
};
socket.onclose = () => {
// dont overwrite failure messages
if (!this.errorFired) {
// @critical onerror + onclose both fire on failed connects; don't overwrite the richer error status.
// See .github/instructions/webclient.instructions.md#websocket-lifecycle.
if (!this.hasReportedError) {
this.config.onStatusChange(StatusEnum.DISCONNECTED, 'Connection Closed');
}
this.errorFired = false;
this.hasReportedError = false;
this.keepAliveService.endPingLoop();
};
socket.onerror = () => {
this.errorFired = true;
this.hasReportedError = true;
this.config.onStatusChange(StatusEnum.DISCONNECTED, 'Connection Failed');
this.config.onConnectionFailed();
};