Update routes/subscription.py

routes/subscription.py

@@ -556,12 +556,27 @@ async def check_subscription(
                     "canceled_date": canceled_at_date
                 }
 
-                await async_request(
-                    f"{SUPABASE_URL}/rest/v1/Subscriptions",
-                    SUPABASE_HEADERS,
-                    json=subscription_data,
-                    method='POST'
+                # Verifica se a assinatura no banco de dados já existe e está marcada como inactive
+                response_existing_sub = await async_request(
+                    f"{SUPABASE_URL}/rest/v1/Subscriptions?customer_id=eq.{user_id}&stylist_id=eq.{data.stylist_id}&sub_id=eq.{subscription_id}",
+                    SUPABASE_HEADERS
                 )
+                if response_existing_sub.status_code == 200 and response_existing_sub.json():
+                    db_subscription = response_existing_sub.json()[0]
+                    db_active = db_subscription.get("active")
+
+                    # Se o status no banco for False e no Stripe for True, atualiza para True
+                    if not db_active and status == "active":
+                        await update_subscription_status(db_subscription["id"], True)
+
+                # Se a assinatura não existir no banco, cria uma nova
+                if response_existing_sub.status_code != 200 or not response_existing_sub.json():
+                    await async_request(
+                        f"{SUPABASE_URL}/rest/v1/Subscriptions",
+                        SUPABASE_HEADERS,
+                        json=subscription_data,
+                        method='POST'
+                    )
 
                 # Retorna informações sobre a assinatura sincronizada
                 return {
@@ -600,18 +615,6 @@ async def check_subscription(
         raise HTTPException(status_code=500, detail="Error checking subscription.")
 
 
-# Função assíncrona para fazer requisições de rede
-async def async_request(url, headers, json=None, method='GET'):
-    method_func = requests.post if method == 'POST' else requests.get
-    response = method_func(url, headers=headers, json=json)
-    return response
-
-# Função assíncrona para chamar a Stripe API
-async def async_stripe_request(func, **kwargs):
-    loop = asyncio.get_event_loop()
-    response = await loop.run_in_executor(None, lambda: func(**kwargs))
-    return response
-
 # Função assíncrona para atualizar o status de uma assinatura
 async def update_subscription_status(subscription_id, status):
     update_data = {
@@ -625,6 +628,6 @@ async def update_subscription_status(subscription_id, status):
         method='PATCH'
     )
     if update_response.status_code == 200:
-        logger.info(f"✅ Subscription {subscription_id} deactivated successfully.")
+        logger.info(f"✅ Subscription {subscription_id} updated to {'active' if status else 'inactive'} successfully.")
     else:
-        logger.error(f"❌ Failed to deactivate subscription {subscription_id}.")
+        logger.error(f"❌ Failed to update subscription {subscription_id}.")