U Tg/@sdZddlZddlZddlmZddlmZddlmZddl m Z ddl m Z ddl mZGd d d eZd d Zd dZdZdZdZdZdZdZdZdZdZddZdaeddZGdddejej Z!e!Z"e"#e"$dddZ%d d!Z&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)fullyQualifiedNamec@s eZdZdS) BananaErrorN)__name__ __module__ __qualname__r r 9/tmp/pip-unpacked-wheel-1_7di8ic/twisted/spread/banana.pyrsrcCsH|dkr|ddS|dks$td|rD|t|d@f|d?}q$dS)Nrz!can only encode positive integers)AssertionErrorbytes)integerstreamr r r int2b128srcCs6d}d}t|D] }t|}|||7}|dK}q|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)steicharnr r r b1282int)s    rcCs|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)limitr r r setPrefixLimitKs r(@i c @seZdZdZddgZdZeZddZddZ d d Z d d Z d dZ ddZ dZddZddZddddddddddd d!d"d#d$d%d&d'd(d)d*d+d,d-d.d/d0d1d2d3d4d5ZiZeD]\ZZeee<qdt|tkrtdt|ftt|||t||ntdtt||dS)Nz#list/tuple is too long to send (%d)zint is too large to send (%d)rrKr+z$byte string is too long to send (%d)z#Banana cannot send {} objects: {!r}) isinstancelisttuplerPrRrrrQrintr/r2r0rVrWr1rTrUfloatr[r\packrr7rrXrSrMrtype)r3r@relemZsymbolIDr r r rJsT                    zBanana._encode)r)r r r __doc__r<r.rRZ sizeLimitr(r5r9rArBrHrLrdr:rrYitemskvrr=rr r r r r*asf  S%  r*r,cCst}|t_t||S)zEncode a list s-expression.)r_ir?r=r)rerr r r encodes rcCs0g}|jt_zt|W5dt_t`X|dS)z) Decode a banana-encoded string. rIr)rErr:rLrd)rrGr r r decodesr)'rrr\iorZtwisted.internetrZtwisted.persistedrZtwisted.pythonrZtwisted.python.compatrZtwisted.python.reflectr ExceptionrrrrQrTrSrWr[rUrVrXrOr(r&rRProtocolZ Ephemeralr*rrBr9rrr r r r s@