Function applyCursorAcpModel

cli/src/cursor/utils/cursorModeConfig.ts:108–153

(
    backend: AcpSdkBackend,
    sessionId: string,
    modelId: string | null | undefined
)

 * Only wire ids present in `availableModels` are accepted.
 */
export async function applyCursorAcpModel(
    backend: AcpSdkBackend,
    sessionId: string,
    modelId: string | null | undefined
): Promise<ApplyCursorAcpModelResult> {
    const trimmed = modelId?.trim();
    if (!trimmed || isDefaultCursorModelId(trimmed)) {
        return { applied: false };
    }

    const metadata = backend.getSessionModelsMetadata(sessionId);
    const available = metadata?.availableModels ?? [];
    const modelOption = backend.getConfigOptionByCategory?.(sessionId, 'model');
    const optionWireIds = modelOption?.options?.map((option) => ({ modelId: option.value })) ?? [];
    const catalog = [...available, ...optionWireIds];
    const resolved = resolveCursorAcpWireId(trimmed, catalog);
    if (!resolved) {
        logger.debug(`[cursor-acp] Model ${trimmed} is not in ACP configOptions; skipping`);
        return { applied: false };
    }

    const trySetConfigOption = async (): Promise<boolean> => {
        if (!modelOption || !backend.setConfigOption) {
            return false;
        }
        try {
            await backend.setConfigOption(sessionId, modelOption.id, resolved);
            return true;
        } catch (error) {
            logger.debug('[cursor-acp] session/set_config_option failed, trying set_model', error);
            return false;
        }
    };

    for (let attempt = 0; attempt < 2; attempt += 1) {
        if (await trySetConfigOption()) {
            backend.pinSessionModelWireId(sessionId, resolved);
            return { applied: true, resolvedWireId: resolved, requestedWireId: trimmed };
        }
        if (attempt === 0) {
            await new Promise((resolve) => setTimeout(resolve, 150));
        }
    }

    return { applied: false };
}