o >h #@sddlZddlmZddlmZmZddlmZddlm Z m Z m Z m Z GdddeZ Gd d d e ZGd d d eZGd ddeZdS)N) async_to_sync) AsyncConsumer SyncConsumer)aclose_old_connections)AcceptConnectionDenyConnectionInvalidChannelLayerError StopConsumerc|eZdZdZdZddZddZddZdfd d Zd d Z dd dZ dfdd Z dfdd Z ddZ ddZZS)WebsocketConsumerz Base WebSocket consumer. Provides a general encapsulation for the WebSocket handling model that other applications can build on. NcO|jdur g|_dSdSNgroupsselfargskwargsrz/var/www/vedio/testing/chatpythonscript.ninositsolution.com/env/lib/python3.10/site-packages/channels/generic/websocket.py__init__  zWebsocketConsumer.__init__cCsz|jD] }t|jj||jqWn tytdwz|WdSty3| YdSt y@| YdSw)? Called when a WebSocket connection is opened. 1BACKEND is unconfigured or doesn't support groupsN) rr channel_layer group_add channel_nameAttributeErrorr connectracceptrclosermessagegrouprrrwebsocket_connects     z#WebsocketConsumer.websocket_connectcCs |dSrr rrrrr-s zWebsocketConsumer.connectcs*d|d}|r t||d<t|dSz, Accepts an incoming socket zwebsocket.accept)type subprotocolheadersNlistsupersendrr*r+r# __class__rrr 0s  zWebsocketConsumer.acceptcCs6|ddur|j|dddS|j|dddSzk Called when a WebSocket frame is received. Decodes it and passes it to receive(). textN) text_databytes) bytes_datagetreceiverr#rrrwebsocket_receive:sz#WebsocketConsumer.websocket_receivecCdSz8 Called with a decoded WebSocket frame. Nrrr5r7rrrr:DzWebsocketConsumer.receiveFcsV|durtd|dn|durtd|dntd|r)||dSdSz7 Sends a reply back down the WebSocket Nzwebsocket.send)r)r4)r)r6z,You must pass one of bytes_data or text_datar.r/ ValueErrorr!rr5r7r!r1rrr/JszWebsocketConsumer.sendcs<ddi}|dur|dur||d<|r||d<t|dSz: Closes the WebSocket from the server end r)zwebsocket.closeNTcodereasonr.r/rrFrGr#r1rrr!Ws zWebsocketConsumer.closecCsPz|jD] }t|jj||jqWn tytdw||dt) Called when a WebSocket connection is closed. Base level so you don't need to call super() all the time. rrF) rrr group_discardrrr disconnectr r"rrrwebsocket_disconnectbs   z&WebsocketConsumer.websocket_disconnectcCr=z? Called when a WebSocket connection is closed. NrrrFrrrrLsr@zWebsocketConsumer.disconnectNNNNF__name__ __module__ __qualname____doc__rrr%rr r<r:r/r!rMrL __classcell__rrr1rr s   r cLeZdZdZdddZddZdfdd Zed d Zed d Z Z S)JsonWebsocketConsumerz Variant of WebsocketConsumer that automatically JSON-encodes and decodes messages as they come in and go out. Expects everything to be text; will error on binary data. NcKs(|r|j||fi|dStdNz-No text section for incoming WebSocket frame! receive_json decode_jsonrCrr5r7rrrrr:szJsonWebsocketConsumer.receivecKr=z3 Called with decoded JSON content. Nrrcontentrrrrr\r@z"JsonWebsocketConsumer.receive_jsonFcstj|||ddS)M Encode the given content as JSON and send it to the client. r5r!Nr.r/ encode_jsonrrar!r1rr send_jsonszJsonWebsocketConsumer.send_jsoncC t|Srjsonloadsclsr5rrrr] z!JsonWebsocketConsumer.decode_jsoncCrhrrjdumpsrmrarrrrernz!JsonWebsocketConsumer.encode_jsonrPF rSrTrUrVr:r\rg classmethodr]rerWrrr1rrYz  rYcr )AsyncWebsocketConsumerz Base WebSocket consumer, async version. Provides a general encapsulation for the WebSocket handling model that other applications can build on. NcOr rrrrrrrrzAsyncWebsocketConsumer.__init__csz|jD] }|j||jIdHqWn tytdwz |IdHWdSty;|IdHYdSt yK| IdHYdSw)rNr) rrrrrr rrr rr!r"rrrr%s"    z(AsyncWebsocketConsumer.websocket_connectcs|IdHdSrr&r'rrrrszAsyncWebsocketConsumer.connectcs2d|d}|rt||d<t|IdHdSr(r,r0r1rrr s   zAsyncWebsocketConsumer.acceptcsD|ddur|j|ddIdHdS|j|ddIdHdSr3r8r;rrrr<sz(AsyncWebsocketConsumer.websocket_receivecdSr>rr?rrrr:zAsyncWebsocketConsumer.receiveFcsj|durtd|dIdHn|dur#td|dIdHntd|r3||IdHdSdSrArBrDr1rrr/szAsyncWebsocketConsumer.sendcsDddi}|dur|dur||d<|r||d<t|IdHdSrErHrIr1rrr!szAsyncWebsocketConsumer.closecsfz|jD] }|j||jIdHqWn tytdw||dIdHtIdHt)rJNrrF) rrrKrrr rLrr r"rrrrMs   z+AsyncWebsocketConsumer.websocket_disconnectcrwrNrrOrrrrLrxz!AsyncWebsocketConsumer.disconnectrPrQrRrrr1rrvs   rvcrX)AsyncJsonWebsocketConsumerz Variant of AsyncWebsocketConsumer that automatically JSON-encodes and decodes messages as they come in and go out. Expects everything to be text; will error on binary data. Ncs6|r|j||IdHfi|IdHdStdrZr[r^rrrr: s(z"AsyncJsonWebsocketConsumer.receivecrwr_rr`rrrr\rxz'AsyncJsonWebsocketConsumer.receive_jsonFcs(tj||IdH|dIdHdS)rbNrcrdrfr1rrrgs&z$AsyncJsonWebsocketConsumer.send_jsonc t|Srrirlrrrr] z&AsyncJsonWebsocketConsumer.decode_jsoncrzrrorqrrrre"r{z&AsyncJsonWebsocketConsumer.encode_jsonrPrrrsrrr1rryrury)rj asgiref.syncrconsumerrrdbr exceptionsrrr r r rYrvryrrrrs  k"i