CCXT Utility Server Showcase: entry crypto exchanges through MQL5 library from MetaTrader 5 – Different – 3 July 2025

First, embrace the headers.

#embrace "ccxtjsmtlib.mqh" 
#embrace "ccxtutil.mqh"

Within the inputs, the Node server setup needs to be performed (by default, it is localhost and port 8124).

enter group "Connection settings"
enter string NodeServer = "http://127.0.0.1:8124";
enter string NodeAuth = ""; 

Subsequent, present a selected alternate you need to work with. Depart the enter empty to view a printout with a listing of all supported exchanges.

enter string Change = ""; 

Additionally present a ticker you are concerned about. If you do not know the identify, run the script first time and have a look at MQL5/Information/CCXT/ folder the place all obtained information is dumped by default, so yow will discover json-files with full markets data.

enter string Ticker = "BCH/USDT";

For watching exams (subscriptions through websockets) specify their period:

enter uint WatchingDuration = 10; 

The script demonstrates find out how to setup credentials for personal APIs, however is not going to use any personal perform.

enter group "Change settings (Non-public API)"
enter string ApiKey = "";
enter string Secret = "";
enter string Uid = "";
enter string Login = "";
enter string Password = "";

Further settings mean you can management the logging stage, dumping of all obtained information, and timeouts.

enter group "Auxiliary settings"
enter ushort Logging = 1; 
enter bool Dumping = true;
enter uint Timeout = 5; 

If the script is working very first time, it’ll ask to unpack (manually) CCXT Utility Server (extracted as ccxtappsrvbundle.jsc from a built-in useful resource), and run Node.js with it.

void OnStart()
{
   
   
   
   PrintFormat("CCXT AppSrvLibrary model: %.2f", AppSrvLibraryVersion());
   const static string standing[] = {"Cannot deploy",
      "App server ZIP is deployed, however not extracted",
      "App server information are deployed"};
   const int d = DeployCcxtAppServer();
   Print(standing[d + 1]);
   if(d <= 0)
   {
      return; 
   }

   
   
   
   SetNodeServer(NodeServer, NodeAuth);

   CcxtLink::Settings settings = {Logging, Dumping, Testing, Timeout, 0};
   CcxtLink *hyperlink = GetLink();  
   hyperlink.applySettings(settings);
   
   
   if(!StringLen(Change))
   {
      Print("Full listing of exchanges:");
      Print(ListExchanges().stringify());
      Print("Professional listing of exchanges with websockets assist:");
      Print(ListExchanges(true).stringify());

      Print("App Server Model: ", AppSrvVersion().stringify());
      Print("CCXT lib model: ", CcxtVersion()["version"].stringify());
      return;
   }

   
   
   
   CCXT::Credentials credentials = {ApiKey, Secret, Uid, Login, Password};
   
   
   CcxtJsExchangeProIntf *ccxt = CreateExchangePro(Change, credentials, false);
   AutoPtr auto(ccxt);
   
   
   
   
   
   if(hyperlink.getLastHttpCode() != 200) 
   {
      return;
   }

   
   const bool isPro = !!*ccxt["pro"];
   if(ShowExchangeProperties)
   {
      Print("Is professional: ", isPro);
      Print("Required Credentials:");
      ccxt["requiredCredentials"].print();
      Print("Supported options:");         
      ccxt["has"].print();
      AutoPtr f = ccxt.get("services"); 
      Print("Services: ", f[].stringify());
   }

   

   
   
   
   AutoPtr test = ccxt.get();
   if(Dumping) DumpJsonToFile("CCXT/check-" + Change, test[]);
   
   
   
   
   
   if(ccxt.name("now").t != JS_PRIMITIVE)
   {
      ccxt.loadMarkets(false , false );
      JsValue *data = ccxt.get("markets"); 
      if(Dumping) DumpJsonToFile("CCXT/onlymarkets-" + Change, data);

      
      
      
      
      
      
   }
   else
   {
      Print("Markets are already loaded on Node");
   }

   

   
   
   

   JsValue *orderbook = ccxt.fetchOrderBook(Ticker, 10);
   if(Dumping) DumpJsonToFile("CCXT/orderbook-" + Change + "-" + Escape(Ticker), orderbook);
   
   JsValue *ticker = ccxt.fetchTicker(Ticker);
   if(Dumping) DumpJsonToFile("CCXT/ticker-" + Change + "-" + Escape(Ticker), ticker);
   
   JsValue *ohlcv = ccxt.fetchOHLCV(Ticker, "1m", t ? t - 1000 * 60 * 10 : 0, 10);
   if(Dumping) DumpJsonToFile("CCXT/ohlcv-" + Change + "-" + Escape(Ticker), ohlcv);

   JsValue *trades = ccxt.fetchTrades(Ticker, t ? t - 10000 : 0, 10);
   if(Dumping) DumpJsonToFile("CCXT/trades-" + Change + "-" + Escape(Ticker), trades);
   
   if(!!*ccxt["has"]["fetchBidsAsks"]) 
   {
      string array[] = {Ticker};
      JsValue *bidsasks = ccxt.fetchBidsAsks(array);
      if(Dumping) DumpJsonToFile("CCXT/bidsasks-" + Change + "-" + Escape(Ticker), bidsasks);
   }

   
   
   
   ccxt.fetchAnything(NULL);
   ...

And now goes the CCXT PRO half primarily based on websockets and reside notification subscriptions.

   
  
   
   if(isPro && ccxt.improve())
   {
      
      ccxt.watchOrderBook(Ticker);
      ccxt.watchTrades(Ticker);
      string tickers[] = {Ticker};
      ccxt.watchBidsAsks(tickers);
      ccxt.watchTrades(Ticker); 
      const uint begin = GetTickCount();
      whereas(!IsStopped() && ccxt.isConnected() && (!WatchingDuration || GetTickCount() - begin < WatchingDuration * 1000))
      {
         AutoPtr j = ccxt.readMessage(); 
         if(j[])
         {
            Remark(j[].stringify()); 
         }
         else
         {
            
         }
      }
   }
   else
   {
      if(isPro && ccxt.isConnected())
      {
         Print("Cannot improve to websockets");
         string headers[][2];
         if(ccxt.ws().getHeaders(headers))
         {
            
         }
         ccxt.ws().shut(); 
      }
   }

   
   if(ccxt.isConnected())
   {
      Print("Unsubscribing...");
      
      ccxt.un().watchOrderBook(Ticker);
      ccxt.un().watchTrades(Ticker);
      ccxt.un().watchBidsAsks(); 
      ccxt.un().watchTrades(Ticker); 

      const uint begin = GetTickCount(); 
      whereas(!IsStopped() && ccxt.isConnected() && (GetTickCount() - begin < 5 * 1000))
      {
         Print("studying...");
         AutoPtr j = ccxt.readMessage();
         if(j[])
         {
            Remark(j[].stringify());
         }
         else
         {
            break;
         }
      }
      
      Print("Closing...");
      
      ccxt.shut();
      
      whereas(!IsStopped()) 
      {
         AutoPtr j = ccxt.readMessage();
         if(j[])
         {
            Remark(j[].stringify());
         }
         else
         {
            break;
         }
      }
   }
}