o i@sddlmZddlmZddlmZddlmZddlmZddlmZddlm Z e de eee d Z e d d ed iZ e d ede dZ e dedeeefdZe dede dZe dede dZee e eeefZe de edZe dee eeeeeeeeedZe dee eee dZe deeeeeeeee dZe ded eed!Ze d"ed ed#Ze d$ed%eee eed&Ze d'd ed%iZe d(ed)ed*Ze d+ed,ed*Ze d-ed.d/d0Ze d1ed2ed/d3Z e d4ed5ed/d3Z!eeeee e!fZ"e d6eee"ed7Z#e d8d9ee#iZ$e d:ed;ee$d<Z%e d=eeeeee d>Z&e d?ed;e&d#Z'e d@edAedBZ(e dCd edAiZ)e dDedEedBZ*e dFd edEiZ+e dGedHee dIZ,e dJd edKiZ-e dLedMe dNZ.e dOedPee dQZ/e dRd edPiZ0e dSedTedUZ1e dVd edTiZ2ee(e*ee%e/e1efZ3e dWedXee3dYZ4ee)e+ee'e0e2efZ5e dZed[ee5d\Z6e d]ed^ee d_Z7ee,e4fZ8ee-e.e6e7fZ9d`S)a) annotations)List)Optional)Union)Literal) NotRequired) TypedDictError)messagecode ValueNulltypenull ValueIntegerinteger)r value ValueFloatfloat ValueTexttext ValueBlobblob)r base64NamedArg)namerStmt)sqlsql_idargs named_args want_rowsCol)rdecltype StmtResult)colsrowsaffected_row_countlast_insert_rowid ExecuteReqexecute)r stream_idstmt ExecuteResp)r result SequenceReqsequence)r r*rr SequenceResp BatchCondOkok)r stepBatchCondErrorerror BatchCondNotnot BatchCond)r cond BatchCondAndand)r conds BatchCondOror BatchStep) conditionr+BatchstepsBatchReqbatch)r r*rD BatchResult) step_results step_errors BatchResp OpenStreamReq open_stream)r r*OpenStreamRespCloseStreamReq close_streamCloseStreamRespHelloMsghello)r jwt HelloOkMsghello_ok HelloErrorMsg hello_error)r r5 StoreSqlReq store_sql)r rr StoreSqlResp CloseSqlReq close_sql)r r CloseSqlResp RequestMsgrequest)r request_idr] ResponseOkMsg response_ok)r r^responseResponseErrorMsgresponse_error)r r^r5N): __future__rtypingrrrtyping_extensionsrrrstrr r rrintrrrValuerboolrr!r#r(r,r.r0r1r4r6r:r=r8r?rArCrErHrIrKrLrNrOrRrTrVrXrYr[Requestr\Responser_rb ClientMsg ServerMsgroroM/home/ubuntu/.local/lib/python3.10/site-packages/libsql_client/hrana/proto.pys