mirror of
https://github.com/sipeed/picoclaw.git
synced 2026-06-12 18:08:54 +00:00
c513ad22d7
- move chat controller, state, protocol, history, and websocket logic into a dedicated chat feature module - improve chat reconnection, session hydration, and send gating based on actual websocket state - preserve gateway status during transient SSE disconnects and update stop state immediately - generate wss websocket URLs behind HTTPS proxies and add backend tests for forwarded proto handling
58 lines
1.3 KiB
TypeScript
58 lines
1.3 KiB
TypeScript
export function normalizeWsUrlForBrowser(wsUrl: string): string {
|
|
let finalWsUrl = wsUrl
|
|
|
|
try {
|
|
const parsedUrl = new URL(wsUrl)
|
|
const isLocalHost =
|
|
parsedUrl.hostname === "localhost" ||
|
|
parsedUrl.hostname === "127.0.0.1" ||
|
|
parsedUrl.hostname === "0.0.0.0"
|
|
const isBrowserLocal =
|
|
window.location.hostname === "localhost" ||
|
|
window.location.hostname === "127.0.0.1"
|
|
|
|
if (isLocalHost && !isBrowserLocal) {
|
|
parsedUrl.hostname = window.location.hostname
|
|
finalWsUrl = parsedUrl.toString()
|
|
}
|
|
} catch (error) {
|
|
console.warn("Could not parse ws_url:", error)
|
|
}
|
|
|
|
return finalWsUrl
|
|
}
|
|
|
|
export function invalidateSocket(socket: WebSocket | null) {
|
|
if (!socket) {
|
|
return
|
|
}
|
|
|
|
socket.onopen = null
|
|
socket.onmessage = null
|
|
socket.onclose = null
|
|
socket.onerror = null
|
|
socket.close()
|
|
}
|
|
|
|
export function isCurrentSocket({
|
|
socket,
|
|
currentSocket,
|
|
generation,
|
|
currentGeneration,
|
|
sessionId,
|
|
currentSessionId,
|
|
}: {
|
|
socket: WebSocket
|
|
currentSocket: WebSocket | null
|
|
generation: number
|
|
currentGeneration: number
|
|
sessionId: string
|
|
currentSessionId: string
|
|
}): boolean {
|
|
return (
|
|
currentSocket === socket &&
|
|
generation === currentGeneration &&
|
|
sessionId === currentSessionId
|
|
)
|
|
}
|