Implement cancel subscription API and frontend integration

Author: Bharani0012

src/backend/base/langflow/api/v1/billing.py

@@ -15,6 +15,7 @@
 from langflow.services.deps import get_settings_service
 from langflow.services.paddle.provisioning import get_paddle_prices
 from langflow.services.paddle.subscriptions import (
+    cancel_subscription,
     ensure_paddle_customer_for_user,
     fetch_active_subscription,
     get_subscriptions_by_customer_id,
@@ -166,4 +167,47 @@ async def get_subscriptions_by_customer(
         "updated": True,
         "subscription_id": active_sub_id,
         "total_subscriptions": len(subscriptions),
-    }
+    }
+
+class CancelSubscriptionRequest(BaseModel):
+    effective_from_immediately: bool = False
+
+
+@router.post("/cancel-subscription")
+async def cancel_subscription_api(
+    body: CancelSubscriptionRequest,
+    current_user: CurrentActiveUser,
+) -> dict:
+    """Cancel subscription using Paddle"""
+
+    if not get_settings_service().auth_settings.CLERK_AUTH_ENABLED:
+        raise HTTPException(status_code=400, detail="Clerk auth not enabled")
+
+    # Get subscription_id from Clerk metadata (JWT)
+    subscription_id = await get_paddle_subscription_id_from_clerk_payload()
+
+    if not subscription_id:
+        raise HTTPException(status_code=400, detail="Missing paddle_subscription_id")
+
+    logger.info(
+        f"Cancel request for subscription {subscription_id}, "
+        f"immediate={body.effective_from_immediately}"
+    )
+
+    try:
+        result = await cancel_subscription(
+            subscription_id=subscription_id,
+            effective_from_immediately=body.effective_from_immediately,
+        )
+
+        return {
+            "success": True,
+            "message": "Subscription cancellation triggered",
+            **result,
+        }
+
+    except Exception as e:
+        raise HTTPException(
+            status_code=500,
+            detail=f"Failed to cancel subscription: {str(e)}",
+        )

src/backend/base/langflow/services/paddle/subscriptions.py

@@ -11,7 +11,8 @@
 from paddle_billing import Client  #noqa: TCH002
 from paddle_billing.Entities.Shared import CustomData
 from paddle_billing.Resources.Customers.Operations import CreateCustomer, UpdateCustomer
-from paddle_billing.Resources.Subscriptions.Operations import ListSubscriptions
+from paddle_billing.Resources.Subscriptions.Operations import ListSubscriptions, CancelSubscription
+from paddle_billing.Entities.Subscriptions import SubscriptionEffectiveFrom
 
 from langflow.services.auth.clerk_metadata_constants import (
     ORGANISATION_CREATED_BY_KEY,
@@ -75,13 +76,17 @@ async def has_active_subscription(
             "subscription_plan_key": None,
             "paddle_subscription_id": None,
             "organisation_created_by": created_by,
+            "next_billed_at": None,
+            "current_period_end": None,
+            "cancel_scheduled": False,
         }
 
     paddle_client = client or get_paddle_client()
     subscription = await asyncio.to_thread(
         paddle_client.subscriptions.get,
         sub_id,
     )
+
     status = getattr(subscription, "status", None)
     if status:
         status = str(status).lower()
@@ -92,13 +97,35 @@ async def has_active_subscription(
     plan_key = subscription_custom_data.get("plan_key")
     if plan_key is not None:
         plan_key = str(plan_key)
-    logger.info(f"Subscription {sub_id} - status: {status}, has_access: {has_access}, active_statuses: {ACTIVE_SUBSCRIPTION_STATUSES}")
+
+    next_billed_at = getattr(subscription, "next_billed_at", None)
+
+    current_period = getattr(subscription, "current_billing_period", None)
+    current_period_end = None
+    if current_period:
+        current_period_end = getattr(current_period, "ends_at", None)
+
+    scheduled_change = getattr(subscription, "scheduled_change", None)
+    cancel_scheduled = False
+    if scheduled_change:
+        action = getattr(scheduled_change, "action", None)
+        cancel_scheduled = str(action).lower() == "cancel"
+
+    logger.info(
+        f"Subscription {sub_id} - status: {status}, "
+        f"has_access: {has_access}, next_billed_at: {next_billed_at}, "
+        f"cancel_scheduled: {cancel_scheduled}"
+    )
+
     return {
         "has_access": has_access,
         "subscription_status": status,
         "subscription_plan_key": plan_key,
         "paddle_subscription_id": sub_id,
         "organisation_created_by": created_by,
+        "next_billed_at": next_billed_at,
+        "current_period_end": current_period_end,
+        "cancel_scheduled": cancel_scheduled,
     }
 
 
@@ -433,3 +460,54 @@ async def retry_with_backoff(
             await asyncio.sleep(delay)
 
     raise last_exception
+
+
+async def cancel_subscription(
+    *,
+    subscription_id: str,
+    effective_from_immediately: bool = False,
+    client: Client | None = None,
+):
+    """
+    Cancel a Paddle subscription.
+
+    Args:
+        subscription_id: Paddle subscription ID (sub_xxx)
+        effective_from_immediately: 
+            True  -> cancel immediately
+            False -> cancel at next billing period (default)
+    """
+    paddle_client = client or get_paddle_client()
+
+    # Map boolean -> Paddle enum
+    effective_from = (
+        SubscriptionEffectiveFrom.IMMEDIATELY
+        if effective_from_immediately
+        else SubscriptionEffectiveFrom.NEXT_BILLING_PERIOD
+    )
+
+    operation = CancelSubscription(
+        effective_from=effective_from
+    )
+
+    try:
+        subscription = await asyncio.to_thread(
+            paddle_client.subscriptions.cancel,
+            subscription_id,
+            operation,
+        )
+
+        logger.info(
+            f"Cancelled subscription {subscription_id} "
+            f"(effective_from={effective_from})"
+        )
+
+        return {
+            "subscription_id": subscription_id,
+            "status": getattr(subscription, "status", None),
+            "effective_from": str(effective_from),
+        }
+
+    except Exception as e:
+        logger.exception(f"Error cancelling subscription {subscription_id}: {e}")
+        raise

src/frontend/src/controllers/API/helpers/constants.ts

@@ -1,4 +1,4 @@
-import { BASE_URL_API, BASE_URL_API_V2 } from "../../../constants/constants";
+  import { BASE_URL_API, BASE_URL_API_V2 } from "../../../constants/constants";
 
 export const URLs = {
   TRANSACTIONS: `monitor/transactions`,
@@ -34,6 +34,7 @@ export const URLs = {
   BILLING_ACCESS: `billing/org-access`,
   GET_PADDLE_PRICES: `billing/paddle-prices`,
   GET_PADDLE_SUBSCRIPTION: `billing/get-subscriptions`,
+  CANCEL_PADDLE_SUBSCRIPTION: `billing/cancel-subscription`,
 } as const;
 
 // IMPORTANT: FOLDERS endpoint now points to 'projects' for backward compatibility