Function createWebSocketHandlers

services/cloud-agent-next/wrapper/src/server.ts:902–967

(config: ServerConfig, deps: ServerDependencies)

      );
    }

    if (!size) {
      return errorResponse('INVALID_REQUEST', 'PTY size is required', 400);
    }

    try {
      const pty = await deps.kiloClient.resizePty(ptyId, size);
      logToFile(`pty/resize: ptyId=${ptyId} cols=${size.cols} rows=${size.rows}`);
      return jsonResponse(pty);
    } catch (error) {
      const msg = error instanceof Error ? error.message : String(error);
      logToFile(`pty/resize: failed ptyId=${ptyId}: ${msg}`);
      return errorResponse('PTY_ERROR', `Failed to resize PTY: ${msg}`, 500);
    }
  };
}

function createPtyDeleteHandler(deps: ServerDependencies, ptyId: string) {
  return async (_req: Request): Promise<Response> => {
    try {
      const success = await deps.kiloClient.deletePty(ptyId);
      logToFile(`pty/delete: ptyId=${ptyId}`);
      return jsonResponse({ success });
    } catch (error) {
      const msg = error instanceof Error ? error.message : String(error);
      logToFile(`pty/delete: failed ptyId=${ptyId}: ${msg}`);
      return errorResponse('PTY_ERROR', `Failed to delete PTY: ${msg}`, 500);
    }
  };
}

function buildPtyUpstreamUrl(
  config: ServerConfig,
  deps: ServerDependencies,
  ptyId: string
): string {
  const upstream = new URL(`/pty/${encodeURIComponent(ptyId)}/connect`, deps.kiloClient.serverUrl);
  upstream.protocol = upstream.protocol === 'https:' ? 'wss:' : 'ws:';
  upstream.searchParams.set('directory', config.workspacePath);
  return upstream.toString();
}

type WrapperWebSocketData = {
  ptyId?: string;
};

type PtyClientClose = {
  code: number;
  reason: string;
};

function isForwardableCloseCode(code: number): boolean {
  return (
    Number.isInteger(code) && code >= 1000 && code <= 4999 && ![1005, 1006, 1015].includes(code)
  );
}

export function resolvePtyClientClose(event: { code: number; reason: string }): PtyClientClose {