Claude
4b02652369
Applied yarn lint --fix to auto-correct: - Import spacing and sorting across multiple files - Trailing commas - Arrow function formatting - Object literal formatting - Indentation consistency - Removed unused imports (BaileysEventType, jest from tests) This commit addresses the linting errors reported in GitHub Actions: - Fixed import ordering in libsignal.ts - Fixed trailing commas in Defaults/index.ts - Cleaned up formatting across 63 files - Reduced line count by ~220 lines through formatting optimization Note: Some lint errors remain (75 errors, 239 warnings) mainly: - @typescript-eslint/no-unused-vars (variables assigned but not used) - @typescript-eslint/no-explicit-any (type safety warnings) These remaining issues are non-blocking and can be addressed incrementally. https://claude.ai/code/session_015R3U3kiprQiNTTNNt31Sg6
71 lines
1.8 KiB
TypeScript
71 lines
1.8 KiB
TypeScript
import WebSocket from 'ws'
|
|
import { DEFAULT_ORIGIN } from '../../Defaults'
|
|
import { AbstractSocketClient } from './types'
|
|
|
|
export class WebSocketClient extends AbstractSocketClient {
|
|
protected socket: WebSocket | null = null
|
|
|
|
get isOpen(): boolean {
|
|
return this.socket?.readyState === WebSocket.OPEN
|
|
}
|
|
get isClosed(): boolean {
|
|
return this.socket === null || this.socket?.readyState === WebSocket.CLOSED
|
|
}
|
|
get isClosing(): boolean {
|
|
return this.socket === null || this.socket?.readyState === WebSocket.CLOSING
|
|
}
|
|
get isConnecting(): boolean {
|
|
return this.socket?.readyState === WebSocket.CONNECTING
|
|
}
|
|
|
|
connect() {
|
|
if (this.socket) {
|
|
return
|
|
}
|
|
|
|
this.socket = new WebSocket(this.url, {
|
|
origin: DEFAULT_ORIGIN,
|
|
headers: this.config.options?.headers as {},
|
|
handshakeTimeout: this.config.connectTimeoutMs,
|
|
timeout: this.config.connectTimeoutMs,
|
|
agent: this.config.agent
|
|
})
|
|
|
|
// Set max listeners from config (default: 20)
|
|
// WARNING: 0 disables limit and allows potential memory leaks
|
|
const maxListeners = this.config.maxWebSocketListeners ?? 20
|
|
if (maxListeners === 0) {
|
|
this.config.logger?.warn('WebSocket setMaxListeners(0) allows UNLIMITED listeners - potential memory leak!')
|
|
}
|
|
|
|
this.socket.setMaxListeners(maxListeners)
|
|
|
|
const events = ['close', 'error', 'upgrade', 'message', 'open', 'ping', 'pong', 'unexpected-response']
|
|
|
|
for (const event of events) {
|
|
this.socket?.on(event, (...args: any[]) => this.emit(event, ...args))
|
|
}
|
|
}
|
|
|
|
async close() {
|
|
if (!this.socket) {
|
|
return
|
|
}
|
|
|
|
const closePromise = new Promise<void>(resolve => {
|
|
this.socket?.once('close', resolve)
|
|
})
|
|
|
|
this.socket.close()
|
|
|
|
await closePromise
|
|
|
|
this.socket = null
|
|
}
|
|
send(str: string | Uint8Array, cb?: (err?: Error) => void): boolean {
|
|
this.socket?.send(str, cb)
|
|
|
|
return Boolean(this.socket)
|
|
}
|
|
}
|