ڊj(`dZddlZddlmZdZdZdZdZdZdZ d Z d Z d Z d Z d Zd ZGd dZy)a TLV (Type-Length-Value) Binary Encoder/Decoder Provides efficient binary serialization for dirty worker protocol messages. Inspired by OpenBSD msgctl/msgsnd message format. Type Codes: 0x00: None (no value bytes) 0x01: bool (1 byte: 0x00 or 0x01) 0x05: int64 (8 bytes big-endian signed) 0x06: float64 (8 bytes IEEE 754) 0x10: bytes (4-byte length + raw bytes) 0x11: string (4-byte length + UTF-8 encoded) 0x20: list (4-byte count + encoded elements) 0x21: dict (4-byte count + encoded key-value pairs) N)DirtyProtocolError !iic\eZdZdZedefdZed dededefdZ edefdZ y) TLVEncoderz TLV binary encoder/decoder. Encodes Python values to binary TLV format and decodes back. Supports: None, bool, int, float, bytes, str, list, dict. returnc|ttgSt|trtt|rdgSdgSt|t r'tt gtjd|zSt|tr'ttgtjd|zSt|trdt|tkDrtdt|dtdttgtjdt|z|zSt|tru|j!d }t|t"kDrtd t|dt"dtt$gtjdt|z|zSt|t&t(frt|t*kDrtd t|d t*dtt,gtjdt|g}|D]&}|j/t0j!|(d j3|St|t4rt|t6kDrtdt|d t6dtt8gtjdt|g}|j;D]h\}}t|ts t|}|j/t0j!||j/t0j!|jd j3|Stdt=|j>)aJ Encode a Python value to TLV binary format. Args: value: Python value to encode (None, bool, int, float, bytes, str, list, or dict) Returns: bytes: TLV-encoded binary data Raises: DirtyProtocolError: If value type is not supported rr>q>dBytes too large: bytes (max: )>Iutf-8String too large: List too large: items (max: Dict too large: z#Unsupported type for TLV encoding: ) bytes TYPE_NONE isinstancebool TYPE_BOOLint TYPE_INT64structpackfloat TYPE_FLOAT64lenMAX_BYTES_SIZEr TYPE_BYTESstrencodeMAX_STRING_SIZE TYPE_STRINGlisttuple MAX_LIST_SIZE TYPE_LISTappendr joindict MAX_DICT_SIZE TYPE_DICTitemstype__name__)valueencodedpartsitemkvs W/var/www/io.vulcan-creative.com/venv/lib/python3.12/site-packages/gunicorn/dirty/tlv.pyr*zTLVEncoder.encode4s =)% % eT ")UT=> >=> > eS !*&T5)AA A eU #,(6;;tU+CC C eU #5zN*('E |4+,A/*&T3u:)FFN N eS !ll7+G7|o-((W7,-Q0+'&++dCL*IIGS S edE] +5zM)(&s5zl3*O1.I;'T3u:)FGE 6 Z..t45 688E? " eT "5zM)(&s5zl3*O1.I;'T3u:)FGE  31!!S)AA Z..q12 Z..q12  3 88E? " 1$u+2F2F1G H  rdataoffsetc , |t|k\rtd|||dz||}|dz }|tk(rd|fS|tk(r3|t|k\rtd||dz |dz||dk7}||dzfS|tk(rM|dzt|kDrtd ||dz |dzt j d |||dzd}||dzfS|tk(rM|dzt|kDrtd ||dz |dzt j d |||dzd}||dzfS|tk(r|d zt|kDrtd||dz |dzt j d|||d zd}|d z }|tkDrtd|dtd||zt|kDr(td|dt||z ||dz |dz||||z}|||zfS|tk(r|d zt|kDrtd||dz |dzt j d|||d zd}|d z }|tkDrtd|dtd||zt|kDr(td|dt||z ||dz |dz ||||zjd}|||zfS|tk(r|d zt|kDrtd||dz |dzt j d|||d zd}|d z }|t kDrtd|dt dg}t#|D],}t$j||\} }|j'| .||fS|t(k(r|d zt|kDrtd||dz |dzt j d|||d zd}|d z }|t*kDrtd|dt*di} t#|D]j}t$j||\} }t-| t.s!td t1| j2t$j||\}}|| | <l| |fStd!|d"||dz |dz#t$r%}td||||t|dzd}~wwxYw)#a9 Decode a TLV-encoded value from binary data. Args: data: Binary data to decode offset: Starting offset in the data Returns: tuple: (decoded_value, new_offset) Raises: DirtyProtocolError: If data is malformed or truncated z Truncated TLV data: no type byteraw_datarNz&Truncated TLV data: missing bool valuerz$Truncated TLV data: incomplete int64rz&Truncated TLV data: incomplete float64rz+Truncated TLV data: incomplete bytes lengthrrrrzTruncated TLV data: expected z bytes, got rz,Truncated TLV data: incomplete string lengthrz bytes for string, got rzInvalid UTF-8 in string: z)Truncated TLV data: incomplete list countrrz)Truncated TLV data: incomplete dict countrzDict key must be string, got zUnknown TLV type code: 0x02x)r&rrrr!r"unpackr%r(r'r,r+decodeUnicodeDecodeErrorminr0r/ranger r1r5r4rr)r7r8) r@rA type_coder9lengthecountr6_r<resultkeys r?rJzTLVEncoder.decodes SY $2fVb[1  L !   !<   !T"(<!&1*Vb[9LD(E&1*$ $  "zCI%(:!&1*Vb[9MM$VFQJ(?@CE&1*$ $  $zCI%(<!&1*Vb[9MM$VFQJ(?@CE&1*$ $  "zCI%(A!&1*Vb[9]]4fVaZ)@A!DF aKF&('x}^ f T" #&=  !zCI%(?!&1*Vb[9MM$VFQJ(?@CE aKF}$(&ug]=/KF5\ $(//f= V!#s+,7S 8J8J7KL!+ 1 1$ ? v#s  $6> ! ' # 7&1*Vb[1  i& (/s3!&#fb/)AB s Q%% R. RRctj|d\}}|t|k7r#tdt||z d|||dz|S)a Decode a complete TLV-encoded value, ensuring all data is consumed. Args: data: Binary data to decode Returns: Decoded Python value Raises: DirtyProtocolError: If data is malformed or has trailing bytes rzTrailing data after TLV: z bytesrCrD)r rJr&r)r@r9rAs r? decode_fullzTLVEncoder.decode_fulls^#))$2 v SY $+CI,>+?vFfVb[1  rN)r) r8 __module__ __qualname____doc__ staticmethodrr*r r.rJrVrr?r r ,spH H H TY UY CY Y Y v%rr )rYr"errorsrrrr!r%r(r,r0r5r+r'r/r4r r[rr?r]s^ "&         #!  CCr