o ѷ6i@szddlZddlmZddlmZddlmZddlmZddlm Z e e Z dd Z ed d Zed d ZddZdS)N)Group)channel_session_user)channel_session_user_from_http)models) app_settingscCs&|jjr tjjj|jdStjjS)z@ :return: Subscription query for a given message's user )settings__user)useris_authenticatedr SubscriptionobjectsfilternonemessagerY/var/www/hoanhtaovolam_webdjango/env/lib/python3.10/site-packages/django_nyt/consumers.pyget_subscriptions s rcCsRtd|j|jddit|D]}ttj j|j j d |jqdS)z( Connected to websocket.connect z!Adding new connection for user {}acceptTnotification_keyN) loggerdebugformatr reply_channelsendrrrNOTIFICATION_CHANNELnotification_typekeyaddr subscriptionrrr ws_connects  r"cCsBtd|jt|D]}ttjj|jj d |j q dS)z+ Connected to websocket.disconnect z,Removing connection for user {} (disconnect)rN) rrrr rrrrrrdiscardrr rrr ws_disconnect's  r$cCstd|jddidS)z Receives messages, this is currently just for debugging purposes as there is no communication API for the websockets. z5Received a message, responding with a non-API messagetextOKN)rrrrrrrr ws_receive5s r')loggingchannelsr channels.authrrrconfr getLogger__name__rrr"r$r'rrrrs