Function openStream

services/cloud-agent-next/test/e2e/client.ts:430–528

(
  config: DriverConfig,
  cloudAgentSessionId: string,
  options: StreamOptions = {}
)

    {
      sourceKiloSessionId: input.sourceKiloSessionId,
      sourceCloudAgentSessionId: input.sourceCloudAgentSessionId,
      operationKey: input.operationKey ?? randomUUID(),
      clientProvenance: 'browser',
      ...(config.kilocodeOrganizationId
        ? { kilocodeOrganizationId: config.kilocodeOrganizationId }
        : {}),
    },
    { internalApiSecret: config.internalApiSecret, signal }
  );
  // Success only, matching the legacy/unified start pattern.
  config.onSessionCreated?.(created.cloudAgentSessionId, created.kiloSessionId);
  return created;
}

/**
 * Set or clear the callback target of an existing session through the internal
 * `updateSession` endpoint.
 *
 * The public grouped `start` schema rejects `callbackTarget`, so the new plane's
 * callback harness registers the sink after `start` through the same endpoint
 * `services/code-review-infra` uses on session continuations. Internal-API
 * authenticated.
 */
export async function updateSessionCallbackTarget(
  config: DriverConfig,
  cloudAgentSessionId: string,
  callbackTarget: CallbackTarget | null,
  signal?: AbortSignal
): Promise<{ success: boolean }> {
  return trpcCall<{ success: boolean }>(
    config,
    'updateSession',
    { cloudAgentSessionId, callbackTarget },
    { internalApiSecret: config.internalApiSecret, ...(signal ? { signal } : {}) }
  );
}

export type SessionSnapshot = {
  sessionId: string;
  kiloSessionId?: string;
  userId: string;
  orgId?: string;
  sandboxId?: string;
  githubRepo?: string;
  gitUrl?: string;
  platform?: string;
  upstreamBranch?: string;
  autoCommit?: boolean;
  worktreeId?: string | null;
  parentSessionId?: string | null;
  cloudAgentSessionScopeId?: string | null;
  cloudAgentWorktreeId?: string;
  initialMessageId?: string;
  latestEventId?: number | null;
  execution: { id: string; status: string } | null;
};

export async function getSessionSnapshot(