Function run

apps/web/src/scripts/posthog/audit-microdollar-usage.ts:204–323

()

// --- Main Logic ---

export async function run(): Promise<void> {
  console.log('🔍 Auditing PostHog for whole-word references to "microdollar_usage"...\n');

  const errorLog: ErrorLog[] = [];

  try {
    // 1. Fetch all Data Warehouse Saved Queries (aka views) via OpenAPI path
    // Spec: /api/environments/{project_id}/warehouse_saved_queries/
    const viewsUrl = `${POSTHOG_API_BASE}/api/environments/${PROJECT_ID}/warehouse_saved_queries/`;
    const views = await fetchAllPages<DataWarehouseSavedQuery>(viewsUrl);
    console.log(`\n✅ Retrieved ${views.length} data warehouse saved queries from: ${viewsUrl}\n`);
    const flaggedViews = views.filter(view => {
      if (view.query?.query) {
        return SEARCH_REGEX.test(view.query.query);
      }
      return false;
    });

    if (flaggedViews.length > 0) {
      console.log(
        `🔴 Found ${flaggedViews.length} Data Warehouse Saved Query(ies) with references:`
      );
      for (const view of flaggedViews) {
        const id = hasId(view) ? String(view.id) : 'unknown';
        console.log(`  - Saved Query: "${view.name}" (ID: ${id})`);
        console.log('    Full object:');
        console.log(JSON.stringify(view, null, 2));
        console.log(`Patching view...`);

        try {
          await patchView(view);
        } catch (error) {
          const errorMessage = error instanceof Error ? error.message : String(error);
          console.error(`❌ Failed to patch view "${view.name}":`, errorMessage);
          errorLog.push({
            type: 'view',
            name: view.name,
            id: view.id,
            error: errorMessage,
            oldQuery: view.query?.query,
            newQuery: view.query?.query.replace(SEARCH_REGEX, REPLACEMENT_TERM),
            timestamp: new Date().toISOString(),
          });
          console.log(`⏭️  Skipping to next view...\n`);
        }
      }
    } else {
      console.log(`🟢 No Data Warehouse Saved Queries found with references.`);
    }

    // 2. Fetch all Insights via OpenAPI path
    // Spec: /api/environments/{project_id}/insights/
    const insightsUrl = `${POSTHOG_API_BASE}/api/environments/${PROJECT_ID}/insights/`;
    const insights: Insight[] = await fetchAllPages<Insight>(insightsUrl);
    console.log(`\n✅ Retrieved ${insights.length} insights from: ${insightsUrl}\n`);

    // 4. Audit Insights - extract HogQL and check for search term
    const flaggedInsights = insights.filter(insight => {