forex-scalping.com

Code: Select all

//@version=5
strategy("Two-Phase Buffer Strategy with Webhooks", overlay=true, initial_capital=10000, margin_long=100, margin_short=100)

// --- Input Parameters ---
silverSym = input.symbol("OANDA:XAGUSD", title="Phase 1: Silver Symbol")
bufferTarget = input.float(50.0, title="Phase 1: Buffer Target (USD)")
forexLotSize = input.float(1.0, title="Phase 2: Forex Lot Size")

// --- State Variables ---
var int tradingPhase = 1
var float riskBufferUSD = 0.0
var float phase2StartEquity = 0.0
var float silverEntryPrice = na
var float silverUnits = 0.0

// --- Fetch Silver Data ---
silverClose = request.security(silverSym, timeframe.period, close)

// --- Webhook JSON Builder ---
// Converts the order action into a clean JSON string for your local server
qtyUnits = forexLotSize * 100000

f_build_payload(_action, _comment) =>
    '{"action": "' + _action + '", "symbol": "' + syminfo.ticker + '", "volume": ' + str.tostring(qtyUnits) + ', "comment": "' + _comment + '"}'

//+------------------------------------------------------------------+
//| Phase 1: The Zero-Leverage Silver Long (Modeled)                 |
//+------------------------------------------------------------------+
if tradingPhase == 1
    if na(silverEntryPrice)
        silverEntryPrice := silverClose
        silverUnits := strategy.equity / silverEntryPrice 

    if not na(silverEntryPrice)
        currentSilverPnL = (silverClose - silverEntryPrice) * silverUnits
        
        if currentSilverPnL >= bufferTarget
            riskBufferUSD := currentSilverPnL
            phase2StartEquity := strategy.equity + riskBufferUSD 
            tradingPhase := 2
            
            silverEntryPrice := na 
            silverUnits := 0.0

//+------------------------------------------------------------------+
//| Phase 2: The "House Money" Transfer & Webhook Execution          |
//+------------------------------------------------------------------+
if tradingPhase == 2
    // Risk Check: Flush all trades if buffer is depleted
    if strategy.equity <= (phase2StartEquity - riskBufferUSD)
        // Generate emergency flush JSON
        flushPayload = f_build_payload("close_all", "Buffer Depleted: Emergency Flush")
        strategy.close_all(comment="Buffer Depleted", alert_message=flushPayload)
        
        tradingPhase := 1
        riskBufferUSD := 0.0

    // --- CORE SCALPING ALGORITHM ---
    fastSMA = ta.sma(close, 10)
    slowSMA = ta.sma(close, 20)
    
    // Build specific JSON payloads for each action
    buyPayload   = f_build_payload("buy", "Phase 2 Long Cross")
    sellPayload  = f_build_payload("sell", "Phase 2 Short Cross")
    closePayload = f_build_payload("close", "Phase 2 Exit")

    if strategy.position_size == 0
        if ta.crossover(fastSMA, slowSMA)
            strategy.entry("Phase 2 Long", strategy.long, qty=qtyUnits, alert_message=buyPayload)
        else if ta.crossunder(fastSMA, slowSMA)
            strategy.entry("Phase 2 Short", strategy.short, qty=qtyUnits, alert_message=sellPayload)
            
    if strategy.position_size > 0 and ta.crossunder(fastSMA, slowSMA)
        strategy.close("Phase 2 Long", alert_message=closePayload)
    if strategy.position_size < 0 and ta.crossover(fastSMA, slowSMA)
        strategy.close("Phase 2 Short", alert_message=closePayload)

//+------------------------------------------------------------------+
//| Visualizing the Phases on the Chart                              |
//+------------------------------------------------------------------+
bgcolor(tradingPhase == 1 ? color.new(color.silver, 90) : na, title="Phase 1 Background")
plotshape(tradingPhase == 2 and tradingPhase[1] == 1, style=shape.labelup, location=location.belowbar, color=color.green, text="BUFFER LOCKED", textcolor=color.white, size=size.small)
plotshape(tradingPhase == 1 and tradingPhase[1] == 2, style=shape.labeldown, location=location.abovebar, color=color.red, text="BUFFER LOST", textcolor=color.white, size=size.small)

Code: Select all

{{strategy.order.alert_message}}

Code: Select all

import uvicorn
import logging
from fastapi import FastAPI, Header, HTTPException, Depends
from pydantic import BaseModel

# Configure logging for real-time monitoring
logging.basicConfig(level=logging.INFO, format="%(asctime)s [%(levelname)s] %(message)s")
logger = logging.getLogger(__name__)

app = FastAPI(title="Trade Execution Server")

# Define the expected JSON payload matching the Pine Script webhook
class TradePayload(BaseModel):
    action: str
    symbol: str
    volume: float
    comment: str

# Security: Define a secret token to validate incoming TradingView webhooks
# In production, load this from an environment variable (.env)
WEBHOOK_SECRET = "your_secure_token_here"

# Dependency to verify the custom header from TradingView
def verify_token(x_webhook_token: str = Header(None)):
    if x_webhook_token != WEBHOOK_SECRET:
        logger.warning(f"Unauthorized webhook attempt. Token provided: {x_webhook_token}")
        raise HTTPException(status_code=401, detail="Unauthorized")
    return x_webhook_token

@app.post("/webhook")
async def receive_webhook(payload: TradePayload, token: str = Depends(verify_token)):
    logger.info(f"Received valid webhook: Action={payload.action} | Symbol={payload.symbol} | Vol={payload.volume} | Comment={payload.comment}")
    
    # --- CORE EXECUTION ROUTING ---
    # This is where you connect to your MT5/cTrader bridge or broker API
    
    try:
        if payload.action == "buy":
            # e.g., mt5.order_send(...)
            logger.info(f"Executing BUY for {payload.volume} units of {payload.symbol}")
            
        elif payload.action == "sell":
            logger.info(f"Executing SELL for {payload.volume} units of {payload.symbol}")
            
        elif payload.action == "close":
            logger.info(f"Closing Phase 2 positions for {payload.symbol}")
            
        elif payload.action == "close_all":
            logger.warning("EMERGENCY FLUSH: Closing all protected positions.")
            
        else:
            logger.error(f"Unknown action received: {payload.action}")
            return {"status": "error", "message": "Unknown action"}
            
        return {"status": "success", "message": f"Processed {payload.action} for {payload.symbol}"}

    except Exception as e:
        logger.error(f"Execution failed: {str(e)}")
        raise HTTPException(status_code=500, detail="Internal Execution Error")

if __name__ == "__main__":
    # Run the server locally
    uvicorn.run("main:app", host="0.0.0.0", port=8000, reload=True)