oh$\dZddlZddlmZddlmZddlmZmZm Z ddl m Z GddZ y) 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!y)"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~NcH|t||_yt|_y)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 b/var/www/pru.catia.catastroantioquia-mas.com/tasa/lib/python3.12/site-packages/paramiko/message.py__init__zMessage.__init__,s  !'*DK!)DKc"|jSN)asbytesr s r __bytes__zMessage.__bytes__9s||~rcTdt|jjzdzS)zP Returns a string representation of this object, for debugging. zparamiko.Message())reprr getvaluers r__repr__zMessage.__repr__<s&#T$++*>*>*@%AACGGrc6|jjS)zO Return the byte stream content of this Message, as a `bytes`. )r rrs rrzMessage.asbytesCs{{##%%rc:|jjdy)zk Rewind the message to the beginning as if no items had been parsed out of it yet. rN)r seekrs rrewindzMessage.rewindIs rc|jj}|jj}|jj||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_remainderPs@ ;;##%KK$$&  "rc|jj}|j|jj|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_farZs4 ;;##% {{))rc|jj|}d}t||cxkr|krn|S|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_bytesdsR KK  Q  q6A $ $yAAJ// /rc$|jdS)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  rc6|jd}|tk7S)z2 Fetch a boolean from the stream. r/)r-rr r+s r get_booleanzMessage.get_boolean|s NN1 I~rc|jd}|tk(r#tj|j S||jdz }t j d|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_ints[ ~~a  8 $$T__%67 7 q!!}}T4(++rcRtjd|jddS)z/ Fetch an int from the stream. r6rr9r:r-rs rget_intzMessage.get_ints#}}T4>>!#45a88rcRtjd|jddS)zj Fetch a 64-bit int from the stream. :return: a 64-bit unsigned integer (`int`). >Qrr?rs r get_int64zMessage.get_int64s# }}T4>>!#45a88rcHtj|jS)zr Fetch a long int (mpint) from the stream. :return: an arbitrary-length integer (`int`). )rr7r8rs r get_mpintzMessage.get_mpints   !233rc@|j|jS)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 ~~dlln--rc4t|jS)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"##rc@|j|jS)z@ Alias for `get_string` (obtains a bytestring). rHrs rr8zMessage.get_binarys~~dlln--rc@|jjdS)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<|jj||S)zj Write bytes to the stream, without any formatting. :param bytes b: bytes to add r writer2s r add_byteszMessage.add_bytes ! rc<|jj||S)zq Write a single byte to the stream, without any formatting. :param bytes b: byte to add rRr2s radd_bytezMessage.add_byterUrc|r!|jjt|S|jjt|S)za Add a boolean value to the stream. :param bool b: boolean value to add )r rSrrr2s r add_booleanzMessage.add_booleans9 KK  h '  KK  i ( rcd|jjtjd||SzU Add an integer to the stream. :param int n: integer to add r6r rSr9packr r*s radd_intzMessage.add_int& &++dA./ rc|tjk\rE|jjt|j t j||S|jjtjd||Sr[) r big_intr rSr add_stringr deflate_longr9r]r^s radd_adaptive_intzMessage.add_adaptive_intsd   KK  h ' OOD--a0 1  KK  fkk$2 3 rcd|jjtjd||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`rcN|jtj||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|}|jt||jj ||S)z[ Add a bytestring to the stream. :param byte s: bytestring to add )rrr_r)r rS)r ss rrczMessage.add_strings8 LLO SV ! rcF|jdj||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  $ rct|tur|j|St|tr|j |St|t ur|j|S|j|Sr) typeboolrY isinstanceintrelistrprc)r is r_addz Message._add'sb 7d?##A& & 3 ((+ + !W_==# #??1% %rc4|D]}|j|y)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 IIdO rr)"__name__ __module__ __qualname____doc__rbrrrrrr%r'r-r0r3r<r@rDrFrIrKr8rPrTrWrYr_rergrjrcrprxr|rrr r sG $H& *  ! ,9 94.$. *    & rr ) rr9iorparamikorparamiko.commonrrr paramiko.utilrr rrrrs*&99__r