@i dZddlZddlZddlmZddlmZmZmZm Z m Z m Z  ddl Z dZ ddlZdZddlmZmZmZmZdd lmZmZmZmZmZmZdd lm Z m!Z!dd l"m"Z"dd l#m$Z$m%Z%m&Z&m'Z'm(Z(dd l)m*Z*ddl+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5ddl6m7Z7m8Z8m9Z9m:Z:m;Z;mZ>dZ?GddZ@GddZAGddZBGddZCy#e$rdZYwxYw#e$rdZYwxYw)z3Implementation of the X protocol for MySQL servers.N)BytesIO)AnyDictListOptionalTupleUnionTF)InterfaceErrorNotSupportedErrorOperationalErrorProgrammingError) ExprParserbuild_bool_scalar build_exprbuild_int_scalar build_scalarbuild_unsigned_int_scalar)encode_to_bytesget_item_or_attr)logger)CRUD_PREPARE_MAPPINGPROTOBUF_REPEATED_TYPESSERVER_MESSAGESMessage mysqlxpb_enum)Column) AddStatementDeleteStatementFilterableStatement FindStatementInsertStatementModifyStatement ReadStatementRemoveStatement SqlStatementUpdateStatement) ColumnType MessageTypeProtobufMessageCextTypeProtobufMessageTypeResultBaseType SocketType StatementType StrOrBytesic@eZdZdZdeddfdZdedefdZdedefdZ y) CompressorzImplements compression/decompression using `zstd_stream`, `lz4_message` and `deflate_stream` algorithms. Args: algorithm (str): Compression algorithm. .. versionadded:: 8.0.21 algorithmreturnNc||_d|_d|_|dk(r3tj|_tj |_y|dk(r3t j|_t j|_yy)N zstd_streamdeflate_stream) _algorithm _compressobj_decompressobjzstdZstdCompressorZstdDecompressorzlib compressobj decompressobjselfr2s I/var/www/html/aiagents/fe/lib/python3.12/site-packages/mysqlx/protocol.py__init__zCompressor.__init__pss(!%#'  % $ 3 3 5D "&"7"7"9D  * * $ 0 0 2D "&"4"4"6D +datac|jdk(r|jj|S|jdk(r`tjj 5}|j }||j|z }||jz }ddd|S|jj|}||jjtjz }|S#1swYSxYw)zCompresses data and returns it. Args: data (str, bytes or buffer object): Data to be compressed. Returns: bytes: Compressed data. r5 lz4_messageN) r7r8compresslz4frameLZ4FrameCompressorbeginflushr= Z_SYNC_FLUSH)rArE compressor compresseds rBrHzCompressor.compress|s ??m +$$--d3 3 ??m +--/ 1:'--/ j11$77 j..00  1 &&//5 d''--d.?.?@@  1 s 8C##C-c|jdk(r|jj|S|jdk(r:tjj 5}|j|}ddd|S|jj|}||jj tjz }|S#1swYSxYw)zDecompresses a frame of data and returns it as a string of bytes. Args: data (str, bytes or buffer object): Data to be compressed. Returns: bytes: Decompresssed data. r5rGN) r7r9 decompressrIrJLZ4FrameDecompressorrMr=rN)rArE decompressor decompresseds rBrRzCompressor.decompresss ??m +&&11$7 7 ??m +//1 =\+66t<  = **55d; ++11$2C2CDD  = s B==C) __name__ __module__ __qualname____doc__strrCr/bytesrHrRrDrBr1r1es@ 7# 7$ 7ZE.zerDr1cXeZdZdZdeddfdZdefdZdefdZdeddfd Z d e ddfd Z y) MessageReaderzImplements a Message Reader. Args: socket_stream (mysqlx.connection.SocketStream): `SocketStream` object. .. versionadded:: 8.0.21 socket_streamr3Nc<||_d|_d|_g|_yN)_stream _compressor_msg _msg_queuerAr_s rBrCzMessageReader.__init__s#0 15!% )+rDcT|jr|jjdStjd|jj d\}}|dk(r t d|jj |dz }|tvrtd||dk(r|d k(r|jStj||}|d k(r|d }t|jj|d }d}||krytjd|j d\}} |j |dz } |jjtj| | ||d zz }||kry|jr|jjdSdS|S)aReads X Protocol messages from the stream and returns a :class:`mysqlx.protobuf.Message` object. Raises: :class:`mysqlx.ProgrammingError`: If e connected server does not have the MySQL X protocol plugin enabled. Returns: mysqlx.protobuf.Message: MySQL X Protobuf Message. r T--8899MNOFO!$55)/ufkk!n)M& h ++lQ&67&&w'B'B8W'UV? ? rDr2c8|rt||_yd|_y)zCreates a :class:`mysqlx.protocol.Compressor` object based on the compression algorithm. Args: algorithm (str): Compression algorithm. .. versionadded:: 8.0.21 Nr1rcr@s rBset_compressionzMessageReader.set_compressions5>:i04rD) rVrWrXrYr-rCr)rurrrZrr\rDrBr^r^s\,j,T, -{-^ $k $    H H HrDr^cDeZdZdZdeddfdZdededdfdZd e ddfd Z y) MessageWriterzImplements a Message Writer. Args: socket_stream (mysqlx.connection.SocketStream): `SocketStream` object. .. versionadded:: 8.0.21 r_r3Nc ||_d|_yra)rbrcrfs rBrCzMessageWriter.__init__s#0 15rDrrc^|j|}|jr0|tkDr&t|j }t j d|dz|}|jjdj||g}td}||d<|dz|d<td}||d<djt|jd d t|jg} td } t j dt| dz| }|jjdj|| gy t|j }t j d|dz|}|jjdj||gy ) zWrite message. Args: msg_type (int): The message type. msg (mysqlx.protobuf.Message): MySQL X Protobuf Message. rhr rDzMysqlx.Connection.Compressionclient_messagesrirmrnNz&Mysqlx.ClientMessages.Type.COMPRESSION) byte_sizerc_COMPRESSION_THRESHOLDrserialize_to_stringrqpackrHjoinrserialize_partial_to_stringrlenrbsendall) rArrmsg_sizemsg_strheaderrPmsg_first_fields msg_payloadoutput msg_comp_ids rB write_messagezMessageWriter.write_messages==%   +A A%c&=&=&?@G[[1 h?F))22388VW:i04rD) rVrWrXrYr-rCintr)rrZrr\rDrBrr sK6j6T6#>c#> #>#>JHHHrDrc 0eZdZdZdededdfdZedee fdZ e de d e ddfd Zd edee fd Z d5d ee efd edeedeeeefffdZde deddfdZdedee fdZde ddfdZde fdZdeddfdZ d6de dee dee ddfdZdefdZ de ddfdZ!d7dZ"de de d ee#e$e%e&e'e(fddfdZ)de de d e ddfd Z*d!e+ddfd"Z,de de d ee efddfd#Z-de de ddfd$Z.d ee#e&fde/e e ffd%Z0d ee%e(fde/e e ffd&Z1d ee$e'fde/e e ffd'Z2 d8d(e d ee e3fd)ee4e efde/e e ffd*Z5e d ee6e7fde/e e ffd+Z8deddfd,Z9dedee fd-Z:dedee;fd.Zd7d1Z?d7d2Z@d8d3eedefd4ZAy)9ProtocolzImplements the MySQL X Protocol. Args: read (mysqlx.protocol.MessageReader): A Message Reader object. writer (mysqlx.protocol.MessageWriter): A Message Writer object. .. versionchanged:: 8.0.21 readerwriterr3Nc<||_||_d|_g|_yra)_reader_writer_compression_algorithm _warnings)rArrs rBrCzProtocol.__init__Ts&, &, 59#$&rDc|jS)zstr: The compresion algorithm.)r)rAs rBcompression_algorithmzProtocol.compression_algorithmZs***rDrstmtc:|jr|j|d<|jr"|dj|j |j r"|dj|j |jr|j|d<yy)zApply filter. Args: msg (mysqlx.protobuf.Message): The MySQL X Protobuf Message. stmt (Statement): A `Statement` based type object. criteriaordergroupinggrouping_criteriaN) has_whereget_where_exprhas_sortextend get_sort_expr has_group_by get_grouping has_having get_having)rrs rB _apply_filterzProtocol._apply_filter_s >>"113C O == L   2 2 4 5     O " "4#4#4#6 7 ??'+'8C# $ rDargc t|tr)td|}tdd|}tdd|St|trtddt |St|t r3|d krtddt |Stddt|St|trZt|d k(rL|\}}td ||j| }td |jg}tdd |St|ts)t|ttfrt|d trg}|D]} g} | jD]A\} }td | |j| }| j|jCtd | } tdd | } |j| jtd}||d<tdd|St|treg} |D]A\} }td | |j| }| j|jCtd | } tdd | } | Sy)zCreate any. Args: arg (object): Arbitrary object. Returns: mysqlx.protobuf.Message: MySQL X Protobuf Message. zMysqlx.Datatypes.Scalar.String)valuezMysqlx.Datatypes.Scalar)typev_stringMysqlx.Datatypes.Anyr )rscalarr#Mysqlx.Datatypes.Object.ObjectFieldkeyrMysqlx.Datatypes.ObjectfldrobjzMysqlx.Datatypes.Arrayr)rarrayN) isinstancerZrboolrrrrtupler _create_any get_messagedictlistitemsrw)rArrrarg_key arg_valueobj_fldr array_valuesrobj_fldsrmsg_objmsg_anyrs rBrzProtocol._create_anypsv c3 .build_values6#E*6688##E*668 8rDNz;The number of bind parameters and placeholders do not matchz*Unable to find placeholder for parameter: ) rr r+r* get_bindingsget_binding_maprrr) rArrrbindings binding_maprcountargsnameposs ` ` rB_get_binding_argszProtocol._get_binding_argss" 9 9 &(?? @ 9$$&**,   4<=5K&= =K 4&. CM !"M $>>+ +KD%;&&@Gd#C#E*DI  + >s Cresultc |ddk(rtjd|d}|jj|jt j d|j|j|j|j|j|jy|ddk(rtjd|dy|ddk(rtjd |d}|d td k(rE|j|d Dcgc]&}tt|d d j(c}yt|d tt r|d dn|d }|d tdk(r|j#t|dy|d tdk(r|j%t|dyyycc}w)zProcess frame. Args: msg (mysqlx.protobuf.Message): A MySQL X Protobuf Message. result (Result): A `Result` based type object. rr zMysqlx.Notice.Warningrnz:Protocol.process_frame Received Warning Notice code %s: %srz$Mysqlx.Notice.SessionVariableChangedrz!Mysqlx.Notice.SessionStateChangedparamzBMysqlx.Notice.SessionStateChanged.Parameter.GENERATED_DOCUMENT_IDSrv_octetsrz9Mysqlx.Notice.SessionStateChanged.Parameter.ROWS_AFFECTEDv_unsigned_intz?Mysqlx.Notice.SessionStateChanged.Parameter.GENERATED_INSERT_IDN)r from_messagerrwrrwarningcodeappend_warninglevelrset_generated_idsrdecoderrrset_rows_affectedset_generated_insert_id)rArrwarn_msgsess_state_msgrsess_state_values rB_process_framezProtocol._process_frames v;! ++,CS^TH NN ! !(,, / NNL     ! !(..(-- N [A   !GY X [A $113S^Ng&-T+(( &4G%< "),UJ? &(#"&w/7N1O#7+A.(0 !"'*mO/,,()9;KL$G, U122()9;KL;s +Gcd |jj}j dk(rt |d|d|j dk(r |j||nx|j dk(ry|j d k(r|jdnG|j d k(r|jdn&|j d k(r|jd |S |S#t$r6}t|j }|rt|d||Yd}~d}~wwxYw#ttf$rY-wxYw) z`Read message. Args: result (Result): A `Result` based type object. Tz reason: N Mysqlx.ErrorrrMysqlx.Notice.FramezMysqlx.Sql.StmtExecuteOkzMysqlx.Resultset.FetchDonez(Mysqlx.Resultset.FetchDoneMoreResultsetsMysqlx.Resultset.Row) rr RuntimeErrorrepr get_warningsrr rAttributeErrorKeyError set_closedset_has_more_results set_has_data)rArrerrwarningss rBruzProtocol._read_messages?  Mll//1 xx>)&s5z3v;??xx00''V47799!!$'GG++D133##D)  3  M 3 3 56&#iz'BCL M'1s)CD D#,DDD/.D/r2c~||_|jj||jj|y)zSets the compression algorithm to be used by the compression object, for uplink and downlink. Args: algorithm (str): Algorithm to be used in compression/decompression. .. versionadded:: 8.0.21 N)rrrrr@s rBrzProtocol.set_compression?s0'0# $$Y/ $$Y/rDcNtd}|jjtd||jj }|j dk(r*|jj }|j dk(r*|j dk(rt|d|d|S)zkGet capabilities. Returns: mysqlx.protobuf.Message: MySQL X Protobuf Message. z!Mysqlx.Connection.CapabilitiesGetz/Mysqlx.ClientMessages.Type.CON_CAPABILITIES_GETrrrr)rrrrrrrr rs rBget_capabiliteszProtocol.get_capabilitesMs 9: "" K L  ll'')hh//,,++-Chh// 88~ %"3u:s6{; ; rDkwargsc |sytd}|jD]\}}td}||d<t|try|}g}|D]A}td||j ||} |j | j Ctd|} td d | } | j |d <n|j ||d <|d j|j gtd} || d <|jjtd|  |jS#t$r} | jdk7rYd} ~ yd} ~ wwxYw)zSet capabilities. Args: **kwargs: Arbitrary keyword arguments. Returns: mysqlx.protobuf.Message: MySQL X Protobuf Message. NzMysqlx.Connection.CapabilitieszMysqlx.Connection.Capabilityrrrrrrrrr capabilitiesz!Mysqlx.Connection.CapabilitiesSetz/Mysqlx.ClientMessages.Type.CON_CAPABILITIES_SETi)rrrrrrwrrrrrread_okr errno)rArrrr capabilityrritemrrrrr s rBset_capabilitieszProtocol.set_capabilitiesasu?@  ,,. LJC !?@J!$Jv %&!;D%= "..uT{;G OOG$7$7$9: ;"";J!"8qgN&-&9&9&; 7#&*&6&6u&= 7#  ( / /1G1G1I0J K' L(9:*N "" K L   <<> ! yyD !  s-D== E EE method auth_datainitial_responsectd}||d<|||d<|||d<|jjtd|y)zSend authenticate start. Args: method (str): Message method. auth_data (Optional[str]): Authentication data. initial_response (Optional[str]): Initial response. z Mysqlx.Session.AuthenticateStart mech_nameNrrz2Mysqlx.ClientMessages.Type.SESS_AUTHENTICATE_STARTrrrr)rArrrrs rBsend_auth_startzProtocol.send_auth_startsX89!K  (C   '&6C" # "" N O  rDc|jj}|jdk(r*|jj}|jdk(r*|jdk7r td|dS)zRead authenticate continue. Raises: :class:`InterfaceError`: If the message type is not `Mysqlx.Session.AuthenticateContinue` Returns: str: The authentication data. r#Mysqlx.Session.AuthenticateContinuez>Unexpected message encountered during authentication handshakerrrrr rs rBread_auth_continuezProtocol.read_auth_continuesnll'')hh//,,++-Chh// 88< < P ;rDchtd|}|jjtd|y)zeSend authenticate continue. Args: auth_data (str): Authentication data. r)rz5Mysqlx.ClientMessages.Type.SESS_AUTHENTICATE_CONTINUENr)rArrs rBsend_auth_continuezProtocol.send_auth_continues/ ;yQ "" Q R  rDc |jj}|jdk(ry|jdk(rt|jO)z~Read authenticate OK. Raises: :class:`mysqlx.InterfaceError`: If message type is `Mysqlx.Error`. zMysqlx.Session.AuthenticateOkrN)rrrr rrs rB read_auth_okzProtocol.read_auth_oksI ,,++-Cxx::xx>)$SWW-- rDrc,|jr|jdk7r|jdk(r|j|\}}nV|jdk(r|j|\}}n2|jdk(r|j |\}}nt d|t |j}td}td}td|| |d <|jdk(rtd||d z |d <||d <t|\}} td} t|| d<|| | <td} |j| d<| | d<|jjtd|  |jy#t$r } t | d} ~ wwxYw)a Send prepare statement. Args: msg_type (str): Message ID string. msg (mysqlx.protobuf.Message): MySQL X Protobuf Message. stmt (Statement): A `Statement` based type object. Raises: :class:`mysqlx.NotSupportedError`: If prepared statements are not supported. .. versionadded:: 8.0.16 Mysqlx.Crud.InsertMysqlx.Crud.FindMysqlx.Crud.UpdateMysqlx.Crud.DeletezInvalid message type: z!Mysqlx.Expr.Expr.Type.PLACEHOLDERzMysqlx.Crud.LimitExprzMysqlx.Expr.Expr)rposition row_countr offset limit_expr#Mysqlx.Prepare.Prepare.OneOfMessagerzMysqlx.Prepare.Preparestmt_idrz*Mysqlx.ClientMessages.Type.PREPARE_PREPAREN) has_limitr build_find build_update build_deletertrrrrrr/rrrr r ) rArrr_r* placeholdermsg_limit_expr oneof_typeoneof_op msg_oneof msg_preparer s rBsend_prepare_preparezProtocol.send_prepare_prepares6 >>chh*>>xx--.311**40311**403 #9(!DEE4,,./H'(KLK$%<=N*1"x+N; 'xx--+2&[8a<,x(!/C 3H= HAB )*5 &! (67 !% I' F "" F G   - LLN -# , -s-E>> FFFct|\}}td}t||d<|||<td}|j|d<|j |d}|r|dj ||j rl|dj |j|jj|j|jjg|jjtd|y ) a  Send execute statement. Args: msg_type (str): Message ID string. msg (mysqlx.protobuf.Message): MySQL X Protobuf Message. stmt (Statement): A `Statement` based type object. .. versionadded:: 8.0.16 r.rzMysqlx.Prepare.Executer/Frrz*Mysqlx.ClientMessages.Type.PREPARE_EXECUTEN) rrrr/rrr0rget_limit_row_countrget_limit_offsetrr) rArrrr7r8r9 msg_executers rBsend_prepare_executezProtocol.send_prepare_executes 4H= HAB )*5 &! (67 !% I%%de%<    & &t , >>   & &$$T%=%=%?@LLN$$T%:%:%<=IIK  "" F G  rDr/ctd}||d<|jjtd||j y)z Send prepare deallocate statement. Args: stmt_id (int): Statement ID. .. versionadded:: 8.0.16 zMysqlx.Prepare.Deallocater/z-Mysqlx.ClientMessages.Type.PREPARE_DEALLOCATEN)rrrrr)rAr/ msg_deallocs rBsend_prepare_deallocatez Protocol.send_prepare_deallocate>sB9: !( I "" I J   rDc&|jrEtd}|j|d<|jdk(r|j |d<||d<|dk7}|j ||}|r|dj ||j||y ) a) Send a message without prepared statements support. Args: msg_type (str): Message ID string. msg (mysqlx.protobuf.Message): MySQL X Protobuf Message. stmt (Statement): A `Statement` based type object. .. versionadded:: 8.0.16 zMysqlx.Crud.Limitr+r'r,limit+Mysqlx.ClientMessages.Type.SQL_STMT_EXECUTEr=rN)r0rr>rr?rrsend_msg)rArrr msg_limitrrs rBsend_msg_without_pszProtocol.send_msg_without_psOs >> 34I%)%=%=%?Ik "xx--&*&;&;&= (#$CL MM %%di%@  K  t $ h$rDcN|jjt||y)z Send a message. Args: msg_type (str): Message ID string. msg (mysqlx.protobuf.Message): MySQL X Protobuf Message. .. versionadded:: 8.0.16 N)rrr)rArrs rBrHzProtocol.send_msgks ""=#:C@rDc t|jrdnd}td|jj|j j}td||}|j r|j|d<|j|||jrtd|d <n|jrtd |d <|jjd kDr|jj|d <d |fS)aBuild find/read message. Args: stmt (Statement): A :class:`mysqlx.ReadStatement` or :class:`mysqlx.FindStatement` object. Returns: (tuple): Tuple containing: * `str`: Message ID string. * :class:`mysqlx.protobuf.Message`: MySQL X Protobuf Message. .. versionadded:: 8.0.16 Mysqlx.Crud.DataModel.DOCUMENTMysqlx.Crud.DataModel.TABLEMysqlx.Crud.Collectionrschemar' data_model collection projectionz'Mysqlx.Crud.Find.RowLock.EXCLUSIVE_LOCKlockingz$Mysqlx.Crud.Find.RowLock.SHARED_LOCKrlocking_optionsz$Mysqlx.ClientMessages.Type.CRUD_FIND) r is_doc_basedrtargetrrQhas_projectionget_projection_exprris_lock_exclusiveis_lock_sharedlock_contentionrrArrSrTrs rBr1zProtocol.build_findws"#  " -.  $!!;;## (ZJW    $ 8 8 :C  3%  ! ! #*+TUC N  "*+QRC N    % % )%)%9%9%?%?C! "5s::rDct|jrdnd}td|jj|j j}td||}|j |||jjD]u\}}td}|j|d<|j|d <|jt|j|d <|dj|jgwd |fS) aBuild update message. Args: stmt (Statement): A :class:`mysqlx.ModifyStatement` or :class:`mysqlx.UpdateStatement` object. Returns: (tuple): Tuple containing: * `str`: Message ID string. * :class:`mysqlx.protobuf.Message`: MySQL X Protobuf Message. .. versionadded:: 8.0.16 rMrNrOrPr(rRzMysqlx.Crud.UpdateOperation operationsourcerz&Mysqlx.ClientMessages.Type.CRUD_UPDATE)rrXrrYrrQrget_update_opsr update_typerbrrrr)rArrSrTrr4 update_opras rBr2zProtocol.build_updates "#  " -.  $!!;;##  ZJ  3% //1779 ?LAy =>I%.%:%:Ik ""+"2"2Ih *%/ %@ '"   # #Y%:%:%<$= >  ?8<  ? __& 3E78C%& ICL''C)D)D)F(GHIG ##Z%6%B%B%D$EF J  s01 2 3 4 % NN,CM7<#e*!>c&kR R 88{ " !AB B #rDcdtd}|jjtd|y)zSend connection close.zMysqlx.Connection.Closez$Mysqlx.ClientMessages.Type.CON_CLOSENrrs rBsend_connection_closezProtocol.send_connection_closes*/0 "" @ A3 rDcdtd}|jjtd|y)z Send close.zMysqlx.Session.Closez%Mysqlx.ClientMessages.Type.SESS_CLOSENrrs rB send_closezProtocol.send_closes*,- "" A BC rDctd}td}||d<d|d<td}|jg|d<|jj td|y ) zSend expectation.z3Mysqlx.Expect.Open.Condition.Key.EXPECT_FIELD_EXISTzMysqlx.Expect.Open.Condition condition_keyz6.1condition_valuezMysqlx.Expect.Opencondz&Mysqlx.ClientMessages.Type.EXPECT_OPENN)rrrrr)rAcond_keymsg_ocmsg_eos rBsend_expect_openzProtocol.send_expect_opensj !VW78"*$) !-. ,,./v "" B CV rD keep_openctd}|# |j|jd}|rd|d<|jj t d||j|ryy#t$rd}YMwxYw)zSend reset session message. Returns: boolean: ``True`` if the server will keep the session open, otherwise ``False``. zMysqlx.Session.ResetTFrz%Mysqlx.ClientMessages.Type.SESS_RESET)rrrr rrr)rArrs rB send_resetzProtocol.send_resets,-   "%%'   #C  "" A BC   " "!  "s"A11 A?>A?)T)NN)r3Nra)BrVrWrXrYr^rrCpropertyrrZr staticmethodr)r rrrr r&rrr+r*rr,rrurr rrr[r r"r$r!rr#r$r%r'r;rArrDrJrHrr1r2r3r.rrkrr"rwrzr|r(rrrrrrr\rDrBrrJs'}'m'' +x}++9;9.A9d99 HsHx '<HVQU,-|;<,IM, tDz4&9;R&R STT U,\4+4~4$4lNx 7LB 0 0 0(...f$(*.   C= #3-    0 E &  C  D   .B-B-B-         B- B-H# # "-# 5H# # Jst"%%%'56 %  %8 A A; A4 A(;-67(; sK (;T'=/?:;'= sK '=R=/?:;= sK =J,0 (B(BC&'(Bc3h( (B sK (BT2=L/122= sK 2=2=h C> Cd C ~ (;2G "."T*=M"H C    HTNdrDr)DrYrqr=iortypingrrrrrr lz4.framerIHAVE_LZ4 ImportError zstandardr: HAVE_ZSTDerrorsr r r rrurrrrrrhelpersrrrprotobufrrrrrrr statementrrr r!r"r#r$r%r&r'typesr(r)r*r+r,r-r.r/rr1r^rrr\rDrBrs:: ::HI 7      AAHaHaHH:H:Hz@@C HIs"CCC CCC