Print Event and wait 60

fireWhale.py

@@ -162,4 +162,31 @@ def encontrar_documento_por_cus(valor_cus):
 
     except Exception as e:
         print(f"❌ Error al buscar documento por 'cus': {e}")
-        return None, None
+        return None, None
+    
+def incrementar_campo_numerico(collection_name, document_id, field_name, amount=1):
+    """
+    Incrementa un campo numérico en un documento de Firestore de forma atómica.
+    Si el documento no existe, lo crea e inicializa el campo con el 'amount'.
+    Si el campo no existe en un documento existente, lo inicializa y aplica el incremento.
+
+    Args:
+        collection_name (str): El nombre de la colección.
+        document_id (str): El ID del documento.
+        field_name (str): El nombre del campo numérico a incrementar.
+        amount (int/float): La cantidad por la cual incrementar (puede ser negativo para decrementar).
+    """
+    doc_ref = db.collection(collection_name).document(document_id)
+
+    try:
+        # Usamos .set() con merge=True para comportamiento de "upsert".
+        # Si el documento no existe, lo crea.
+        # Si el campo no existe, lo crea e inicializa con 'amount'.
+        # Si el campo ya existe, lo incrementa con 'amount'.
+        doc_ref.set(
+            {field_name: firestore.Increment(amount)},
+            merge=True  # Esta es la clave para que se cree si no existe y no sobrescriba otros campos
+        )
+        print(f"✔️ Campo '{field_name}' en el documento '{document_id}' actualizado/creado e incrementado en {amount}.")
+    except Exception as e:
+        print(f"❌ Error al operar en el campo '{field_name}' del documento '{document_id}': {e}")

herramientas.py

@@ -53,4 +53,6 @@ def registrar_evento(cus: str, tokens: int):
     resultado = fireWhale.encontrar_documento_por_cus(cus)
     # print("Ésto es el resultado de buscar el cus:")
     # print(resultado)
-    fireWhale.editaDato('usuarios', resultado, 'tokens', tokens)
+    fireWhale.editaDato('usuarios', resultado, 'tokens', tokens)
+
+    fireWhale.incrementar_campo_numerico('usuarios', resultado, tokens, amount=tokens)

main.py

@@ -32,9 +32,10 @@ async def webhook_received(request: Request, stripe_signature: str = Header(None
             sig_header=stripe_signature,
             secret=webhook_secret
         )
-        # print("Evento construido...") 
-        # print(event)   
-        # print("Evento impreso")            
+        print("Evento construido...") 
+        print(event)   
+        print("Evento impreso")
+        time.sleep(60)            
 
     except Exception as e:     
         print("Excepción es: ", e)