|
import time |
|
import stripe |
|
from fastapi import FastAPI, Request, Header |
|
import sulkuPypi |
|
import globales |
|
import herramientas |
|
|
|
app = FastAPI() |
|
|
|
string_key = globales.llave |
|
|
|
app.state.stripe_customer_id = None |
|
|
|
@app.get("/") |
|
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("data ready") |
|
|
|
|
|
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") |
|
time.sleep(30) |
|
|
|
except Exception as e: |
|
print("Excepción es: ", e) |
|
|
|
try: |
|
event_data = event['data']['object'] |
|
except Exception as e: |
|
print("Excepción es: ", e) |
|
|
|
event_type = event['type'] |
|
print("Voy a imprimir el event type:") |
|
print(event_type) |
|
print("El tipo de event type es: ", type(event_type)) |
|
|
|
if event_type == 'payment_intent.succeeded': |
|
print('payment intent succeed') |
|
print(event_data) |
|
print("Ready") |
|
print(event_data['created']) |
|
print(event_data['id']) |
|
|
|
print(event_data['payment_method']) |
|
|
|
print("Customer:") |
|
cus = event_data['customer'] |
|
print(cus) |
|
herramientas.registrar_evento(cus, 999) |
|
|
|
else: |
|
print(f'unhandled event: {event_type}') |
|
|
|
return {"status": "success"} |
|
|
|
|
|
|