>i&dZddlZddlZddlZddlmZddlmZddlmZm Z ddlm Z m Z m Z dZ erdZnd Zd Zd Zd Zd Zy)zAMQP Table Encoding/DecodingN)datetime) exceptions)PY2 basestring) unicode_typelongas_bytesct|}t|}|dkDrtj||j t j d||j |d|zS)zEncode a string value as short string and append it to pieces list returning the size of the encoded value. :param list pieces: Already encoded values :param str value: String value to encode :rtype: int B)r lenrShortStringTooLongappendstructpack)piecesvalue encoded_valuelengths C/var/www/html/aiagents/fe/lib/python3.12/site-packages/pika/data.pyencode_short_stringr s^UOM  F|++M:: MM&++c6*+ MM- v:ctjd||d}|dz }||||z} t|}||z }||fS#t$rYwxYw)IDecode a short string value from ``encoded`` data at ``offset``. r rr )r unpack_frombytesUnicodeEncodeErrorencodedoffsetrrs rdecode_short_stringr".sp##C&9!<! v/ %LE &f}"   s = A A ctjd||d}|dz }||||z} |jd}||z }||fS#t$rYwxYw)rr rr utf8)rrdecodeUnicodeDecodeErrorrs rr"r"?ss##C&9!<! v/ LL(E &f}"   sA AAc|xsi}t|}|jdd}|jD]#\}}|t||z }|t ||z }%t j d|||<|dzS)zEncode a dict as an AMQP table appending the encded table to the pieces list passed in. :param list pieces: Already encoded frame pieces :param dict table: The dict to encode :rtype: int Nr>I)rritemsr encode_valuerr)rtable length_index tablesizekeyrs r encode_tabler0Ms KREv;L MM$I 1 e(55 \&%00 1";;tY7F< q=rc  trt|trcISxz>cBtrz>cqLz>cQl z>ciI z>cBiDTz>cFr rAV)r isinstancerrencoderrrrrboolintrerrordecimalDecimal normalizeas_tupleexponentrcalendartimegm utctimetupledictr0listr+joinrUnsupportedAMQPFieldException)rrpackeddecimalsraw list_piecesvalpieces rr+r+bs eZ (%. W- MM&++eT3u:> ? MM% s5z> ! eZ (LL)E MM&++eT3u:> ? MM% s5z> ! eU # MM&++eT3u:> ? MM% s5z> !% fkk%s5z:;% 19 MM&++eT59 : MM&++eT59 : E3  [[e4F MM& ! E7?? +! >>  $ $q ((111Hewr2H<=>C MM&++fdHcB C MM&++fdAs5zB C E8 $ KKtX__U5G5G5I%J K M E4  fkk$-.<... E4   +C c * +% fkk%s5z:; e3u:~  fkk$-.66vuEEI|| qyUD$u+>UD$u+> MM& !  s(Q..A*SSci}tjd||d}|dz }||z}||kr)t||\}}t||\}}|||<||kr)||fS)aDecode the AMQP table passed in from the encoded value returning the decoded result and the number of bytes read plus the offset. :param str encoded: The binary encoded data to decode :param int offset: The starting byte offset :rtype: tuple r(rr))rrr" decode_value)r r!resultr.limitr/rs r decode_tabler]szF""4&9!rc|||dz}|dz }|dk(r.tjd||d}t|}|dz }||fS|dk(r#tjd||d}|dz }||fS|dk(r#tjd||d}|dz }||fS|dk(r#tjd ||d}|d z }||fS|d k(r#tjd ||d}|d z }||fS|d k(r#tjd||d}|dz }||fS|dk(r#tjd||d}|dz }||fS|dk(r,ttjd||d}|dz }||fS|dk(r,ttjd||d}|dz }||fS|dk(r,ttjd||d}|dz }||fS|dk(r,ttjd||d}|dz }||fS|dk(rqtjd||d}|dz }tjd||d}|dz }t j |t j d| zz}||fS|dk(r#tjd ||d}|d z }||fS|dk(rBtjd||d}|dz }||||z} |j d }||z }||fS|d!k(r0tjd||d}|dz }||||z}||z }||fS|d"k(rUtjd||d}|dz }||z}g}||kr&t||\}}|j|||kr&||fS|d#k(r6tjtjd||d}|dz }||fS|d$k(rt||\}}||fS|d%k(rd&}||fStj|#t$rYwxYw)'a5Decode the value passed in returning the decoded value and the number of bytes read in addition to the starting offset. :param str encoded: The binary encoded data to decode :param int offset: The starting byte offset :rtype: tuple :raises: pika.exceptions.InvalidFieldTypeException r r5z>BrbBz>bUz>hr6uz>Hr:z>ir)ir(r7z>qr8z>Qfz>fdz>dr<r r;sr2r$r4r@r>r?rAN)rrrDrrGrHr%r&rZrrutcfromtimestampr]rInvalidFieldTypeException) r r!kindrrTrUr offset_endrWs rrZrZs< 6&1* %D aKF t|""4&9!<U ! Z &=U ""4&9!<! P &=K ""4&9!<! F &=A ""4&9!<! | &=w ""4&9!<! r &=m ""4&9!<! h &=c ""4&9!<! ^ &=Y V''gv>qAB! T &=O V''gv>qAB! J &=E V''gv>qAB! @ &={ V''gv>qAB! v &=q %%c7F;A>!   w7:! $(;hY(FGf &=_ ""4&9!<! Z &=U ##D'6:1=! v/ LL(E &D &=A ##D'6:1=! v/&8 &=3 ##D'6:1=! f_ z!&w7KC LL z!( &= ))   tWf 5a 8:!  &= &w7 &=  &=22488E"   sO O)(O))__doc__rrGrLrpikar pika.compatrrrrr rr"r0r+r]rZrrrpsL" '44> " *PFf(r