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