Update routes/subscription.py

routes/subscription.py

@@ -62,15 +62,15 @@ class CreatePriceRequest(BaseModel):
 
 def get_active_subscribers_by_price_id(price_id: str) -> list:
     """
-    Retorna uma lista de user_ids que têm uma assinatura ativa com o price_id fornecido.
+    Retorna uma lista de customer_ids que têm uma assinatura ativa com o price_id fornecido.
     """
     response = requests.get(
-        f"{SUPABASE_URL}/rest/v1/Subscriptions?price_id=eq.{price_id}&select=user_id",
+        f"{SUPABASE_URL}/rest/v1/Subscriptions?price_id=eq.{price_id}&active=eq.true&select=customer_id",
         headers=SUPABASE_ROLE_HEADERS
     )
     if response.status_code == 200:
         data = response.json()
-        return [entry["user_id"] for entry in data if "user_id" in entry]
+        return [entry["customer_id"] for entry in data if "customer_id" in entry]
     logger.warning(f"⚠️ Failed to fetch subscribers: {response.status_code} - {response.text}")
     return []