Merge pull request #357 from pikers/paper_eng_msg_fixes

Oof, paper engine msg fixes after using `msgspec.Struct`..
pikers · Jul 11, 2022 · f449672 · f449672
2 parents 37f634a + fd22f45
commit f449672
Showing 1 changed file with 6 additions and 7 deletions.
diff --git a/piker/clearing/_paper_engine.py b/piker/clearing/_paper_engine.py
@@ -111,11 +111,12 @@ async def submit_limit(
         msg = BrokerdStatus(
             status='submitted',
             reqid=reqid,
-            broker=self.broker,
             time_ns=time.time_ns(),
             filled=0.0,
             reason='paper_trigger',
             remaining=size,
+
+            broker_details={'name': 'paperboi'},
         )
         await self.ems_trades_stream.send(msg)
 
@@ -168,10 +169,9 @@ async def submit_cancel(
 
         msg = BrokerdStatus(
             status='cancelled',
-            oid=oid,
             reqid=reqid,
-            broker=self.broker,
             time_ns=time.time_ns(),
+            broker_details={'name': 'paperboi'},
         )
         await self.ems_trades_stream.send(msg)
 
@@ -229,14 +229,13 @@ async def fake_fill(
                 filled=size,
                 remaining=0 if order_complete else remaining,
 
-                action=action,
-                size=size,
-                price=price,
-
                 broker_details={
                     'paper_info': {
                         'oid': oid,
                     },
+                    'action': action,
+                    'size': size,
+                    'price': price,
                     'name': self.broker,
                 },
             )