7g$ddZddlZddlmZddlmZddlmZmZm Z ddl m Z GddZ dS) z& Implementation of an SSH2 "message". N)BytesIO)util) zero_bytemax_byteone_byte)uceZdZdZdZd!dZdZdZdZdZ d Z d Z d Z d Z d ZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZ d Z!dS)"Messagea~ An SSH2 message is a stream of bytes that encodes some combination of strings, integers, bools, and infinite-precision integers. This class builds or breaks down such a byte stream. Normally you don't need to deal with anything this low-level, but it's exposed for people implementing custom extensions, or features that paramiko doesn't support yet. l~Nc\|t||_dSt|_dS)z Create a new SSH2 message. :param bytes content: the byte stream to use as the message content (passed in only when decomposing a message). N)rpacket)selfcontents J/var/www/html/syslog/venv/lib/python3.11/site-packages/paramiko/message.py__init__zMessage.__init__,s,  !'**DKKK!))DKKKc*|SN)asbytesr s r __bytes__zMessage.__bytes__9s||~~rcZdt|jzdzS)zP Returns a string representation of this object, for debugging. zparamiko.Message())reprr getvaluers r__repr__zMessage.__repr__<s*#T$+*>*>*@*@%A%AACGGrc4|jS)zO Return the byte stream content of this Message, as a `bytes`. )r rrs rrzMessage.asbytesCs{##%%%rc:|jddS)zk Rewind the message to the beginning as if no items had been parsed out of it yet. rN)r seekrs rrewindzMessage.rewindIs rc|j}|j}|j||S)zk Return the `bytes` of this message that haven't already been parsed and returned. )r tellreadr)r position remainders r get_remainderzMessage.get_remainderPsF ;##%%K$$&&  """rc|j}||j|S)z Returns the `bytes` of this message that have been parsed and returned. The string passed into a message's constructor can be regenerated by concatenating ``get_so_far`` and `get_remainder`. )r r!rr")r r#s r get_so_farzMessage.get_so_farZs: ;##%% {)))rc|j|}d}t||cxkr|kr nn|t|t|z zzS|S)a  Return the next ``n`` bytes of the message, without decomposing into an int, decoded string, etc. Just the raw bytes are returned. Returns a string of ``n`` zero bytes if there weren't ``n`` bytes remaining in the message. i)r r"lenr)r nb max_pad_sizes r get_byteszMessage.get_bytesdse K  Q   q66A $ $ $ $ $ $ $ $ $yAAJ// /rc,|dS)a  Return the next byte of the message, without decomposing it. This is equivalent to `get_bytes(1) `. :return: the next (`bytes`) byte of the message, or ``b''`` if there aren't any bytes remaining. )r-rs rget_bytezMessage.get_byteqs~~a   rcB|d}|tkS)z2 Fetch a boolean from the stream. r/)r-rr r+s r get_booleanzMessage.get_boolean|s NN1  I~rc|d}|tkr&tj|S||dz }t jd|dS)zZ Fetch an int from the stream. :return: a 32-bit unsigned `int`. r/>Ir)r-rr inflate_long get_binarystructunpack)r bytes rget_adaptive_intzMessage.get_adaptive_intsh ~~a   8  $T__%6%677 7 q!!!}T4((++rc^tjd|ddS)z/ Fetch an int from the stream. r6rr9r:r-rs rget_intzMessage.get_ints'}T4>>!#4#455a88rc^tjd|ddS)zj Fetch a 64-bit int from the stream. :return: a 64-bit unsigned integer (`int`). >Qrr?rs r get_int64zMessage.get_int64s' }T4>>!#4#455a88rcNtj|S)zr Fetch a long int (mpint) from the stream. :return: an arbitrary-length integer (`int`). )rr7r8rs r get_mpintzMessage.get_mpints  !2!2333rcP||S)z Fetch a "string" from the stream. This will actually be a `bytes` object, and may contain unprintable characters. (It's not unheard of for a string to contain another byte-stream message.) r-r@rs r get_stringzMessage.get_strings ~~dllnn---rcDt|S)z Fetch a Unicode string from the stream. This currently operates by attempting to encode the next "string" as ``utf-8``. )rrIrs rget_textzMessage.get_texts""###rcP||S)z@ Alias for `get_string` (obtains a bytestring). rHrs rr8zMessage.get_binarys~~dllnn---rcP|dS)z Fetch a list of `strings ` from the stream. These are trivially encoded as comma-separated values in a string. ,)rKsplitrs rget_listzMessage.get_lists }}$$S)))rc:|j||S)zj Write bytes to the stream, without any formatting. :param bytes b: bytes to add r writer2s r add_byteszMessage.add_bytes ! rc:|j||S)zq Write a single byte to the stream, without any formatting. :param bytes b: byte to add rRr2s radd_bytezMessage.add_byterUrc|r |jtn|jt|S)za Add a boolean value to the stream. :param bool b: boolean value to add )r rSrrr2s r add_booleanzMessage.add_booleans@  ) K  h ' ' ' ' K  i ( ( ( rc`|jtjd||SzU Add an integer to the stream. :param int n: integer to add r6r rSr9packr r*s radd_intzMessage.add_int+ &+dA../// rc|tjkrG|jt|t j|n-|jtj d||Sr[) r big_intr rSr add_stringr deflate_longr9r]r^s radd_adaptive_intzMessage.add_adaptive_intsn    K  h ' ' ' OOD-a00 1 1 1 1 K  fk$22 3 3 3 rc`|jtjd||S)zX Add a 64-bit int to the stream. :param int n: long int to add rBr\r^s r add_int64zMessage.add_int64r`rcT|tj||S)z Add a long int to the stream, encoded as an infinite-precision integer. This method only works on positive numbers. :param int z: long int to add )rcrrd)r zs r add_mpintzMessage.add_mpints& )!,,--- rctj|}|t||j||S)z[ Add a bytestring to the stream. :param byte s: bytestring to add )rrr_r)r rS)r ss rrczMessage.add_stringsD LOO SVV ! rcV|d||S)z Add a list of strings to the stream. They are encoded identically to a single string of values separated by commas. (Yes, really, that's how SSH2 does it.) :param l: list of strings to add rN)rcjoin)r ls radd_listzMessage.add_lists%  $$$ rc,t|tur||St|tr||St|t ur||S||Sr) typeboolrY isinstanceintrelistrprc)r is r_addz Message._add's~ 77d??##A&& & 3   &((++ + !WW__==## #??1%% %rc:|D]}||dS)a Add a sequence of items to the stream. The values are encoded based on their type: bytes, str, int, bool, or list. .. warning:: Longs are encoded non-deterministically. Don't use this method. :param seq: the sequence of items N)rx)r seqitems raddz Message.add3s.  D IIdOOOO  rr)"__name__ __module__ __qualname____doc__rbrrrrrr%r'r-r0r3r<r@rDrFrIrKr8rPrTrWrYr_rergrjrcrprxr|rrr r sG $ $ $ $HHH&&& ***    ! ! ! , , ,999 999444...$$$... ***            &&&     rr ) rr9iorparamikorparamiko.commonrrr paramiko.utilrr rrrrs& 9999999999__________r