Working protocol

This commit is contained in:
2026-07-28 16:53:15 +02:00
parent 2b26ce46fc
commit 7764cf8f7a
5 changed files with 85 additions and 12 deletions
+13 -2
View File
@@ -36,7 +36,7 @@ class PulseWire:
class Strategy(PulseWire):
def on_request(self, req: plugin.StrategyEngineMessage):
pass
...
def send(self, req: plugin.StrategyMessageType):
self.send_raw(req.to_com())
@@ -69,7 +69,7 @@ class Strategy(PulseWire):
class Risk(PulseWire):
def on_request(self, req: plugin.RiskEngineMessage):
pass
...
def send(self, req: plugin.RiskMessageType):
self.send_raw(req.to_com())
@@ -94,3 +94,14 @@ class Risk(PulseWire):
def on_raw_engine_request(self, data: bytes):
com = plugin.RiskEngineMessage.from_com(data=data)
class Bro(Strategy):
def __init__(self):
self.log(general.EventLog.info("bro", "Hello, World"))
super().__init__()
def on_request(self, req: plugin.StrategyEngineMessage):
# self.log(general.EventLog.info("bro", "Hello, World"))
pass
Bro().start()