Something went wrong. Try again.
leaflet fork for copy edit / bug fixes forked from leaflet.pub/leaflet
Something went wrong. Try again.
123456789101112131415161718192021222324252627282930313233343536373839import { after } from "next/server";import { tinybird } from "lib/tinybird";
// Active-user counts are "distinct identities with any event"; finer questions// (who moved from reading to writing) are query-time filters on `event` and// `properties`, so add event names and properties freely rather than columns.export type UserEvent = | "page_view" // client beacon on every route change (see actions/trackPageView.ts) | "push"; // ran replicache mutations
// Only signed-in sessions are tracked: the identity row keys the actor so a// person on several devices counts once, and anonymous traffic is left to the// Vercel analytics drain.export type TrackedIdentity = { id: string; atp_did?: string | null };
// Deliberately unthrottled: dedupe happens in Tinybird's endpoints, not here.// Ingestion runs in `after()` so it never blocks or fails the user-facing// request, which also means this must be called from a Next request context.export function trackUserEvent( identity: TrackedIdentity, event: UserEvent, properties: Record<string, string> = {},) { if (!process.env.TINYBIRD_TOKEN) return; after(async () => { try { await tinybird.userEvents.ingest({ timestamp: Date.now(), identity_id: identity.id, did: identity.atp_did ?? "", event, properties: new Map(Object.entries(properties)), }); } catch (e) { console.error("[trackUserEvent] ingest failed:", e); } });}