Update routes/subscription.py

routes/subscription.py

@@ -68,6 +68,50 @@ def verify_token(user_token: str) -> str:
     else:
         raise HTTPException(status_code=401, detail="Invalid or expired token")
 
+@router.post("/subscription_details")
+async def subscription_details(data: SubscriptionRequest):
+    try:
+        subscription_id = data.id
+
+        # Buscar detalhes da assinatura no Stripe
+        subscription = await async_stripe_request(
+            stripe.Subscription.retrieve,
+            id=subscription_id,
+            expand=["items.data.price"]
+        )
+
+        if not subscription:
+            raise HTTPException(status_code=404, detail="Subscription not found")
+
+        # Pegando os detalhes do preço atual
+        current_price = subscription["items"]["data"][0]["price"]["unit_amount"] / 100
+        currency = subscription["items"]["data"][0]["price"]["currency"].upper()
+        
+        # Data da próxima cobrança
+        next_billing_date = datetime.utcfromtimestamp(subscription["current_period_end"]).isoformat()
+        
+        # Preço da próxima cobrança
+        upcoming_invoice = await async_stripe_request(
+            stripe.Invoice.upcoming,
+            subscription=subscription_id
+        )
+        next_invoice_amount = upcoming_invoice["amount_due"] / 100 if upcoming_invoice else None
+
+        return {
+            "status": "success",
+            "subscription_id": subscription_id,
+            "current_price": f"{current_price} {currency}",
+            "next_invoice_amount": f"{next_invoice_amount} {currency}" if next_invoice_amount else "N/A",
+            "next_billing_date": next_billing_date
+        }
+
+    except stripe.error.StripeError as e:
+        logger.error(f"Stripe error: {str(e)}")
+        raise HTTPException(status_code=500, detail=f"Stripe error: {str(e)}")
+    except Exception as e:
+        logger.error(f"Error retrieving subscription details: {str(e)}")
+        raise HTTPException(status_code=500, detail="Error retrieving subscription details.")
+
 @router.post("/generate_dashboard_link")
 async def generate_dashboard_link(data: UserIDRequest):
     try: