Function replaceInQuery

apps/web/src/scripts/posthog/audit-microdollar-usage.ts:110–138

(query: unknown)

}

function replaceInQuery(query: unknown): unknown {
  if (!query) return query;

  // Handle direct HogQLQuery
  const hogqlResult = HogQLQuerySchema.safeParse(query);
  if (hogqlResult.success) {
    return {
      ...hogqlResult.data,
      query: hogqlResult.data.query.replace(SEARCH_REGEX, REPLACEMENT_TERM),
    };
  }

  // Handle DataVisualizationNode with HogQL source
  const dvnResult = _DataVisualizationNodeSchema.safeParse(query);
  if (dvnResult.success) {
    const sourceResult = HogQLQuerySchema.safeParse(dvnResult.data.source);
    if (sourceResult.success) {
      return {
        ...dvnResult.data,
        source: {
          ...sourceResult.data,
          query: sourceResult.data.query.replace(SEARCH_REGEX, REPLACEMENT_TERM),
        },
      };
    }
  }

  return query;
}

async function patchView(view: DataWarehouseSavedQuery): Promise<void> {
  if (!view.query) return;