Workflow for keeping a websession open for trading

[uerdogan]

Hi everyone.

Instead of one shot commands with the pytr cli, I want to connect once and keep the connection open.
My idea is to have an input loop, which reads in commands from a fifo and outputs results to another fifo. The inputs would be raw json strings like sub 7 {"type": "ticker", "id": "xxxxx.yyy"} and so on. Therefore one could code just the code to generate those commands and use the pytr code as a black box. The pytr code should only manage the reconnection of the websocket and resubscribe not closed subscriptions.

My code wrapper would use it like this:

tr_api = login(web=True, store_credentials=True)
bridge = TRBridge(tr_api)

await asyncio.gather(
    bridge.background_reader(),
    bridge.command_loop(),
    bridge.heartbeat_loop()
)

Thx.