FIX-Rofex2020.1/mainClass.py at master · pjseoane/FIX-Rofex2020.1 · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
import sys
import argparse
import time
import configparser
from threading import Thread
import quickfix as fix
from RofexEngine.RofexEngine import rofexEngine


# from RofexEngine.bots import bots


class main:
    def __init__(self, config_file, usrId, pswd, targetCompID, tickers, entries):
        # def __init__(self, config_file, usrId, pswd, targetCompID):
        self.config_file = config_file
        self.usrId = usrId
        self.pswd = pswd
        self.targetCompID = targetCompID
        self.tickers = tickers
        self.entries = entries

        try:
            self.settings = fix.SessionSettings(self.config_file)
            self.myFixApplication = rofexEngine(self.usrId, self.pswd, self.targetCompID, self.tickers, self.entries)
            self.storefactory = fix.FileStoreFactory(self.settings)
            self.logfactory = fix.FileLogFactory(self.settings)
            self.initiator = fix.SocketInitiator(self.myFixApplication, self.storefactory, self.settings,
                                                 self.logfactory)

            """
            * Se puede iniciar desde aca

            self.initiator.start()
            self.myFixApplication.run()
            self.initiator.stop()
            """
        except (fix.ConfigError, fix.RuntimeError) as e:

            print(e)
            self.initiator.stop()
            sys.exit()

    def run(self):
        print("Paso x run")

        while 1:
            # time.sleep(2)
            action = self.queryAction()
            if action == '1':
                print(action)
                self.myFixApplication.suscribeMD()

            elif action == '2':
                print(action)
                # msg = msgToRofex.secList()

            elif action == '3':
                self.myFixApplication.printAllSecurities()
                print(action)
            elif action == '4':
                # print(self.actualMarket)
                print(action)

            elif action == '5':
                print(action)
                break

        fixMain.initiator.stop()

    def queryAction(self):
        print("1) Suscribir MD2\n2) SecList\n3) Print allSecuritiesList\n4) Actual Market\n5) Quit")
        action = input("Action:\n")
        return action


if __name__ == '__main__':
    # rofexLogon('Initiator\configuration\primaryInitiator.cfg','pjseoane232','AiZkiC5#')

    parser = argparse.ArgumentParser(description='FIX Client Configuration')
    parser.add_argument('file_name', type=str, help='Name of configuration file')
    args = parser.parse_args()

    suscribeTuple = ['RFX20Dic20', 'DODic20']
    entries = ['0', '1', '2', '4', '5', '6', '7', '8', 'B', 'C']

    fixMain = main(args.file_name, 'pjseoane232', 'AiZkiC5#', 'ROFX', suscribeTuple, entries)

    fixMain.initiator.start()
    # fixMain.myFixApplication.run()
    fixMain.run()