D>g < G d de Z G d d ZdS )c 0 e Zd ZdZd Zd Zd Zd Zd ZdS )
LineBufferz
Allows to accumulate data, and than iterate over it getting tokens
split by line breaks '
'. If at the end there is no line break,
the data will sit in the line buffer until more data with line
break comes in.
c d| _ d S N bufselfs Q/opt/imunify360/venv/lib/python3.11/site-packages/defence360agent/utils/buffer.py__init__zLineBuffer.__init__
c & | xj |z
c_ d S Nr r
datas r appendzLineBuffer.append s Dr c | S r r s r __iter__zLineBuffer.__iter__ r c | j d }|dk r(| j d| }| j |dz d | _ |S t )N
)r find
StopIteration)r
posresults r __next__zLineBuffer.__next__ sN hmmD!! "99Xae_Fxa *DHMr c d| _ d S r r r s r cleanzLineBuffer.clean r
r N) __name__
__module__ __qualname____doc__r r r r! r# r r r r r si r r c ( e Zd ZddZd Zd Zd ZdS )
SizeBuffer c " d| _ || _ d S )Nr )_buf _size_len)r
size_lens r r zSizeBuffer.__init__ s !r c & | xj |z
c_ d S r )r, r s r r zSizeBuffer.append# s T r c | S r r r s r r zSizeBuffer.__iter__& r r c D | j st t | j d | j d }t | j | j d |k r:| j | j | j |z }| j | j |z d | _ |S t )Nbig)r, r int
from_bytesr- len)r
sizer s r r! zSizeBuffer.__next__) s y ~~di(8$.(8 95AA ty ))* + +t 3 39T^dnt.C CDD $.4"7"9"9:DIKr N)r* )r$ r% r& r r r r! r r r r) r) sU " " " " r r) N)objectr r) r r r r8 sa : r