pikers
/
piker
3
0
Fork 0
Code Issues 5 Pull Requests 7 Packages Projects Releases Wiki Activity

Strip ib prefix before acctid use

lifo_pps_ib
Tyler Goodlet 2022-06-21 12:52:20 -04:00
parent 4fdfb81876
commit 3713288b48
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
piker/brokers/ib/broker.py
View File

@ -551,13 +551,14 @@ async def emit_pp_update(
# ib's positions data, and relay re-formatted pps as # ib's positions data, and relay re-formatted pps as
# msgs to the ems. # msgs to the ems.
by_acct = pp.get_pps('ib', acctids={acctid}) by_acct = pp.get_pps('ib', acctids={acctid})
by_fqsn = by_acct[acctid.strip('ib.')] acctname = acctid.strip('ib.')
by_fqsn = by_acct[acctname]
for fqsn, p in by_fqsn.items(): for fqsn, p in by_fqsn.items():
if p.bsuid == trade_entry['contract']['conId']: if p.bsuid == trade_entry['contract']['conId']:
# should only be one right? # should only be one right?
msgs = await update_and_audit( msgs = await update_and_audit(
acctid, acctname,
{fqsn: p}, {fqsn: p},
cids2pps, cids2pps,
validate=False, validate=False,
@ -572,7 +573,7 @@ async def deliver_trade_events(
trade_event_stream: trio.MemoryReceiveChannel, trade_event_stream: trio.MemoryReceiveChannel,
ems_stream: tractor.MsgStream, ems_stream: tractor.MsgStream,
accounts_def: dict[str, str], accounts_def: dict[str, str], # eg. `'ib.main'` -> `'DU999999'`
cids2pps: dict[tuple[str, str], BrokerdPosition], cids2pps: dict[tuple[str, str], BrokerdPosition],
proxies: dict[str, MethodProxy], proxies: dict[str, MethodProxy],
@ -851,7 +852,7 @@ def norm_trade_records(
dt.set(hour=tsdt.hour, minute=tsdt.minute, second=tsdt.second) dt.set(hour=tsdt.hour, minute=tsdt.minute, second=tsdt.second)
else: else:
epoch_dt = pendulum.from_timestamp(record.get('time')) # epoch_dt = pendulum.from_timestamp(record.get('time'))
dt = pendulum.parse(date) dt = pendulum.parse(date)
# special handling of symbol extraction from # special handling of symbol extraction from