#property strict
#include "../Include/UnifiedTradeLogger.mqh"

int checks = 0;
int failures = 0;
void Check(bool passed, string label)
{
   checks++;
   if(!passed) { failures++; Print("[LOGGER FAIL] ", label); }
}

string ReadLog(string path)
{
   int file = FileOpen(path, FILE_READ|FILE_TXT|FILE_ANSI|DUALEA_FILE_COMMON, 0, CP_UTF8);
   if(file == INVALID_HANDLE) return "";
   string result = "";
   while(!FileIsEnding(file)) result += FileReadString(file) + "\n";
   FileClose(file);
   return result;
}

int Occurrences(string text, string token)
{
   int count=0, pos=0;
   while((pos=StringFind(text, token, pos)) >= 0) { count++; pos+=StringLen(token); }
   return count;
}

bool BalancedJSON(string text)
{
   bool quoted=false, escaped=false;
   string stack="";
   for(int i=0; i<StringLen(text); i++)
   {
      ushort ch=StringGetCharacter(text,i);
      if(quoted)
      {
         if(escaped) escaped=false;
         else if(ch==92) escaped=true;
         else if(ch==34) quoted=false;
         else if(ch<32) return false;
         continue;
      }
      if(ch==34) quoted=true;
      else if(ch==123 || ch==91) stack+=ShortToString(ch);
      else if(ch==125 || ch==93)
      {
         int size=StringLen(stack);
         if(size==0) return false;
         ushort opening=StringGetCharacter(stack,size-1);
         if((ch==125 && opening!=123) || (ch==93 && opening!=91)) return false;
         stack=StringSubstr(stack,0,size-1);
      }
   }
   StringTrimLeft(text);
   StringTrimRight(text);
   return !quoted && stack=="" && StringLen(text)>1 && StringGetCharacter(text,0)==123 && StringGetCharacter(text,StringLen(text)-1)==125;
}

int OnInit()
{
   if(!MQLInfoInteger(MQL_TESTER)) return INIT_FAILED;
   // Each run uses its own tester-local directory, never the live trade log.
   string directory="DualEA\\logger_contract_"+IntegerToString((long)GetTickCount64());
   CUnifiedTradeLogger logger(directory);
   UnifiedTradeRecord record;
   Check(record.journey_length == 0, "new record has an empty journey");
   Check(record.blocking_gate == -1, "new record has no blocking gate");
   Check(record.reviews_performed == 0 && !record.is_closed, "new lifecycle state is initialized");
   string json = logger.FormatTradeAsJSON(record, false);
   Check(StringFind(json, "\"gate\":") < 0, "empty journey formats without indexing entries");

   for(int i=0; i<ArraySize(record.gate_journey); i++)
   {
      record.gate_journey[i].gate_name = "test_" + IntegerToString(i);
      record.gate_journey[i].gate_index = i;
   }
   record.journey_length = 1;
   json = logger.FormatTradeAsJSON(record, false);
   Check(StringFind(json, "test_0") >= 0 && StringFind(json, "test_1") < 0, "one-step journey stays one step");
   record.journey_length = 2147483647;
   json = logger.FormatTradeAsJSON(record, false);
   Check(StringFind(json, "test_23") >= 0, "oversized journey clamps to fixed capacity");
   record.journey_length = -1;
   json = logger.FormatTradeAsJSON(record, true);
   Check(StringFind(json, "\"gate\":") < 0, "negative journey formats as empty");
   Check(StringFind(json, "\"outcome\":") >= 0, "close formatting remains available");

   MqlDateTime dt;
   TimeToStruct(TimeCurrent(),dt);
   string path=directory+"\\trades_"+StringFormat("%04d%02d%02d",dt.year,dt.mon,dt.day)+".json";
   record.journey_length=1;
   record.trade_id="trade-a";
   record.execution_time=TimeCurrent();
   record.strategy_name="quoted \"strategy\" with \\ slash\nbrace }";
   logger.LogTradeExecution(record);
   string first=ReadLog(path);
   Check(BalancedJSON(first) && Occurrences(first,"\"trade_id\":")==1, "first write is a complete document");
   record.trade_id="trade-b";
   logger.LogTradeExecution(record);
   string second=ReadLog(path);
   Check(BalancedJSON(second) && Occurrences(second,"\"trade_id\":")==2, "second append preserves both records and balanced arrays");
   Check(Occurrences(second,"\"status\": \"open\"")==2, "both executions are open");
   Check(StringFind(second,"quoted \\\"strategy\\\" with \\\\ slash\\nbrace }")>=0, "string quotes, slashes and newlines are escaped");
   record.trade_id="trade-a";
   record.close_time=TimeCurrent();
   record.profit_absolute=12.5;
   logger.LogTradeClose(record);
   string closed=ReadLog(path);
   Check(BalancedJSON(closed) && Occurrences(closed,"\"trade_id\":")==2, "closing preserves two complete records");
   Check(Occurrences(closed,"\"status\": \"closed\"")==1 && Occurrences(closed,"\"status\": \"open\"")==1, "only matching trade is closed");
   Check(Occurrences(closed,"\"outcome\":")==1 && StringFind(closed,"\"profit_absolute\": 12.50")>=0, "close outcome persisted");
   int logged, total_closed;
   logger.GetStatistics(logged,total_closed);
   Check(logged==2 && total_closed==1, "statistics reflect committed writes");
   record.trade_id="missing";
   logger.LogTradeClose(record);
   Check(ReadLog(path)==closed, "unknown close leaves log unchanged");
   Print("[LOGGER ARTIFACT] ",path);
   PrintFormat("[LOGGER-CONTRACT] RESULT checks=%d failures=%d", checks, failures);
   return failures == 0 ? INIT_SUCCEEDED : INIT_FAILED;
}
void OnTick() { ExpertRemove(); }
double OnTester() { return failures == 0 ? checks : -failures; }