AiDataTaskRuner/Backend/Mcp/McpServ.mq5

//+------------------------------------------------------------------+
//|                                                      McpServ.mq5 |
//|                                  Copyright 2026, Niquel Mendoza. |
//|                          https://www.mql5.com/es/users/nique_372 |
//+------------------------------------------------------------------+
#property copyright "Copyright 2026, Niquel Mendoza."
#property link      "https://www.mql5.com/es/users/nique_372"
#property version   "1.00"
#property strict

//+------------------------------------------------------------------+
//| Defines                                                          |
//+------------------------------------------------------------------+
#define PUBLIC_VERSION

//+------------------------------------------------------------------+
//| Include                                                          |
//+------------------------------------------------------------------+
#include "Functions.mqh"
#include "Secrets.mqh"

//+------------------------------------------------------------------+
//| Inputs                                                           |
//+------------------------------------------------------------------+
input string InpTbpUserId = THE_BOT_PLACE_USER_ID; // Tbp User Id
input string InpSoketAdres = "127.0.0.1"; // Sockets address
input uint InpSoketPort = 9999; // Socket port
input int InpMsPool = 70; // Ms pool
input int InpMsTimeoutReadNoTls = 10000; // Timeout for read (NO-TLS)
input long InpChartIdPanel = 0;

//+------------------------------------------------------------------+
//| Global variables                                                 |
//+------------------------------------------------------------------+
TSN::IMcpBase* g_mcp_server;

//+------------------------------------------------------------------+
//| Expert initialization function                                   |
//+------------------------------------------------------------------+
int OnInit()
 {
//---
#ifdef TSN_MCPSERVER_FUNC_CTS
  g_mcp_server = TSN_MCPSERVER_FUNC_CTS(InpTbpUserId);
#else
  g_mcp_server = McpServerByLeo_Create(InpTbpUserId);
#endif // TSN_MCPSERVER_FUNC_CTS


//---
  ::EventSetMillisecondTimer(InpMsPool);
  g_mcp_server.AddLogFlags(LOG_ALL);

//---
  const long current_chart_id = ChartID();
  g_mcp_server.AddItemFast(new TSN::CMcpFuncAiTaskRunnerAddTask(InpChartIdPanel, current_chart_id));
  g_mcp_server.AddItemFast(new TSN::CMcpFuncAiTaskRunnerGetTaskTotal(InpChartIdPanel, current_chart_id));
  g_mcp_server.AddItemFast(new TSN::CMcpFuncAiTaskRunnerGetTaskByIndex(InpChartIdPanel, current_chart_id));
  g_mcp_server.AddItemFast(new TSN::CMcpFuncAiTaskRunnerGetTaskStatus(InpChartIdPanel, current_chart_id));
  g_mcp_server.AddItemFast(new TSN::CMcpFuncAiTaskRunnerCleanAllTasks(InpChartIdPanel, current_chart_id));
  g_mcp_server.AddItemFast(new TSN::CMcpFuncAiTaskRunnerExecuteAllTasks(InpChartIdPanel, current_chart_id));
  g_mcp_server.AddItemFast(new TSN::CMcpFuncAiTaskRunnerSaveTasksToFile(InpChartIdPanel, current_chart_id));
  g_mcp_server.AddItemFast(new TSN::CMcpFuncAiTaskRunnerLoadTasksFromFile(InpChartIdPanel, current_chart_id));
  g_mcp_server.AddItemFast(new TSN::CMcpFuncAiTaskRunnerLoadConfig(InpChartIdPanel, current_chart_id));
  g_mcp_server.AddItemFast(new TSN::CMcpFuncAiTaskRunnerSaveConfig(InpChartIdPanel, current_chart_id));
  g_mcp_server.AddItemFast(new TSN::CMcpFuncAiTaskRunnerGetMainFolder(InpChartIdPanel, current_chart_id));
  g_mcp_server.AddItemFast(new TSN::CMcpFuncAiTaskRunnerGetTaskFolder(InpChartIdPanel, current_chart_id));
  g_mcp_server.AddItemFast(new TSN::CMcpFuncAiTaskRunnerIsInCommonFolder(InpChartIdPanel, current_chart_id));
//---
  g_mcp_server.Set(InpMsPool, InpMsTimeoutReadNoTls);
  if(!g_mcp_server.Conectar(InpSoketAdres, InpSoketPort, (10 * 1000))) // 10 segundos de espera para conectarse
    return INIT_FAILED;

//---
  return(INIT_SUCCEEDED);
 }
//+------------------------------------------------------------------+
//| Expert deinitialization function                                 |
//+------------------------------------------------------------------+
void OnDeinit(const int reason)
 {
//---
  ::EventKillTimer();
//---
  if(CheckPointer(g_mcp_server) == POINTER_DYNAMIC)
    delete g_mcp_server;

 }
//+------------------------------------------------------------------+
//| Expert tick function                                             |
//+------------------------------------------------------------------+
void OnTick()
 {
//---
 }
//+------------------------------------------------------------------+
//| Timer function                                                   |
//+------------------------------------------------------------------+
void OnTimer(void)
 {
  g_mcp_server.TimerEvent();
 }
//+------------------------------------------------------------------+
//| ChartEvent function                                              |
//+------------------------------------------------------------------+
void OnChartEvent(const int id,
                  const long &lparam,
                  const double &dparam,
                  const string &sparam)
 {
//---
  g_mcp_server.ChartEvent(id, lparam, dparam, sparam);
 }
//+------------------------------------------------------------------+