ї oWчiTЦС├≈UddlZddlZddlZddlmZmZmZddlmZddl m Z ddlmZm Z ejeі╚Zedg╛і╚ZgZeeed<gZeeed <d eedefd└Ze═d і╚defd└і╚Ze═dі╚defd└і╚Zdefd└Zdedefd└ZdS)ИN)з APIRouterз WebSocketзWebSocketDisconnect)зselect)зAsyncSessionLocal)зTradeзTradeStatusз websockets)зtagsз_trade_connectionsз_signal_connectionsзconnectionsзpayloadc┐СЖK≈g}tj|і╚}|D]C} |═|і╚┐d{V≈├▄#t$r|═|і╚Y▄@wxYw|D]}|═|і╚▄dS)zDSend JSON payload to all connected clients; remove dead connections.N)зjsonзdumpsз send_textз Exceptionзappendзremove)rrзdeadзmessageзwss З6/var/www/html/crypto-bot/backend/app/api/websockets.pyз _broadcastrsЁХХ─Ю ─Dщ▄j≤я!т!─GьПП┬П ь≈,▓,≤wя'т'п'п'п'п'п'п'п'п'ЬщП П П ь▐K┼K≤┴O▄O┬O┬O┬OП ЬЬЬЮПП┬ьвр≤2ятппППs·:╨AаAz /ws/tradesз websocketc┐СЧK≈|═і╚┐d{V≈├t═|і╚t═dі╚ tjdі╚┐d{V≈├tі╚4┐d{V≈├}|═ttі╚═tjtjkі╚і╚┐d{V≈├}|═і╚═і╚}dd└|Dі╚d°}dddі╚┐d{V≈├n#1┐d{V≈├swxYwY|═t%j|і╚і╚┐d{V≈├░▄#t($r8t═|і╚t═dі╚YdSt,$rQ}t═d |⌡²і╚|tvr t═|і╚Yd}~dSYd}~dSd}~wwxYw) zh Broadcasts all open trades every 5 seconds. Clients receive a JSON array of trade objects. NzWS /ws/trades client connectedTИз trades_updatecС6≈g|]}|═і╚▒▄S╘)зto_dict)з.0зts rЗ zws_trades..3s ─п9п9п9╗Q≤Q÷Y Y≥[°[п9п9п9С╘зtypeзdataz!WS /ws/trades client disconnectedzWS /ws/trades error: )зacceptrrзloggerзinfoзasyncioзsleeprзexecuterrзwhereзstatusr зOPENзscalarsзallrrrrrrзerror)rзdbзresultзtradesrзes rз ws_tradesr: sаХХ─Пв р я т пппппппщвр≤iя(т(п(щ ┤K┌Kп0я1т1п1П1П ;щ■-═я"т"п"п"п"п"п"п"п"щ(я*т*П П П П П П П ╗bь!÷z zщ²5▒M■Mв'р'ґ╛Ґт8Hр(HяIтIЯ Т ПППППП░П ÷ я)т)в-р-я/т/░Ю+ь9п9╟&п9я9т9ПП░П П П Я Т П П П П П П П П П П П П П П П П П П ЬЬЬП П П П Пв%р%╔dєj╟я&9т&9я:т:п:п:п:п:п:п:п:Я ;ЬУП9П9П9щв!р!═)я,т,п,щ▐┼п7я8т8п8п8п8п8щП1П1П1щ▐┼п0╗Qп0п0я1т1п1ьу*п*п*щв%р%═iя0т0п0п0п0п0п0п0п0П+п*п*п*п*п*ЬЬЬЬП1ЬЬЬsDа/E!бBD!дE!д! D+д+E!д.D+д/2E!е!>G<ф" G<ф+AG7г7G?sХХ─П в р я т пппппппщвр≤yя)т)п)щ ┤K┌Kп1я2т2п2П2П Dщ■-═я#т#п#п#п#п#п#п#п#ьв%р%╔dєj╟&╦&п1Aя&Bт&BяCтCпCпCпCпCпCпCпCП DЬУП:П:П:щв"р"═9я-т-п-щ▐┼п8я9т9п9п9п9п9щП2П2П2щ▐┼п1╗aп1п1я2т2п2ьу+п+п+щв&р&═yя1т1п1п1п1п1п1п1п1П,п+п+п+п+п+ЬЬЬЬП2ЬЬЬs аABб>D8ц D8ц'AD3д3D8зsignal_payloadc┐СFK≈ttd|d°і╚┐d{V≈├dS)z1Called externally when a new signal is generated.з new_signalr'N)rr )r?s rзbroadcast_signalrBUs7ХХ─Е у(╟<хп*Xп*Xя Yт YпYпYпYпYпYпYпYпYпYr&зeventз trade_datac┐СFK≈tt||d°і╚┐d{V≈├dS)zSPush a specific trade event (opened/closed/sl_hit/tp_hit) to all trade subscribers.r'N)rr)rCrDs rзbroadcast_trade_eventrFZs7ХХ─Е у'╟%юп)Lп)Lя Mт MпMпMпMпMпMпMпMпMпMr&)r-rзloggingзfastapirrrз sqlalchemyrзapp.databaserзapp.models.traderr з getLoggerз__name__r+зrouterrзlistз__annotations__r зdictrrr:r>rBзstrrFr!r&rЗrSsЄПь────ь───ь───ь=п=п=п=п=п=п=п=п=п=ьпппппЮ*п*п*п*п*п*ь/п/п/п/п/п/п/п/Ю ┬т ≤8я $т $─Ю ┬≤≤п 'я 'т '─П')п░D≤■Oп(п(я(ь')п░T≤)■_п)п)я)П ═$═yє/П ╦DП П П П Пвр░,ятП1≤yП1П1П1Я тП1П<вр░-я т П2═ П2П2П2Я!т П2П*Z╗4ПZПZПZПZП N═sПN╦ПNПNПNПNПNПNr&