\d/vdZddlZddlZddlmZddlmZddlmZddl m Z ddl m Z ddl mZGd d eZd Zd Zd ZdZdZdZdZdZdZdZd ZdZdaeddZGddejej Z!e!Z"e"#e"$ddZ%dZ&dS)z Banana -- s-exp based protocol. Future Plans: This module is almost entirely stable. The same caveat applies to it as applies to L{twisted.spread.jelly}, however. Read its future plans for more details. @author: Glyph Lefkowitz N)BytesIO)protocol)styles)log) iterbytes)fullyQualifiedNameceZdZdS) BananaErrorN)__name__ __module__ __qualname__5lib/python3.11/site-packages/twisted/spread/banana.pyr r sDrr c|dkr |ddS|dks Jd|r%|t|dzf|dz }|#dSdS)Nrz!can only encode positive integers)bytes)integerstreams rint2b128rs!||u  Q;;;;;;; ugn&''(((Q, rcjd}d}t|D]}t|}|||zz }|dz}|S)z Convert an integer represented as a base 128 string into an L{int}. @param st: The integer encoded in a byte string. @type st: L{bytes} @return: The integer value extracted from the byte string. @rtype: L{int} rr)rord)steicharns rb1282intr!)sK A A"  II QU  a Hrc |adS)ak Set the limit on the prefix length for all Banana connections established after this call. The prefix length limit determines how many bytes of prefix a banana decoder will allow before rejecting a potential object as too large. @type limit: L{int} @param limit: The number of bytes of prefix for banana to allow when decoding. N) _PREFIX_LIMIT)limits rsetPrefixLimitr-Ks MMMr@i c8eZdZdZddgZdZeZdZdZ dZ dZ d Z d Z d Zd Zd Ziddddddddddddddddddd d!d"d#d$d%d&d'd(d)d*d+d,d-d.d/d0d1d2d3d4d5d6d7d8d9d:d;dZiZeD] \ZZeee< dBd?Zd@ZdAZdS)CBananaz L{Banana} implements the I{Banana} s-expression protocol, client and server. @ivar knownDialects: These are the profiles supported by this Banana implementation. @type knownDialects: L{list} of L{bytes} pbnoneNcr||_d|dzz dz|_d|_d|_d|dzzdz |_dS)zt Set the prefix limit for decoding done by this protocol instance. @see: L{setPrefixLimit} rriiN) prefixLimit_smallestLongInt _smallestInt _largestInt_largestLongInt)selfr,s rr-zBanana.setPrefixLimitrsQ !"# "2 3a 7&& UQY/!3rcdS)zPSurrogate for connectionMade Called after protocol negotiation. Nrr:s rconnectionReadyzBanana.connectionReady~src<||_|dSN)currentDialectr=)r:dialects r_selectDialectzBanana._selectDialects"% rc|jr||dS|jrj|D]8}||jvr-||||dS9t jd|j dS||jvr||dSt jd|j dS)NzSThe client doesn't speak any of the protocols offered by the server: disconnecting.zYThe client selected a protocol the server didn't suggest and doesn't know: disconnecting.) r@expressionReceivedisClient knownDialects sendEncodedrBrmsg transportloseConnection)r:obj serverVers rcallExpressionReceivedzBanana.callExpressionReceiveds   4  # #C ( ( ( ( (} 4!$ 4 4I D$666((333++I6667 G@N1133333$,,,'',,,,,GCN1133333rc|td|_|js||jdSdSr?)r-r+r@rErGrFr<s rconnectionMadezBanana.connectionMadesO M***"} 1   T/ 0 0 0 0 0 1 1rc|j}|r#|dd|dS||dS)Nr) listStackappendrM)r:itemls rgotItemzBanana.gotItemsK N  . bE!HOOD ! ! ! ! !  ' ' - - - - -rrcV|j|z}|j}|j}|r|j|ks=Jdt |jt |||_d}t |D]}|t krn+|dz}||jkrtd|jfzdS|d|}|||dz}||dzd} t||jkrtd|jfz|tkrDt|}|tkrtd| |gf| }n|tkr]t|}|tkrtdt| |kr| |d}|| d|nadS|tkr| }t|}||n6|t kr| }t|}||n |t"kr| }t|}|| n|t$kr| }t| }||n|t&krG| }t|}|j|} |jdkr || n{t-d | |t.krLt| d kr7| d d}|t1jd | dd dndSt-d ||r}t|d d|d dkrR|d} || |r+t|d d|d dkR|d|_dS)NzThis ain't right: {} {}rrz1Security precaution: more than %d bytes of prefixz9Security precaution: longer than %d bytes worth of prefixz#Security precaution: List too long.z%Security precaution: String too long.r1zInvalid item for pb protocol !dzInvalid Type Byte rQr)bufferrRrVformatreprr HIGH_BIT_SETr5r lenLISTr! SIZE_LIMITrSSTRINGINTLONGINTLONGNEGNEGVOCABincomingVocabularyr@NotImplementedErrorFLOATstructunpackpop) r:chunkrZrRrVposchnumtypebyterestrTs r dataReceivedzBanana.dataReceiveds u$N ,L ;&(((*C*J*JT[!!V ++(((!DKC''  %%EAg)))%K+-.#,CcC!Gm,H#'))$D3xx$***!O')*4smm##%&KLLL  #r+++V##smm##%&MNNNt99##!#$$ZFGD#J''''FSsmm W$$smm W$$smm S}}n U""smm.s3&%//GDMMMM-.Vd.V.VWWWU""t99>>!!""XFGFM$RaR99!<====F)*Kx*K*KLLL Yr]1%5!6!6)B-:J!J!J }}q)  Yr]1%5!6!6)B-:J!J!JUL Z rct)z=Called when an expression (list, string, or int) is received.)rh)r:lsts rrDzBanana.expressionReceiveds!###rsNonersclassr4s dereferences references dictionarysfunctionsinstancerslistrXsmodule s persistent stuple s unpersistable scopy scachescachedsremoteslocal)slcachesversionsloginspasswords challenges logged_ins not_logged_ins cachemessagesmessagesanswerserrorsdecrefsdecachesuncacheclg|_tj|j|_d|_||_dS)Nr)rRcopyoutgoingVocabularyoutgoingSymbolsoutgoingSymbolCountrE)r:rEs r__init__zBanana.__init__4s1#y)@AA#$   rct}|||j|}|j|dS)a  Send the encoded representation of the given object: @param obj: An object to encode and send. @raise BananaError: If the given object is not an instance of one of the types supported by Banana. @return: L{None} N)r_encodewritegetvaluerI)r:rK encodeStreamvalues rrGzBanana.sendEncoded:sQyy  S,,---%%'' U#####rc t|ttfrt|tkr t dt|fzt t|||t|D]}|||dSt|tr||j ks ||j krt d|fz||j kr#t | ||tdS|dkr#t | ||tdS||jkr"t |||t dSt |||t"dSt|t$r0|t&|t)jd|dSt|t,r|jdkr8||jvr/|j|}t |||t2dSt|tkr t dt|fzt t|||t4||dSt dt9t;||)Nz#list/tuple is too long to send (%d)zint is too large to send (%d)rrYr1z$byte string is too long to send (%d)z#Banana cannot send {} objects: {!r}) isinstancelisttupler^r`r rr_rintr6r9r7rdrer8rbrcfloatrirjpackrr@rrfrar[rtype)r:rKrelemsymbolIDs rrzBanana._encodeJs cD%= ) ), 3xx*$$!"G3s88+"UVVV SXXu % % % E$KKK * * T5)))) * * S ! !% T***cD4H.H.H!"ASF"JKKKT&&&#u%%%gq#u%%%c (((e$$$c e$$$g U # #  E%LLL E&+dC(( ) ) ) ) ) U # # "e++t7K0K0K/45)))e s88j((%>#c((LS5)))f c 5<<&tCyy113 r)r)r r r __doc__rFr5r` sizeLimitr-r=rBrMrOrVrZrsrDrrgitemskvrrGrrrrr0r0as-G$MKI 4 4 4   444<111 ...FQQQf$$$## !#  # a # q # Q# Q# # 1# r# "# "# # "!#" 2##$ 2%#& "'#(E###J"((**""1 !1!!!! $$$ -----rr0r2ct}|t_t||S)zEncode a list s-expression.)r_irIrGr)rurs rencoders699LBLNN3  " ""rcg}|jt_ t|dt_t`n#dt_t`wxYw|dS)z) Decode a banana-encoded string. rr)rSrrDrsrZ)rrUs rdecoders_ AHB"   ! !  !!!!! Q4Ks AA)'rrrjiortwisted.internetrtwisted.persistedrtwisted.pythonrtwisted.python.compatrtwisted.python.reflectr Exceptionr rr!r_rbrarerircrdrfr]r-r+r`Protocol Ephemeralr0rrOrBrrrrrrs  %%%%%%$$$$$$++++++555555     )      (           r  VVVVVX  0VVVt VXX'###     r