BSMarketTrend

//+------------------------------------------------------------------+
//|                                               FractalsSignal.mq4 |
//|                                                                  |
//|                                                                  |
//+------------------------------------------------------------------+
#property copyright ""
#property link      ""
#property version   "1.00"
#property strict
#property indicator_chart_window

const extern int _BARS_FOR_TRENDCHECK = 48;

const int _MARKET_TREND_UP = 1; const int _MARKET_TREND_DOWN = 2;
const int _MARKET_TREND_UNKNOWN = 0;
const int _BARS_UNTIL_VERIFIED = 2;

string _sCurrentSymbol = "";

int _nM30Trend = 0;
int _nH4Trend = 0;

datetime _LastBarTime[9]; //M1 to MN in increasing order

int OnInit()
  {
   //declaration & initialisation
   int i = 0;

   //get the open time of the last bars of all periods
   _LastBarTime[0] = iTime(_sCurrentSymbol, PERIOD_M1, 0);
   _LastBarTime[1] = iTime(_sCurrentSymbol, PERIOD_M5, 0);
   _LastBarTime[2] = iTime(_sCurrentSymbol, PERIOD_M15, 0);
   _LastBarTime[3] = iTime(_sCurrentSymbol, PERIOD_M30, 0);
   _LastBarTime[4] = iTime(_sCurrentSymbol, PERIOD_H1, 0);
   _LastBarTime[5] = iTime(_sCurrentSymbol, PERIOD_H4, 0);
   _LastBarTime[6] = iTime(_sCurrentSymbol, PERIOD_D1, 0);
   _LastBarTime[7] = iTime(_sCurrentSymbol, PERIOD_W1, 0);
   _LastBarTime[8] = iTime(_sCurrentSymbol, PERIOD_MN1, 0);

   _nM30Trend = GetTrend(PERIOD_M30);
   _nH4Trend = GetTrend(PERIOD_H4);

   Comment(_nM30Trend + "\n" + _nH4Trend + "\n" + Symbol());

   return(INIT_SUCCEEDED);
  }

void OnDeinit(const int reason)
  {
   Comment("");
  }

int OnCalculate(const int rates_total,
                const int prev_calculated,
                const datetime &time[],
                const double &open[],
                const double &high[],
                const double &low[],
                const double &close[],
                const long &tick_volume[],
                const long &volume[],
                const int &spread[])
  {
   return(rates_total);
  }


int GetTrend(int nTimeframe)
{
   int i = 0;
   int nTrend = _MARKET_TREND_UNKNOWN;

   double dUpFractal = -1;
   double dDownFractal = -1;
   double dTmpFractal = -1;

   //check all bars that could have verified fractals first
   for(i = _BARS_FOR_TRENDCHECK; i > _BARS_UNTIL_VERIFIED; i--)
   {
      // check for broken fractals
      // up and down fractal broken simultaneously
      if(iLow(_sCurrentSymbol, nTimeframe, i) < dDownFractal && dDownFractal > 0
         && iHigh(_sCurrentSymbol, nTimeframe, i) > dUpFractal && dUpFractal > 0)
      {
         nTrend = _MARKET_TREND_UNKNOWN;
         dUpFractal = -1;                          //devalue fractal once broken
         dDownFractal = -1;
      }
      else
      {
         if(iHigh(_sCurrentSymbol, nTimeframe, i) > dUpFractal && dUpFractal > 0)
         {
            nTrend = _MARKET_TREND_UP;
            dUpFractal = -1;
         }
         if(iLow(_sCurrentSymbol, nTimeframe, i) < dDownFractal && dDownFractal > 0)
         {
            nTrend = _MARKET_TREND_DOWN;
            dDownFractal = -1;
         }
      }

      //find the last active fractals (smallest up fractal that was not broken/largest down fractal that was not broken)
      dTmpFractal = iFractals(_sCurrentSymbol, nTimeframe, MODE_UPPER, i);
      if(dTmpFractal > 0)
      {
         if(dTmpFractal < dUpFractal || dUpFractal < 0)
         {
            dUpFractal = dTmpFractal;
         }
      }

      dTmpFractal = iFractals(_sCurrentSymbol, nTimeframe, MODE_LOWER, i);
      if(dTmpFractal > 0)
      {
         if(dTmpFractal > dDownFractal || dDownFractal < 0)
         {
            dDownFractal = dTmpFractal;
         }
      }
   }
   //check remaining bars for broken fractals
   for(i = _BARS_UNTIL_VERIFIED; i >=0; i--)
   {
      if(iLow(_sCurrentSymbol, nTimeframe, i) < dDownFractal && dDownFractal > 0
         && iHigh(_sCurrentSymbol, nTimeframe, i) > dUpFractal && dUpFractal > 0)
      {
         nTrend = _MARKET_TREND_UNKNOWN;
         dUpFractal = -1;                          //devalue fractal once broken
         dDownFractal = -1;
      }
      else
      {
         if(iHigh(_sCurrentSymbol, nTimeframe, i) > dUpFractal && dUpFractal > 0)
         {
            nTrend = _MARKET_TREND_UP;
            dUpFractal = -1;
         }
         if(iLow(_sCurrentSymbol, nTimeframe, i) < dDownFractal && dDownFractal > 0)
         {
            nTrend = _MARKET_TREND_DOWN;
            dDownFractal = -1;
         }
      }
   }
   return(nTrend);
}

bool HasNewBar(int nPeriod)
{
   int i;
   bool bHasNewBar = False;

   //match input periods with index of _LastBarTime
   if(nPeriod == PERIOD_M1){        i = 0;}
   else if(nPeriod == PERIOD_M5){   i = 1;}
   else if(nPeriod == PERIOD_M15){  i = 2;}
   else if(nPeriod == PERIOD_M30){  i = 3;}
   else if(nPeriod == PERIOD_H1){   i = 4;}
   else if(nPeriod == PERIOD_H4){   i = 5;}
   else if(nPeriod == PERIOD_D1){   i = 6;}
   else if(nPeriod == PERIOD_W1){   i = 7;}
   else if(nPeriod == PERIOD_MN1){  i = 8;}

   //if the open time of the last bar is greater than that in _LastBarTime, then there's a new bar
   if(_LastBarTime[i] < iTime(_sCurrentSymbol, nPeriod, 0))
   {
      bHasNewBar = True;
      //overwrite _LastBarTime to hold the newest open time
      _LastBarTime[i] = iTime(_sCurrentSymbol, nPeriod, 0);
   }

   return(bHasNewBar);
}