mt5server.py

import time
import json
import configparser
import MetaTrader5 as mt5
import paho.mqtt.client as mqtt

config = configparser.ConfigParser()
config.read('mt5account.ini')  # load configuration file

MT5_EXE = config.get('MetaTrader', 'exe_path')
MT5_ACCOUNT = int(config.get('MetaTrader', 'account_number'))
MT5_PASS = config.get('MetaTrader', 'password')
MT5_SERVER = config.get('MetaTrader', 'server')

def create_json_obj(symbol, volume, profit):
    return {
        "symbol": symbol,
        "volume": volume,
        "profit": profit
    }


class MT5Client():

    def __init__(self) -> None:
        self.init_mt5()
        self.init_mqtt_client()

    def __del__(self):
        # Disconnect from MetaTrader 5 and MQTT broker
        mt5.shutdown()
        self.mqtt_client.disconnect()

    def init_mt5(self):
        while not mt5.initialize(
           MT5_EXE,
           login=MT5_ACCOUNT,
           password=MT5_PASS,
           server=MT5_SERVER,
           timeout=10,
           portable=False
           ):
            print(f"Reattempting login: {mt5.last_error()}")

        self.get_account_info()

    def get_account_info(self):
        self.ac_info = mt5.account_info()
        return self.ac_info

    def init_mqtt_client(self):
        # Set up MQTT client
        self.mqtt_client = mqtt.Client(mqtt.CallbackAPIVersion.VERSION2)
        self.mqtt_client.connect("localhost", 1883)  # Replace with your MQTT broker address and port

    # Function to publish time to MQTT topic
    def publish_to_topic(self, topic, data):
        self.mqtt_client.publish(topic, data)

def main():
    mt5client = MT5Client()
    bal_topic = "mt5/balance"
    eq_topic = "mt5/equity"
    equity = 0

    while True:
        day = time.localtime().tm_wday
        # From Mon-Fri and Sun
        if (0 <= day <= 4) or (day == 6):
            if mt5client.get_account_info().equity != equity:
                equity = mt5client.get_account_info().equity
                balance = mt5client.get_account_info().balance
                mt5client.publish_to_topic(eq_topic, equity)
                mt5client.publish_to_topic(bal_topic, balance)
            time.sleep(60)
        else:
            time.sleep(23*60*60)

main()