dualea/Experts/Advisors/DualEA/Include/CGateAudit.mqh

#ifndef DUALEA_GATE_AUDIT_MQH
#define DUALEA_GATE_AUDIT_MQH
// Tracks signal coverage for each registered strategy.
class CGateAudit
{
private:
   string m_names[];
   int m_counts[];
   bool m_enabled;
   int m_min_signals, m_min_uptime, m_cooldown;
   datetime m_started, m_last_alert;
public:
   CGateAudit() : m_enabled(false), m_min_signals(1), m_min_uptime(5), m_cooldown(30), m_started(0), m_last_alert(0) {}
   void Initialize(string strategies)
   {
      int count = StringSplit(strategies, ',', m_names);
      ArrayResize(m_counts, count);
      ArrayInitialize(m_counts, 0);
      m_started = TimeCurrent();
      m_last_alert = 0;
   }
   void Configure(int signals, int uptime, int cooldown)
   {
      m_min_signals = MathMax(0, signals);
      m_min_uptime = MathMax(0, uptime);
      m_cooldown = MathMax(0, cooldown);
   }
   void SetEnabled(bool enabled) { m_enabled = enabled; }
   void LogStrategyProcessed(string strategy, string id, bool passed, double confidence, string reason)
   {
      if(!m_enabled) return;
      for(int i=0; i<ArraySize(m_names); i++)
         if(m_names[i] == strategy) { m_counts[i]++; break; }
      string skipped;
      int count;
      RunAudit(skipped, count);
   }
   bool RunAudit(string &skipped_strategies, int &skipped_count)
   {
      skipped_strategies = "";
      skipped_count = 0;
      if(!m_enabled || TimeCurrent()-m_started < m_min_uptime*60) return true;
      for(int i=0; i<ArraySize(m_names); i++)
         if(m_counts[i] < m_min_signals)
         {
            if(skipped_count > 0) skipped_strategies += ",";
            skipped_strategies += m_names[i];
            skipped_count++;
         }
      if(skipped_count > 0 && (m_last_alert == 0 || TimeCurrent()-m_last_alert >= m_cooldown*60))
      {
         Print("[GateAudit] Strategies below signal coverage: ", skipped_strategies);
         m_last_alert = TimeCurrent();
      }
      return skipped_count == 0;
   }
};
CGateAudit g_gate_audit;
#endif