Function findActiveKeyByKeyString

src/repository/key.ts:483–542

(keyString: string)

}

export async function findActiveKeyByKeyString(keyString: string): Promise<Key | null> {
  const vfSaysMissing = apiKeyVacuumFilter.isDefinitelyNotPresent(keyString) === true;

  // Redis 缓存命中：避免打 DB
  const cached = await getCachedActiveKey(keyString);
  if (cached) {
    // 多实例一致性：若 Vacuum Filter 判定缺失但 Redis 命中，说明本机 filter 可能滞后。
    // 最佳努力将 key 写入本机 filter（不影响正确性，仅提升后续性能）。
    if (vfSaysMissing) {
      apiKeyVacuumFilter.noteExistingKey(keyString);
    }
    return cached;
  }

  // Vacuum Filter 负向短路：肯定不存在则直接返回 null，避免打 DB
  // 注意：此处必须放在 Redis 读取之后，避免多实例环境中新建 key 的短暂误拒绝窗口。
  if (vfSaysMissing) {
    return null;
  }

  const [key] = await db
    .select({
      id: keys.id,
      userId: keys.userId,
      key: keys.key,
      name: keys.name,
      isEnabled: keys.isEnabled,
      expiresAt: keys.expiresAt,
      canLoginWebUi: keys.canLoginWebUi,
      limit5hUsd: keys.limit5hUsd,
      limit5hResetMode: keys.limit5hResetMode,
      limitDailyUsd: keys.limitDailyUsd,
      dailyResetMode: keys.dailyResetMode,
      dailyResetTime: keys.dailyResetTime,
      limitWeeklyUsd: keys.limitWeeklyUsd,
      limitMonthlyUsd: keys.limitMonthlyUsd,
      limitTotalUsd: keys.limitTotalUsd,
      costResetAt: keys.costResetAt,
      limitConcurrentSessions: keys.limitConcurrentSessions,
      providerGroup: keys.providerGroup,
      cacheTtlPreference: keys.cacheTtlPreference,
      createdAt: keys.createdAt,
      updatedAt: keys.updatedAt,
      deletedAt: keys.deletedAt,
    })
    .from(keys)
    .where(
      and(
        eq(keys.key, keyString),
        isNull(keys.deletedAt),
        eq(keys.isEnabled, true),
        or(isNull(keys.expiresAt), gt(keys.expiresAt, new Date()))
      )
    );

  if (!key) return null;
  const active = toKey(key);
  cacheActiveKey(active).catch(() => {});