Webhook

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

from flask import Flask, request, jsonify, abort

app = Flask(__name__)

# Sign secret provided by mobway
SIGN_SECRET = 'YOUR_SIGN_SECRET_PROVIDED_BY_MOBWAY'

logging.basicConfig(level=logging.INFO)

def verify_signature(payload, signature):
    """
    Checks the authenticity of the webhook signature.
    
    Args:
      Payload (str): The content of the webhook received.
      Signature (str): The HMAC signature received in the webhook header.
    
    Returns:
      Bool: True if the signature is valid, False otherwise.
    """
    logging.info("Checking signature...")
    computed_signature = hmac.new(SIGN_SECRET.encode(), payload.encode(), hashlib.sha256).hexdigest()
    is_valid = hmac.compare_digest(computed_signature, signature)
    logging.info(f"Valid signature: {is_valid}")
    return is_valid

def process_data(data):
    """
    Processes the data received from the webhook.
    
    Args:
      Data (dict): Payload data in JSON format.
    """
    logging.info(f"Processing data: {data}")
    # Here you can add the logic to process the received data

async def handle_request(payload, signature):
    """
      Deals with the webhook request, verifying the signature and processing the payload.
      
      Args:
        Payload (str): The content of the webhook received.
        Signature (str): The HMAC signature received in the webhook header.
    """
    if not verify_signature(payload, signature):
        logging.warning("Invalid signature, aborting...")
        abort(403)
    
    logging.info("Signature successfully verified, processing request...")
    data = json.loads(payload)
    thread = threading.Thread(target=process_data, args=(data,))
    thread.start()
    thread.join()

@app.route('/', methods=['GET'])
def home():
    """
    Basic route for server status check.
    
    Returns:
      Response: Returns a success message.
    """
    return jsonify({"status": "success"}), 200

@app.route('/webhook', methods=['POST'])
async def webhook():
    """
    Route to receive webhook data.
    
    Returns:
      Response: Returns a success message after webhook processing.
    """
    logging.info("Webhook received...")
    payload = request.get_data(as_text=True)
    signature = request.headers.get('X-Signature')
    await handle_request(payload, signature)
    logging.info("Webhook processed successfully!")
    return jsonify({"status": "success"}), 200

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