Function createPtyResizeHandler

services/cloud-agent-next/wrapper/src/server.ts:810–844

(deps: ServerDependencies, ptyId: string)

    }

    setAborted();

    try {
      await kiloClient.abortSession({ sessionId: session.kiloSessionId });
      logToFile(`job/abort: aborted kilo session ${session.kiloSessionId}`);
    } catch (error) {
      const msg = error instanceof Error ? error.message : String(error);
      logToFile(`job/abort: abort request failed (continuing): ${msg}`);
    }

    state.sendToIngest({
      streamEventType: 'interrupted',
      data: { reason: 'aborted via API' },
      timestamp: new Date().toISOString(),
    });

    state.clearAllMessages();
    triggerDrainAndClose();

    return jsonResponse({ status: 'aborted' });
  };
}

function createPtyCreateHandler(config: ServerConfig, deps: ServerDependencies) {
  return async (req: Request): Promise<Response> => {
    let body: PtyCreateBody;
    try {
      body = await readJsonBody<PtyCreateBody>(req, {});
    } catch {
      return errorResponse('INVALID_REQUEST', 'Invalid JSON body', 400);
    }

    let size: WrapperPtySize | null;
    try {
      size = parsePtySize(body);
    } catch (error) {
      return errorResponse(
        'INVALID_REQUEST',