Connecteur SMS

				
					# This Python script serves as an SMS proxy/gateway designed to facilitate communication
# between two PBXWare instances. The application acts as an intermediary for sending and
# receiving SMS messages, forwarding them from one PBXWare instance to another.
#
# Purpose:
# - Act as an SMS bridge between PBXWare instances, allowing seamless communication.
# - Handle incoming POST requests to the '/messages' endpoint, validating Bearer
#   Authorization with the provided token, printing the received JSON payload, and
#   forwarding the message to the specified PBXWare instance.
# - Return a JSON response with status and message fields based on the success or failure
#   of the forwarding operation, utilizing the response from the receiving PBXWare instance.
#
# Command-Line Arguments:
# --listen: Specifies the host and port for the HTTP server to listen on.
#           Example: --listen 127.0.0.1:5000
#
# --forward-to: Specifies the URL where incoming SMS messages will be forwarded.
#               Example: --forward-to https://my.pbxware.com/smsservice/connector
#
# --auth-token: Specifies the token for Bearer Authorization, ensuring secure communication.
#               Example: --auth-token my_secret_token
#
# Example Usage:
# python sms_proxy.py --listen 127.0.0.1:5000 --forward-to https://my.pbxware.com/smsservice/connector --auth-token my_secret_token
#
# Note: This script serves as an illustrative example and may need modification to suit
# specific requirements or environments.
import argparse
import json
from flask import Flask, request, abort, jsonify
import requests
app = Flask(__name__)
def parse_args():
    parser = argparse.ArgumentParser(description="HTTP Server with Forwarding")
    parser.add_argument("--listen", required=True, help="Host and port for HTTP server")
    parser.add_argument("--forward-to", required=True, help="URL where requests will be forwarded to")
    parser.add_argument("--auth-token", required=True, help="Token for Bearer Authorization")
    return parser.parse_args()
def validate_auth_token(request):
    auth_header = request.headers.get('Authorization')
    if not auth_header or auth_header != f'Bearer {args.auth_token}':
        abort(401, 'Unauthorized')
def forward_request(url, data, auth_token):
    headers = {'Content-Type': 'application/json', 'Authorization': f'Bearer {auth_token}'}
    response = requests.post(url, data=json.dumps(data), headers=headers)
    return response
@app.route('/messages', methods=['POST'])
def receive_message():
    try:
        validate_auth_token(request)
        data = request.json
        print("Received Message:")
        print(json.dumps(data, indent=2))
        forward_response = forward_request(args.forward_to, data, args.auth_token)
        if forward_response.status_code == 200:
            return jsonify({"status": "success", "message": ""}), 200
        else:
            return jsonify({"status": "error", "message": f"Forwarding failed with status code {forward_response.status_code}"}), 200
    except Exception as e:
        return jsonify({"status": "error", "message": str(e)}), 500
if __name__ == '__main__':
    args = parse_args()
    host, port = args.listen.split(':')
    app.run(host=host, port=int(port))