/usr/lib/python3/dist-packages/twisted/spread/__pycache__
Edit: /usr/lib/python3/dist-packages/twisted/spread/__pycache__/banana.cpython-310.pyc (9382B)
o
b/ @ s d Z ddlZddlZddlmZ ddlmZ ddlmZ ddl m
Z
ddl m Z ddl
mZ G d d
d
eZd d Zd
d ZdZdZdZdZdZdZdZdZdZdd Z da e d dZ G dd d ej ej Z!e! Z"e"# e"$d d d Z%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 e Zd ZdS ) BananaErrorN)__name__
__module__ __qualname__ r r 7/usr/lib/python3/dist-packages/twisted/spread/banana.pyr s r c C sN | dkr
|d d S | dksJ d| r%|t | d@ f | d? } | sd S d S )Nr z!can only encode positive integers )bytes)integerstreamr r r
int2b128 s r c C s6 d}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}
r r )r ord)steicharnr r r
b1282int) s
r c C s | a dS )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
setPrefixLimitK s
r' @ i
c @ s( e Zd ZdZddgZdZeZdd Zdd Z d d
Z
d d Z d
d Z dd Z
dZdd Zdd Zi ddddddd d d d d d!d"d#d$d%d&d'd(d)d*d+d,d-d.d/d0d1d2d3d4d5d6d7d8d9d:d;d
d?d@dAdBdCdDdEdFZi Ze D ]\ZZeee< q|dMdGdHZdIdJ ZdKdL ZdS )NBananaz
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}
pb noneNc C s< || _ d|d d | _d| _d| _d|d d | _dS )zt
Set the prefix limit for decoding done by this protocol instance.
@see: L{setPrefixLimit}
r r i iN) prefixLimit_smallestLongInt _smallestInt _largestInt_largestLongInt)selfr& r r r
r' r s
zBanana.setPrefixLimitc C s dS )zPSurrogate for connectionMade
Called after protocol negotiation.
Nr r2 r r r
connectionReady~ s zBanana.connectionReadyc C s || _ | d S N)currentDialectr4 )r2 dialectr r r
_selectDialect s zBanana._selectDialectc C s | j r
| | d S | jr0|D ]}|| jv r#| | | | d S qtd | j d S || jv r<| | d S td | j d S )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.)
r6 expressionReceivedisClient
knownDialects sendEncodedr8 r msg transportloseConnection)r2 obj serverVerr r r
callExpressionReceived s&
z Banana.callExpressionReceivedc C s* | t d | _| js| | j d S d S r5 )r' r% r6 r: r< r; r3 r r r
connectionMade s
zBanana.connectionMadec C s. | j }|r|d d | d S | | d S )Nr ) listStackappendrB )r2 itemlr r r
gotItem s zBanana.gotItem c C s | j | }| j}| j}|re| j |ks J dt| j t||| _ d}t|D ] }|tkr1 n|d }q)|| jkrCtd| jf d S |d | }|||d }||d d } t || jkrjtd| jf |t
krt |}|t krztd|
|g f | }n|tkrt |}|t krtdt | |kr| |d }|| d | nd S |tkr| }t |}|| n{|tkr| }t |}|| nl|tkr| }t |}|| n\|tkr| }t | }|| nL|tkr | }t |}| j| }
| jdkr||
n1td |
|tkr.t | d
kr,| d
d }|td | d d
d n d S td ||rct |d
d |d
d krc| d }
||
|rct |d
d |d
d ksG|sd| _ d S )NzThis ain't right: {} {}r r z1Security 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.r* z Invalid item for pb protocol !dzInvalid Type Byte rD rJ )bufferrE rI formatreprr HIGH_BIT_SETr- r lenLISTr
SIZE_LIMITrF STRINGINTLONGINTLONGNEGNEGVOCABincomingVocabularyr6 NotImplementedErrorFLOATstructunpackpop) r2 chunkrM rE rI poschnumtypebyterestrG r r r
dataReceived s
$ $
MzBanana.dataReceivedc C s t )z=Called when an expression (list, string, or int) is received.)r[ )r2 lstr r r
r9 s zBanana.expressionReceiveds Noner s classr, s dereference s reference s
dictionary s function s instancer s listrK s module s
persistent
s tuple s
unpersistable s copy
s cache s cached s remote s local )s lcaches versions logins passwords challenges logged_ins
not_logged_ins cachemessages messages answers errors decrefs decaches uncachec C s$ g | _ t| j| _d| _|| _d S )Nr )rE copyoutgoingVocabularyoutgoingSymbolsoutgoingSymbolCountr: )r2 r: r r r
__init__4 s
zBanana.__init__c C s, t }| ||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 _encodewritegetvaluer> )r2 r@ encodeStreamvaluer r r
r< : s zBanana.sendEncodedc C s t |ttfr.t|tkrtdt|f tt|| |t |D ]}| || q#d S t |t r|| j
k s=|| j krDtd|f || j k rUt| | |t
d S |dk ret| | |t d S || jkrut|| |t d S t|| |t d S t |tr|t |td| d S t |tr| jdkr|| jv r| j| }t|| |t d S t|tkrtdt|f tt|| |t || d S tdt t ||)Nz#list/tuple is too long to send (%d)z int is too large to send (%d)r rL r* z$byte string is too long to send (%d)z#Banana cannot send {} objects: {!r})
isinstancelisttuplerQ rS r r rR r intr. r1 r/ rW rX r0 rU rV floatr\ r] packr r6 r rY rT rN r type)r2 r@ r elemsymbolIDr r r
r J sT
zBanana._encode)r )r r
r __doc__r; r- rS sizeLimitr' r4 r8 rB rC rI rM rf r9 r rZ itemskvr r< r r r r r
r) a s S
%
r) r+ c C s t }|t_t| | S )zEncode a list s-expression.)r _ir> r< r )rg r r r r
encode s
r c C s8 g }|j t_zt| W dt_t`|d S dt_t`w )z)
Decode a banana-encoded string.
rJ r )rF r r9 rf rM )r rH r r r
decode s r )'r r r] ior twisted.internetr twisted.persistedr twisted.pythonr twisted.python.compatr twisted.python.reflectr Exceptionr r r rR rU rT rX r\ rV rW rY rP r' r% rS Protocol Ephemeralr) r rC r8 r r r r r r
sB