MTsocketAPI - Low Latency Metatrader API

$Address = [System.Net.IPAddress]::Parse($IP)
$Socket = New-Object System.Net.Sockets.TCPClient("127.0.0.1",77)
$Stream = $Socket.GetStream()
 
$Writer = New-Object System.IO.StreamWriter($Stream)
$Reader = New-Object System.IO.StreamReader($Stream)
 
$Cmd = "" | Select MSG,MODE,FROM_DATE,TO_DATE
$Cmd.MSG = "TRADE_HISTORY"
$Cmd.MODE = "POSITIONS"
$Cmd.FROM_DATE = "2022/11/10 00:00:00"
$Cmd.TO_DATE = "2022/11/16 23:59:00"
 
$Json = ConvertTo-Json $Cmd -Compress
 
$Writer.WriteLine($Json)
$Writer.Flush()
 
$Response = $Reader.ReadLine()
$DataObj = ConvertFrom-Json $Response
if ($DataObj.ERROR_ID -ge 0) {
     $DataObj.POSITIONS | Export-Csv -Path "History.csv" -Delimiter "," -NoTypeInformation
     Write-Host "Exported to CSV!"
}
else {
     Write-Host $DataObj.ERROR_DESCRIPTION
}
 
$Stream.Close()
$Socket.Close()

using System;
using System.Net.Sockets;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
namespace ConsoleApp
{
    internal class Program
    {
        static int bufferLen = 8192;
        
        static void Main(string[] args)
        {
            TcpClient tcpClient_cmd = new TcpClient("127.0.0.1", 77);
            TcpClient tcpClient_data = new TcpClient("127.0.0.1", 78);
            JArray ja = new JArray();
            ja.Add("EURUSD");
            JObject jo = new JObject();
            jo["MSG"] = "TRACK_OHLC";
            jo["TIMEFRAME"] = "PERIOD_M1";
            jo["SYMBOLS"] = ja;
            Byte[] data = System.Text.Encoding.ASCII.GetBytes(jo.ToString(Formatting.None) + "\r\n");
            NetworkStream stream_cmd = tcpClient_cmd.GetStream();
            NetworkStream stream_data = tcpClient_data.GetStream();
            stream_cmd.Write(data, 0, data.Length);
            data = new Byte[bufferLen];
            String responseData = String.Empty;
            int bytes = stream_cmd.Read(data, 0, data.Length);
            responseData = System.Text.Encoding.ASCII.GetString(data, 0, bytes);
            Console.WriteLine(responseData);
            do
            {
                bytes = stream_data.Read(data, 0, data.Length);
                responseData = System.Text.Encoding.ASCII.GetString(data, 0, bytes);
                JObject jresult = JsonConvert.DeserializeObject<JObject>(responseData);
                Console.WriteLine("Time: {0}  Symbol: {1}  Open: {2}  Close: {3}  High: {4}  Low: {5}", jresult["OHLC"][0]["TIME"], jresult["SYMBOL"], jresult["OHLC"][0]["OPEN"], jresult["OHLC"][0]["CLOSE"], jresult["OHLC"][0]["HIGH"], jresult["OHLC"][0]["LOW"]);
            } while (true);
            stream_cmd.Close();
            stream_data.Close();
            tcpClient_cmd.Close();
            tcpClient_data.Close();
        }
    }
}

Time: 2022.04.19 12:15:00  Symbol: EURUSD  Open: 1.07865  Close: 1.07854  High: 1.07867  Low: 1.07854
Time: 2022.04.19 12:16:00  Symbol: EURUSD  Open: 1.07855  Close: 1.07874  High: 1.07879  Low: 1.07855
Time: 2022.04.19 12:17:00  Symbol: EURUSD  Open: 1.07880  Close: 1.07867  High: 1.07881  Low: 1.07860
Time: 2022.04.19 12:18:00  Symbol: EURUSD  Open: 1.07869  Close: 1.07870  High: 1.07872  Low: 1.07859
Time: 2022.04.19 12:19:00  Symbol: EURUSD  Open: 1.07871  Close: 1.07868  High: 1.07872  Low: 1.07868
Time: 2022.04.19 12:20:00  Symbol: EURUSD  Open: 1.07867  Close: 1.07877  High: 1.07878  Low: 1.07867
Time: 2022.04.19 12:21:00  Symbol: EURUSD  Open: 1.07878  Close: 1.07883  High: 1.07884  Low: 1.07869

const Net = require('net');
const client_cmd = new Net.Socket();
client_cmd.connect(77, "localhost", function() {
        const JSONobj = {};
        JSONobj["MSG"]="QUOTE";
        JSONobj["SYMBOL"]="EURUSD";
        client_cmd.write(JSON.stringify(JSONobj) + '\r\n');
});
client_cmd.on('data', function(chunk) {
        //console.log(`${chunk.toString()}`);
        const JSONresult = JSON.parse(chunk.toString());
        console.log(`Time: ${JSONresult["TIME"]} Symbol: ${JSONresult["SYMBOL"]} Ask: ${JSONresult["ASK"]} Bid: ${JSONresult["BID"]}`);
        client_cmd.end();
});

Time: 2022.04.13 13:01:20.0 Symbol: EURUSD Ask: 1.08335 Bid: 1.08333

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netdb.h>
/*
*
*
* gcc -o sendorder sendorder.c (Compile)
* ./sendorder 127.0.0.1 77 (Run)
*
*/
int main(int argc, char *argv[])
{
    int sockfd, portno, n;
    struct sockaddr_in serv_addr;
    struct hostent *server;
    char msg[]="{\"MSG\":\"ORDER_SEND\",\"SYMBOL\":\"EURUSD\",\"VOLUME\":0.03,\"TYPE\":\"ORDER_TYPE_BUY\"}\r\n";
    char buffer[512];
    if (argc < 3) {
       fprintf(stderr,"usage %s hostname port\n", argv[0]);
       return 0;
    }
    portno = atoi(argv[2]);
    sockfd = socket(AF_INET, SOCK_STREAM, 0);
    if (sockfd < 0)
        printf("ERROR opening socket\r\n");
    server = gethostbyname(argv[1]);
    if (server == NULL) {
        fprintf(stderr,"ERROR, no such host\n");
        exit(0);
    }
    bzero((char *) &serv_addr, sizeof(serv_addr));
    serv_addr.sin_family = AF_INET;
    bcopy((char *)server->h_addr,
         (char *)&serv_addr.sin_addr.s_addr,
         server->h_length);
    serv_addr.sin_port = htons(portno);
    if (connect(sockfd, (struct sockaddr *) &serv_addr, sizeof(serv_addr)) < 0)
    {
        printf("ERROR connecting\r\n");
        return 0;
    }
    n = write(sockfd, msg, strlen(msg));
    if (n < 0)
        printf("ERROR writing to socket\r\n");
    bzero(buffer,512);
    n = read(sockfd, buffer, 511);
    if (n < 0)
        printf("ERROR reading from socket\r\n");
    printf("%s\n", buffer);
    close(sockfd);
    return 0;
}

using MTsocketAPI.MT5;
namespace ConsoleApp
{
    internal class Program
    {
        static void Main(string[] args)
        {
            try
            {
                Terminal mt5 = new Terminal();
                if (!mt5.Connect())
                {
                    Console.WriteLine("Error connecting to MTsocketAPI. Please check if MT5 is running and MTsocketAPI started successfully");
                    return;
                }
                TradeResult buy = mt5.SendOrder("EURUSD", 0.01, OrderType.ORDER_TYPE_BUY);
                Console.WriteLine("Result:" + buy.ToString());
            }
            catch (Exception ex)
            {
                Console.WriteLine (ex.ToString());
            }
        }
    }
}

Result:{"ASK":1.08326,"BID":1.08321,"COMMENT":null,"DEAL":3736823,"ORDER":3872764,"PRICE":1.08326,"REQUEST_ID":3727291777,"RETCODE":10009,"RETCODE_EXTERNAL":0,"VOLUME":0.01,"TYPE":"ORDER_TYPE_BUY"}

{"MSG":"CALENDAR_LIST","FROM_DATE":"2024.05.03","TO_DATE":"2024.05.04","CURRENCY":"USD"}

{
   "MSG":"CALENDAR_LIST",
   "EVENTS":[
      {
         "TIME":"2024.05.03 15:30:00",
         "EVENT_COUNTRY_ID":840,
         "EVENT_DIGITS":1,
         "EVENT_CODE":"unemployment-rate",
         "EVENT_FREQUENCY":"CALENDAR_FREQUENCY_MONTH",
         "EVENT_ID":840030015,
         "EVENT_IMPORTANCE":"CALENDAR_IMPORTANCE_MODERATE",
         "EVENT_MULTIPLIER":"CALENDAR_MULTIPLIER_NONE",
         "EVENT_NAME":"Unemployment Rate",
         "EVENT_SECTOR":"CALENDAR_SECTOR_JOBS",
         "EVENT_SOURCE_URL":"https:\/\/www.bls.gov",
         "EVENT_TIME_MODE":"CALENDAR_TIMEMODE_DATETIME",
         "EVENT_TYPE":"CALENDAR_TYPE_INDICATOR",
         "EVENT_UNIT":"CALENDAR_UNIT_PERCENT",
         "ACTUAL_VALUE":3.9000,
         "FORECAST_VALUE":3.7000,
         "PREVIOUS_VALUE":3.8000,
         "IMPACT_TYPE":"CALENDAR_UNIT_CURRENCY",
         "REVISION":0,
         "PERIOD":"2024.04.01 00:00:00"
      },
      {
         "TIME":"2024.05.03 15:30:00",
         "EVENT_COUNTRY_ID":840,
         "EVENT_DIGITS":0,
         "EVENT_CODE":"nonfarm-payrolls",
         "EVENT_FREQUENCY":"CALENDAR_FREQUENCY_MONTH",
         "EVENT_ID":840030016,
         "EVENT_IMPORTANCE":"CALENDAR_IMPORTANCE_HIGH",
         "EVENT_MULTIPLIER":"CALENDAR_MULTIPLIER_THOUSANDS",
         "EVENT_NAME":"Nonfarm Payrolls",
         "EVENT_SECTOR":"CALENDAR_SECTOR_JOBS",
         "EVENT_SOURCE_URL":"https:\/\/www.bls.gov",
         "EVENT_TIME_MODE":"CALENDAR_TIMEMODE_DATETIME",
         "EVENT_TYPE":"CALENDAR_TYPE_INDICATOR",
         "EVENT_UNIT":"CALENDAR_UNIT_JOB",
         "ACTUAL_VALUE":175.0000,
         "FORECAST_VALUE":197.0000,
         "PREVIOUS_VALUE":303.0000,
         "REVISED_VALUE":315.0000,
         "IMPACT_TYPE":"CALENDAR_UNIT_CURRENCY",
         "REVISION":0,
         "PERIOD":"2024.04.01 00:00:00"
      },
      ...
      {
         "TIME":"2024.05.03 22:30:00",
         "EVENT_COUNTRY_ID":840,
         "EVENT_DIGITS":1,
         "EVENT_CODE":"cftc-nasdaq-100-non-commercial-net-positions",
         "EVENT_FREQUENCY":"CALENDAR_FREQUENCY_WEEK",
         "EVENT_ID":840520011,
         "EVENT_IMPORTANCE":"CALENDAR_IMPORTANCE_LOW",
         "EVENT_MULTIPLIER":"CALENDAR_MULTIPLIER_THOUSANDS",
         "EVENT_NAME":"CFTC Nasdaq 100 Non-Commercial Net Positions",
         "EVENT_SECTOR":"CALENDAR_SECTOR_MARKET",
         "EVENT_SOURCE_URL":"https:\/\/www.cftc.gov\/",
         "EVENT_TIME_MODE":"CALENDAR_TIMEMODE_DATETIME",
         "EVENT_TYPE":"CALENDAR_TYPE_INDICATOR",
         "EVENT_UNIT":"CALENDAR_UNIT_POSITION",
         "PREVIOUS_VALUE":6.1000,
         "IMPACT_TYPE":"CALENDAR_UNIT_NONE",
         "REVISION":0,
         "PERIOD":"2024.04.30 00:00:00"
      }
   ],
   "ERROR_ID":0,
   "ERROR_DESCRIPTION":"The operation completed successfully"
}

import http.client
conn = http.client.HTTPConnection("127.0.0.1:81")
payload = ""
headers = { 'Content-Type': "application/json", 'Accept': "application/json" }
conn.request("POST", "/v1/order?symbol=EURUSD&volume=0.01&type=ORDER_TYPE_BUY", payload, headers)
res = conn.getresponse()
data = res.read()
print(data.decode("utf-8"))

import http.client
conn = http.client.HTTPConnection("127.0.0.1:81")
headers = { 'Accept': "application/json" }
conn.request("GET", "/v1/order/list", headers=headers)
res = conn.getresponse()
data = res.read()
print(data.decode("utf-8"))

import http.client
conn = http.client.HTTPConnection("127.0.0.1:81")
headers = { 'Accept': "application/json" }
conn.request("GET", "/v1/quote?symbol=EURUSD", headers=headers)
res = conn.getresponse()
data = res.read()
print(data.decode("utf-8"))

import http.client
conn = http.client.HTTPConnection("127.0.0.1:81")
headers = { 'Accept': "application/json" }
conn.request("GET", "/v1/symbol/list", headers=headers)
res = conn.getresponse()
data = res.read()
print(data.decode("utf-8"))

import http.client
conn = http.client.HTTPConnection("127.0.0.1:81")
headers = { 'Accept': "application/json" }
conn.request("GET", "/v1/account", headers=headers)
res = conn.getresponse()
data = res.read()
print(data.decode("utf-8"))

curl --request POST 'http://127.0.0.1:81/v1/order?symbol=EURUSD&volume=0.01&type=ORDER_TYPE_BUY'

curl --request POST "http://127.0.0.1:81/v1/order?symbol=EURUSD&volume=0.01&type=ORDER_TYPE_BUY"