From 4497ee326ceb2dfc3fe9d57b7b9ec9e8adc0cf8b Mon Sep 17 00:00:00 2001
From: Joel Grunbaum <joelgrun@gmail.com>
Date: Fri, 07 Jan 2022 05:02:19 +0000
Subject: [PATCH] Added book sorting and protocol decyphering
---
test.py | 36 ++++++++++++++++++------------------
1 files changed, 18 insertions(+), 18 deletions(-)
diff --git a/test.py b/test.py
index 788ceff..ae18f62 100644
--- a/test.py
+++ b/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()
--
Gitblit v1.9.3