From 317610e00ae4098aa43a125169cb4bf2acb8ed80 Mon Sep 17 00:00:00 2001
From: Tyler Goodlet <jgbt@protonmail.com>
Date: Sun, 14 Aug 2022 16:39:35 -0400
Subject: [PATCH] Store positions globally and deliver on ctx connects

---
 piker/clearing/_paper_engine.py | 17 +++++++++++++++--
 1 file changed, 15 insertions(+), 2 deletions(-)

diff --git a/piker/clearing/_paper_engine.py b/piker/clearing/_paper_engine.py
index 04b52870..609db6fb 100644
--- a/piker/clearing/_paper_engine.py
+++ b/piker/clearing/_paper_engine.py
@@ -482,6 +482,7 @@ _sells: dict[
         tuple[float, str, str],
     ]
 ] = {}
+_positions: dict[str, Position] = {}
 
 
 @tractor.context
@@ -503,10 +504,22 @@ async def trades_dialogue(
         ) as feed,
 
     ):
+        pp_msgs: list[BrokerdPosition] = []
+        pos: Position
+        token: str  # f'{symbol}.{self.broker}'
+        for token, pos in _positions.items():
+            pp_msgs.append(BrokerdPosition(
+                broker=broker,
+                account='paper',
+                symbol=fqsn,
+                size=pos.size,
+                avg_price=pos.ppu,
+            ))
+
         # TODO: load paper positions per broker from .toml config file
         # and pass as symbol to position data mapping: ``dict[str, dict]``
         # await ctx.started(all_positions)
-        await ctx.started(({}, ['paper']))
+        await ctx.started((pp_msgs, ['paper']))
 
         async with (
             ctx.open_stream() as ems_stream,
@@ -521,7 +534,7 @@ async def trades_dialogue(
                 _reqids=_reqids,
 
                 # TODO: load paper positions from ``positions.toml``
-                _positions={},
+                _positions=_positions,
 
                 # TODO: load postions from ledger file
                 _trade_ledger={},