Function createPtyCreateHandler

services/cloud-agent-next/wrapper/src/server.ts:760–808

(config: ServerConfig, deps: ServerDependencies)

      return jsonResponse({
        questions: questions.filter(question => question.sessionID === kiloSessionId),
        permissions: permissions.filter(permission => permission.sessionID === kiloSessionId),
      });
    } catch (error) {
      const msg = error instanceof Error ? error.message : String(error);
      logToFile(`job/pending-interactions: failed: ${msg}`);
      return errorResponse('KILO_STATE_ERROR', `Failed to read pending interactions: ${msg}`, 500);
    }
  };
}

export function createAnswerQuestionHandler(deps: ServerDependencies) {
  return async (req: Request): Promise<Response> => {
    const { state, kiloClient } = deps;

    if (!state.hasSession) {
      return errorResponse('NO_SESSION', 'No session context', 400);
    }

    let body: AnswerQuestionBody;
    try {
      body = (await req.json()) as AnswerQuestionBody;
    } catch {
      return errorResponse('INVALID_REQUEST', 'Invalid JSON body', 400);
    }

    if (!body.questionId || !body.answers) {
      return errorResponse('INVALID_REQUEST', 'questionId and answers are required', 400);
    }

    try {
      const success = await kiloClient.answerQuestion(body.questionId, body.answers);
      state.updateActivity();
      logToFile(`job/answer-question: questionId=${body.questionId}`);
      return jsonResponse({ status: 'answered', success });
    } catch (error) {
      const msg = error instanceof Error ? error.message : String(error);
      logToFile(`job/answer-question: failed: ${msg}`);
      return errorResponse('QUESTION_ERROR', `Failed to answer question: ${msg}`, 500);
    }
  };
}

export function createRejectQuestionHandler(deps: ServerDependencies) {
  return async (req: Request): Promise<Response> => {
    const { state, kiloClient } = deps;

    if (!state.hasSession) {
      return errorResponse('NO_SESSION', 'No session context', 400);
    }

    let body: RejectQuestionBody;
    try {