Function createAbortHandler

services/cloud-agent-next/wrapper/src/server.ts:728–758

(deps: ServerDependencies, triggerDrainAndClose: () => void)

    }
  };
}

/**
 * The interactions this session currently waits on, as the Worker's
 * `getPendingInteractions` read needs them: the same Kilo state the `connected`
 * snapshot replays, filtered to this session's root Kilo session.
 *
 * A legacy `agent_*` Cloud Agent session keeps no pending set of its own — its
 * Durable Object is only told about `question.asked`/`permission.asked` as
 * events — so the wrapper is the only place that read can come from. A session
 * with no bound Kilo session yet has nothing pending.
 */
export function createPendingInteractionsHandler(deps: ServerDependencies) {
  return async (): Promise<Response> => {
    const { state, kiloClient } = deps;

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

    const kiloSessionId = state.currentSession?.kiloSessionId;
    if (!kiloSessionId) {
      return jsonResponse({ questions: [], permissions: [] });
    }

    try {
      const [questions, permissions] = await Promise.all([
        kiloClient.getQuestions(),
        kiloClient.getPermissions(),
      ]);
      return jsonResponse({
        questions: questions.filter(question => question.sessionID === kiloSessionId),
        permissions: permissions.filter(permission => permission.sessionID === kiloSessionId),
      });