File tree Expand file tree Collapse file tree 2 files changed +5
-8
lines changed Expand file tree Collapse file tree 2 files changed +5
-8
lines changed Original file line number Diff line number Diff line change 86
86
"premium" : str ,
87
87
"oraclePx" : str ,
88
88
"markPx" : str ,
89
- "midPx" : str ,
90
- "impactPxs" : Tuple [str , str ],
89
+ "midPx" : Optional [ str ] ,
90
+ "impactPxs" : Optional [ Tuple [str , str ] ],
91
91
"dayBaseVlm" : str ,
92
92
},
93
93
)
94
94
ActiveAssetCtx = TypedDict ("ActiveAssetCtx" , {"coin" : str , "ctx" : PerpAssetCtx })
95
- ActiveAssetSpotCtx = TypedDict ("ActiveAssetSpotCtx " , {"coin" : str , "ctx" : SpotAssetCtx })
95
+ ActiveSpotAssetCtx = TypedDict ("ActiveSpotAssetCtx " , {"coin" : str , "ctx" : SpotAssetCtx })
96
96
ActiveAssetCtxMsg = TypedDict ("ActiveAssetCtxMsg" , {"channel" : Literal ["activeAssetCtx" ], "data" : ActiveAssetCtx })
97
97
ActiveSpotAssetCtxMsg = TypedDict (
98
- "ActiveSpotAssetCtxMsg" , {"channel" : Literal ["activeSpotAssetCtx" ], "data" : ActiveAssetSpotCtx }
98
+ "ActiveSpotAssetCtxMsg" , {"channel" : Literal ["activeSpotAssetCtx" ], "data" : ActiveSpotAssetCtx }
99
99
)
100
100
Fill = TypedDict (
101
101
"Fill" ,
Original file line number Diff line number Diff line change @@ -66,11 +66,8 @@ def ws_msg_to_identifier(ws_msg: WsMsg) -> Optional[str]:
66
66
return f'webData2:{ ws_msg ["data" ]["user" ].lower ()} '
67
67
elif ws_msg ["channel" ] == "bbo" :
68
68
return f'bbo:{ ws_msg ["data" ]["coin" ].lower ()} '
69
- elif ws_msg ["channel" ] == "activeAssetCtx" :
69
+ elif ws_msg ["channel" ] == "activeAssetCtx" or ws_msg [ "channel" ] == "activeSpotAssetCtx" :
70
70
return f'activeAssetCtx:{ ws_msg ["data" ]["coin" ].lower ()} '
71
- elif ws_msg ["channel" ] == "activeSpotAssetCtx" :
72
- return f'activeAssetCtx:{ ws_msg ["data" ]["coin" ].lower ()} '
73
- pass
74
71
75
72
76
73
class WebsocketManager (threading .Thread ):
You can’t perform that action at this time.
0 commit comments