mai
/
posimai-root
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat: stripe webhook plan upgrade/downgrade, add plan/subscription columns

This commit is contained in:
posimai 2026-04-05 14:01:41 +09:00
parent c7b6d0b2d3
commit 8e9f232dba
1 changed files with 23 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
server.js
View File

@ -642,6 +642,9 @@ async function initDB() {
`ALTER TABLE users ADD COLUMN IF NOT EXISTS email_verified BOOLEAN DEFAULT false`, `ALTER TABLE users ADD COLUMN IF NOT EXISTS email_verified BOOLEAN DEFAULT false`,
`ALTER TABLE users ADD COLUMN IF NOT EXISTS purchased_at TIMESTAMPTZ`, `ALTER TABLE users ADD COLUMN IF NOT EXISTS purchased_at TIMESTAMPTZ`,
`ALTER TABLE users ADD COLUMN IF NOT EXISTS stripe_session_id TEXT`, `ALTER TABLE users ADD COLUMN IF NOT EXISTS stripe_session_id TEXT`,
`ALTER TABLE users ADD COLUMN IF NOT EXISTS plan VARCHAR(20) NOT NULL DEFAULT 'free'`,
`ALTER TABLE users ADD COLUMN IF NOT EXISTS stripe_customer_id TEXT`,
`ALTER TABLE users ADD COLUMN IF NOT EXISTS stripe_subscription_id TEXT`,
]; ];
for (const sql of migrations) { for (const sql of migrations) {
await pool.query(sql).catch(e => console.warn('[DB] Migration warning:', e.message)); await pool.query(sql).catch(e => console.warn('[DB] Migration warning:', e.message));
@ -2863,11 +2866,12 @@ async function handleStripeWebhook(req, res) {
); );
} }
await pool.query( await pool.query(
`UPDATE users SET purchased_at = NOW(), stripe_session_id = $1 `UPDATE users SET purchased_at = NOW(), stripe_session_id = $1,
WHERE user_id = $2`, plan = 'premium', stripe_customer_id = $2, stripe_subscription_id = $3
[session.id, userId] WHERE user_id = $4`,
[session.id, session.customer, session.subscription, userId]
); );
console.log(`[Stripe] Purchase recorded for ${email} (userId: ${userId})`); console.log(`[Stripe] Plan upgraded to premium for ${email}`);
} catch (e) { } catch (e) {
console.error('[Stripe] DB error recording purchase:', e.message); console.error('[Stripe] DB error recording purchase:', e.message);
return res.status(500).json({ error: 'DB error' }); return res.status(500).json({ error: 'DB error' });
@ -2875,6 +2879,21 @@ async function handleStripeWebhook(req, res) {
} }
} }
// サブスクリプション解約 → plan を free に戻す
if (event.type === 'customer.subscription.deleted') {
const subscription = event.data.object;
try {
await pool.query(
`UPDATE users SET plan = 'free', stripe_subscription_id = NULL
WHERE stripe_customer_id = $1`,
[subscription.customer]
);
console.log(`[Stripe] Plan downgraded to free for customer: ${subscription.customer}`);
} catch (e) {
console.error('[Stripe] DB error downgrading plan:', e.message);
}
}
res.json({ received: true }); res.json({ received: true });
} }