o .j@shddlmZddlZddlZddlZzddlmZWney)ddlm ZYnwGdddeZ dS)) annotationsN)AsyncWebSocketExtensionFromHTTP)AsyncRawExtensionFromHTTPc@sPeZdZdZdddZdd d Zedd dZdddZdddZ dddZ dS)ASGIWebSocketExtensionzAsync WebSocket extension for ASGI applications. Uses the ASGI websocket protocol with send/receive queues to communicate with the application task. returnNonecCs$d|_t|_t|_d|_dS)NF)_closedasyncioQueue_app_send_queue_app_receive_queue_taskselfrW/home/thesage/.local/lib/python3.10/site-packages/niquests/extensions/sgi/_async/_ws.py__init__s   zASGIWebSocketExtension.__init__app typing.Anyscopedict[str, typing.Any]cs,dfdd }dfdd }t||||_jd d iId HjId H}|d d krad _jt tj jId HWd n1sQwYt d|dd|d dkrd _jt tj jId HWd n1swYt d|d d S)z.receivemessagercsj|IdHdSr)r put)rrrrsend"sz*ASGIWebSocketExtension.start..sendtypezwebsocket.connectNwebsocket.closeTz(WebSocket connection rejected with code codezwebsocket.acceptz*Unexpected ASGI message during handshake: )rr)rrrr) r create_taskrr rr rr cancel contextlibsuppressCancelledErrorConnectionError)rrrrrrrrrstarts*    zASGIWebSocketExtension.startboolcCs|jSr)r rrrrclosed:szASGIWebSocketExtension.closedstr | bytes | Nonecsj|jrtd|jIdH}|ddkr(d|vr|dSd|vr&|dSdS|ddkr3d |_dSdS) zlAwait the next message from the ASGI WebSocket app. Returns None when the app closes the connection.!The WebSocket extension is closedNrzwebsocket.sendtextbytesrT)r OSErrorr r)rrrrr next_payload>s  z#ASGIWebSocketExtension.next_payloadbuf str | bytescsZ|jrtdt|ttfr|jdt|dIdHdS|jd|dIdHdS)z)Send a message to the ASGI WebSocket app.r,zwebsocket.receive)rr.N)rr-)r r0 isinstancer. bytearrayr r)rr2rrr send_payloadSs  z#ASGIWebSocketExtension.send_payloadcs|jrdSd|_|jdddIdH|jdurC|jsE|jttj |jIdHWddS1ss