^jEdZddlZddlmZddlmZddlmZddlmZddlm Z m Z dd l m Z dd l mZdd lmZdd lmZd ZdZdZdZdZdZdZdZdZdZdZej<eiZGddZ y)zeConvert between bytestreams and higher-level AMQP types. 2007-11-05 Barry Pederson N)datetime)timezone)Decimal)BytesIO)pack unpack_from)FrameSyntaxError)Basic) bytes_to_str) str_to_bytesz* Table type {0!r} not handled by amqp. zCTable type {0!r} for key {1!r} not handled by amqp. [value: {2!r}] z9 Table type {0!r} not handled by amqp. [value: {1!r}] ct||}|dz }|dk(r/td||\}|dz } t||||z}||z }||fS|dk(rtd||\}|dz }||fS|dk(r%td||\}|dz }||||z}||z }||fS|d k(rtd ||\}|dz }||fS|d k(rtd ||\}|dz }||fS|d k(rtd||\}|dz }||fS|dk(rtd||\}|dz }||fS|dk(rtd||\}|dz }||fS|dk(rtd||\}|dz }||fS|dk(rtd||\}|dz }||fS|dk(rtd||\}|dz }||fS|dk(rtd||\}|dz }||fS|dk(rtd||\}|dz }||fS|dk(rFtd ||\}|dz }td||\}|dz }t |t d|zz }||fS|dk(rftd||\}|dz }||z} i}|| krBtd ||\} |dz }t|||| z} || z }t ||\|| <}|| krB||fS|dk(rJtd||\} |dz }|| z} g}|| kr&t ||\} }|j | || kr&||fS|dk(r#td ||\}t|}|dz }||fS|d k(rMtd!||\}|dz }tj|tj"jd#}||fS|d$k(rd}||fStd%j|t|#t$r ||||z}Y4wxYw)&Nr S>Isz>hxbz>bB>BUu>HIz>iiLz>qlf>fdz>dD FAtT>QtztzinfoVz#Unknown value in table: {!r} ({!r}))chrrpstr_tUnicodeDecodeErrorr _read_itemappendboolr fromtimestamprutcreplacer formattype)bufoffsetftypeslenvalblenr"ntlenlimitkeylenkeyalenvs T/var/www/html/metafoliadorv2/venv/lib/python3.12/site-packages/amqp/serialization.pyr2r2!s F E aKF |D#v.!  ,VFTM23C $J ;C #4f-! ~ ;{ #D#v.! &$'$r ;o #4f-! j ;g #4f-! b ;_ #4f-! Z ;W #4f-! R ;O #4f-! J ;G #4f-! B ;} #4f-! x ;q #4f-! l ;i #4f-! d ;a #4f-! \ ;Y # sF +!  sF +! aj727++N ;K #D#v.!  un!$V4GF aKFVFVO45C f F)#v6 CHf un@ ;3 #D#v.!  un"3/IAv JJqMun( ;! #4f-3i!  ; #4f-! $$SX\\:BB$BO ; # ; 1 8 8tE{ $% %K" ,fVd]+C ,sMM43M4cdx}}g}|j}t|}|D]}|dk(r.|st|||dz}|dz }d}|dzdk(}|dz}|dz}ni|dk(rdx}}td||\}|dz }nJ|dk(rdx}}td||\}|d z }n+|d k(rdx}}td ||\}|d z }n |d k(rdx}}td||\}|dz }n|dk(rdx}}td||\}|d z }n|dk(r7dx}}td||\} |dz }|||| zj dd}|| z }n|dk(r7dx}}td ||\} |d z }|||| zj dd}|| z }nV|dk(r#td ||\} |d z }|||| z}|| z }n.|dk(rhdx}}td ||\} |d z }|| z} i}|| krtd||\} |dz }t|||| z}|| z }t ||\||<}|| krBn|dk(rKdx}}td ||\}|d z }||z} g}|| krt ||\}}|j||| kr&nq|dk(rNdx}}td||\}|dz }t j|tjjd}nttj|||||fS)zDeserialize amqp format. bit = b octet = o short = B long = l long long = L float = f shortstr = s longstr = S table = F array = A timestamp = T rrr rorrrrrrrrr)r r!rutf-8 surrogatepassrrr%r&r(r*Nr,)r3r0ordrdecoder2rr5rr6r7r ILLEGAL_TABLE_TYPEr8)r8r:r;bitcountbitsvaluesr3pr>r=r?rArBrCrDrEavals rGloadsrTsHt F ]]F F^F K 83vfqj12! !8/C QJD MH #X HttS&1DC aKF #X HttS&1DC aKF #X HttS&1DC aKF #X HttS&1DC aKF #X HttS&1DC aKF #X HtS&1ED aKFfVd]+227OLC dNF #X Htc62ED aKFfVd]+227OLC dNF #Xc62ED aKFfVd]+C dNF #X Htc62ED aKFTMEC5.%dC8! S89& #-c6#: C& 5. #X Htc62ED aKFTMEC5.)#v6 f 4 5.#X HttS&1DC aKF((>FFGC##5#<#cN|r#|tdt|zg|g|ddy)Nrr)rlen)rPwrites rG _flushbitsrYs+  d3T?*T*+Q rUc Dd}g}t}|j}t|}t|D]Q\}}||}|dk(r7|rdnd}|dz} | dk(r|j d|dxx|| zzcc<|dz }H|dk(rt ||}|t d|l|dk(r(t ||}|t dt||d k(rt ||}|t d ||d k(rt ||}|t d ||d k(r t ||}|t d||dk(rY|xsd}t ||}t|tr|jdd}|t dt|||d|dk(s|dk(rY|xsd}t ||}t|tr|jdd}|t d t||||dk(rt ||}t|xsi|||dk(rt ||}t|xsg|||dk(s|t d ttj|j!Tt |||j#S)zSerialize AMQP arguments. Notes: bit = b octet = o short = B long = l long long = L shortstr = s longstr = S byte array = x table = F array = A rrr rrIrrrrrr)r r!rrJrKrrr%r&r()rrXr0 enumerater3rYrint isinstancestrencoderW _write_table _write_arraycalendartimegm utctimetuplegetvalue) r8rQrOrPoutrXrr>rRshifts rGdumpsrjsmH D )C IIE F^FF#-H3 1I 8!CqLEz A H &H MH #X!$.H $sC. ! #X!$.H $tSX& ' #X!$.H $tS/ " #X!$.H $tS/ " #X!$.H $tS/ " #X)C!$.H#s#jj/: $sCH% & #J #Xc)C!$.H#s#jj/: $tSX& ' #J #X!$.H E4 0 #X!$.H E4 0 #X $tS1A1A1C!DEF G[-H\tU <<>rUc t}|j}|jD]X\}}t|tr|j dd}|t dt||| t|||Z|j}|t dt|||y#t$r*ttjt|||wxYw)NrJrKrr)rrXitemsr_r`rarrW _write_item ValueErrorr ILLEGAL_TABLE_TYPE_WITH_KEYr8r9rg)r"rXrPrhtwritekrF table_datas rGrbrbJs )C YYF C1 a /2AtCQ !q  C 64 ( CJ $tS_ %& *  C"+2247AqAC C Cs 3 B663C)c *t}|j}|D]} t||||j}|tdt|||y#t$r)t t j t||wxYw)Nr) rrXrmrnr ILLEGAL_TABLE_TYPE_WITH_VALUEr8r9rgrrW)list_rXrPrhawriterF array_datas rGrcrc\s )C YYF B B 64 (B J $tS_ %& *  B"-44T!Wa@B B Bs A  2Bc t|ttfrGt|tr|jdd}|t ddt |||yt|t r|t ddt|yt|tr|t dd|yt|tr2|d kDs|d kr|t d d |y|t d d|yt|tr@|j\}}}d}|D] }|dz|z} |r| }|t dd| |yt|tr>|t ddttj|jyt|tr|dt!|||yt|t"t$fr|dt'|||y| |dyt))NrJrKz>cISz>cBtz>cddiiz>cqLz>ciIrr$z>cBiDz>cQTFAV)r_r`bytesrarrWr4r^floatras_tuplerrdrerfdictrblisttuplercrn)rFrXrPsigndigitsexponentr"s rGrmrmjs!c5\" a /2A d5$A'( a At  d5$A'( Au  d5$"# As  z>Q_ $udA& ' $udA& ' Aw !"fh  AR1 A  A d64(A./ Ax  c(//!..2B"CD E G At  d Qt$ Ae} % d Qt$  d lrUci}td||\}|dz }|dzr-td||\}|dz }t||||z|d<||z }|dzr-td||\}|dz }t||||z|d<||z }|d zrtd ||\}}|\|d <|d zrtd||\|d <|dz }|dzrtd||\|d<|dz }|dzr-td||\}|dz }t||||z|d<||z }|dzr-td||\}|dz }t||||z|d<||z }|dzr-td||\}|dz }t||||z|d<||z }|dzr-td||\}|dz }t||||z|d<||z }|dzrtd||\|d<|dz }|dzr-td||\}|dz }t||||z|d<||z }|dzr-td||\}|dz }t||||z|d<||z }|dzr-td||\}|dz }t||||z|d <||z }|d!zr-td||\}|dz }t||||z|d"<||z }||fS)#zDecode basic properties.rrirr content_typei@content_encodingi r%application_headersi delivery_modeipriorityicorrelation_idireply_to expiration message_id@r) timestampr r9user_idapp_idr cluster_id)rr0rT)r:r; propertiesflagsr=_fs rGdecode_properties_basicrsdJ sF +FE aKF v~D#v.! %+Cv},E%F >"$ v~D#v.! )/F6D=0I)J %&$ v~3V, F-/* () v~'24f'E$ ?#!  v~"-dC"@ :!  v~D#v.! '-c&$.G'H #$$ v~D#v.! !'F6D=(A!B :$ v~D#v.! #)#fVd]*C#D < $ v~D#v.! #)#fVd]*C#D < $ v~#.tS&#A ;!  v~D#v.! #Cv}$=> 6$ v~D#v.!  &s6&4-'@ A 9$ v~D#v.! %c&$&?@ 8$ v~D#v.! #)#fVd]*C#D < $ v rUcFeZdZdZdZdgZd dZdZdZdZ dZ d d Z d Z y) GenericContentzdAbstract base class for AMQP content. Subclasses should override the PROPERTIES attribute. N)dummyrc f||_||_||_g|_d|_d|_d|_y)NrF) frame_method frame_argsr_pending_chunks body_received body_sizeready)selfrrpropss rG__init__zGenericContent.__init__s6($! rU) rrrrrrr__dict__ __weakref__cr|dk(r td||jvr|j|St|)N __setstate__)AttributeErrorr)rnames rG __getattr__zGenericContent.__getattr__s= > ! 0 0 4?? "??4( (T""rUc8t|||\}}||_|S)zLoad AMQP properties. Given the raw bytes containing the property-flags and property-list from a content-frame-header, parse and insert into a dictionary stored in this object as an attribute named 'properties'. )PROPERTY_CLASSESr)rclass_idr:r;rs rG_load_propertieszGenericContent._load_propertiess%)23? v rUcd}d}g}gg}}|j}|jD]p\}}|j|d} | R|dk(r|j|d}d}|d|zz}|dk7r+|jt ||j| |dz}r|j|t } | j } |D]}| td|| tdj||| jS)zSerialize AMQP properties. Serialize the 'properties' attribute (a dictionary) into the raw bytes making up a set of property flags and a property list, suitable for putting into a content frame header. rNr bitrrU) r PROPERTIESgetr3r rrXrrjjoinrg) rri flag_bitsrsformatsvaluesrrDproptyper>resultrXs rG_serialize_propertiesz$GenericContent._serialize_propertiess  r!__ MC))C&CA:LL+ !IEa5j) u$NN<#9:NN3' QJE   Y  )I $tY' ( ) eCHHW%w/0  rUctd||\}|_|dz }|j||||jsd|_|S)Nz>HxxQ T)rrrr)rr:r;rs rGinbound_headerzGenericContent.inbound_header7sE#.wV#D $."  hV4~~DJ rUcF|j}|xjt|z c_|j|jk\rM|r<|j |t j ||_g|ddd|_y||_d|_y|j |y)NT) rrrWrr3rrbodyr)rr:chunkss rG inbound_bodyzGenericContent.inbound_body?s%% c#h&    / c"!GLL0 q DJ  DJ MM# rU)NN)r) __name__ __module__ __qualname____doc__CLASS_IDrr __slots__rrrrrrUrGrrs< H !J  I # !!F rUr)!rrdrrdecimalriorstructrr exceptionsr specr utilsr r0r rNrortr2rTrYrjrbrcrmrrrrrrUrGrs$()! rjaH FR$ #LER NN+ nnrU