Function createKiloProxyHandler

services/cloud-agent-next/wrapper/src/server.ts:1054–1078

(deps: ServerDependencies)

        if (typeof message === 'string' || message instanceof ArrayBuffer) {
          upstream.send(message);
          return;
        }
        const copy = new Uint8Array(message.byteLength);
        copy.set(message);
        upstream.send(copy.buffer);
      }
    },
    close(ws: Bun.ServerWebSocket<WrapperWebSocketData>) {
      const upstream = ptyUpstreams.get(ws);
      if (upstream) {
        try {
          upstream.close();
        } catch {
          // Already closed.
        }
        ptyUpstreams.delete(ws);
      }
    },
  };
}

export function createSessionReadyHandler(deps: ServerDependencies) {
  let inFlight:
    | {
        request: WrapperSessionReadyRequest;
        promise: Promise<WrapperSessionReadyResponse>;
      }
    | undefined;