extract useSubscription to core/hooks

app/settings/hooks/use-subscription.ts

@@ -1,117 +0,0 @@
-import { useEffect, useRef, useState } from "react";
-import { useQuery, useMutation, useSession } from "blitz";
-
-import type { Subscription } from "db";
-import { SubscriptionStatus } from "db";
-import getSubscription from "../queries/get-subscription";
-import usePaddle from "./use-paddle";
-import useCurrentUser from "../../core/hooks/use-current-user";
-import updateSubscription from "../mutations/update-subscription";
-
-type Params = {
-	initialData?: Subscription;
-};
-
-export default function useSubscription({ initialData }: Params = {}) {
-	const session = useSession();
-	const { user } = useCurrentUser();
-	const [isWaitingForSubChange, setIsWaitingForSubChange] = useState(false);
-	const [subscription] = useQuery(getSubscription, null, {
-		initialData,
-		refetchInterval: isWaitingForSubChange ? 1500 : false,
-	});
-	const [updateSubscriptionMutation] = useMutation(updateSubscription);
-
-	const resolve = useRef<() => void>();
-	const promise = useRef<Promise<void>>();
-
-	const { Paddle } = usePaddle({
-		eventCallback(data) {
-			if (["Checkout.Close", "Checkout.Complete"].includes(data.event)) {
-				resolve.current!();
-				promise.current = new Promise((r) => (resolve.current = r));
-			}
-		},
-	});
-
-	// cancel subscription polling when we get a new subscription
-	useEffect(() => setIsWaitingForSubChange(false), [subscription?.paddleSubscriptionId, subscription?.status]);
-
-	useEffect(() => {
-		promise.current = new Promise((r) => (resolve.current = r));
-	}, []);
-
-	type BuyParams = {
-		planId: number;
-		coupon?: string;
-	};
-
-	async function subscribe(params: BuyParams) {
-		if (!user || !session.orgId) {
-			return;
-		}
-
-		const { planId, coupon } = params;
-		const checkoutOpenParams = {
-			email: user.email,
-			product: planId,
-			allowQuantity: false,
-			passthrough: JSON.stringify({ organizationId: session.orgId }),
-			coupon: "",
-		};
-
-		if (coupon) {
-			checkoutOpenParams.coupon = coupon;
-		}
-
-		Paddle.Checkout.open(checkoutOpenParams);
-		setIsWaitingForSubChange(true);
-
-		return promise.current;
-	}
-
-	async function updatePaymentMethod({ updateUrl }: { updateUrl: string }) {
-		const checkoutOpenParams = { override: updateUrl };
-
-		Paddle.Checkout.open(checkoutOpenParams);
-		setIsWaitingForSubChange(true);
-
-		return promise.current;
-	}
-
-	async function cancelSubscription({ cancelUrl }: { cancelUrl: string }) {
-		const checkoutOpenParams = { override: cancelUrl };
-
-		Paddle.Checkout.open(checkoutOpenParams);
-		setIsWaitingForSubChange(true);
-
-		return promise.current;
-	}
-
-	type ChangePlanParams = {
-		planId: number;
-	};
-
-	async function changePlan({ planId }: ChangePlanParams) {
-		if (planId === -1) {
-			return cancelSubscription({ cancelUrl: subscription!.cancelUrl });
-		}
-
-		try {
-			await updateSubscriptionMutation({ planId });
-		} catch (error) {
-			console.log("error", error);
-		}
-	}
-
-	const hasActiveSubscription = Boolean(subscription && subscription?.status !== SubscriptionStatus.deleted);
-
-	return {
-		subscription,
-		hasActiveSubscription,
-		subscribe,
-		updatePaymentMethod,
-		cancelSubscription,
-		changePlan,
-	};
-}