blame | history | patch | commit | commitdiff | ignore whitespace
Joel Grunbaum
2022-01-07 4497ee326ceb2dfc3fe9d57b7b9ec9e8adc0cf8b 
 test.py


@@ -1,5 +1,4 @@


""".#test.py main module."""


import json


import time


import httpx


from whereismysock import all


@@ -7,19 +6,16 @@


import book


import protocol




test = False




HOST: str = 'sytev070'


PORT: str = '9000'


if (test):


    PORT: str = '9005'


else:


    PORT: str = '9000'




USER: str = 'test'


PASS: str = 'none'






def send(message):


    """Send message to exchange."""


    return httpx.post(f"http://{HOST}:{PORT}/execution",


                      data={"message": json.dumps(message),


                            "username": USER,


                            "password": PASS}).json()






def logAllIncomingMessages():


@@ -45,8 +41,6 @@


        protocol.handleMessage(bs, message)






message = {"type": "ADD", "product": "F_SOH_APP0104T1700", "price": 99.0,


           "side": "BUY", "volume": 1000000}


# print(json.dumps(message))


# print(send(message))


# printRecoveryLog()


@@ -55,9 +49,15 @@


# wstest()




bs = {}


# recoverBook(bs)


# print(list(bs))


# for i in bs:


    # print(bs[i].product)


    # bs[i].printBook()


book.testBook()


recoverBook(bs)


print(list(bs))


for i in bs:


    print(bs[i].product)


    bs[i].printBook()


    print()


    if (len(bs[i].askSide.levels) > 0):


        print(bs[i].askSide.levels[0])


    if (len(bs[i].bidSide.levels)):


        print(bs[i].bidSide.levels[0])


    print()


# book.testBook()