Analytics

autenticacion.py

@@ -6,15 +6,16 @@ def defineAmbiente(env):
 
     print("Estoy en defineambiente...")
     if local_check():
-        print("Entorno Local...")        
+        print("Entorno Local...")  
+           
         import bridges      
         if env == 'prod':  
             llave = bridges.llave_prod 
             webhook = bridges.webhook_prod
             firestore = 'config_prod.json'
-        else: #if dev
-            llave == bridges.llave_sandbox
-            webhook == bridges.webhook_sandbox
+        else: #if dev         
+            llave = bridges.llave_sandbox              
+            webhook = bridges.webhook_sandbox
             firestore = 'config_dev.json'
     else:
         print("Entorno remoto listo...")

ga4Ejemplo.py

@@ -0,0 +1,68 @@
+import requests
+import json
+import os
+
+# Tu API Secret y Measurement ID de Google Analytics 4
+GA4_API_SECRET = "zqxXw6mdR1CR0FaQYWaZEQ" # Reemplaza con tu secreto
+GA4_MEASUREMENT_ID = "G-PHPJCWFF9L" # Reemplaza con tu ID de medición
+
+def send_ga4_purchase_event(event_data):
+    """
+    Función para enviar un evento de compra a GA4 usando Measurement Protocol.
+    
+    Args:
+        event_data: Un diccionario con los datos del evento de compra de Stripe.
+    """
+    url = f"https://www.google-analytics.com/mp/collect?measurement_id={GA4_MEASUREMENT_ID}&api_secret={GA4_API_SECRET}"
+    
+    # Extrae la información de la sesión de Stripe
+    session = event_data['data']['object']
+    
+    # Prepara los items (productos) para GA4
+    items = []
+    # Nota: Tendrías que obtener los detalles de los productos
+    # de Stripe de manera más robusta, por ejemplo, de tu base de datos
+    # o de los metadatos de la sesión si los guardaste allí.
+    # Por simplicidad, aquí se usa un ejemplo estático.
+    
+    # Simulación de obtención de items
+    # En un caso real, esto sería más complejo.
+    items.append({
+        "item_id": "SKU_EJEMPLO",
+        "item_name": "Producto Ejemplo",
+        "price": session['amount_total'] / 100.0, # Stripe usa céntimos
+        "quantity": 1
+    })
+
+    payload = {
+        "client_id": "CLIENT_ID_DEL_USUARIO", # Aquí deberías usar el Client ID o User ID del usuario
+        "events": [
+            {
+                "name": "purchase",
+                "params": {
+                    "debug_mode": True,
+                    "transaction_id": session['id'],
+                    "value": session['amount_total'] / 100.0, # Convierte de céntimos a la unidad de moneda
+                    "currency": session['currency'].upper(),
+                    "items": items
+                }
+            }
+        ]
+    }
+
+    try:
+        response = requests.post(url, data=json.dumps(payload), headers={"Content-Type": "application/json"})
+        response.raise_for_status() # Lanza una excepción si la respuesta no es 2xx
+        print("Evento de compra enviado a GA4 con éxito.")
+        return True
+    except requests.exceptions.RequestException as e:
+        print(f"Error al enviar el evento a GA4: {e}")
+        return False
+
+# --- Lógica de tu webhook ---
+# Esta es una parte de ejemplo de tu endpoint.
+# Aquí recibes el evento de Stripe.
+# Puedes verificar el evento con la firma para mayor seguridad.
+
+# if stripe_event.type == 'checkout.session.completed':
+#     send_ga4_purchase_event(stripe_event)

globales.py

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

main.py

@@ -2,12 +2,12 @@ import stripe
 import globales
 import herramientas
 from fastapi import FastAPI, Request, Header
+import ga4Ejemplo
+
 
 app = FastAPI()
 
 string_key = globales.llave
-# This is a terrible idea, only used for demo purposes!
-#app.state.stripe_customer_id = None
 
 @app.get("/")
 def start(): 
@@ -53,6 +53,8 @@ async def webhook_received(request: Request, stripe_signature: str = Header(None
         print(event_data['payment_method_options']) 
         print("Cantidad de elementos:")
         print(len(event_data['payment_method_options']))
+        print("Sending to GA4...")
+        ga4Ejemplo.send_ga4_purchase_event(event_data)
         #Si hay un elemento que es card abona inmediatamente. 
         #Si no, por ahora ignora. 
         if len(event_data['payment_method_options']) > 0: #Si es mayor que cero checa si existe card.