Something went wrong. Try again.
a tool for shared writing and social publishing
Something went wrong. Try again.
2.1 kB · 58 lines
TypeScript
1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859import { isActiveMembership, resolvePublicationMembership, type MembershipStatusFields, type ResolvedPublicationMembership,} from "src/membership";
// The one viewer-facing shape for "how am I subscribed to this publication",// derived from the three underlying tables (atproto subscription row, email// subscriber rows, paid membership row). Client-safe: used by// useViewerSubscription off the identity payload's SUBSCRIPTION_STATE_EMBEDS.export type SubscriptionState = { // Any form of subscription, including an active membership. The atproto // record is the root for linked accounts, but an email-only identity's email // row (or membership) counts on its own. subscribed: boolean; atprotoSubscribed: boolean; // A confirmed email row = email delivery on. Muting email flips the row to // `unsubscribed`; there is no separate "muted" state. emailEnabled: boolean; // The application-level relationship. Free membership is synthesized from // subscription state; only paid membership has a persisted billing row. membership: ResolvedPublicationMembership | null;};
export function deriveSubscriptionState( publicationUri: string | undefined, rows: { subscriptions?: { publication: string }[] | null; emailSubscribers?: { publication: string; state: string }[] | null; memberships?: | ({ publication: string } & MembershipStatusFields & { tier: string; })[] | null; },): SubscriptionState { const atprotoSubscribed = (rows.subscriptions ?? []).some( (s) => s.publication === publicationUri, ); const emailEnabled = (rows.emailSubscribers ?? []).some( (s) => s.publication === publicationUri && s.state === "confirmed", ); const paidMembership = (rows.memberships ?? []).find( (m) => m.publication === publicationUri && isActiveMembership(m), ) ?? null; const subscribed = atprotoSubscribed || emailEnabled || !!paidMembership; return { subscribed, atprotoSubscribed, emailEnabled, membership: resolvePublicationMembership({ isSubscriber: subscribed, paidMembership, }), };}