Function syncInternalUsageStats

apps/web/src/lib/model-stats/sync-internal-data.ts:196–275

()

 * 3. Updates the chartData field in model_stats
 */
export async function syncInternalUsageStats(): Promise<void> {
  // Fetch mode rankings data from PostHog
  const chartDataUpdates = await fetchModeRankingsData();

  // Fetch weekly token usage data and merge it
  const weeklyTokenUsage = await fetchWeeklyTokenUsage();
  for (const [model, data] of Object.entries(weeklyTokenUsage)) {
    chartDataUpdates[model] = { ...chartDataUpdates[model], ...data };
  }

  // Get ALL existing model stats to match normalized model names to openrouterId
  // This ensures we update any model in the database, not just preferred ones
  const allModelStats = await db.select().from(modelStats);
  const modelStatsMap = new Map(allModelStats.map(stat => [stat.openrouterId, stat]));

  console.log(`[sync-internal-data] Found ${allModelStats.length} models in database`);

  // Track updates
  let updatedCount = 0;
  let skippedCount = 0;

  // Update each model's chartData with mode rankings
  for (const [normalizedModelName, updateData] of Object.entries(chartDataUpdates)) {
    // Try to find matching model in database
    // The normalized model name from PostHog might not exactly match openrouterId
    // We need to handle various cases like:
    // - "claude-sonnet-4.5" -> "anthropic/claude-sonnet-4.5"
    // - "grok-code-fast-1" -> "x-ai/grok-code-fast-1"
    // - etc.

    let matchingModel = modelStatsMap.get(normalizedModelName);

    // If no exact match, try with common provider prefixes
    if (!matchingModel) {
      for (const provider of MODEL_PROVIDERS) {
        const withProvider = `${provider}/${normalizedModelName}`;
        matchingModel = modelStatsMap.get(withProvider);
        if (matchingModel) break;
      }
    }

    // Try with :free suffix - any model might have this
    if (!matchingModel) {
      const withFreeSuffix = `${normalizedModelName}:free`;
      matchingModel = modelStatsMap.get(withFreeSuffix);
    }

    // Also try with provider prefix + :free suffix
    if (!matchingModel) {
      for (const provider of MODEL_PROVIDERS) {
        const withProviderAndSuffix = `${provider}/${normalizedModelName}:free`;
        matchingModel = modelStatsMap.get(withProviderAndSuffix);
        if (matchingModel) break;
      }
    }

    if (!matchingModel) {
      skippedCount++;