Webhook

import hmac
import json
import logging
import asyncio
import hashlib
import threading

from flask import Flask, request, jsonify, abort

app = Flask(__name__)

# chave secreta fornecida pela mobway
SIGN_SECRET = 'SUA_SIGN_SECRET_FORNECIDA_PELA_MOBWAY'

logging.basicConfig(level=logging.INFO)

def verify_signature(payload, signature):
    """
    Verifica a autenticidade da assinatura do webhook.
    
    Args:
        payload (str): O conteúdo do webhook recebido.
        signature (str): A assinatura HMAC recebida no cabeçalho do webhook.
    
    Returns:
        bool: True se a assinatura for válida, False caso contrário.
    """
    logging.info("Verificando assinatura...")
    computed_signature = hmac.new(SIGN_SECRET.encode(), payload.encode(), hashlib.sha256).hexdigest()
    is_valid = hmac.compare_digest(computed_signature, signature)
    logging.info(f"Assinatura válida: {is_valid}")
    return is_valid

def process_data(data):
    """
    Processa os dados recebidos do webhook.
    
    Args:
        data (dict): Dados do payload em formato JSON.
    """
    logging.info(f"Processando dados: {data}")
    # Aqui você pode adicionar a lógica para tratar os dados recebidos

async def handle_request(payload, signature):
    """
    Lida com a requisição do webhook, verificando a assinatura e processando o payload.
    
    Args:
        payload (str): O conteúdo do webhook recebido.
        signature (str): A assinatura HMAC recebida no cabeçalho do webhook.
    """
    if not verify_signature(payload, signature):
        logging.warning("Assinatura inválida, abortando...")
        abort(403)
    
    logging.info("Assinatura verificada com sucesso, processando requisição...")
    data = json.loads(payload)
    thread = threading.Thread(target=process_data, args=(data,))
    thread.start()
    thread.join()

@app.route('/', methods=['GET'])
def home():
    """
    Rota básica para verificação de status do servidor.
    
    Returns:
        Response: Retorna uma mensagem de sucesso.
    """
    return jsonify({"status": "success"}), 200

@app.route('/webhook', methods=['POST'])
async def webhook():
    """
    Rota para receber os dados do webhook.
    
    Returns:
        Response: Retorna uma mensagem de sucesso após o processamento do webhook.
    """
    logging.info("Webhook recebido...")
    payload = request.get_data(as_text=True)
    signature = request.headers.get('X-Signature')
    await handle_request(payload, signature)
    logging.info("Webhook processado com sucesso!")
    return jsonify({"status": "success"}), 200

if __name__ == '__main__':
    logging.info("Iniciando aplicativo Flask...")
    app.run(host='0.0.0.0', port=5000, debug=True)