`kraken`: handle ws connection startup status msgs

2023-04-04 13:35:29 -04:00 · 2023-04-04 13:35:29 -04:00 · 70efce1631
parent a63599828b
commit 70efce1631
1 changed files with 11 additions and 0 deletions
--- a/piker/brokers/kraken/feed.py
+++ b/piker/brokers/kraken/feed.py
@ -189,6 +189,17 @@ async def process_data_feed_msgs(
                    #     chan_id, *payload_array, chan_name, pair = msg
                    #     print(msg)

+                case {
+                    'connectionID': conid,
+                    'event': 'systemStatus',
+                    'status': 'online',
+                    'version': ver,
+                }:
+                    log.info(
+                        f'Established {ver} ws connection with id: {conid}'
+                    )
+                    continue
+
                case _:
                    print(f'UNHANDLED MSG: {msg}')
                    # yield msg