Function posthogQuery

apps/web/src/lib/posthog-query.ts:26–60

(name: string, query: string)

 * @returns Query response with results or error
 */
export async function posthogQuery(name: string, query: string): Promise<PostHogQueryResponse> {
  const apiKey = getEnvVariable('POSTHOG_QUERY_API_KEY');
  if (!apiKey) {
    throw new Error('No PostHog Query API Key');
  }

  const response = await fetch('https://us.posthog.com/api/projects/141915/query/', {
    method: 'POST',
    headers: {
      Authorization: `Bearer ${apiKey}`,
      'Content-Type': 'application/json',
    },
    body: JSON.stringify({
      query: {
        kind: 'HogQLQuery',
        query,
      },
      name,
    }),
    cache: 'no-store',
  });

  if (!response.ok) {
    return {
      status: 'error',
      statusCode: response.status,
      error: await response.json().catch(() => ({ error: 'Unknown error' })),
    };
  }

  return {
    status: 'ok',
    body: await response.json(),
  };
}

const CACHE_TTL_SECONDS = 60 * 60 * 24; // 24 hours
const MEMORY_CACHE_TTL_MS = 60 * 60 * 1000; // 1 hour