249 lines
9.9 KiB
JavaScript
249 lines
9.9 KiB
JavaScript
import { getProviderConnections, validateApiKey, updateProviderConnection, getSettings } from "@/lib/localDb";
|
|
import { formatRetryAfter, checkFallbackError, isModelLockActive, buildModelLockUpdate, buildClearModelLocksUpdate, getEarliestModelLockUntil } from "open-sse/services/accountFallback.js";
|
|
import { resolveProviderId } from "@/shared/constants/providers.js";
|
|
import * as log from "../utils/logger.js";
|
|
|
|
// Mutex to prevent race conditions during account selection
|
|
let selectionMutex = Promise.resolve();
|
|
|
|
/**
|
|
* Get provider credentials from localDb
|
|
* Filters out unavailable accounts and returns the selected account based on strategy
|
|
* @param {string} provider - Provider name
|
|
* @param {string|null} excludeConnectionId - Connection ID to exclude (for retry with next account)
|
|
* @param {string|null} model - Model name for per-model rate limit filtering
|
|
*/
|
|
export async function getProviderCredentials(provider, excludeConnectionId = null, model = null) {
|
|
// Acquire mutex to prevent race conditions
|
|
const currentMutex = selectionMutex;
|
|
let resolveMutex;
|
|
selectionMutex = new Promise(resolve => { resolveMutex = resolve; });
|
|
|
|
try {
|
|
await currentMutex;
|
|
|
|
// Resolve alias to provider ID (e.g., "kc" -> "kilocode")
|
|
const providerId = resolveProviderId(provider);
|
|
|
|
const connections = await getProviderConnections({ provider: providerId, isActive: true });
|
|
log.debug("AUTH", `${provider} | total connections: ${connections.length}, excludeId: ${excludeConnectionId || "none"}, model: ${model || "any"}`);
|
|
|
|
if (connections.length === 0) {
|
|
log.warn("AUTH", `No credentials for ${provider}`);
|
|
return null;
|
|
}
|
|
|
|
// Filter out model-locked and excluded connections
|
|
const availableConnections = connections.filter(c => {
|
|
if (excludeConnectionId && c.id === excludeConnectionId) return false;
|
|
if (isModelLockActive(c, model)) return false;
|
|
return true;
|
|
});
|
|
|
|
log.debug("AUTH", `${provider} | available: ${availableConnections.length}/${connections.length}`);
|
|
connections.forEach(c => {
|
|
const excluded = excludeConnectionId && c.id === excludeConnectionId;
|
|
const locked = isModelLockActive(c, model);
|
|
if (excluded || locked) {
|
|
const lockUntil = getEarliestModelLockUntil(c);
|
|
log.debug("AUTH", ` → ${c.id?.slice(0, 8)} | ${excluded ? "excluded" : ""} ${locked ? `modelLocked(${model}) until ${lockUntil}` : ""}`);
|
|
}
|
|
});
|
|
|
|
if (availableConnections.length === 0) {
|
|
// Find earliest lock expiry across all connections for retry timing
|
|
const lockedConns = connections.filter(c => isModelLockActive(c, model));
|
|
const expiries = lockedConns.map(c => getEarliestModelLockUntil(c)).filter(Boolean);
|
|
const earliest = expiries.sort()[0] || null;
|
|
if (earliest) {
|
|
const earliestConn = lockedConns[0];
|
|
log.warn("AUTH", `${provider} | all ${connections.length} accounts locked for ${model || "all"} (${formatRetryAfter(earliest)}) | lastError=${earliestConn?.lastError?.slice(0, 50)}`);
|
|
return {
|
|
allRateLimited: true,
|
|
retryAfter: earliest,
|
|
retryAfterHuman: formatRetryAfter(earliest),
|
|
lastError: earliestConn?.lastError || null,
|
|
lastErrorCode: earliestConn?.errorCode || null
|
|
};
|
|
}
|
|
log.warn("AUTH", `${provider} | all ${connections.length} accounts unavailable`);
|
|
return null;
|
|
}
|
|
|
|
const settings = await getSettings();
|
|
const strategy = settings.fallbackStrategy || "fill-first";
|
|
|
|
let connection;
|
|
if (strategy === "round-robin") {
|
|
const stickyLimit = settings.stickyRoundRobinLimit || 3;
|
|
|
|
// Sort by lastUsed (most recent first) to find current candidate
|
|
const byRecency = [...availableConnections].sort((a, b) => {
|
|
if (!a.lastUsedAt && !b.lastUsedAt) return (a.priority || 999) - (b.priority || 999);
|
|
if (!a.lastUsedAt) return 1;
|
|
if (!b.lastUsedAt) return -1;
|
|
return new Date(b.lastUsedAt) - new Date(a.lastUsedAt);
|
|
});
|
|
|
|
const current = byRecency[0];
|
|
const currentCount = current?.consecutiveUseCount || 0;
|
|
|
|
if (current && current.lastUsedAt && currentCount < stickyLimit) {
|
|
// Stay with current account
|
|
connection = current;
|
|
// Update lastUsedAt and increment count (await to ensure persistence)
|
|
await updateProviderConnection(connection.id, {
|
|
lastUsedAt: new Date().toISOString(),
|
|
consecutiveUseCount: (connection.consecutiveUseCount || 0) + 1
|
|
});
|
|
} else {
|
|
// Pick the least recently used (excluding current if possible)
|
|
const sortedByOldest = [...availableConnections].sort((a, b) => {
|
|
if (!a.lastUsedAt && !b.lastUsedAt) return (a.priority || 999) - (b.priority || 999);
|
|
if (!a.lastUsedAt) return -1;
|
|
if (!b.lastUsedAt) return 1;
|
|
return new Date(a.lastUsedAt) - new Date(b.lastUsedAt);
|
|
});
|
|
|
|
connection = sortedByOldest[0];
|
|
|
|
// Update lastUsedAt and reset count to 1 (await to ensure persistence)
|
|
await updateProviderConnection(connection.id, {
|
|
lastUsedAt: new Date().toISOString(),
|
|
consecutiveUseCount: 1
|
|
});
|
|
}
|
|
} else {
|
|
// Default: fill-first (already sorted by priority in getProviderConnections)
|
|
connection = availableConnections[0];
|
|
}
|
|
|
|
return {
|
|
apiKey: connection.apiKey,
|
|
accessToken: connection.accessToken,
|
|
refreshToken: connection.refreshToken,
|
|
projectId: connection.projectId,
|
|
copilotToken: connection.providerSpecificData?.copilotToken,
|
|
providerSpecificData: connection.providerSpecificData,
|
|
connectionId: connection.id,
|
|
// Include current status for optimization check
|
|
testStatus: connection.testStatus,
|
|
lastError: connection.lastError,
|
|
// Pass full connection for clearAccountError to read modelLock_* keys
|
|
_connection: connection
|
|
};
|
|
} finally {
|
|
if (resolveMutex) resolveMutex();
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Mark account+model as unavailable — locks modelLock_${model} in DB.
|
|
* All errors (429, 401, 5xx, etc.) lock per model, not per account.
|
|
* @param {string} connectionId
|
|
* @param {number} status - HTTP status code from upstream
|
|
* @param {string} errorText
|
|
* @param {string|null} provider
|
|
* @param {string|null} model - The specific model that triggered the error
|
|
* @returns {{ shouldFallback: boolean, cooldownMs: number }}
|
|
*/
|
|
export async function markAccountUnavailable(connectionId, status, errorText, provider = null, model = null) {
|
|
const connections = await getProviderConnections({ provider });
|
|
const conn = connections.find(c => c.id === connectionId);
|
|
const backoffLevel = conn?.backoffLevel || 0;
|
|
|
|
const { shouldFallback, cooldownMs, newBackoffLevel } = checkFallbackError(status, errorText, backoffLevel);
|
|
if (!shouldFallback) return { shouldFallback: false, cooldownMs: 0 };
|
|
|
|
const reason = typeof errorText === "string" ? errorText.slice(0, 100) : "Provider error";
|
|
const lockUpdate = buildModelLockUpdate(model, cooldownMs);
|
|
|
|
await updateProviderConnection(connectionId, {
|
|
...lockUpdate,
|
|
testStatus: "unavailable",
|
|
lastError: reason,
|
|
errorCode: status,
|
|
lastErrorAt: new Date().toISOString(),
|
|
backoffLevel: newBackoffLevel ?? backoffLevel
|
|
});
|
|
|
|
const lockKey = Object.keys(lockUpdate)[0];
|
|
log.warn("AUTH", `${connectionId.slice(0, 8)} locked ${lockKey} for ${Math.round(cooldownMs / 1000)}s [${status}]`);
|
|
|
|
if (provider && status && reason) {
|
|
console.error(`❌ ${provider} [${status}]: ${reason}`);
|
|
}
|
|
|
|
return { shouldFallback: true, cooldownMs };
|
|
}
|
|
|
|
/**
|
|
* Clear account error status on successful request.
|
|
* - Clears modelLock_${model} (the model that just succeeded)
|
|
* - Lazy-cleans any other expired modelLock_* keys
|
|
* - Resets error state only if no active locks remain
|
|
* @param {string} connectionId
|
|
* @param {object} currentConnection - credentials object (has _connection) or raw connection
|
|
* @param {string|null} model - model that succeeded
|
|
*/
|
|
export async function clearAccountError(connectionId, currentConnection, model = null) {
|
|
const conn = currentConnection._connection || currentConnection;
|
|
const now = Date.now();
|
|
const allLockKeys = Object.keys(conn).filter(k => k.startsWith("modelLock_"));
|
|
|
|
if (!conn.testStatus && !conn.lastError && allLockKeys.length === 0) return;
|
|
|
|
// Keys to clear: current model's lock + all expired locks
|
|
const keysToClear = allLockKeys.filter(k => {
|
|
if (model && k === `modelLock_${model}`) return true; // succeeded model
|
|
if (model && k === "modelLock___all") return true; // account-level lock
|
|
const expiry = conn[k];
|
|
return expiry && new Date(expiry).getTime() <= now; // expired
|
|
});
|
|
|
|
if (keysToClear.length === 0 && conn.testStatus !== "unavailable" && !conn.lastError) return;
|
|
|
|
// Check if any active locks remain after clearing
|
|
const remainingActiveLocks = allLockKeys.filter(k => {
|
|
if (keysToClear.includes(k)) return false;
|
|
const expiry = conn[k];
|
|
return expiry && new Date(expiry).getTime() > now;
|
|
});
|
|
|
|
const clearObj = Object.fromEntries(keysToClear.map(k => [k, null]));
|
|
|
|
// Only reset error state if no active locks remain
|
|
if (remainingActiveLocks.length === 0) {
|
|
Object.assign(clearObj, { testStatus: "active", lastError: null, lastErrorAt: null, backoffLevel: 0 });
|
|
}
|
|
|
|
await updateProviderConnection(connectionId, clearObj);
|
|
log.info("AUTH", `Account ${connectionId.slice(0, 8)} cleared lock for model=${model || "__all"}`);
|
|
}
|
|
|
|
/**
|
|
* Extract API key from request headers
|
|
*/
|
|
export function extractApiKey(request) {
|
|
// Check Authorization header first
|
|
const authHeader = request.headers.get("Authorization");
|
|
if (authHeader?.startsWith("Bearer ")) {
|
|
return authHeader.slice(7);
|
|
}
|
|
|
|
// Check Anthropic x-api-key header
|
|
const xApiKey = request.headers.get("x-api-key");
|
|
if (xApiKey) {
|
|
return xApiKey;
|
|
}
|
|
|
|
return null;
|
|
}
|
|
|
|
/**
|
|
* Validate API key (optional - for local use can skip)
|
|
*/
|
|
export async function isValidApiKey(apiKey) {
|
|
if (!apiKey) return false;
|
|
return await validateApiKey(apiKey);
|
|
}
|