Function fetchPathPageviewCounts

server/src/services/posthog-query.ts:260–345

(
  pathnames: string[],
  days = 30
)

}

export async function fetchPathPageviewCounts(
  pathnames: string[],
  days = 30
): Promise<PathPageviewCounts | null> {
  const uniquePathnames = Array.from(
    new Set(
      pathnames
        .filter((pathname): pathname is string => typeof pathname === "string" && pathname.trim().length > 0)
        .map((pathname) => pathname.trim())
    )
  );

  if (uniquePathnames.length === 0) {
    return {};
  }

  const cacheKey = `${days}:${uniquePathnames.join("|")}`;
  const cached = pathPageviewCache.get(cacheKey);
  if (cached && Date.now() - cached.timestamp < PATH_PAGEVIEW_CACHE_TTL_MS) {
    return cached.data;
  }

  const config = getPostHogQueryConfig();
  if (!config) return null;

  const regex = `^(?:${uniquePathnames.map(escapeRegExp).join("|")})$`;

  try {
    const query = {
      kind: "InsightVizNode",
      source: {
        kind: "TrendsQuery",
        dateRange: { date_from: `-${days}d` },
        series: [
          {
            kind: "EventsNode",
            event: "$pageview",
            custom_name: "Perspective pageviews",
            properties: [
              {
                key: "$pathname",
                type: "event",
                operator: "regex",
                value: regex,
              },
            ],
          },
        ],
        breakdownFilter: {
          breakdown: "$pathname",
          breakdown_type: "event",
          breakdown_limit: uniquePathnames.length,
        },
        trendsFilter: { display: "ActionsBarValue" },
      },
    };

    const result = await queryPostHog(config, query);