"use client"; import { useEffect, useState } from "react"; import { useRouter } from "next/navigation"; import { SubscribeWithHandle, AtSubscribeSuccess } from "./HandleSubscribe"; import { EmailInput, EmailButton, EmailConfirm } from "./EmailSubscribe"; import { EmailSubscribeSuccess } from "./EmailSubscribeSuccess"; import { LinkIdentityModal } from "./LinkIdentityModal"; import { SUBSCRIBE_ERROR_MESSAGES as ERROR_MESSAGES } from "./subscribeErrors"; import { Modal } from "components/Modal"; import { ButtonPrimary } from "components/Buttons"; import { ManageSubscription } from "./ManageSubscribe"; import { ReservedGeometry } from "components/utils/ReservedGeometry"; import { useToaster } from "components/Toast"; import { refreshIdentityData, useIdentityData, } from "components/IdentityProvider"; import { AtmosphereAccount } from "components/Icons/AtmosphereAccount"; import { EmailTiny } from "components/Icons/EmailTiny"; import { Menu, MenuItem, RadioMenuGroup, RadioMenuItem } from "components/Menu"; import { RSSTiny } from "components/Icons/RSSTiny"; import { requestPublicationEmailSubscription, confirmPublicationEmailSubscription, } from "actions/publications/subscribeEmail"; import { encodeActionToSearchParam } from "app/api/oauth/[route]/afterSignInActions"; import { mainSiteAuthBase } from "src/utils/customDomain"; import { useViewerSubscription, type ViewerUser } from "./viewerSubscription"; import { Separator } from "components/Layout"; import { ArrowDownTiny } from "components/Icons/ArrowDownTiny"; type SubscribeMode = "email" | "atproto"; const LOGGED_OUT_VIEWER: ViewerUser = { loggedIn: false, email: undefined, handle: undefined, atprotoSubscribed: false, emailSubscribed: false, }; // Logged-out email subscribe goes through the main-site email-login flow with a // `subscribe` after-sign-in action, so the session is minted on the main site // and handed back to the custom domain (see postAuthRedirect). function redirectToEmailSubscribe(email: string, publicationUri: string) { let base = mainSiteAuthBase() || window.location.origin; let url = new URL("/api/auth/email-login", base); url.searchParams.set("email", email); url.searchParams.set("redirect", window.location.href); url.searchParams.set( "action", encodeActionToSearchParam({ action: "subscribe", publication: publicationUri, }), ); window.location.href = url.toString(); } export type SubscribeProps = { autoFocus?: boolean; compact?: boolean; publicationUri: string; publicationUrl?: string; publicationName: string; publicationDescription?: string; newsletterMode: boolean; }; export const SubscribePanel = (props: SubscribeProps) => { return (

{props.publicationName}

{props.publicationDescription && (
{props.publicationDescription}
)}
); }; export const SubscribeInput = (props: SubscribeProps) => { let toaster = useToaster(); let router = useRouter(); const user = useViewerSubscription(props.publicationUri); const { identity, mutate: mutateIdentity } = useIdentityData(); let [email, setEmail] = useState(user.email ?? ""); // On a published page identity resolves after first paint, so the initial // value above is always the logged-out one. Without this the email field // stays empty while EmailInput disables itself on the identity's email being // known — an input that can be neither typed into nor submitted. Only seeds // an untouched field, so it can't clobber what someone is typing. useEffect(() => { if (user.email) setEmail((current) => (current === "" ? user.email! : current)); }, [user.email]); let [requesting, setRequesting] = useState(false); let [confirming, setConfirming] = useState(false); let [confirmOpen, setConfirmOpen] = useState(false); let [confirmState, setConfirmState] = useState<"confirm" | "success">( "confirm", ); let [atSuccessOpen, setAtSuccessOpen] = useState(false); // Tracks that the user passed through LinkIdentityModal — when they enter the // confirmation code we attach the email to their current atp identity (or // merge from any existing email-only identity) instead of creating a // disconnected email-only account. let [linkToCurrent, setLinkToCurrent] = useState(false); let [locallySubscribed, setLocallySubscribed] = useState(false); let [linkModalOpen, setLinkModalOpen] = useState(false); let [subscribeMode, setSubscribeMode] = useState("email"); const viewerHandle = identity?.bsky_profiles?.handle; const viewerAtpDid = identity?.atp_did; const viewerEmail = identity?.email; // The atp-only-but-subscribing-via-email case: signed in as a Bluesky // account with no email yet. The modal asks them to link the typed email // (or log out) before we send a confirmation code. const needsLinkConfirmation = !!viewerAtpDid && !viewerEmail && !!email; const sendRequest = async (link: boolean) => { setRequesting(true); setLinkToCurrent(link); let res = await requestPublicationEmailSubscription( props.publicationUri, email, ); setRequesting(false); if (!res.ok) { toaster({ type: "error", content: ERROR_MESSAGES[res.error] }); return; } if (res.value.confirmed) { setConfirmState("success"); refreshIdentityData(); router.refresh(); } setConfirmOpen(true); }; const showManage = props.newsletterMode ? user.emailSubscribed : user.atprotoSubscribed; const isSubscribed = showManage || locallySubscribed; const modeMenu = ( ); const emailForm = ( { if (!email || requesting) return; if (needsLinkConfirmation) { setLinkModalOpen(true); return; } redirectToEmailSubscribe(email, props.publicationUri); }} action={ Subscribe } /> ); // The form an anonymous reader gets: on a published page that's what static // HTML ships and what the rest of the page is laid out around, so it's also // the box every resolved state has to fit inside. const anonymousForm = props.newsletterMode ? (
{emailForm}
) : ( ); return ( <> {isSubscribed ? ( <> {props.newsletterMode && user.atprotoSubscribed && !user.emailSubscribed ? (
Opt in to get updates via email!
{ if (requesting || !email) return; if (needsLinkConfirmation) { setLinkModalOpen(true); return; } await sendRequest(false); }} action={ Get Emails } />
) : null} ) : props.newsletterMode ? (
{user.loggedIn && user.email ? ( setLocallySubscribed(true)} /> ) : subscribeMode === "email" ? ( emailForm ) : ( setAtSuccessOpen(true)} leading={modeMenu} /> )}
) : ( setLocallySubscribed(true)} /> )}
{props.newsletterMode && needsLinkConfirmation && ( { setLinkModalOpen(false); await sendRequest(true); }} /> )} { setAtSuccessOpen(open); if (!open) { setLocallySubscribed(true); mutateIdentity(); router.refresh(); } }} > {props.newsletterMode && ( { setConfirmOpen(open); if (!open) { if (confirmState === "success") setLocallySubscribed(true); setConfirmState("confirm"); setLinkToCurrent(false); } }} > {confirmState === "success" ? ( ) : ( setConfirmOpen(false)} emailValue={email} onSubmit={async (code) => { if (confirming) return; setConfirming(true); let res = await confirmPublicationEmailSubscription( props.publicationUri, email, code, linkToCurrent, ); setConfirming(false); if (!res.ok) { toaster({ type: "error", content: ERROR_MESSAGES[res.error], }); return; } setConfirmState("success"); refreshIdentityData(); router.refresh(); }} /> )} )} ); }; export const SubscribeButton = (props: SubscribeProps) => { const user = useViewerSubscription(props.publicationUri); let [locallySubscribed, setLocallySubscribed] = useState(false); const showManage = props.newsletterMode ? user.emailSubscribed : user.atprotoSubscribed; // What an anonymous reader gets — and the tallest state this button resolves // into, so reserving it keeps the row's height fixed through identity landing. const subscribeTrigger = ( Subscribe ); return ( {showManage || locallySubscribed ? ( ) : !props.newsletterMode && user.loggedIn && user.handle ? ( setLocallySubscribed(true)} /> ) : props.newsletterMode && user.loggedIn && user.email ? ( setLocallySubscribed(true)} /> ) : ( // Nothing to one-click with — either logged out, or logged in but // missing the identity this pub needs (a handle for atproto pubs, an // email for newsletters). Both open the full SubscribePanel (pub // name/description + form) in a modal.
)}
); }; const SubscribeInputModeMenu = (props: { mode: SubscribeMode; onChange: (mode: SubscribeMode) => void; }) => { return (
{props.mode === "email" ? : } } >
Subscribe via…
props.onChange(v as SubscribeMode)} > Email Atmosphere
); }; export type SubscribeButtonModeMenuAccount = { value: SubscribeMode; label: string; icon: React.ReactNode; // The account the main button currently subscribes with — marked in the menu. selected: boolean; // Subscribe with this account directly, rather than just toggling selection. onSelect: () => void; }; // The caret dropdown beside the compact subscribe button. Each account is a // one-click subscribe (it runs the subscribe action, not just a toggle), and // the optional RSS item links the feed. Shared by the atproto (HandleSubscribe) // and email (EmailSubscribe) buttons. export const SubscribeButtonModeMenu = (props: { disabled: boolean; publicationUrl?: string; accounts: SubscribeButtonModeMenuAccount[]; }) => { let selectedValue = props.accounts.find((a) => a.selected)?.value ?? props.accounts[0]?.value; return ( } >
Subscribe with…
{props.accounts.map((account) => ( account.onSelect()} > {account.icon} {account.label} ))} {props.publicationUrl && ( window.open( `${props.publicationUrl}/rss`, "_blank", "noopener,noreferrer", ) } > RSS Feed )}
); };