Stripe

stripe({
    // ... 기타 옵션
    createCustomerOnSignUp: true,
    onCustomerCreate: async ({ customer, stripeCustomer, user }, request) => {
        // 새로 생성된 고객으로 무언가를 수행
        console.log(`사용자 ${user.id}에 대해 고객 ${customer.id}가 생성되었습니다`);
    },
    getCustomerCreateParams: async ({ user, session }, request) => {
        // Stripe 고객 생성 매개변수 사용자 지정
        return {
            metadata: {
                referralSource: user.metadata?.referralSource
            }
        };
    }
})

// 정적 플랜
subscription: {
    enabled: true,
    plans: [
        {
            name: "basic", // 플랜 이름, 데이터베이스에 저장될 때 자동으로 소문자로 변환됩니다
            priceId: "price_1234567890", // stripe의 가격 ID
            annualDiscountPriceId: "price_1234567890", // (선택 사항) 할인이 적용된 연간 청구의 가격 ID
            limits: {
                projects: 5,
                storage: 10
            }
        },
        {
            name: "pro",
            priceId: "price_0987654321",
            limits: {
                projects: 20,
                storage: 50
            },
            freeTrial: {
                days: 14,
            }
        }
    ]
}

// 동적 플랜 (데이터베이스 또는 API에서 가져옴)
subscription: {
    enabled: true,
    plans: async () => {
        const plans = await db.query("SELECT * FROM plans");
        return plans.map(plan => ({
            name: plan.name,
            priceId: plan.stripe_price_id,
            limits: JSON.parse(plan.limits)
        }));
    }
}

await client.subscription.upgrade({
    plan: "pro",
    successUrl: "/dashboard",
    cancelUrl: "/pricing",
    annual: true, // 선택 사항: 연간 플랜으로 업그레이드
    referenceId: "org_123", // 선택 사항: 기본값은 현재 로그인한 사용자 ID
    seats: 5 // 선택 사항: 팀 플랜용
});

await client.subscription.upgrade({
    plan: "pro",
    successUrl: "/dashboard",
    cancelUrl: "/pricing",
    subscriptionId: "sub_123", // 사용자의 현재 플랜의 Stripe 구독 ID
});

// 조직에 대한 구독 생성
await client.subscription.upgrade({
    plan: "pro",
    referenceId: "org_123456",
    successUrl: "/dashboard",
    cancelUrl: "/pricing",
    seats: 5 // 팀 플랜의 좌석 수
});

// 조직의 구독 목록
const { data: subscriptions } = await client.subscription.list({
    query: {
        referenceId: "org_123456"
    }
});

subscription: {
    // ... 기타 옵션
    authorizeReference: async ({ user, session, referenceId, action }) => {
        // 사용자가 이 참조에 대한 구독을 관리할 권한이 있는지 확인
        if (action === "upgrade-subscription" || action === "cancel-subscription" || action === "restore-subscription") {
            const org = await db.member.findFirst({
                where: {
                    organizationId: referenceId,
                    userId: user.id
                }
            });
            return org?.role === "owner"
        }
        return true;
    }
}

stripe({
    // ... 기타 옵션
    onEvent: async (event) => {
        // 모든 Stripe 이벤트 처리
        switch (event.type) {
            case "invoice.paid":
                // 지불된 송장 처리
                break;
            case "payment_intent.succeeded":
                // 성공적인 결제 처리
                break;
        }
    }
})

subscription: {
    // ... 기타 옵션
    onSubscriptionComplete: async ({ event, subscription, stripeSubscription, plan }) => {
        // 구독이 성공적으로 생성될 때 호출됨
        await sendWelcomeEmail(subscription.referenceId, plan.name);
    },
    onSubscriptionUpdate: async ({ event, subscription }) => {
        // 구독이 업데이트될 때 호출됨
        console.log(`구독 ${subscription.id}가 업데이트되었습니다`);
    },
    onSubscriptionCancel: async ({ event, subscription, stripeSubscription, cancellationDetails }) => {
        // 구독이 취소될 때 호출됨
        await sendCancellationEmail(subscription.referenceId);
    },
    onSubscriptionDeleted: async ({ event, subscription, stripeSubscription }) => {
        // 구독이 삭제될 때 호출됨
        console.log(`구독 ${subscription.id}가 삭제되었습니다`);
    }
}

{
    name: "pro",
    priceId: "price_0987654321",
    freeTrial: {
        days: 14,
        onTrialStart: async (subscription) => {
            // 평가판이 시작될 때 호출됨
            await sendTrialStartEmail(subscription.referenceId);
        },
        onTrialEnd: async ({ subscription, user }, request) => {
            // 평가판이 종료될 때 호출됨
            await sendTrialEndEmail(user.email);
        },
        onTrialExpired: async (subscription) => {
            // 평가판이 전환 없이 만료될 때 호출됨
            await sendTrialExpiredEmail(subscription.referenceId);
        }
    }
}

stripe({
    // ... 기타 옵션
    schema: {
        subscription: {
            modelName: "stripeSubscriptions", // subscription 테이블을 stripeSubscriptions에 매핑
            fields: {
                plan: "planName" // plan 필드를 planName에 매핑
            }
        }
    }
})

// 활성 조직 가져오기
const { data: activeOrg } = client.useActiveOrganization();

// 조직에 대한 구독 생성
await client.subscription.upgrade({
    plan: "team",
    referenceId: activeOrg.id,
    seats: 10,
    annual: true, // 연간 플랜으로 업그레이드 (선택 사항)
    successUrl: "/org/billing/success",
    cancelUrl: "/org/billing"
});

authorizeReference: async ({ user, referenceId, action }) => {
    const member = await db.members.findFirst({
        where: {
            userId: user.id,
            organizationId: referenceId
        }
    });

    return member?.role === "owner" || member?.role === "admin";
}

getCheckoutSessionParams: async ({ user, session, plan, subscription }, request) => {
    return {
        params: {
            allow_promotion_codes: true,
            tax_id_collection: {
                enabled: true
            },
            billing_address_collection: "required",
            custom_text: {
                submit: {
                    message: "구독을 즉시 시작하겠습니다"
                }
            },
            metadata: {
                planType: "business",
                referralCode: user.metadata?.referralCode
            }
        },
        options: {
            idempotencyKey: `sub_${user.id}_${plan.name}_${Date.now()}`
        }
    };
}

subscription: {
    // ... 기타 옵션
    getCheckoutSessionParams: async ({ user, session, plan, subscription }, request) => {
        return {
            params: {
                tax_id_collection: {
                    enabled: true
                }
            }
        };
    }
}

subscription: {
    // ... 기타 옵션
    getCheckoutSessionParams: async ({ user, session, plan, subscription }, request) => {
        return {
            params: {
                automatic_tax: {
                    enabled: true
                }
            }
        };
    }
}