[{"_1":2,"_174":-5,"_175":-5},"loaderData",{"_3":4,"_92":93},"root",{"_5":6,"_35":36,"_65":66},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":32,"_33":20,"_34":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","notificationCount",0,"flagDenols","isTeamOrgMember","ENV",{"_37":38,"_39":40,"_41":42,"_43":44,"_45":46,"_47":48,"_49":50,"_51":52,"_53":54,"_55":56,"_57":58,"_59":60,"_61":62,"_63":64},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","4e736cb42e83c17c10d9f33412034a74b06f3941","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","API_URL","https://api.val.town","clerkState",{"_67":68},"__internal_clerk_state",{"_69":70,"_71":46,"_72":73,"_74":73,"_75":20,"_76":73,"_77":73,"_78":73,"_79":73,"_80":81,"_90":20,"_91":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_82":20,"_19":20,"_83":73,"_84":85,"_86":73,"_87":46,"_88":20,"_89":73},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_94":95,"_96":97,"_98":99,"_100":101,"_148":149,"_171":172,"_173":-5},"handle","wolf","name","ValTownEditor","path","ls/transports/LSWebSocketTransport.tsx","project",{"_102":103,"_96":97,"_104":105,"_106":-5,"_107":20,"_108":109,"_110":-5,"_111":-5,"_12":112,"_113":-5,"_114":20,"_115":-5,"_116":-5,"_117":32,"_14":118,"_119":120,"_121":120,"_122":123,"_124":123,"_125":123,"_126":120,"_127":120,"_23":128,"_131":132,"_134":135,"_147":20},"id","1873f9de-584c-11f0-92d0-f69ea79377d9","createdAt",["D",1751574429946],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","4555dd0e-707e-4444-acd3-049d206eb1db","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","bced381e-9ab2-4b55-929d-e7c5064f7f38","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_94":95,"_129":130},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvdXBsb2FkZWQvaW1nXzJvVXpPVUZRTjZGTGd2Q2t4c0RRdFpNZWJ5UCJ9","org",{"_94":95,"_133":130,"_12":112},"avatar","branch",{"_136":137,"_96":44,"_102":138,"_139":103,"_140":-5,"_141":-5,"_142":-5,"_143":-5,"_144":-5,"_145":97,"_146":95},"version",39,"187464b4-584c-11f0-92d0-f69ea79377d9","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_102":150,"_96":151,"_152":153,"_154":155,"_156":138,"_157":137,"_158":159,"_104":160,"_136":161,"_162":163,"_164":165,"_166":20,"_167":-5,"_98":168},"214fcc1c-584d-11f0-ac2c-f69ea79377d9","LSWebSocketTransport.tsx","fileId","9e6b4d58-584c-11f0-bc58-f69ea79377d9","parentId","ed1fd4f0-584c-11f0-9f14-f69ea79377d9","branchId","branchVersion","latest",true,["D",1751574874300],6,"fileType","script","content","import {\n createMessageConnection,\n type Disposable,\n Emitter,\n type MessageConnection,\n type MessageReader,\n type MessageWriter,\n type RAL,\n ReadableStreamMessageReader,\n WriteableStreamMessageWriter,\n} from \"npm:vscode-jsonrpc\";\nimport pTimeout from \"npm:p-timeout\";\nimport type { LSITransport } from \"./LSITransport\";\nimport WebSocket, {\n type CloseEvent,\n type ErrorEvent, // isomorphic-ws provides better type safety than vanilla WebSockets\n type Event,\n} from \"npm:isomorphic-ws\";\n\nconst MAX_CHUNK = 200 * 1024;\n\ninterface LSWebSocketTransportOptions {\n onWSOpen?: (e: Event) => void;\n onWSClose?: (e: CloseEvent) => void;\n onWSError?: (error: ErrorEvent) => void;\n onLSHealthy?: () => void;\n}\n\nexport class LSWebSocketTransport implements LSITransport {\n public connection?: WebSocket;\n public uri: string;\n\n public onWSOpen?: (e: Event) => void;\n public onWSClose?: (e: CloseEvent) => void;\n public onWSError?: (error: ErrorEvent) => void;\n public onLSHealthy?: () => void;\n\n #messageConnection: MessageConnection | null = null;\n #connectingPromise: Promise | null = null;\n #disposed = false;\n\n #notifyBuffer: [string, unknown][] = [];\n #requestBuffer: [\n string,\n unknown,\n number | undefined,\n (result: unknown) => void,\n (error: unknown) => void,\n ][] = [];\n\n #errorCallbacks: ((error: Error) => void)[] = [];\n #notifyCallbacks: ((method: string, params: unknown) => void)[] = [];\n #requestCallbacks: ((method: string, params: unknown) => void)[] = [];\n\n constructor(\n uri: string,\n {\n onWSOpen,\n onWSClose,\n onLSHealthy,\n onWSError,\n }: LSWebSocketTransportOptions = {},\n ) {\n this.uri = uri.replace(\"http\", \"ws\");\n this.onLSHealthy = onLSHealthy;\n this.onWSOpen = onWSOpen;\n this.onWSClose = onWSClose;\n this.onWSError = onWSError;\n }\n\n async sendRequest(\n method: string,\n params?: unknown,\n timeout?: number,\n ): Promise {\n this.#errorIfDisposed();\n\n if (this.#messageConnection) {\n const promise = this.#messageConnection.sendRequest(method, params);\n return timeout ? pTimeout(promise, { milliseconds: timeout }) : promise;\n } else {\n return new Promise((resolve, reject) => {\n this.#requestBuffer.push([method, params, timeout, resolve, reject]);\n });\n }\n }\n\n public onRequest(\n handler: (method: string, params: unknown) => unknown,\n ): void {\n this.#errorIfDisposed();\n this.#requestCallbacks.push(handler);\n }\n\n public sendNotification(method: string, params?: unknown): void {\n this.#errorIfDisposed();\n\n if (this.#messageConnection) {\n this.#messageConnection.sendNotification(method, params);\n } else {\n this.#notifyBuffer.push([method, params]);\n }\n }\n\n public onNotification(\n handler: (method: string, params: unknown) => void,\n ): void {\n this.#errorIfDisposed();\n this.#notifyCallbacks.push(handler);\n }\n\n public onError(handler: (error: unknown) => void): void {\n this.#errorIfDisposed();\n this.#errorCallbacks.push(handler);\n }\n\n public dispose(): void {\n this.connection?.close(1000, \"Transport disposed\");\n this.#disposed = true;\n }\n\n public close(): void {\n // Impl for LSITransport.close\n this.dispose();\n }\n\n public connected(): boolean {\n return this.connection?.readyState === WebSocket.OPEN;\n }\n\n public connect(): Promise {\n this.#errorIfDisposed();\n\n if (this.#connectingPromise) {\n return this.#connectingPromise;\n }\n\n if (this.connected()) {\n return Promise.resolve();\n }\n\n this.connection = new WebSocket(this.uri);\n\n this.#connectingPromise = new Promise((resolve, reject) => {\n const onOpenCb = (e: Event) => {\n this.#errorIfDisposed();\n\n this.connection?.removeEventListener(\"open\", onOpenCb);\n this.connection?.removeEventListener(\"error\", onErrorCb);\n\n this.#setupMessageConnection();\n this.onWSOpen?.(e);\n this.#connectingPromise = null;\n resolve();\n };\n this.connection?.addEventListener(\"open\", onOpenCb);\n\n const onCloseCb = (e: CloseEvent) => {\n this.#errorIfDisposed();\n\n this.connection?.removeEventListener(\"close\", onCloseCb);\n this.#messageConnection?.dispose();\n this.#messageConnection = null;\n this.onWSClose?.(e);\n this.dispose();\n };\n this.connection?.addEventListener(\"close\", onCloseCb);\n\n const onErrorCb = (error: ErrorEvent) => {\n this.#errorIfDisposed();\n\n this.connection?.removeEventListener(\"open\", onOpenCb);\n this.connection?.removeEventListener(\"error\", onErrorCb);\n this.onWSError?.(error);\n this.#connectingPromise = null;\n reject(error);\n };\n this.connection?.addEventListener(\"error\", onErrorCb);\n });\n\n return this.#connectingPromise;\n }\n\n public async sendHeartbeat(timeout = 3_000): Promise {\n try {\n const resp = await this.sendRequest(\"vtlsp/ping\", {}, timeout);\n return Boolean(\n resp &&\n typeof resp === \"object\" &&\n resp !== null &&\n \"status\" in resp &&\n resp.status === \"pong\",\n );\n } catch {\n return false;\n }\n }\n\n #errorIfDisposed(): void {\n if (this.#disposed) {\n throw new WebSocketJSONRPCClientDisposedError();\n }\n }\n\n #setupMessageConnection(): void {\n if (!this.connection || this.connection.readyState !== WebSocket.OPEN) {\n return;\n }\n\n const { reader, writer } = createWebSocketConnection(this.connection);\n this.#messageConnection = createMessageConnection(reader, writer);\n\n this.#messageConnection.onNotification((method, params) => {\n if (method === \"vtlsp/didFinishCaching\") {\n this.onLSHealthy?.();\n }\n\n for (const cb of this.#notifyCallbacks) {\n try {\n cb(method, params);\n } catch (error) {\n for (const errorCb of this.#errorCallbacks) {\n errorCb(error as Error);\n }\n }\n }\n });\n\n this.#messageConnection.onRequest((method, params) => {\n for (const cb of this.#requestCallbacks) {\n try {\n cb(method, params);\n } catch (error) {\n for (const errorCb of this.#errorCallbacks) {\n errorCb(error as Error);\n }\n }\n }\n });\n\n this.#messageConnection.listen();\n\n for (const [method, params] of this.#notifyBuffer) {\n this.#messageConnection.sendNotification(method, params);\n }\n this.#notifyBuffer = [];\n\n for (\n const [method, params, timeout, resolve, reject] of this\n .#requestBuffer\n ) {\n try {\n const promise = this.#messageConnection.sendRequest(method, params);\n const finalPromise = timeout\n ? pTimeout(promise, { milliseconds: timeout })\n : promise;\n finalPromise.then(resolve).catch(reject);\n } catch (error) {\n reject(error);\n }\n }\n this.#requestBuffer = [];\n }\n}\n\nclass WebSocketJSONRPCClientDisposedError extends Error {\n constructor() {\n super(\"WebSocketJSONRPCClient has been disposed\");\n this.name = \"WebSocketJSONRPCClientDisposedError\";\n }\n}\n\nclass WebSocketWritableStream implements RAL.WritableStream {\n private socket: WebSocket;\n private errorEmitter = new Emitter();\n private closeEmitter = new Emitter();\n\n constructor(socket: WebSocket) {\n this.socket = socket;\n this.socket.binaryType = \"arraybuffer\";\n this.socket.addEventListener(\"error\", (event) => {\n this.errorEmitter.fire(new Error(`WebSocket error: ${event}`));\n });\n this.socket.addEventListener(\"close\", () => {\n this.closeEmitter.fire(undefined);\n });\n }\n\n async write(data: string | Uint8Array, encoding?: string): Promise {\n if (this.socket.readyState !== WebSocket.OPEN) {\n throw new Error(\"WebSocket is not open\");\n }\n\n let uint8Data: Uint8Array;\n if (typeof data === \"string\") {\n if (encoding && [\"utf-8\", \"acii\"].includes(encoding.toLowerCase())) {\n throw new Error(`Unsupported encoding: ${encoding}`);\n }\n uint8Data = new TextEncoder().encode(data);\n } else {\n uint8Data = new Uint8Array(\n data.buffer.slice(data.byteOffset, data.byteOffset + data.byteLength),\n );\n }\n\n for (const chunk of chunkByteArray(uint8Data, MAX_CHUNK)) {\n this.socket.send(chunk.buffer);\n }\n }\n\n public end(): void {\n this.socket.close();\n }\n\n public onError(callback: (error: Error) => void): Disposable {\n return this.errorEmitter.event(callback);\n }\n\n public onClose(callback: () => void): Disposable {\n return this.closeEmitter.event(callback);\n }\n\n public onEnd(callback: () => void): Disposable {\n return this.closeEmitter.event(callback);\n }\n}\n\nclass WebSocketReadableStream implements RAL.ReadableStream {\n private dataEmitter = new Emitter();\n private errorEmitter = new Emitter();\n private closeEmitter = new Emitter();\n\n constructor(socket: WebSocket) {\n socket.binaryType = \"arraybuffer\";\n socket.addEventListener(\"message\", (event) => {\n try {\n let data: Uint8Array;\n if (event.data instanceof ArrayBuffer) {\n data = new Uint8Array(event.data);\n } else if (typeof event.data === \"string\") {\n data = new TextEncoder().encode(event.data);\n } else if (event.data instanceof Blob) {\n event.data\n .arrayBuffer()\n .then((buffer) => {\n const uint8Data = new Uint8Array(buffer);\n this.dataEmitter.fire(uint8Data);\n })\n .catch((e) => {\n this.errorEmitter.fire(e);\n });\n return;\n } else {\n throw new Error(\n `Unsupported message data format: ${typeof event.data}`,\n );\n }\n this.dataEmitter.fire(data);\n } catch (e) {\n this.errorEmitter.fire(e as Error);\n }\n });\n\n socket.addEventListener(\"error\", (event) => {\n this.errorEmitter.fire(new Error(`WebSocket error: ${event}`));\n });\n\n socket.addEventListener(\"close\", () => {\n this.closeEmitter.fire(undefined);\n });\n }\n\n public onData(callback: (data: Uint8Array) => void): Disposable {\n return this.dataEmitter.event(callback);\n }\n\n public onError(callback: (error: Error) => void): Disposable {\n return this.errorEmitter.event(callback);\n }\n\n public onClose(callback: () => void): Disposable {\n return this.closeEmitter.event(callback);\n }\n\n public onEnd(callback: () => void): Disposable {\n return this.closeEmitter.event(callback);\n }\n}\n\nfunction createWebSocketConnection(socket: WebSocket): {\n reader: MessageReader;\n writer: MessageWriter;\n} {\n const readableStream = new WebSocketReadableStream(socket);\n const reader = new ReadableStreamMessageReader(readableStream);\n\n const writerStream = new WebSocketWritableStream(socket);\n const writer = new WriteableStreamMessageWriter(writerStream);\n\n return { reader, writer };\n}\n\n// copied from vtlsp/lsp-server/src/lib/lsp/WSStream.ts\nfunction* chunkByteArray(\n byteArray: Uint8Array,\n chunkSize: number,\n): Generator {\n const totalSize = byteArray.byteLength;\n for (let i = 0; i < totalSize; i += chunkSize) {\n yield byteArray.slice(i, Math.min(totalSize, i + chunkSize));\n }\n}","deleted","label",[169,170,151],"ls","transports","permalink","https://www.val.town/x/wolf/ValTownEditor/code/ls/transports/LSWebSocketTransport.tsx","extension","actionData","errors"]