class FSBNewsGate_v2_1 : public Indicator
{
public:
   FSBNewsGate_v2_1(SlotTypes slotType);
   virtual void Calculate(DataSet &dataSet);

private:
   datetime m_newsUtc[];
   string   m_newsPriority[];
   string   m_newsCurrency[];
   string   m_newsTitle[];

   double   m_lastFeedStamp;
   datetime m_lastLoadOk;
   datetime m_lastLoadTry;
   datetime m_lastPanelUpdate;
   datetime m_lastHealthCheck;
   string   m_lastError;
   string   m_cachedFile;

   void EnsureInit();
   int ClampInt(int value, int minValue, int maxValue);
   bool ResolveContinueOnError();
   int ResolvePriorityMode();
   string PriorityModeText(const int priorityMode);
   bool FileHealthCheck(const string fileName, string &errText);
   string ReadFileUtf8(const string fileName, string &error);
   string TrimSimple(string s);
   void ResetNewsArrays();
   int ParseNewsContent(const string content);
   int LoadNewsIfNeeded();
   bool AcceptPriority(const string prio, const int priorityMode);
   bool AcceptCurrency(const string ccy, const string baseCcy, const string quoteCcy);
   string FirstSixLettersUpperFromDataSymbol();
   string GetSymbolBase();
   string GetSymbolQuote();
   int ActiveNewsIndex(const datetime nowUtc,
                       const int priorityMode,
                       const int beforeHigh,
                       const int afterHigh,
                       const int beforeMed,
                       const int afterMed,
                       const int tolSec,
                       const string baseCcy,
                       const string quoteCcy);
   void UpdateStatusPanel(const bool allowNow,
                          const int priorityMode,
                          const bool continueOnError,
                          const int records,
                          const double stamp,
                          const datetime lastLoadOk,
                          const double ageMin,
                          const double bypass,
                          const string lastError);
};

void FSBNewsGate_v2_1::FSBNewsGate_v2_1(SlotTypes slotType)
{
   SlotType = slotType;
   IndicatorName = "FSBNewsGate_v2_1";
   WarningMessage = "";
   IsAllowLTF = false;
   ExecTime = ExecutionTime_DuringTheBar;
   IsSeparateChart = false;
   IsDiscreteValues = false;
   IsDeafultGroupAll = false;
   IsDefaultGroupAll = false;

   m_lastFeedStamp = -1.0;
   m_lastLoadOk = 0;
   m_lastLoadTry = 0;
   m_lastPanelUpdate = 0;
   m_lastHealthCheck = 0;
   m_lastError = "";
   m_cachedFile = "news-feed.txt";

   ArrayResize(m_newsUtc, 0);
   ArrayResize(m_newsPriority, 0);
   ArrayResize(m_newsCurrency, 0);
   ArrayResize(m_newsTitle, 0);
}

void FSBNewsGate_v2_1::EnsureInit()
{
   if(m_cachedFile == "")
      m_cachedFile = "news-feed.txt";
}

int FSBNewsGate_v2_1::ClampInt(int value, int minValue, int maxValue)
{
   if(value < minValue) return minValue;
   if(value > maxValue) return maxValue;
   return value;
}

bool FSBNewsGate_v2_1::ResolveContinueOnError()
{
   if(CheckParam[0].Enabled)
      return CheckParam[0].Checked;
   return true;
}

int FSBNewsGate_v2_1::ResolvePriorityMode()
{
   if(NumParam[5].Enabled)
      return ClampInt((int)NumParam[5].Value, 0, 2);
   if(ListParam[0].Enabled)
      return ClampInt(ListParam[0].Index, 0, 2);
   return 1;
}

string FSBNewsGate_v2_1::PriorityModeText(const int priorityMode)
{
   if(priorityMode == 0) return "Disabled";
   if(priorityMode == 1) return "HighOnly";
   return "High+Med";
}

bool FSBNewsGate_v2_1::FileHealthCheck(const string fileName, string &errText)
{
   errText = "";
   datetime now = TimeCurrent();
   if(now <= m_lastHealthCheck + 15)
      return (m_lastError == "");

   m_lastHealthCheck = now;
   int h = FileOpen(fileName, FILE_READ | FILE_BIN);
   if(h < 0)
   {
      errText = "Missing/unreadable: " + fileName + " err=" + IntegerToString(GetLastError());
      return false;
   }

   int sz = (int)FileSize(h);
   FileClose(h);
   if(sz <= 0)
   {
      errText = "Empty file: " + fileName;
      return false;
   }

   return true;
}

string FSBNewsGate_v2_1::ReadFileUtf8(const string fileName, string &error)
{
   error = "";
   int h = FileOpen(fileName, FILE_READ | FILE_BIN);
   if(h < 0)
   {
      error = "Cannot open news file: " + fileName + " err=" + IntegerToString(GetLastError());
      return "";
   }

   int sz = (int)FileSize(h);
   if(sz <= 0)
   {
      FileClose(h);
      error = "News file is empty: " + fileName;
      return "";
   }

   char buf[];
   ArrayResize(buf, sz);
   FileReadArray(h, buf, 0, sz);
   FileClose(h);
   return CharArrayToString(buf, 0, sz, CP_UTF8);
}

string FSBNewsGate_v2_1::TrimSimple(string s)
{
   StringReplace(s, "\r", "");
   StringTrimLeft(s);
   StringTrimRight(s);
   return s;
}

void FSBNewsGate_v2_1::ResetNewsArrays()
{
   ArrayResize(m_newsUtc, 0);
   ArrayResize(m_newsPriority, 0);
   ArrayResize(m_newsCurrency, 0);
   ArrayResize(m_newsTitle, 0);
}

int FSBNewsGate_v2_1::ParseNewsContent(const string content)
{
   ResetNewsArrays();

   string lines[];
   int ln = StringSplit(content, '\n', lines);
   if(ln <= 0)
   {
      m_lastError = "Cannot parse news feed (no lines)";
      return 0;
   }

   int added = 0;
   for(int i = 0; i < ln; i++)
   {
      string line = TrimSimple(lines[i]);
      if(line == "") continue;
      if(StringSubstr(line, 0, 1) == "#") continue;

      string f[];
      int fn = StringSplit(line, ';', f);
      if(fn != 4) continue;

      string tsText = TrimSimple(f[0]);
      string pr = TrimSimple(f[1]);
      string cc = TrimSimple(f[2]);
      string title = TrimSimple(f[3]);

      StringToLower(pr);
      StringToUpper(cc);

      if(tsText == "" || pr == "" || cc == "")
         continue;

      datetime t = (datetime)StringToInteger(tsText);
      if((int)t <= 0)
         continue;

      int k = ArraySize(m_newsUtc);
      ArrayResize(m_newsUtc, k + 1);
      ArrayResize(m_newsPriority, k + 1);
      ArrayResize(m_newsCurrency, k + 1);
      ArrayResize(m_newsTitle, k + 1);

      m_newsUtc[k] = t;
      m_newsPriority[k] = pr;
      m_newsCurrency[k] = cc;
      m_newsTitle[k] = title;
      added++;
   }

   if(added == 0)
      m_lastError = "Parsed 0 news records";

   return added;
}

int FSBNewsGate_v2_1::LoadNewsIfNeeded()
{
   m_lastError = "";
   m_lastLoadTry = TimeCurrent();

   double stamp = -1.0;
   if(GlobalVariableCheck("FSB_NEWS_FEED_TS"))
      stamp = GlobalVariableGet("FSB_NEWS_FEED_TS");

   bool needReload = false;
   if(stamp > 0.0 && stamp != m_lastFeedStamp)
   {
      needReload = true;
      m_lastFeedStamp = stamp;
   }
   else
   {
      if(m_lastLoadOk == 0 || TimeCurrent() > m_lastLoadOk + 600)
         needReload = true;
   }

   if(!needReload && ArraySize(m_newsUtc) > 0 && m_lastError == "")
      return 1;

   string err = "";
   string content = ReadFileUtf8(m_cachedFile, err);
   if(err != "")
   {
      m_lastError = err;
      ResetNewsArrays();
      return 0;
   }

   int parsed = ParseNewsContent(content);
   if(parsed > 0)
   {
      m_lastLoadOk = TimeCurrent();
      m_lastError = "";
      return 1;
   }

   if(m_lastError == "")
      m_lastError = "Parsed 0 news records";
   ResetNewsArrays();
   return 0;
}

bool FSBNewsGate_v2_1::AcceptPriority(const string prio, const int priorityMode)
{
   if(priorityMode == 2)
      return (prio == "high" || prio == "medium");
   if(priorityMode == 1)
      return (prio == "high");
   return false;
}

bool FSBNewsGate_v2_1::AcceptCurrency(const string ccy, const string baseCcy, const string quoteCcy)
{
   if(ccy == "ALL") return true;
   if(baseCcy != "" && ccy == baseCcy) return true;
   if(quoteCcy != "" && ccy == quoteCcy) return true;
   return false;
}

string FSBNewsGate_v2_1::FirstSixLettersUpperFromDataSymbol()
{
   string up = Data.Symbol;
   StringToUpper(up);

   string letters = "";
   int len = StringLen(up);
   for(int i = 0; i < len; i++)
   {
      int ch = StringGetCharacter(up, i);
      if(ch >= 65 && ch <= 90)
      {
         letters += StringSubstr(up, i, 1);
         if(StringLen(letters) >= 6)
            break;
      }
   }
   return letters;
}

string FSBNewsGate_v2_1::GetSymbolBase()
{
   string letters = FirstSixLettersUpperFromDataSymbol();
   if(StringLen(letters) < 6) return "";
   return StringSubstr(letters, 0, 3);
}

string FSBNewsGate_v2_1::GetSymbolQuote()
{
   string letters = FirstSixLettersUpperFromDataSymbol();
   if(StringLen(letters) < 6) return "";
   return StringSubstr(letters, 3, 3);
}

int FSBNewsGate_v2_1::ActiveNewsIndex(const datetime nowUtc,
                                      const int priorityMode,
                                      const int beforeHigh,
                                      const int afterHigh,
                                      const int beforeMed,
                                      const int afterMed,
                                      const int tolSec,
                                      const string baseCcy,
                                      const string quoteCcy)
{
   int n = ArraySize(m_newsUtc);
   if(n <= 0)
      return -1;

   for(int i = 0; i < n; i++)
   {
      string pr = m_newsPriority[i];
      string cc = m_newsCurrency[i];
      datetime t = m_newsUtc[i];

      if(!AcceptPriority(pr, priorityMode)) continue;
      if(!AcceptCurrency(cc, baseCcy, quoteCcy)) continue;

      if(pr == "high")
      {
         datetime start = t - beforeHigh * 60 - tolSec;
         datetime end = t + afterHigh * 60 + tolSec;
         if(nowUtc >= start && nowUtc <= end)
            return i;
      }
      else if(pr == "medium")
      {
         datetime start = t - beforeMed * 60 - tolSec;
         datetime end = t + afterMed * 60 + tolSec;
         if(nowUtc >= start && nowUtc <= end)
            return i;
      }
   }

   return -1;
}

void FSBNewsGate_v2_1::UpdateStatusPanel(const bool allowNow,
                                         const int priorityMode,
                                         const bool continueOnError,
                                         const int records,
                                         const double stamp,
                                         const datetime lastLoadOk,
                                         const double ageMin,
                                         const double bypass,
                                         const string lastError)
{
   datetime now = TimeCurrent();
   if(now <= m_lastPanelUpdate + 5)
      return;
   m_lastPanelUpdate = now;

   string name = "FSBNewsGate_Status_" + Data.Symbol + "_" + IntegerToString((int)Data.Period) + "_" + IntegerToString(priorityMode);
   string prTxt = PriorityModeText(priorityMode);
   string coeTxt = continueOnError ? "ON" : "OFF";
   string stampTxt = (stamp > 0.0) ? TimeToString((datetime)stamp, TIME_DATE | TIME_SECONDS) : "n/a";
   string loadTxt = (lastLoadOk > 0) ? TimeToString(lastLoadOk, TIME_DATE | TIME_SECONDS) : "n/a";
   string utcTxt = TimeToString(TimeGMT(), TIME_DATE | TIME_SECONDS);
   string srvTxt = TimeToString(TimeCurrent(), TIME_DATE | TIME_SECONDS);

   string st;
   if(lastError != "") st = continueOnError ? "ERROR (Fail-Open)" : "ERROR (Fail-Closed)";
   else st = allowNow ? "OK (Allow)" : "OK (Blocked)";

   string text = "FSBNewsGate_v2_1\n" +
                 "Status: " + st + "\n" +
                 "Priority: " + prTxt + "\n" +
                 "ContinueOnError: " + coeTxt + "\n" +
                 "Records: " + IntegerToString(records) + "\n" +
                 "Now UTC: " + utcTxt + "\n" +
                 "Now Server: " + srvTxt + "\n" +
                 "FeedTS: " + stampTxt + "\n" +
                 "LastLoad: " + loadTxt + "\n" +
                 "AgeMin: " + DoubleToString(ageMin, 2) + "\n" +
                 "Bypass: " + DoubleToString(bypass, 0) + "\n" +
                 "File: " + m_cachedFile + "\n";
   if(lastError != "")
      text += "Err: " + lastError + "\n";

   if(ObjectFind(0, name) < 0)
   {
      ObjectCreate(0, name, OBJ_LABEL, 0, 0, 0);
      ObjectSetInteger(0, name, OBJPROP_CORNER, CORNER_RIGHT_LOWER);
      ObjectSetInteger(0, name, OBJPROP_XDISTANCE, 10);
      ObjectSetInteger(0, name, OBJPROP_YDISTANCE, 10);
      ObjectSetString(0, name, OBJPROP_FONT, "Arial");
      ObjectSetInteger(0, name, OBJPROP_FONTSIZE, 9);
      ObjectSetInteger(0, name, OBJPROP_BACK, true);
      ObjectSetInteger(0, name, OBJPROP_SELECTABLE, false);
      ObjectSetInteger(0, name, OBJPROP_HIDDEN, true);
   }

   color c = clrLime;
   if(lastError != "") c = continueOnError ? clrOrange : clrRed;
   else if(!allowNow) c = clrGold;

   ObjectSetInteger(0, name, OBJPROP_COLOR, c);
   ObjectSetString(0, name, OBJPROP_TEXT, text);
}

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

   int bars = Data.Bars;
   if(bars <= 0)
      return;

   int last = bars - 1;
   int prev = bars - 2;

   int priorityMode = ResolvePriorityMode();
   int beforeHigh = ClampInt((int)NumParam[0].Value, 0, 240);
   int afterHigh  = ClampInt((int)NumParam[1].Value, 0, 240);
   int beforeMed  = ClampInt((int)NumParam[2].Value, 0, 240);
   int afterMed   = ClampInt((int)NumParam[3].Value, 0, 240);
   int tolSec     = ClampInt((int)NumParam[4].Value, 0, 60);
   bool continueOnError = ResolveContinueOnError();
   int firstBar = 0;

   ArrayResize(Component[0].Value, bars); ArrayInitialize(Component[0].Value, 1.0);
   ArrayResize(Component[1].Value, bars); ArrayInitialize(Component[1].Value, 1.0);
   ArrayResize(Component[2].Value, bars); ArrayInitialize(Component[2].Value, 1.0);
   ArrayResize(Component[3].Value, bars); ArrayInitialize(Component[3].Value, -1.0);
   ArrayResize(Component[4].Value, bars); ArrayInitialize(Component[4].Value, 0.0);
   ArrayResize(Component[5].Value, bars); ArrayInitialize(Component[5].Value, 0.0);

   Component[0].CompName = "Allow long entry";
   Component[0].DataType = IndComponentType_AllowOpenLong;
   Component[0].FirstBar = firstBar;
   Component[0].ShowInDynInfo = true;

   Component[1].CompName = "Allow short entry";
   Component[1].DataType = IndComponentType_AllowOpenShort;
   Component[1].FirstBar = firstBar;
   Component[1].ShowInDynInfo = true;

   Component[2].CompName = "NewsFeed OK";
   Component[2].DataType = IndComponentType_IndicatorValue;
   Component[2].FirstBar = firstBar;
   Component[2].ShowInDynInfo = true;

   Component[3].CompName = "NewsLoadAgeMin";
   Component[3].DataType = IndComponentType_IndicatorValue;
   Component[3].FirstBar = firstBar;
   Component[3].ShowInDynInfo = true;

   Component[4].CompName = "FailOpenBypass";
   Component[4].DataType = IndComponentType_IndicatorValue;
   Component[4].FirstBar = firstBar;
   Component[4].ShowInDynInfo = true;

   Component[5].CompName = "NewsLastLoadTS";
   Component[5].DataType = IndComponentType_IndicatorValue;
   Component[5].FirstBar = firstBar;
   Component[5].ShowInDynInfo = true;

   Component[6].DataType = IndComponentType_NotDefined;
   Component[7].DataType = IndComponentType_NotDefined;
   Component[8].DataType = IndComponentType_NotDefined;
   Component[9].DataType = IndComponentType_NotDefined;

   double stampNow = GlobalVariableCheck("FSB_NEWS_FEED_TS") ? GlobalVariableGet("FSB_NEWS_FEED_TS") : -1.0;
   double ageMin = (m_lastLoadOk > 0) ? (double)(TimeCurrent() - m_lastLoadOk) / 60.0 : -1.0;

   if(priorityMode == 0)
   {
      if(last >= 0)
      {
         Component[2].Value[last] = 2.0;
         Component[3].Value[last] = 0.0;
         Component[4].Value[last] = 0.0;
         Component[5].Value[last] = (double)m_lastLoadOk;
      }
      if(prev >= 0)
      {
         Component[2].Value[prev] = 2.0;
         Component[3].Value[prev] = 0.0;
         Component[4].Value[prev] = 0.0;
         Component[5].Value[prev] = (double)m_lastLoadOk;
      }
      UpdateStatusPanel(true, priorityMode, continueOnError, ArraySize(m_newsUtc), stampNow, m_lastLoadOk, 0.0, 0.0, "");
      return;
   }

   string healthErr = "";
   if(!FileHealthCheck(m_cachedFile, healthErr))
   {
      m_lastError = healthErr;
      ResetNewsArrays();
      double bypass = continueOnError ? 1.0 : 0.0;

      if(last >= 0)
      {
         Component[2].Value[last] = 0.0;
         Component[3].Value[last] = ageMin;
         Component[4].Value[last] = bypass;
         Component[5].Value[last] = (double)m_lastLoadOk;
         Component[0].Value[last] = continueOnError ? 1.0 : 0.0;
         Component[1].Value[last] = continueOnError ? 1.0 : 0.0;
      }
      if(prev >= 0)
      {
         Component[2].Value[prev] = 0.0;
         Component[3].Value[prev] = ageMin;
         Component[4].Value[prev] = bypass;
         Component[5].Value[prev] = (double)m_lastLoadOk;
         Component[0].Value[prev] = continueOnError ? 1.0 : 0.0;
         Component[1].Value[prev] = continueOnError ? 1.0 : 0.0;
      }

      UpdateStatusPanel(continueOnError, priorityMode, continueOnError, 0, stampNow, m_lastLoadOk, ageMin, bypass, m_lastError);
      return;
   }

   int ok = LoadNewsIfNeeded();
   int recordsNow = ArraySize(m_newsUtc);
   ageMin = (m_lastLoadOk > 0) ? (double)(TimeCurrent() - m_lastLoadOk) / 60.0 : -1.0;

   int staleAfterMin = 180;
   bool stale = (m_lastLoadOk > 0 && ageMin > staleAfterMin);
   if(stale && m_lastError == "")
      m_lastError = "Stale feed: last successful load is older than " + IntegerToString(staleAfterMin) + " min";

   if(ok == 0 || stale)
   {
      double bypass2 = continueOnError ? 1.0 : 0.0;
      if(last >= 0)
      {
         Component[2].Value[last] = 0.0;
         Component[3].Value[last] = ageMin;
         Component[4].Value[last] = bypass2;
         Component[5].Value[last] = (double)m_lastLoadOk;
         Component[0].Value[last] = continueOnError ? 1.0 : 0.0;
         Component[1].Value[last] = continueOnError ? 1.0 : 0.0;
      }
      if(prev >= 0)
      {
         Component[2].Value[prev] = 0.0;
         Component[3].Value[prev] = ageMin;
         Component[4].Value[prev] = bypass2;
         Component[5].Value[prev] = (double)m_lastLoadOk;
         Component[0].Value[prev] = continueOnError ? 1.0 : 0.0;
         Component[1].Value[prev] = continueOnError ? 1.0 : 0.0;
      }

      UpdateStatusPanel(continueOnError, priorityMode, continueOnError, recordsNow, stampNow, m_lastLoadOk, ageMin, bypass2, m_lastError);
      return;
   }

   if(last >= 0)
   {
      Component[2].Value[last] = 1.0;
      Component[3].Value[last] = ageMin;
      Component[4].Value[last] = 0.0;
      Component[5].Value[last] = (double)m_lastLoadOk;
   }
   if(prev >= 0)
   {
      Component[2].Value[prev] = 1.0;
      Component[3].Value[prev] = ageMin;
      Component[4].Value[prev] = 0.0;
      Component[5].Value[prev] = (double)m_lastLoadOk;
   }

   string baseCcy = GetSymbolBase();
   string quoteCcy = GetSymbolQuote();
   datetime nowUtc = TimeGMT();
   int idx = ActiveNewsIndex(nowUtc, priorityMode, beforeHigh, afterHigh, beforeMed, afterMed, tolSec, baseCcy, quoteCcy);
   bool allowNow = (idx < 0);

   if(last >= 0)
   {
      Component[0].Value[last] = allowNow ? 1.0 : 0.0;
      Component[1].Value[last] = allowNow ? 1.0 : 0.0;
   }
   if(prev >= 0)
   {
      Component[0].Value[prev] = allowNow ? 1.0 : 0.0;
      Component[1].Value[prev] = allowNow ? 1.0 : 0.0;
   }

   UpdateStatusPanel(allowNow, priorityMode, continueOnError, recordsNow, stampNow, m_lastLoadOk, ageMin, 0.0, "");
}