#property copyright "Copyright (C) 2025 NAYA +237674724684"
#property link      "https://forexsb.com"
#property version   "1.2"
#property strict

#include <Forexsb.com/Indicator.mqh>
#include <Forexsb.com/Enumerations.mqh>

class SessionVWAPStepped : public Indicator
{
public:
   SessionVWAPStepped(SlotTypes slotType)
     {
      SlotType          = slotType;
      IndicatorName     = "SessionVWAPStepped";
      WarningMessage    = "Anchored VWAP that resets at stepped periods (15-1440 min) with broker time sync";
      IsAllowLTF        = true;
      ExecTime          = ExecutionTime_DuringTheBar;
      IsSeparateChart   = false;
      IsDiscreteValues  = false;
      IsDefaultGroupAll = false;
     }

   virtual void Calculate(DataSet &dataSet);

private:
   datetime GetNextResetTime(datetime barTime, int anchorHour, int anchorMinute, int resetPeriod);
};

void SessionVWAPStepped::Calculate(DataSet &dataSet)
{
   Data = GetPointer(dataSet);

   // Read parameters
   string logic         = ListParam[0].Text;
   int    anchorHour    = (int)StringToInteger(ListParam[1].Text);
   int    anchorMinute  = (int)StringToInteger(ListParam[2].Text);
   int    resetPeriod   = (int)StringToInteger(ListParam[3].Text);
   int    shift         = (int)StringToInteger(ListParam[4].Text);
   bool   usePrevious   = CheckParam[0].Checked;

   const int firstBar = 3;
   int       bars     = Data.Bars;

   // Allocate buffers
   double vwapBuffer[];     ArrayResize(vwapBuffer, bars);    ArrayInitialize(vwapBuffer, 0.0);
   double shiftedVWAP[];    ArrayResize(shiftedVWAP, bars);   ArrayInitialize(shiftedVWAP, 0.0);

   double cumPV = 0.0;
   double cumV  = 0.0;
   datetime currentResetTime = 0;

   // Main calculation loop
   for(int bar = firstBar; bar < bars; bar++)
     {
      datetime barTime = Data.Time[bar]; // MT4 bar opening time
      datetime barEndTime = barTime + Period() * 60; // Bar end time (broker timezone)
      datetime nextReset = GetNextResetTime(barEndTime, anchorHour, anchorMinute, resetPeriod);

      if(nextReset != currentResetTime)
        {
         cumPV = 0.0;
         cumV  = 0.0;
         currentResetTime = nextReset;
        }

      double tp = (Data.Open[bar] + Data.High[bar] + Data.Low[bar] + Data.Close[bar]) / 4.0;
      long   vol = Data.Volume[bar];

      cumPV += tp * (double)vol;
      cumV  += (double)vol;

      vwapBuffer[bar] = (cumV > 0.0) ? (cumPV / cumV) : 0.0;
     }

   // Apply shift
   for(int bar = 0; bar < bars; bar++)
     {
      int src = bar - shift;
      if(src >= 0 && src < bars)
         shiftedVWAP[bar] = vwapBuffer[src];
      else
         shiftedVWAP[bar] = 0.0;
     }

   // Build components
   if(SlotType == SlotTypes_Open || SlotType == SlotTypes_Close)
     {
      ArrayResize(Component[1].Value, bars);
      ArrayInitialize(Component[1].Value, 0.0);

      for(int bar = firstBar + shift; bar < bars; bar++)
        {
         int prevBar = usePrevious ? 1 : 0;
         double v0 = shiftedVWAP[bar - prevBar];
         double v1 = shiftedVWAP[bar - prevBar - 1];
         double outPrice = v0;

         if((v1 > Data.High[bar - 1] && v0 < Data.Open[bar]) ||
            (v1 < Data.Low[bar - 1]  && v0 > Data.Open[bar]) ||
            (Data.Close[bar - 1] < v0 && v0 < Data.Open[bar]) ||
            (Data.Close[bar - 1] > v0 && v0 > Data.Open[bar]))
           {
            outPrice = Data.Open[bar];
           }

         Component[1].Value[bar] = outPrice;
        }
     }
   else
     {
      ArrayResize(Component[1].Value, bars);
      ArrayResize(Component[2].Value, bars);
      Component[1].FirstBar = firstBar + shift;
      Component[2].FirstBar = firstBar + shift;
     }

   // Main VWAP line
   ArrayResize(Component[0].Value, bars);
   Component[0].CompName   = "SessionVWAPStepped Value";
   Component[0].DataType   = IndComponentType_IndicatorValue;
   Component[0].FirstBar   = firstBar + shift;
   ArrayCopy(Component[0].Value, shiftedVWAP);

   // Assign component types
   if(SlotType == SlotTypes_Open)
     {
      Component[1].CompName = "Position opening price";
      Component[1].DataType = IndComponentType_OpenPrice;
     }
   else if(SlotType == SlotTypes_OpenFilter)
     {
      Component[1].CompName = "Is long entry allowed";
      Component[1].DataType = IndComponentType_AllowOpenLong;
      Component[2].CompName = "Is short entry allowed";
      Component[2].DataType = IndComponentType_AllowOpenShort;
     }
   else if(SlotType == SlotTypes_Close)
     {
      Component[1].CompName = "Position closing price";
      Component[1].DataType = IndComponentType_ClosePrice;
     }
   else if(SlotType == SlotTypes_CloseFilter)
     {
      Component[1].CompName = "Close out long position";
      Component[1].DataType = IndComponentType_ForceCloseLong;
      Component[2].CompName = "Close out short position";
      Component[2].DataType = IndComponentType_ForceCloseShort;
     }

   // Apply filter logic
   if(SlotType == SlotTypes_OpenFilter || SlotType == SlotTypes_CloseFilter)
     {
      int usePrev = usePrevious ? 1 : 0;
      
      if(logic == "The SessionVWAPStepped rises")
         IndicatorRisesLogic(firstBar + shift, usePrev, shiftedVWAP, Component[1], Component[2]);
      else if(logic == "The SessionVWAPStepped falls")
         IndicatorFallsLogic(firstBar + shift, usePrev, shiftedVWAP, Component[1], Component[2]);
      else if(logic == "The bar opens above the SessionVWAPStepped")
         BarOpensAboveIndicatorLogic(firstBar + shift, usePrev, shiftedVWAP, Component[1], Component[2]);
      else if(logic == "The bar opens below the SessionVWAPStepped")
         BarOpensBelowIndicatorLogic(firstBar + shift, usePrev, shiftedVWAP, Component[1], Component[2]);
      else if(logic == "The bar opens above the SessionVWAPStepped after opening below it")
         BarOpensAboveIndicatorAfterOpeningBelowLogic(firstBar + shift, usePrev, shiftedVWAP, Component[1], Component[2]);
      else if(logic == "The bar opens below the SessionVWAPStepped after opening above it")
         BarOpensBelowIndicatorAfterOpeningAboveLogic(firstBar + shift, usePrev, shiftedVWAP, Component[1], Component[2]);
      else if(logic == "The position opens above the SessionVWAPStepped")
        {
         Component[0].PosPriceDependence = PositionPriceDependence_BuyHigherSellLower;
         Component[0].UsePreviousBar     = usePrev;
         Component[1].ShowInDynInfo      = false;
         Component[2].ShowInDynInfo      = false;
        }
      else if(logic == "The position opens below the SessionVWAPStepped")
        {
         Component[0].PosPriceDependence = PositionPriceDependence_BuyLowerSellHigher;
         Component[0].UsePreviousBar     = usePrev;
         Component[1].ShowInDynInfo      = false;
         Component[2].ShowInDynInfo      = false;
        }
      else if(logic == "The bar closes below the SessionVWAPStepped")
         BarClosesBelowIndicatorLogic(firstBar + shift, usePrev, shiftedVWAP, Component[1], Component[2]);
      else if(logic == "The bar closes above the SessionVWAPStepped")
         BarClosesAboveIndicatorLogic(firstBar + shift, usePrev, shiftedVWAP, Component[1], Component[2]);
     }
}

datetime SessionVWAPStepped::GetNextResetTime(datetime barEndTime, int anchorHour, int anchorMinute, int resetPeriod)
{
   MqlDateTime tm;
   TimeToStruct(barEndTime, tm);
   
   // Create anchor time for today in broker timezone
   MqlDateTime anchorStruct = tm;
   anchorStruct.hour = anchorHour;
   anchorStruct.min  = anchorMinute;
   anchorStruct.sec  = 0;
   datetime anchorToday = StructToTime(anchorStruct);
   
   if(barEndTime >= anchorToday)
     {
      // Calculate time since today's anchor
      int minutesSinceAnchor = (int)((barEndTime - anchorToday) / 60);
      int periods = minutesSinceAnchor / resetPeriod;
      return anchorToday + (periods + 1) * resetPeriod * 60;
     }
   else
     {
      // Use yesterday's anchor time
      datetime anchorYesterday = anchorToday - 86400;
      int minutesSinceAnchor = (int)((barEndTime - anchorYesterday) / 60);
      int periods = minutesSinceAnchor / resetPeriod;
      return anchorYesterday + (periods + 1) * resetPeriod * 60;
     }
}