forex-scalping.com

Code: Select all

from flask import Flask, request, jsonify
import json

app = Flask(__name__)

# Global variable to store the latest signal
latest_signal = {}

@app.route('/webhook', methods=['POST'])
def webhook():
    global latest_signal
    try:
        # Parse the JSON payload from TradingView
        data = request.get_json(force=True)
        
        # Basic validation to ensure required fields exist
        if 'action' in data and 'symbol' in data:
            latest_signal = data
            print(f"✅ New Signal Received: {data}")
            return jsonify({"status": "success", "message": "Signal stored"}), 200
        else:
            print("❌ Invalid payload format")
            return jsonify({"status": "error", "message": "Invalid payload"}), 400
            
    except Exception as e:
        print(f"❌ Error processing webhook: {str(e)}")
        return jsonify({"status": "error", "message": str(e)}), 500

@app.route('/get_latest_alert', methods=['GET'])
def get_latest_alert():
    # MT5 will hit this endpoint every second
    global latest_signal
    
    if latest_signal:
        return jsonify(latest_signal), 200
    else:
        # Return an empty JSON object if no signal has been received yet
        return jsonify({}), 200

if __name__ == '__main__':
    # Run the server on port 5000 (localhost)
    app.run(host='0.0.0.0', port=5000)

Code: Select all

//+------------------------------------------------------------------+
//|                                           TV_Webhook_Receiver.mq4|
//+------------------------------------------------------------------+
#property strict
#include <JAson.mqh> // Download from MQL4/MQL5 CodeBase

string server_url = "http://localhost:5000/get_latest_alert"; 
string last_processed_signal = "";
int magic_number = 777777; // Unique ID to manage only TV webhook trades

//+------------------------------------------------------------------+
//| Expert initialization function                                   |
//+------------------------------------------------------------------+
int OnInit()
{
    // Enable polling every 1 second
    EventSetTimer(1); 
    Print("EA Initialized. Listening for TradingView signals...");
    return(INIT_SUCCEEDED);
}

//+------------------------------------------------------------------+
//| Expert deinitialization function                                 |
//+------------------------------------------------------------------+
void OnDeinit(const int reason)
{
    EventKillTimer();
}

//+------------------------------------------------------------------+
//| Expert timer function                                            |
//+------------------------------------------------------------------+
void OnTimer()
{
    string headers = "";
    string result_headers = "";
    char post[], result[];
    
    // MQL4 uses a slightly different WebRequest parameter structure than MT5
    int res = WebRequest("GET", server_url, headers, 500, post, result, result_headers);
    
    if(res == 200)
    {
        string json_string = CharArrayToString(result);
        
        // Prevent duplicate execution of the same signal
        if(json_string != last_processed_signal && json_string != "") 
        {
            ParseAndExecute(json_string);
            last_processed_signal = json_string;
        }
    }
}

//+------------------------------------------------------------------+
//| Parse JSON and Execute Trade                                     |
//+------------------------------------------------------------------+
void ParseAndExecute(string json_payload)
{
    CJAVal json;
    
    // Deserialize the JSON string sent by TradingView
    if(json.Deserialize(json_payload))
    {
        string action = json["action"].ToStr();
        string symbol = json["symbol"].ToStr();
        
        // Fetch current broker pricing and digit structure
        double ask = MarketInfo(symbol, MODE_ASK);
        double bid = MarketInfo(symbol, MODE_BID);
        int digits = (int)MarketInfo(symbol, MODE_DIGITS);
        
        // Placeholder for Rule 5 position sizing
        double lot_size = 0.1; 
        
        if(action == "long")
        {
            // MT4 requires strict price normalization before execution
            double sl = NormalizeDouble(json["sl"].ToDbl(), digits);
            double tp = NormalizeDouble(json["tp"].ToDbl(), digits);
            
            int ticket = OrderSend(symbol, OP_BUY, lot_size, ask, 3, sl, tp, "TV Long Sweep", magic_number, 0, clrGreen);
            if(ticket < 0) Print("OrderSend Error: ", GetLastError());
            else Print("Executed Long on ", symbol);
        }
        else if(action == "short")
        {
            double sl = NormalizeDouble(json["sl"].ToDbl(), digits);
            double tp = NormalizeDouble(json["tp"].ToDbl(), digits);
            
            int ticket = OrderSend(symbol, OP_SELL, lot_size, bid, 3, sl, tp, "TV Short Sweep", magic_number, 0, clrRed);
            if(ticket < 0) Print("OrderSend Error: ", GetLastError());
            else Print("Executed Short on ", symbol);
        }
        else if(action == "exit_long" || action == "exit_short")
        {
            // Iterate backwards through the order pool to safely close positions
            for(int i = OrdersTotal() - 1; i >= 0; i--)
            {
                if(OrderSelect(i, SELECT_BY_POS, MODE_TRADES))
                {
                    if(OrderSymbol() == symbol && OrderMagicNumber() == magic_number)
                    {
                        // Determine correct closing price based on order direction
                        double close_price = (OrderType() == OP_BUY) ? MarketInfo(symbol, MODE_BID) : MarketInfo(symbol, MODE_ASK);
                        bool closed = OrderClose(OrderTicket(), OrderLots(), close_price, 3, clrGray);
                        
                        if(!closed) Print("OrderClose Error: ", GetLastError());
                        else Print("Closed position on ", symbol, " due to TV exit signal.");
                    }
                }
            }
        }
    }
}

Code: Select all

ngrok config add-authtoken YOUR_TOKEN_HERE

Code: Select all

ngrok http 5000

Code: Select all

from flask import Flask, request, jsonify

app = Flask(__name__)

# Holds the most recent webhook payload in memory
latest_signal = {}

# Layer 1: TradingView's official webhook IP addresses
TRADINGVIEW_IPS = [
    "52.89.214.238",
    "34.212.75.30",
    "54.218.53.128",
    "52.32.178.7"
]

# Layer 2: Your custom secret PIN
SECRET_PASSPHRASE = "FairmanBlueprint2026!"

@app.route('/webhook', methods=['POST'])
def webhook():
    global latest_signal
    
    # --- SECURITY LAYER 1: IP ALLOWLIST ---
    # Because Ngrok proxies the connection locally, request.remote_addr is always 127.0.0.1.
    # We must extract the true origin IP from the X-Forwarded-For header.
    forwarded_for = request.headers.get('X-Forwarded-For', '')
    client_ip = forwarded_for.split(',')[0].strip() if forwarded_for else request.remote_addr
    
    if client_ip not in TRADINGVIEW_IPS:
        print(f"⛔ Intrusion blocked: Unauthorized IP {client_ip}")
        return jsonify({"error": "Unauthorized IP"}), 403

    try:
        data = request.get_json(force=True)
        
        # --- SECURITY LAYER 2: PASSPHRASE ---
        if data.get("passphrase") != SECRET_PASSPHRASE:
            print(f"⛔ Intrusion blocked: Invalid Passphrase from {client_ip}")
            return jsonify({"error": "Unauthorized payload"}), 403
            
        # Execute trade logic
        if 'action' in data and 'symbol' in data:
            latest_signal = data
            print(f"⚡ Secure Signal Processed: {data['action'].upper()} on {data['symbol']}")
            return jsonify({"status": "success", "message": "Signal queued for MT4"}), 200
        else:
            return jsonify({"error": "Invalid payload structure"}), 400
            
    except Exception as e:
        print(f"❌ Webhook Error: {str(e)}")
        return jsonify({"error": "Failed to process payload"}), 500

@app.route('/get_latest_alert', methods=['GET'])
def get_latest_alert():
    global latest_signal
    if latest_signal:
        return jsonify(latest_signal), 200
    else:
        return jsonify({}), 200

if __name__ == '__main__':
    print("🚀 Secure Webhook Server running on http://localhost:5000")
    app.run(host='0.0.0.0', port=5000)

Code: Select all

// Construct dynamic JSON for Long Entry
string long_json = '{"passphrase": "FairmanBlueprint2026!", "action": "long", "symbol": "' + syminfo.ticker + '", "price": ' + str.tostring(close) + ', "sl": ' + str.tostring(long_sl) + ', "tp": ' + str.tostring(long_tp) + '}'