| | |
| | | import book |
| | | import protocol |
| | | |
| | | test = False |
| | | test = True |
| | | |
| | | HOST: str = 'sytev070' |
| | | if (test): |
| | |
| | | for message in so_far_today: |
| | | protocol.handleMessage(bs, message) |
| | | |
| | | 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) |
| | | |
| | | |
| | | message = {"type": "ADD", "product": "F_THS_APP0119T2230", "price": 99.0, |
| | | "side": "BUY", "volume": 1} |
| | | |
| | | # print(json.dumps(message)) |
| | | # print(send(message)) |
| | | print(protocol.send(message)) |
| | | # printRecoveryLog() |
| | | # logAllIncomingMessages() |
| | | # print(getInformation()) |
| | | # wstest() |
| | | |
| | | bs = {} |
| | | 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() |
| | | # bs = {} |
| | | # recoverBook(bs) |
| | | # 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() |