| #include "RuntimeStorage.mqh"
|
| //+------------------------------------------------------------------+
|
| //| InsightsLoader.mqh - Load insights from JSON for LiveEA gating |
|
| //+------------------------------------------------------------------+
|
| #ifndef INSIGHTSLOADER_MQH
|
| #define INSIGHTSLOADER_MQH
|
|
|
| //+------------------------------------------------------------------+
|
| //| Load insights from insights.json in Common Files |
|
| //+------------------------------------------------------------------+
|
| int Insights_Load_Default(
|
| string &out_strat[],
|
| string &out_sym[],
|
| int &out_tf[],
|
| int &out_cnt[],
|
| double &out_wr[],
|
| double &out_avgR[],
|
| double &out_pf[],
|
| double &out_dd[]
|
| )
|
| {
|
| // Reset arrays
|
| ArrayResize(out_strat, 0);
|
| ArrayResize(out_sym, 0);
|
| ArrayResize(out_tf, 0);
|
| ArrayResize(out_cnt, 0);
|
| ArrayResize(out_wr, 0);
|
| ArrayResize(out_avgR, 0);
|
| ArrayResize(out_pf, 0);
|
| ArrayResize(out_dd, 0);
|
|
|
| string path = "DualEA\\insights.json";
|
| FolderCreate("DualEA", DUALEA_FILE_COMMON);
|
| if(!FileIsExist(path, DUALEA_FILE_COMMON))
|
| {
|
| return 0; // Cold start: insights not generated yet
|
| }
|
| int h = FileOpen(path, FILE_READ|FILE_TXT|DUALEA_FILE_COMMON|FILE_ANSI);
|
| if(h == INVALID_HANDLE)
|
| {
|
| int err = GetLastError();
|
| static datetime s_last_warn = 0;
|
| static int s_last_err = -1;
|
| datetime now = TimeCurrent();
|
| if((now - s_last_warn) >= 300 || err != s_last_err)
|
| {
|
| PrintFormat("[InsightsLoader] Cannot open %s (Common). Err=%d", path, err);
|
| s_last_warn = now;
|
| s_last_err = err;
|
| }
|
| return 0; // Treat as no insights available
|
| }
|
|
|
| string cur_s = "", cur_y = "";
|
| int cur_tf = -1, cur_cnt = 0;
|
| double cur_wr = 0.0, cur_avgR = 0.0, cur_pf = 0.0, cur_dd = 0.0;
|
|
|
| while(!FileIsEnding(h))
|
| {
|
| string line = FileReadString(h);
|
| if(line == "" && FileIsEnding(h)) break;
|
|
|
| int p;
|
|
|
| // strategy
|
| p = StringFind(line, "\"strategy\"", 0);
|
| if(p >= 0)
|
| {
|
| int q = StringFind(line, ",", p+1);
|
| string seg = (q > p ? StringSubstr(line, p, q-p) : StringSubstr(line, p));
|
| int c3 = StringFind(seg, "\"", 0);
|
| c3 = StringFind(seg, "\"", c3+1);
|
| int c4 = StringFind(seg, "\"", c3+1);
|
| int c5 = StringFind(seg, "\"", c4+1);
|
| if(c4 > 0 && c5 > c4)
|
| cur_s = StringSubstr(seg, c4+1, c5-c4-1);
|
| }
|
|
|
| // symbol
|
| p = StringFind(line, "\"symbol\"", 0);
|
| if(p >= 0)
|
| {
|
| int q = StringFind(line, ",", p+1);
|
| string seg = (q > p ? StringSubstr(line, p, q-p) : StringSubstr(line, p));
|
| int c3 = StringFind(seg, "\"", 0);
|
| c3 = StringFind(seg, "\"", c3+1);
|
| int c4 = StringFind(seg, "\"", c3+1);
|
| int c5 = StringFind(seg, "\"", c4+1);
|
| if(c4 > 0 && c5 > c4)
|
| cur_y = StringSubstr(seg, c4+1, c5-c4-1);
|
| }
|
|
|
| // timeframe
|
| p = StringFind(line, "\"timeframe\"", 0);
|
| if(p >= 0)
|
| {
|
| int c = StringFind(line, ":", p);
|
| if(c >= 0)
|
| {
|
| string num = StringSubstr(line, c+1);
|
| StringTrimLeft(num);
|
| cur_tf = (int)StringToInteger(num);
|
| }
|
| }
|
|
|
| // trade_count
|
| p = StringFind(line, "\"trade_count\"", 0);
|
| if(p >= 0)
|
| {
|
| int c = StringFind(line, ":", p);
|
| if(c >= 0)
|
| {
|
| string num = StringSubstr(line, c+1);
|
| StringTrimLeft(num);
|
| cur_cnt = (int)StringToInteger(num);
|
| }
|
| }
|
|
|
| // win_rate
|
| p = StringFind(line, "\"win_rate\"", 0);
|
| if(p >= 0)
|
| {
|
| int c = StringFind(line, ":", p);
|
| if(c >= 0)
|
| {
|
| string num = StringSubstr(line, c+1);
|
| StringTrimLeft(num);
|
| cur_wr = StringToDouble(num);
|
| }
|
| }
|
|
|
| // avg_R
|
| p = StringFind(line, "\"avg_R\"", 0);
|
| if(p >= 0)
|
| {
|
| int c = StringFind(line, ":", p);
|
| if(c >= 0)
|
| {
|
| string num = StringSubstr(line, c+1);
|
| StringTrimLeft(num);
|
| cur_avgR = StringToDouble(num);
|
| }
|
| }
|
|
|
| // profit_factor
|
| p = StringFind(line, "\"profit_factor\"", 0);
|
| if(p >= 0)
|
| {
|
| int c = StringFind(line, ":", p);
|
| if(c >= 0)
|
| {
|
| string num = StringSubstr(line, c+1);
|
| StringTrimLeft(num);
|
| cur_pf = StringToDouble(num);
|
| }
|
| }
|
|
|
| // max_drawdown_R
|
| p = StringFind(line, "\"max_drawdown_R\"", 0);
|
| if(p >= 0)
|
| {
|
| int c = StringFind(line, ":", p);
|
| if(c >= 0)
|
| {
|
| string num = StringSubstr(line, c+1);
|
| StringTrimLeft(num);
|
| cur_dd = StringToDouble(num);
|
| }
|
| }
|
|
|
| // Commit when we have strategy and symbol
|
| if(cur_s != "" && cur_y != "" && cur_tf >= 0)
|
| {
|
| int n = ArraySize(out_strat);
|
| ArrayResize(out_strat, n+1);
|
| ArrayResize(out_sym, n+1);
|
| ArrayResize(out_tf, n+1);
|
| ArrayResize(out_cnt, n+1);
|
| ArrayResize(out_wr, n+1);
|
| ArrayResize(out_avgR, n+1);
|
| ArrayResize(out_pf, n+1);
|
| ArrayResize(out_dd, n+1);
|
|
|
| out_strat[n] = cur_s;
|
| out_sym[n] = cur_y;
|
| out_tf[n] = cur_tf;
|
| out_cnt[n] = cur_cnt;
|
| out_wr[n] = cur_wr;
|
| out_avgR[n] = cur_avgR;
|
| out_pf[n] = cur_pf;
|
| out_dd[n] = cur_dd;
|
|
|
| // Reset for next slice
|
| cur_s = "";
|
| cur_y = "";
|
| cur_tf = -1;
|
| cur_cnt = 0;
|
| cur_wr = 0.0;
|
| cur_avgR = 0.0;
|
| cur_pf = 0.0;
|
| cur_dd = 0.0;
|
| }
|
| }
|
|
|
| FileClose(h);
|
|
|
| int loaded = ArraySize(out_strat);
|
| if(loaded > 0)
|
| PrintFormat("[InsightsLoader] Loaded %d insight slices", loaded);
|
| else
|
| Print("[InsightsLoader] No slices loaded (cold start mode)");
|
|
|
| return loaded;
|
| }
|
|
|
| #endif // INSIGHTSLOADER_MQH
|
