+ iHjRt^RIHt^RIt^RIt^RIt^RIHtHtH t ]P!R4t Rt Rt RtRt!RR]4t!RR ]4tR R ltR R ltRRltRRltRRltRRltRRRlltRRlt.ROtR#)a,Minimal LSP JSON-RPC 2.0 framer over async streams. Wire format: ``Content-Length: \r\n\r\n`` where the body is a JSON-RPC 2.0 request, response, or notification. Just the framer plus envelope helpers, so :class:`agent.lsp.client.LSPClient` can focus on protocol semantics. ) annotationsN)AnyOptionalTuplezagent.lsp.protocoli c]tRt^tRtRtR#)LSPProtocolErrorzeThe framing or envelope itself is broken (vs. :class:`LSPRequestError`, a conformant error response).N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__r7/home/ubuntu/.hermes/hermes-agent/agent/lsp/protocol.pyrrsorrc6a]tRt^tRtRRV3RllltRtV;t#)LSPRequestErrorz[An LSP request returned a JSON-RPC error response; carries ``code``, ``message``, ``data``.c(V^8dQhRRRRRRRR/#) codeintmessagestrdatarreturnNoner)formats"r __annotate__LSPRequestError.__annotate__ s.AASA3AcATArc \<\SV`RV RV 24WVuVnVnVnR#)z LSP error z: N)super__init__rrr)selfrrr __class__s&&&&rr!LSPRequestError.__init__ s1 :dV2gY78-1D* 4<r)rrrN)r r r r r r!r __classcell__)r#s@rrrseAAArrc V^8dQhRRRR/#)robjdictrbytesr)rs"rrr%sIIIIrc\P!VRRR7PR4pR\V4 R2PR4V,#)zMEncode an envelope as compact UTF-8 JSON with an exact Content-Length header.F) separators ensure_asciiutf-8zContent-Length: z ascii),:)jsondumpsencodelen)r(bodys& rencode_messager7%sB ::cju E L LW UD c$i[ 1 8 8 AD HHrc V^8dQhRRRR/#rreaderzasyncio.StreamReaderrzOptional[dict]r)rs"rrr+s55 455rc"/p^pVPR4GRjxL pT\ T4, pT\ 8d \ R4hTRR pT'gT#TPR4PR4wrVpT'g\ R T: 24hTP4YP4P4&KL \PdApTP'gT'gRp?R#\ RTP: R24ThRp?ii;i \dp\ RT: 24ThRp?ii;i5i) zGRead the header block; ``None`` on clean EOF before any header started.s Nz2unexpected EOF while reading LSP headers (partial=)z2LSP header block exceeded 8 KiB without terminatorr/r1znon-ASCII LSP header: zmalformed LSP header line: ) readuntilasyncioIncompleteReadErrorpartialrr5_MAX_HEADER_BYTESdecode partitionUnicodeDecodeErrorstriplower)r:headers header_byteslineekey_values& r _read_headersrO+s.GL  o))'22D D ! + +"#WX XCRyN M KK0::3?MCE"%@#IJ J',{{} !!#$'3** o999W"%WXYXaXaWdde#fgmn n  o" M"%;D8#DE1 L MsmECCC7E#D=E?ECDD5E;DDE D>)D99D>>Ec V^8dQhRRRR/#r9r)rs"rrrGsBB3BBrc "\V4GRjxL pVfR#VPR4pVf\RV: 24h\V4pT^8g T\ 8d\RT 24hTP T4GRjxL p\P!TPR44#L \dp\RT: 24ThRp?ii;iLO \Pd+p\RT R\TP4 24ThRp?ii;i \Pdp\R T 24ThRp?i\dp\R T 24ThRp?ii;i5i) zRead one framed message. ``None`` on clean EOF between messages (typical shutdown); :class:`LSPProtocolError` on malformed framing. Nzcontent-lengthz$LSP message missing Content-Length: znon-integer Content-Length: zunreasonable Content-Length: ztruncated LSP body: expected z bytes, got r.zinvalid JSON in LSP body: znon-UTF-8 LSP body: )rOgetrr ValueError_MAX_BODY_BYTES readexactlyr?r@r5rAr2loadsrCJSONDecodeErrorrE)r:rHclnrKr6s& r read_messagerZGsk "&))G % &B z!Eg[QRRM G 1uO#!>qcBCCg''**Bzz$++g.//%* M!=bVDE1LM +  & &g!>qccRSR[R[nM]^_effg   H!;A3?@aG B!5aS9:ABsEB,.E B. E-CCC$D+E. C9C  CECD(%D  DEE*D99 EEEEEc$V^8dQhRRRRRR/#)rmethodrparamsrrr)r)rs"rrres&bbcb3b4brc$RRRV/Vf/C#RV/C#)z7Build a JSON-RPC 2.0 notification envelope (no ``id``).jsonrpc2.0r\r]r)r\r]s&&rmake_notificationraes( uh a2 aahX^M_ aarc(V^8dQhRRRRRRRR/#) rreq_idrr\rr]rrr)r)rs"rrrjs.pppcp3p4prc(RRRVRV/Vf/C#RV/C#)z&Build a JSON-RPC 2.0 request envelope.r_r`idr\r]r)rcr\r]s&&&r make_requestrfjs- udFHf ov~ oo\dfl[m oorc$V^8dQhRRRRRR/#)rrcrresultrr)r)rs"rrros!>>#>s>t>rcRRRVRV/#)z/Build a JSON-RPC 2.0 success response envelope.r_r`rerhr)rcrhs&&r make_responserjos udFHf ==rc ,V^8dQhRRRRRRRRRR /#) rrcrrrrrrrr)r)rs"rrrts0:::3::C:SW:rc2RVRV/Vf/MRV/CpRRRVRV/#)z-Build a JSON-RPC 2.0 error response envelope.rrrr_r`reerrorr)rcrrrerrs&&&& rmake_error_responserots3 4G XdlQU XC udFGS 99rc V^8dQhRRRR/#)rmsgr)rztuple[str, Any]r)rs"rrrzs U U$ U? Urc\V\4'dVPR4R8wdR #RV9d.RV9d RVR,3#RV9gRV9d RVR,3#R #RV9d R VR,3#R #) uReturn ``(kind, key)``: kind ∈ request/response/notification/invalid; key is the id (request/response), the method (notification) or ``None`` (invalid).r_r`rer\requestrhrmresponse notification)invalidN) isinstancer)rR)rqs&rclassify_messagerxzs c4 CGGI$6%$? s{ s?c$i' '+3s?gn CI&dSdd.6#oNCM *TCTTriiir%) ERROR_CONTENT_MODIFIEDERROR_METHOD_NOT_FOUNDrrrxr7rorarfrjrZ)r __future__rr?r2loggingtypingrrr getLoggerloggerryrzrBrT Exceptionrrr7rOrZrarfrjrorx__all__rrrrs# ''   / 0 "pypAiAI 58B<b p > : U r