Function bindSessionContext

services/cloud-agent-next/wrapper/src/server.ts:255–372

(
  binding: SessionBinding | undefined,
  config: ServerConfig,
  deps: ServerDependencies,
  feedPolicy: SessionBoundFeedPolicy = 'restart'
)

  return {
    ptyId,
    action: match[2] === 'connect' ? 'connect' : undefined,
  };
}

async function notifySessionBound(
  deps: ServerDependencies,
  feedPolicy: SessionBoundFeedPolicy
): Promise<void> {
  if (!deps.onSessionBound) return;
  try {
    await deps.onSessionBound(feedPolicy);
  } catch (error) {
    logToFile(
      `session-bound callback failed: ${error instanceof Error ? error.message : String(error)}`
    );
  }
}

export async function bindSessionContext(
  binding: SessionBinding | undefined,
  config: ServerConfig,
  deps: ServerDependencies,
  feedPolicy: SessionBoundFeedPolicy = 'restart',
  /**
   * The kiloSessionId to bind, when the caller already knows it (e.g. from a
   * fresh session/ready request) but hasn't yet written it back to `config`.
   * Falls back to `config.sessionId` for callers that rebind an
   * already-bootstrapped wrapper, where `config.sessionId` is already current.
   */
  kiloSessionIdOverride?: string,
  logArchiveId?: string
): Promise<Response | null> {
  const { state } = deps;
  const kiloSessionId = kiloSessionIdOverride ?? config.sessionId;
  const blockedWrapperRunId = state.finalizingWrapperRunId;
  const isFreshRunAfterFinalization =
    state.admissionsBlocked &&
    !state.hasSession &&
    blockedWrapperRunId !== undefined &&
    binding?.wrapperRunId !== undefined &&
    binding.wrapperRunId !== blockedWrapperRunId;

  if (state.admissionsBlocked && !isFreshRunAfterFinalization) {
    return wrapperFinalizingResponse(state);
  }

  if (!binding) {
    if (!state.hasSession) {
      return errorResponse('NO_SESSION', 'No session context and no binding provided', 400);
    }
    return null;
  }

  const missingFields: string[] = [];
  if (!binding.wrapperRunId) missingFields.push('wrapperRunId');
  if (binding.wrapperGeneration === undefined || binding.wrapperGeneration === null) {
    missingFields.push('wrapperGeneration');
  }