router.post('/:streamId', requireAuth, async (req, res) => const userId = req.user.id; const streamId = req.params;
-- Subscriptions (active recurring) CREATE TABLE user_subscriptions ( id BIGSERIAL PRIMARY KEY, user_id BIGINT REFERENCES users(id) ON DELETE CASCADE, plan_id BIGINT REFERENCES subscription_plans(id), stripe_sub_id VARCHAR(255) UNIQUE, status VARCHAR(20) CHECK (status IN ('active','canceled','past_due')), current_period_end TIMESTAMP, created_at TIMESTAMP DEFAULT NOW() );
module.exports = router;
// routes/purchases.js const express = require('express'); const router = express.Router(); const stripe = require('stripe')(process.env.STRIPE_SECRET_KEY); const requireAuth = require('../middleware/auth'); const Stream, Purchase = require('../models');
if (event.type === 'checkout.session.completed') const session = event.data.object; const userId, streamId = session.metadata; camwhores.v
-- Streams (live or recorded) CREATE TABLE streams ( id BIGSERIAL PRIMARY KEY, model_id BIGINT REFERENCES users(id), title VARCHAR(255), is_live BOOLEAN DEFAULT FALSE, start_time TIMESTAMP, end_time TIMESTAMP, is_premium BOOLEAN DEFAULT FALSE, -- true = requires purchase/subscription price_cents INTEGER, -- optional PPV price thumbnail_url VARCHAR(255) ); | Method | URL | Description | Auth | |--------|-----|-------------|------| | GET /api/plans | List all subscription plans | Public | | POST /api/subscriptions | Create a Stripe Checkout session for a plan | Viewer (JWT) | | POST /api/webhooks/stripe | Handle subscription events ( invoice.payment_succeeded , customer.subscription.deleted ) | Stripe secret | | GET /api/streams/:id | Retrieve stream metadata; includes access flag | Viewer (JWT) | | POST /api/purchases/:streamId | Create a PPV checkout session for a specific stream | Viewer (JWT) | | GET /api/user/me | Current user profile + subscription status | Viewer/Model (JWT) |
// Handle subscription events similarly… router
function StreamPage() const id = useParams(); const [stream, setStream] = useState(null); const [hasAccess, setHasAccess] = useState(false); const [loading, setLoading] = useState(true); const location = useLocation();