forex-scalping.com

Code: Select all

//+------------------------------------------------------------------+
//|                                                  BD_LSS_v2.mq5   |
//|                        Bi-Directional Liquidity Sweep Engine     |
//|                        For ECN Spot Execution                    |
//+------------------------------------------------------------------+
#property copyright "Copyright 2026, Autonomous Trading Systems"
#property link      "https://www.forex-scalping.com"
#property version   "2.00"
#property strict

#include <Trade\Trade.mqh>

//--- Inputs
input group "--- Risk & Money Management ---"
input double   InpLotSize        = 0.1;       // Base Lot Size (Series Allocation)
input double   InpStopLossPips   = 30.0;      // Stop Loss in Pips
input double   InpTakeProfitPips = 60.0;      // Take Profit in Pips
input ulong    InpMagicNumber    = 13372026;  // EA Magic Number

input group "--- Execution & Filters ---"
input int      InpMaxSpreadPips  = 3;         // Max Allowed Spread (Pips)
input int      InpATRPeriod      = 14;        // ATR Period for Volatility Bands
input double   InpDevMultiplier  = 1.5;       // ATR Deviation Multiplier from Median

input group "--- Session & Flat Clocks ---"
input int      InpStartHour      = 8;         // Trading Start Hour (UTC/Broker Time)
input int      InpEndHour        = 20;        // Trading End Hour (Flatten Time)

//--- Global Objects & Variables
CTrade         trade;
int            atr_handle;
datetime       last_bar_time;

//+------------------------------------------------------------------+
//| Expert initialization function                                   |
//+------------------------------------------------------------------+
int OnInit()
{
   trade.SetExpertMagicNumber(InpMagicNumber);
   trade.SetDeviationInPoints(10);
   
   // Initialize ATR Indicator Handle
   atr_handle = iATR(_Symbol, _Period, InpATRPeriod);
   if(atr_handle == INVALID_HANDLE)
   {
      Print("Error creating ATR indicator handle.");
      return(INIT_FAILED);
   }

   last_bar_time = 0;
   Print("BD-LSS-v2 Initialized Successfully on ", _Symbol);
   return(INIT_SUCCEEDED);
}

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

//+------------------------------------------------------------------+
//| Expert tick function                                             |
//+------------------------------------------------------------------+
void OnTick()
{
   // 1. Time & Session Check (Flat-by Clock)
   MqlDateTime dt;
   TimeToStruct(TimeCurrent(), dt);
   
   if(dt.hour < InpStartHour || dt.hour >= InpEndHour)
   {
      // Outside trading hours -> Force flatten active positions if flat-by rule triggers
      CloseAllPositions();
      return;
   }

   // 2. Spread Filter Check
   long spread_points = SymbolInfoInteger(_Symbol, SYMBOL_SPREAD);
   double point_size  = _Point;
   double current_spread_pips = (spread_points * point_size) / (_Digits == 3 || _Digits == 5 ? point_size * 10 : point_size);
   
   if(current_spread_pips > InpMaxSpreadPips)
      return; // Skip tick due to high spread / low liquidity

   // 3. New Bar Check for Execution Logic
   datetime current_bar_time = iTime(_Symbol, _Period, 0);
   if(current_bar_time == last_bar_time)
      return; // Execute once per bar interval

   last_bar_time = current_bar_time;

   // 4. Retrieve Indicator Values (ATR & Price Structure)
   double atr_val[];
   ArraySetAsSeries(atr_val, true);
   if(CopyBuffer(atr_handle, 0, 0, 2, atr_val) <= 0)
      return;

   double atr = atr_val[0];
   double ask = SymbolInfoDouble(_Symbol, SYMBOL_ASK);
   double bid = SymbolInfoDouble(_Symbol, SYMBOL_BID);
   double median_price = (ask + bid) / 2.0;

   // Calculate dynamic deviation bands based on median price and ATR
   double upper_band = median_price + (atr * InpDevMultiplier);
   double lower_band = median_price - (atr * InpDevMultiplier);

   // Get current open positions count for bi-directional engine tracking
   int buy_positions = CountOpenPositions(POSITION_TYPE_BUY);
   int sell_positions = CountOpenPositions(POSITION_TYPE_SELL);

   // 5. Bi-Directional Liquidity Sweep Entry Logic
   // Long Engine: Price sweeps below lower deviation band (Mean Reversion / Sweep Buy)
   if(bid <= lower_band && buy_positions == 0)
   {
      double sl = bid - (InpStopLossPips * _Point * (_Digits == 3 || _Digits == 5 ? 10 : 1));
      double tp = bid + (InpTakeProfitPips * _Point * (_Digits == 3 || _Digits == 5 ? 10 : 1));
      trade.Buy(InpLotSize, _Symbol, ask, sl, tp, "BD-LSS-v2: Long Sweep");
   }

   // Short Engine: Price sweeps above upper deviation band (Mean Reversion / Sweep Sell)
   if(ask >= upper_band && sell_positions == 0)
   {
      double sl = ask + (InpStopLossPips * _Point * (_Digits == 3 || _Digits == 5 ? 10 : 1));
      double tp = ask - (InpTakeProfitPips * _Point * (_Digits == 3 || _Digits == 5 ? 10 : 1));
      trade.Sell(InpLotSize, _Symbol, bid, sl, tp, "BD-LSS-v2: Short Sweep");
   }
}

//+------------------------------------------------------------------+
//| Count active positions by type                                   |
//+------------------------------------------------------------------+
int CountOpenPositions(ENUM_POSITION_TYPE pos_type)
{
   int count = 0;
   for(int i = PositionsTotal() - 1; i >= 0; i--)
   {
      if(PositionGetSymbol(i) == _Symbol && PositionGetInteger(POSITION_MAGIC) == InpMagicNumber)
      {
         if(PositionGetInteger(POSITION_TYPE) == pos_type)
            count++;
      }
   }
   return count;
}

//+------------------------------------------------------------------+
//| Close all open positions for this symbol & magic number          |
//+------------------------------------------------------------------+
void CloseAllPositions()
{
   for(int i = PositionsTotal() - 1; i >= 0; i--)
   {
      if(PositionGetSymbol(i) == _Symbol && PositionGetInteger(POSITION_MAGIC) == InpMagicNumber)
      {
         trade.PositionClose(PositionGetTicket(i));
      }
   }
}
//+------------------------------------------------------------------+