Welcome funciones standard

funciones.py

@@ -0,0 +1,83 @@
+import stripe
+import globales
+import herramientas
+import ga4Analiticas
+from fastapi import Request, Header
+
+async def procesa_evento(request: Request, stripe_signature: str = Header(None)):
+
+    webhook_secret = globales.webhook
+    data = await request.body()    
+    
+    try:         
+        event = stripe.Webhook.construct_event(
+            payload=data,
+            sig_header=stripe_signature,
+            secret=webhook_secret
+        )
+        # print("Evento construido...") 
+        # print(event)   
+        # print("Evento impreso")         
+
+    except Exception as e:     
+        print("Excepción es: ", e)         
+
+    try:
+        event_data = event['data']['object']     
+    except Exception as e:     
+        print("Excepción-183 es: ", e)
+    
+    event_type = event['type']
+    print("Voy a imprimir el event type:")
+    print(event_type)
+    print("Sucedido a las: ", herramientas.imprimeTime())
+    gaCliente = event_data['metadata'].get('gaCliente', None)
+
+    if event_type == 'checkout.session.completed': 
+        print("Checkout Session completado.")
+        print("Status:")
+        print(event_data['status'])   
+        print("Payment Method Options:")     
+        print(event_data['payment_method_options']) 
+        print("Cantidad de elementos:")
+        print(len(event_data['payment_method_options']))        
+        
+        #Importante: Todas las acciones relacionadas a la compra con tarjeta deben ir en el IF.
+        #De lo contrario se marcará también en OXXO, antes de hacerce el pago.
+        if len(event_data['payment_method_options']) > 0: #Si es mayor que cero checa si existe card.
+            if len(event_data['payment_method_options']["card"]) > 1: #Si el contenido de card es mayor de uno, si existe y puedes finalmente procesar el pago.
+                cus_id = event_data['customer']
+                print("Customer directo:", cus_id)
+                imagenes = event_data['metadata']['imagenes']
+                print("Imágenes:")
+                print(imagenes)  
+                firebase_user = event_data['metadata']['firebase_user']
+                herramientas.registrar_evento(cus_id, firebase_user, int(imagenes))  
+                #Analytics se hace al final después de registrar la venta.
+                print("gacliente:", gaCliente)
+                print("Sending to GA4...")
+                ga4Analiticas.send_ga4_purchase_event(event_data)           
+
+    if event_type == 'checkout.session.async_payment_succeeded': 
+        print("Pago asíncrono completado.")
+        print("Checkout Session completado.")
+        print("Status:")
+        print(event_data['status'])  
+        print("Payment Method Options:")     
+        print(event_data['payment_method_options']) 
+        print("Cantidad de elementos:")
+        print(len(event_data['payment_method_options']))
+        cus_id = event_data['customer']
+        print("Customer directo:", cus_id)
+        imagenes = event_data['metadata']['imagenes']
+        print("Imágenes:")
+        print(imagenes)  
+        herramientas.registrar_evento(cus_id, int(imagenes))
+        print("gacliente:", gaCliente)
+        print("Sending to GA4...")
+        ga4Analiticas.send_ga4_purchase_event(event_data)
+        
+    else:
+        print(f'unhandled event: {event_type}')      
+    
+    return {"status": "success"}

globales.py

@@ -1,7 +1,4 @@
 import autenticacion
 
 env = 'dev' #o dev
-llave, webhook, ga4Key = autenticacion.defineAmbiente(env)
-
-# print("La llave es: ", llave)
-# print("Y el webhook es: ", webhook)
+llave, webhook, ga4Key = autenticacion.defineAmbiente(env)

main.py

@@ -1,7 +1,5 @@
-import stripe
 import globales
-import herramientas
-import ga4Analiticas
+import funciones
 from fastapi import FastAPI, Request, Header
 
 app = FastAPI()
@@ -13,83 +11,8 @@ def start():
     return {f"Status":"Deployed"}
 
 @app.post("/webhook")
-async def webhook_received(request: Request, stripe_signature: str = Header(None)):    
-    
-    webhook_secret = globales.webhook 
-
-    data = await request.body()
-    
-    print("Construyendo el evento:")
-    
-    try:         
-        event = stripe.Webhook.construct_event(
-            payload=data,
-            sig_header=stripe_signature,
-            secret=webhook_secret
-        )
-        # print("Evento construido...") 
-        # print(event)   
-        # print("Evento impreso")         
-
-    except Exception as e:     
-        print("Excepción es: ", e)         
-
-    try:
-        event_data = event['data']['object']     
-    except Exception as e:     
-        print("Excepción-183 es: ", e)
-    
-    event_type = event['type']
-    print("Voy a imprimir el event type:")
-    print(event_type)
-    print("Sucedido a las: ", herramientas.imprimeTime())
-    gaCliente = event_data['metadata'].get('gaCliente', None)
-
-    if event_type == 'checkout.session.completed': 
-        print("Checkout Session completado.")
-        print("Status:")
-        print(event_data['status'])   
-        print("Payment Method Options:")     
-        print(event_data['payment_method_options']) 
-        print("Cantidad de elementos:")
-        print(len(event_data['payment_method_options']))        
-        
-        #Importante: Todas las acciones relacionadas a la compra con tarjeta deben ir en el IF.
-        #De lo contrario se marcará también en OXXO, antes de hacerce el pago.
-        if len(event_data['payment_method_options']) > 0: #Si es mayor que cero checa si existe card.
-            if len(event_data['payment_method_options']["card"]) > 1: #Si el contenido de card es mayor de uno, si existe y puedes finalmente procesar el pago.
-                cus_id = event_data['customer']
-                print("Customer directo:", cus_id)
-                imagenes = event_data['metadata']['imagenes']
-                print("Imágenes:")
-                print(imagenes)  
-                firebase_user = event_data['metadata']['firebase_user']
-                herramientas.registrar_evento(cus_id, firebase_user, int(imagenes))  
-                #Analytics se hace al final después de registrar la venta.
-                print("gacliente:", gaCliente)
-                print("Sending to GA4...")
-                ga4Analiticas.send_ga4_purchase_event(event_data)           
+async def webhook_received(request: Request, stripe_signature: str = Header(None)):
 
-    if event_type == 'checkout.session.async_payment_succeeded': 
-        print("Pago asíncrono completado.")
-        print("Checkout Session completado.")
-        print("Status:")
-        print(event_data['status'])  
-        print("Payment Method Options:")     
-        print(event_data['payment_method_options']) 
-        print("Cantidad de elementos:")
-        print(len(event_data['payment_method_options']))
-        cus_id = event_data['customer']
-        print("Customer directo:", cus_id)
-        imagenes = event_data['metadata']['imagenes']
-        print("Imágenes:")
-        print(imagenes)  
-        herramientas.registrar_evento(cus_id, int(imagenes))
-        print("gacliente:", gaCliente)
-        print("Sending to GA4...")
-        ga4Analiticas.send_ga4_purchase_event(event_data)
-        
-    else:
-        print(f'unhandled event: {event_type}')      
+    return funciones.procesa_evento(request, stripe_signature)
     
-    return {"status": "success"}
+