o m=8jˆ ã@sîUdZddlZddlmZddlmZddlmZmZm Z m Z e gd¢ƒZ ee e d<Gdd „d eƒZGd d „d eƒZGd d „d e ƒZGdd„de ƒZeZeeBZe eejddf¡Ze eejddf¡ZGdd„deƒZGdd„deƒZdS)z0Models for WebSocket protocol versions 13 and 8.éN)ÚCallable)ÚIntEnum)ÚAnyÚFinalÚ NamedTupleÚcast)rréÿrÚWS_DEFLATE_TRAILINGc@s@eZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdS)Ú WSCloseCodeièiéiêiëiîiïiðiñiòióiôiõiöN)Ú__name__Ú __module__Ú __qualname__ÚOKÚ GOING_AWAYÚPROTOCOL_ERRORÚUNSUPPORTED_DATAÚABNORMAL_CLOSUREÚ INVALID_TEXTÚPOLICY_VIOLATIONÚMESSAGE_TOO_BIGÚMANDATORY_EXTENSIONÚINTERNAL_ERRORÚSERVICE_RESTARTÚTRY_AGAIN_LATERÚ BAD_GATEWAY©rrú`/home/nk/hobo-godmode/plappi-mvp/.venv/lib/python3.10/site-packages/aiohttp/_websocket/models.pyr sr c@sPeZdZdZdZdZdZdZdZdZ dZ d Z eZ eZ eZeZeZe Ze Ze Zd S) Ú WSMsgTyperééé é ééiiN)r r r Ú CONTINUATIONÚTEXTÚBINARYÚPINGÚPONGÚCLOSEÚCLOSINGÚCLOSEDÚERRORÚtextÚbinaryÚpingÚpongÚcloseÚclosingÚclosedÚerrorrrrrrs$rc@sNeZdZUeed<eed<edBed<ejdœde egefdefdd „ZdS) Ú WSMessageÚtypeÚdataNÚextra©Úloadsr:ÚreturncCó ||jƒS)zAReturn parsed JSON data. .. versionadded:: 0.22 ©r7©Úselfr:rrrÚjson9s zWSMessage.json) r r r rÚ__annotations__rÚstrr@r:rrrrrr53s  (r5c@sReZdZUdZeed<eed<edBed<ej dœde egefdefd d „ZdS) ÚWSMessageTextBytesz:WebSocket TEXT message with raw bytes (no UTF-8 decoding).r6r7Nr8r9r:r;cCr<)zReturn parsed JSON data.r=r>rrrr@Ks zWSMessageTextBytes.json) r r r Ú__doc__rrArrBr@r:rrrrrrCAs  (rCcs<eZdZdZdededdf‡fdd„ Zdefdd „Z‡ZS) ÚWebSocketErrorz WebSocket protocol parser error.ÚcodeÚmessager;Ncs||_tƒ ||¡dS)N)rFÚsuperÚ__init__)r?rFrG©Ú __class__rrrIbszWebSocketError.__init__cCstt|jdƒS)Nr)rrBÚargs)r?rrrÚ__str__fszWebSocketError.__str__) r r r rDÚintrBrIrMÚ __classcell__rrrJrrE_srEc@seZdZdZdS)ÚWSHandshakeErrorz#WebSocket protocol handshake error.N)r r r rDrrrrrPjsrP)rDr@Úcollections.abcrÚenumrÚtypingrrrrÚbytesr rAr rr5rCÚWSMessageDecodeTextÚWSMessageNoDecodeTextÚtupleÚ__new__r+ÚWS_CLOSED_MESSAGEr*ÚWS_CLOSING_MESSAGEÚ ExceptionrErPrrrrÚs