Update routes/subscription.py

routes/subscription.py

@@ -509,9 +509,11 @@ def check_subscription(
         if not subscriptions or "data" not in subscriptions or not subscriptions["data"]:
             return {"status": "inactive", "message": "No subscriptions found for this user."}
 
-        # 🔹 Sincronização de assinaturas para o estilista
+        # 🔹 Verifica se existe uma assinatura ativa para o estilista
+        stylist_found = False
         for subscription in subscriptions["data"]:
             if subscription["metadata"].get("stylist_id") == data.stylist_id:
+                stylist_found = True
                 subscription_id = subscription["id"]
                 price_id = subscription["items"]["data"][0]["price"]["id"]
                 status = subscription.get("status")
@@ -562,7 +564,36 @@ def check_subscription(
                     "expiration_date": expiration_date
                 }
 
-        return {"status": "inactive", "message": "No subscription found for this stylist."}
+        # 🔹 Caso não tenha encontrado assinatura ativa para o estilista, desativa todas as assinaturas no banco de dados
+        if not stylist_found:
+            logger.info(f"No active subscription found for stylist {data.stylist_id}. Deactivating all subscriptions for this user.")
+            
+            # 🔹 Buscar todas as assinaturas do cliente no banco de dados
+            response_subscriptions = requests.get(
+                f"{SUPABASE_URL}/rest/v1/Subscriptions?customer_id=eq.{user_id}",
+                headers=SUPABASE_HEADERS
+            )
+            if response_subscriptions.status_code == 200:
+                subscriptions_data = response_subscriptions.json()
+                for sub in subscriptions_data:
+                    # 🔹 Atualiza para "active = false" para todas as assinaturas do cliente no banco
+                    update_data = {
+                        "active": False
+                    }
+                    subscription_url = f"{SUPABASE_URL}/rest/v1/Subscriptions?id=eq.{sub['id']}"
+                    update_response = requests.patch(
+                        subscription_url,
+                        headers=SUPABASE_HEADERS,
+                        json=update_data
+                    )
+                    if update_response.status_code == 200:
+                        logger.info(f"✅ Subscription {sub['id']} deactivated successfully for user {user_id}.")
+                    else:
+                        logger.error(f"❌ Failed to deactivate subscription {sub['id']} for user {user_id}.")
+            else:
+                logger.error(f"❌ Failed to fetch subscriptions from Supabase for user {user_id}.")
+            
+            return {"status": "inactive", "message": "No active subscription found for stylist."}
 
     except stripe.error.StripeError as e:
         logger.error(f"Stripe error: {str(e)}")