Something went wrong. Try again.
a tool for shared writing and social publishing
Something went wrong. Try again.
TypeScript
12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849import { createHash } from "crypto";import { AtUri } from "@atproto/syntax";import { tinybird } from "lib/tinybird";import type { SubscriptionSource } from "src/subscriptionSource";
// Framework-free (no next/server imports) so the appview firehose consumer can// call it directly. In Next.js request contexts, wrap calls in `after()` so// ingestion never blocks or fails the user-facing action.export async function trackSubscriptionEvent(event: { event: "subscribe" | "unsubscribe"; method: "atproto" | "email"; origin: "app" | "firehose"; publicationUri: string; subscriberDid?: string | null; subscriberEmail?: string | null; recordUri?: string | null; source?: SubscriptionSource | null;}): Promise<void> { if (!process.env.TINYBIRD_TOKEN) return; let publicationDid = ""; try { publicationDid = new AtUri(event.publicationUri).host; } catch {} const subscriber = event.subscriberDid ? event.subscriberDid : event.subscriberEmail ? createHash("sha256") .update(event.subscriberEmail.trim().toLowerCase()) .digest("hex") : ""; try { await tinybird.subscriptionEvents.ingest({ timestamp: Date.now(), event: event.event, method: event.method, origin: event.origin, publication_uri: event.publicationUri, publication_did: publicationDid, subscriber, record_uri: event.recordUri ?? "", source_placement: event.source?.placement ?? "", source_publication: event.source?.publication ?? "", source_url: event.source?.url ?? "", }); } catch (e) { console.error("[trackSubscriptionEvent] ingest failed:", e); }}