bl_telegram_to_mt4/blTelegramToMT4.mq4

//+------------------------------------------------------------------+
//|                                              blTelegramToMT4.mq4 |
//|                                  Copyright 2025, MQL Development |
//|                                  https://www.mqldevelopment.com/ |
//+------------------------------------------------------------------+
#property copyright "Copyright 2025, MQL Development"
#property link      "https://www.mqldevelopment.com/"
#property version   "1.00"
#property strict

#define buy "buy"
#define sell "sell"
#define MaxOrders 10000

struct msgDetails
  {
   int               msgid;
                     msgDetails()
     {
      msgid       = -1;
     }
  };

msgDetails od[MaxOrders];

struct new_trade_store
  {
   ulong             ticket;         // Ticket
   int               order_type;     // OrderType
   double            lot;            // Lot
   double            stop_loss;      // StopLoss
   double            take_profit;    // TakeProfit
   double            price;          // Price
   string            symbol;         // Symbol
   int               chatId;         // ChatId
   string            trade_type;     // Trade Type (Trade Type: Tp1, Tp2, Tp3.... Tpn)

                     new_trade_store()
     {
      ticket = -1;
      chatId=-1;
      trade_type = "";
     }

  };
new_trade_store newTradeStore[MaxOrders];

input       string               Settings              = " ------------- General Settings ------------- ";   //_
input       int                  magic_no              = 333;                                                // Magic no
input       string               symbolMatch           = "GOLD:XAUUSD,BitCoin:BTCUSD";                       // Symbol Mapping (Telegram:MT5)
input       string               suffix                = "";                                                 // Account Suffix
input       string               prefix                = "";                                                 // Account Prefix
input       double               lotSize               = 0.1;                                                // Lot Size

//+------------------------------------------------------------------+
//| Expert initialization function                                   |
//+------------------------------------------------------------------+
// Global Variables
string      url1      = "http://127.0.0.1";
string      header    = "Content-Type: application/json\r\nAccept: application/json\r\n";

int getme_result;

string symbolChart[];
string symbolSnd[];
string symbolsListUserInput[];
uchar  sym1[];
uchar  sym2[];
datetime ea_start_time = 0;
int OnInit()
  {
//--- create timer
   ea_start_time = TimeCurrent();

   ushort u_sep = StringGetCharacter(",",0);
   StringSplit(symbolMatch,u_sep,symbolsListUserInput);
   ArrayResize(symbolChart,0);
   ArrayResize(symbolSnd,0);

   for(int i = 0; i < ArraySize(symbolsListUserInput); i++)
     {

      string str = symbolsListUserInput[i];

      int index  = StringFind(str,":");
      int index2 = StringLen(str);

      ArrayResize(sym1,0);
      ArrayResize(sym2,0);

      for(int j = 0; j < index; j++)
        {
         ArrayResize(sym1,ArraySize(sym1)+1);
         sym1[j] = uchar(str[j]);
        }

      int k = 0;

      for(int j = index + 1 ; j < index2; j++)
        {
         ArrayResize(sym2,ArraySize(sym2)+1);
         sym2[k] = uchar(str[j]);
         k++;
        }

      ArrayResize(symbolChart,ArraySize(symbolChart)+1);
      ArrayResize(symbolSnd,ArraySize(symbolSnd)+1);

      symbolChart[i] = CharArrayToString(sym1);
      symbolSnd[i]   = CharArrayToString(sym2);

     }

   string SplitArray[];

   string jsonString = GET_function(url1+"/get-all-messages",header);
   StringReplace(jsonString,"},", "*");
   StringSplit(jsonString,'*',SplitArray);

   for(int i = 0; i < ArraySize(SplitArray); i++)
     {
      seperatingDataOnint(i,SplitArray[i]);
     }

   EventSetTimer(1);

//---
   return(INIT_SUCCEEDED);
  }
//+------------------------------------------------------------------+
//| Expert deinitialization function                                 |
//+------------------------------------------------------------------+
void OnDeinit(const int reason)
  {
//--- destroy timer
   EventKillTimer();

  }
//+------------------------------------------------------------------+
//| Expert tick function                                             |
//+------------------------------------------------------------------+
void OnTick()
  {
//---

  }
//+------------------------------------------------------------------+
//| Timer function                                                   |
//+------------------------------------------------------------------+
void OnTimer()
  {
//---
   string SplitArray[];

   string jsonString = GET_function(url1+"/get-all-messages",header);
   StringReplace(jsonString,"},", "*");
   StringSplit(jsonString,'*',SplitArray);

   for(int i = 0; i < ArraySize(SplitArray); i++)
     {
      seperatingData(i,SplitArray[i]);
     }
  }
//+------------------------------------------------------------------+
//|                                                                  |
//+------------------------------------------------------------------+
string  GET_function(string url,string headers)
  {

   string result_string = NULL;
   int timeout          = 10;  // Set the timeout value in seconds

   char result[],data[];
   string resultHeaders;
   int res = WebRequest("GET",url,headers,timeout,data,result,resultHeaders);

   if(res == 200)
     {
      result_string = CharArrayToString(result);
     }
   else
     {
      Print("content GETT: ", result_string," Error: ",GetLastError(), " res: ",res);
     }

   return result_string;
  }
//+------------------------------------------------------------------+
//|                                                                  |
//+------------------------------------------------------------------+
void seperatingDataOnint(int index, string data)
  {

   string message = getJsonStringValue(data,"message",4,"\"");
   int message_id = (int)getJsonStringValue(data,"message_id",4,"\"");

   if(checkExistingTrade(message_id) == false)
     {
      Print(" ================ OnInit New Trade Message Found ================");
      StringReplace(message,"~","#");
      StringToLower(message);
      Print("Message is ", message);
      for(int i=0; i < MaxOrders; i++)
        {
         if(od[i].msgid == -1)
           {
            od[i].msgid = message_id;
            break;
           }
        }
     }
  }
//+------------------------------------------------------------------+
//|                                                                  |
//+------------------------------------------------------------------+
bool checkExistingTrade(int message_id)
  {
   for(int i=0; i < MaxOrders; i++)
     {
      if(od[i].msgid == message_id)
        {
         return true;
        }
     }
   return false;
  }

//+------------------------------------------------------------------+
//|                                                                  |
//+------------------------------------------------------------------+
string getJsonStringValue(string json,string key,int addUp,string endSign)
  {
   int indexStart = StringFind(json,key)+StringLen(key)+addUp;
   int indexEnd   = StringFind(json,endSign,indexStart);
   return StringSubstr(json,indexStart,indexEnd-indexStart);
  }
//+------------------------------------------------------------------+
//|                                                                  |
//+------------------------------------------------------------------+
void seperatingData(int index, string data)
  {
// Print(" Data: ", data);
   string message = getJsonStringValue(data,"message",4,"\"");
   int message_id = (int)getJsonStringValue(data,"message_id",4,"\"");

   string isReplyValue = getJsonStringValue(data,"is_reply",4,"\"");
   int reply_to_msg_id = (int)getJsonStringValue(data,"reply_to_msg_id",4,"\"");

   if(isReplyValue == "False")
     {
      if(checkExistingTrade(message_id) == false)
        {
         Print(" --------------- New Trade Message Found ----------------- ", " Message Id: ", message_id);
         StringReplace(message,"~","#");
         StringReplace(message,"##", "#");
         StringToLower(message);
         message = removeExtraSpaces(message);
         Print("Message is ",message);
         addtoMessageStructure(message_id,message);

         string result[];
         string tempResult[];
         int indexTemp = 0;

         StringSplit(message,'#',tempResult);

         for(int i=0; i<ArraySize(tempResult); i++)
           {
            //result[i] = StringTrimLeft(result[i]);
            //result[i] = StringTrimRight(result[i]);
            //Print("Temp Result : ", tempResult[i], " index is: ", i);
            if(HasAlphanumeric(tempResult[i]))
              {
               //Print(" contains alphanumeric characters.");
               ArrayResize(result,ArraySize(result)+1);
               result[indexTemp] = tempResult[i];
               indexTemp++;
              }
            else
              {
               //Print(" does not contain alphanumeric characters.");
               //ArrayResize(indexToDelete,ArraySize(indexToDelete)+1);
               //indexToDelete[indexTemp] = i;
               //indexTemp++;
              }
           }



        }
     }

   if(isReplyValue == "True")
     {
      if(checkExistingTrade(message_id) == false)
        {
         Print(" --------------- New Replied Message Found ----------------- ", " Message Id: ", message_id, " Reply Message Id: ", reply_to_msg_id);
         StringToLower(message);
         Print("Message is ",message);
         addtoMessageStructure(message_id,message);
        }
     }
  }
//+------------------------------------------------------------------+
//|                                                                  |
//+------------------------------------------------------------------+
void addtoMessageStructure(int message_id,string message)
  {
   for(int i=0; i < MaxOrders; i++)
     {
      if(od[i].msgid == -1)
        {
         od[i].msgid = message_id;
         break;
        }
     }

  }
//+------------------------------------------------------------------+
//|                                                                  |
//+------------------------------------------------------------------+
string removeExtraSpaces(string str)
  {
   string result = "";
   int len = StringLen(str);
   bool lastWasSpace = false;

   for(int i = 0; i < len; i++)
     {
      string currentChar = StringSubstr(str, i, 1);

      if(currentChar == " ")
        {
         // Skip adding this space if the last character was also a space
         if(lastWasSpace)
            continue;

         lastWasSpace = true;
        }
      else
        {
         lastWasSpace = false;
        }

      result += currentChar;
     }

   return result;
  }
//+------------------------------------------------------------------+
//|                                                                  |
//+------------------------------------------------------------------+
bool HasAlphanumeric(string str)
  {
//Print("String Length: ", StringLen(str));
   for(int i = 0; i <= StringLen(str); i++)
     {
      //Print("Here ", StringLen(str));
      if(IsAlphanumeric((char)str[i]))
        {
         return true;
         break;
        }
     }
   return false;
  }
//+------------------------------------------------------------------+
//|                                                                  |
//+------------------------------------------------------------------+
bool IsAlphanumeric(char c)
  {
   if((c >= '0' && c <= '9') || (c >= 'A' && c <= 'Z') || (c >= 'a' && c <= 'z'))
      return true;
   return false;
  }
//+------------------------------------------------------------------+
//|                                                                  |
//+------------------------------------------------------------------+
//+------------------------------------------------------------------+