Initial shift to rapidjson

Joel Grunbaum

2022-01-09 b4cf0a2e71ad2c204925b33f9600dc720e25b827

 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():
@@ -44,9 +40,11 @@
    for message in so_far_today:
        protocol.handleMessage(bs, message)


message = {"type": "ADD", "product": "F_SOH_APP0104T1700", "price": 99.0,
           "side": "BUY", "volume": 1000000}
def testRecoverBook(bs: {str, book.Book}):
    f = open("data.test", "r");
    so_far_today = f.read();
    for message in so_far_today:
        protocol.handleMessage(bs, message)
# print(json.dumps(message))
# print(send(message))
# printRecoveryLog()
@@ -56,8 +54,15 @@

bs = {}
# recoverBook(bs)
# print(list(bs))
# for i in bs:
    # print(bs[i].product)
    # bs[i].printBook()
book.testBook()
testRecoverBook(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()