o j @s<dZddlZddlZddlZGdddZGdddZdS)uE V11 — Feeds: Binance (precio spot) y CLOB (orderbook Polymarket). Nc@s*eZdZdefddZddZddZdS) BinanceFeedws_urlcCs||_d|_d|_d|_dSNgF)rlast_px_ws_stop)selfrr -/var/www/html/MetaHedge/POLYBOT1/v12/feeds.py__init__s zBinanceFeed.__init__c sfdd}d}jsNztjj|d_jjdddd}Wnty9}z td|WYd}~nd}~wwjsIt |t |dd }jr dSdS) Ncs0z tt|d_WdStyYdSw)Np)floatjsonloadsr Exception)wsmsgrr r on_msgs  zBinanceFeed.run..on_msg) on_message  ping_interval ping_timeoutz[binance] ws error: <) r websocket WebSocketApprr run_foreverrprinttimesleepmin)rrbackoffer rr runs  zBinanceFeed.runcC,d|_z|jWdStyYdSwNTrrcloserrr r r stop  zBinanceFeed.stopN)__name__ __module__ __qualname__strr r&r+r r r r rs rc@sBeZdZdZdedefddZddZdd Zd d Zd d Z dS)CLOBFeedz:Tracks best bid/ask for a single token via CLOB websocket.token_idrcCs(||_||_d|_d|_d|_d|_dSr)r2rbest_bidbest_askrr)rr2rr r r r +s  zCLOBFeed.__init__cCs|td|jgddS)Nmarket)type assets_ids)sendrdumpsr2)rrr r r _on_open3szCLOBFeed._on_opencCszFt|}t|tr |n|g}|D]1}|ddksd|vrC|dg}|dg}|r7tdd|D|_|rCtdd|D|_qWdSt yPYdSw)N event_typebookbidsaskscs|] }t|dVqdSpriceNr .0xr r r ?z#CLOBFeed._on_msg..csr?r@rBrCr r r rFArG) rr isinstancelistgetmaxr3r#r4r)rrrititemsibar r r _on_msg6s     zCLOBFeed._on_msgc Csd}|jsSztj|j|j|jd|_|jjdddd}Wn!ty>}zt d|j ddd|WYd}~nd}~ww|jsNt |t |dd }|jrdSdS) Nr)on_openrrrrz[clob:z ] reconnect: r)rrrrr:rQrrrr r2r!r"r#)rr$r%r r r r&Es  * z CLOBFeed.runcCr'r(r)rr r r r+Sr,z CLOBFeed.stopN) r-r.r/__doc__r0r r:rQr&r+r r r r r1(s r1)rTrr!rrr1r r r r s!