Code-MCP

import Stripe from 'stripe'; import express from 'express'; // ============================================ // Configuration // ============================================ const stripe = new Stripe(process.env.STRIPE_SECRET_KEY!, { apiVersion: '2023-10-16', // Update to latest }); const endpointSecret = process.env.STRIPE_WEBHOOK_SECRET!; // ============================================ // Services // ============================================ export const stripeService = { // Create Checkout Session async createCheckoutSession(priceId: string, customerId?: string) { const session = await stripe.checkout.sessions.create({ mode: 'subscription', // or 'payment' payment_method_types: ['card'], line_items: [ { price: priceId, quantity: 1, }, ], customer: customerId, success_url: `${process.env.DOMAIN}/success?session_id={CHECKOUT_SESSION_ID}`, cancel_url: `${process.env.DOMAIN}/cancel`, }); return session; }, // Create Customer Portal Session async createPortalSession(customerId: string) { const session = await stripe.billingPortal.sessions.create({ customer: customerId, return_url: `${process.env.DOMAIN}/account`, }); return session; }, // Get Customer Subscription async getSubscription(customerId: string) { const subscriptions = await stripe.subscriptions.list({ customer: customerId, status: 'active', limit: 1, }); return subscriptions.data[0] || null; } }; // ============================================ // Webhook Handler // ============================================ export const webhookHandler = async (req: express.Request, res: express.Response) => { const sig = req.headers['stripe-signature']; let event: Stripe.Event; try { event = stripe.webhooks.constructEvent( req.body, // Must be raw buffer sig!, endpointSecret ); } catch (err: any) { console.error(`Webhook Error: ${err.message}`); return res.status(400).send(`Webhook Error: ${err.message}`); } // Handle the event try { switch (event.type) { case 'checkout.session.completed': { const session = event.data.object as Stripe.Checkout.Session; // Provision access, update database, send email console.log('Payment successful for session:', session.id); break; } case 'customer.subscription.updated': { const subscription = event.data.object as Stripe.Subscription; // Update subscription status in DB console.log('Subscription updated:', subscription.id); break; } case 'customer.subscription.deleted': { const subscription = event.data.object as Stripe.Subscription; // Revoke access console.log('Subscription canceled:', subscription.id); break; } default: console.log(`Unhandled event type ${event.type}`); } } catch (error) { console.error('Error processing webhook:', error); return res.status(500).send('Error processing webhook'); } res.json({ received: true }); };