feat(subscriptions): add subscription change management with upgrade/downgrade scheduling

- Add subscription_change_pending_tier and subscription_change_pending_date fields to UserProfile
- Create migration 019_add_subscription_change_pending
- Add apply_pending_subscription_changes(), request_subscription_change(), cancel_pending_subscription_change() utilities
- Add POST /api/subscriptions/change and DELETE /api/subscriptions/change endpoints
- Update GET /api/subscriptions/my to apply pending changes and return pending change info
- Update subscription view to apply pending changes and pass period_start + pending info
- Update subscription.html: per-tier action buttons (upgrade/downgrade/cancel), pending-change banner, period start date
- Add Celery daily task apply_pending_subscription_changes_all at 00:05 UTC
- Add 19 new tests covering all new utility functions and API endpoints

Co-authored-by: christianlouis <361235+christianlouis@users.noreply.github.com>
This commit is contained in:
copilot-swe-agent[bot]
2026-03-07 20:14:12 +00:00
parent 0599cf86b3
commit 231f983429
9 changed files with 1074 additions and 59 deletions
+25 -1
View File
@@ -10,7 +10,14 @@ import logging
from fastapi import Depends, Request
from sqlalchemy.orm import Session
from app.utils.subscription import TIER_ORDER, get_all_tiers, get_tier, get_user_tier_id, get_user_usage
from app.utils.subscription import (
TIER_ORDER,
apply_pending_subscription_changes,
get_all_tiers,
get_tier,
get_user_tier_id,
get_user_usage,
)
from app.views.base import APIRouter, get_db, require_login, templates
logger = logging.getLogger(__name__)
@@ -36,19 +43,31 @@ async def pricing_page(request: Request, db: Session = Depends(get_db)):
async def my_subscription_page(request: Request, db: Session = Depends(get_db)):
"""Authenticated user's subscription status and usage page."""
from app.config import settings
from app.models import UserProfile
user = request.session.get("user") or {}
owner_id: str = user.get("username") or user.get("email") or user.get("sub") or ""
if settings.multi_user_enabled and owner_id:
# Apply any pending changes that have become due before rendering
apply_pending_subscription_changes(db, owner_id)
tier_id = get_user_tier_id(db, owner_id)
usage = get_user_usage(db, owner_id)
profile = db.query(UserProfile).filter(UserProfile.user_id == owner_id).first()
pending_tier_id = profile.subscription_change_pending_tier if profile else None
pending_date = profile.subscription_change_pending_date if profile else None
period_start = profile.subscription_period_start if profile else None
else:
tier_id = "business"
usage = None
pending_tier_id = None
pending_date = None
period_start = None
tier = get_tier(tier_id, db)
all_tiers = get_all_tiers(db)
pending_tier = get_tier(pending_tier_id, db) if pending_tier_id else None
return templates.TemplateResponse(
"subscription.html",
@@ -60,5 +79,10 @@ async def my_subscription_page(request: Request, db: Session = Depends(get_db)):
"all_tiers": all_tiers,
"multi_user_enabled": settings.multi_user_enabled,
"owner_id": owner_id,
"tier_order": TIER_ORDER,
"pending_tier_id": pending_tier_id,
"pending_tier": pending_tier,
"pending_date": pending_date,
"period_start": period_start,
},
)