+
    Di!                       a  R t:0 t ^ RIt^ RIHtHtHtHtHtHtH	t	H
t
Ht ^RIHtHtHtHt ^RIHtHtHtHtHt ^RIHt ^RIHtHtHtHtHtHtH t H!t! ^RI"H#t#H$t$H%t%H&t& R.t']PP                  ! ]PR                  ! R	4      4      t*]PP                  ! R
4      t+R R lt,R R lt-]PP                  ! ]PR                  ! R	4      4      t.R R lt/]PP                  ! ]PR                  ! R	4      4      t0R R lt1 ! R R4      t2]PP                  ! ]PR                  ! R	4      4      t3 ! R R4      t4 ! R R4      t5R R lt6]]]
]%,          ]	]
]%,          ]
]%,          3,          3,          ]]R]3,          ]]7]R]3,          3,          3,          3,          t8]]3]/]!]3]1]!] 3]1]]3]6]]3]6]]3]6]!]3]6]!]3]6]!]3]6]R]4R]2R]5//
t9] ^ k R# )     N)	AnyCallableDictIterableNoReturnOptionalTupleTypeUnion)chunk_headerheader_fieldrequest_linestatus_line)DataEndOfMessageInformationalResponseRequestResponseReceiveBuffer)CLIENTCLOSEDDONEIDLE
MUST_CLOSE	SEND_BODYSEND_RESPONSESERVER)LocalProtocolErrorRemoteProtocolErrorSentinelvalidateREADERSasciis   [ \t]+c                \    V ^8  d   QhR\         \        ,          R\         \        ,          /#    linesreturn)r   bytes)formats   "j/Users/tonyclaw/.openclaw/workspace/services/omi-webhook/venv/lib/python3.14/site-packages/h11/_readers.py__annotate__r-   +   s"      x 8E?     c              #   D  "   \        V 4      pR pV F~  p\        P                  V4      pV'       dU   Vf   \        R4      h\	        V\
        4      '       g   \        V4      pVR,          pW#VP                  4       R  ,          pKt  Ve   Vx  TpK  	  Ve   Vx  R # R # 5i)Nz%continuation line at start of headers    )iterobs_fold_rematchr   
isinstance	bytearrayend)r(   itlastliner3   s   &    r,   _obsolete_line_foldr:   +   s     	eB D!!$'|()PQQdI.. DLD''D
D  
 s   BB c                ~    V ^8  d   QhR\         \        ,          R\         \        \        \        3,          ,          /# r&   )r   r*   r	   )r+   s   "r,   r-   r-   @   s.     > >E?>eE5L!">r.   c              #   ~   "   \        V 4       F)  p\        \        VR V4      pVR,          VR,          3x  K+  	  R# 5i)zillegal header line: {!r}
field_namefield_valueN)r:   r"   header_field_re)r(   r9   matchess   &  r,   _decode_header_linesrA   @   s<      $E*?D2MtT|$gm&<== +s   ;=c                F    V ^8  d   QhR\         R\        \        ,          /# r'   bufr)   )r   r   r   )r+   s   "r,   r-   r-   K   s      ] x7H r.   c           
      &   V P                  4       pVf$   V P                  4       '       d   \        R4      hR # V'       g   \        R4      h\        \        V^ ,          RV^ ,          4      p\        RR\        \        VR,          4      4      RR/VB # )	Nillegal request linezno request line receivedzillegal request line: {!r}headers   NN_parsedT )maybe_extract_lines+is_next_line_obviously_invalid_request_liner   r"   request_line_rer   listrA   )rD   r(   r@   s   &  r,   maybe_read_from_IDLE_clientrP   K   s    ##%E}::<<$%;<< !;<<q#?qG  )%)45?CGN r.   c                T    V ^8  d   QhR\         R\        \        \        R3,          /# r'   rD   r)   N)r   r   r   r   )r+   s   "r,   r-   r-   ^   s)      	
 (D01r.   c                    V P                  4       pVf$   V P                  4       '       d   \        R4      hR # V'       g   \        R4      h\        \        V^ ,          RV^ ,          4      pVR,          f   RMVR,          pVR,          f   RMVR,          p\        VR,          4      pV^8  d   \        M\        pV! \        \        VR	,          4      4      R
VVVR7      # )NrF   zno response line receivedzillegal status line: {!r}http_versions   1.1reasonr.   status_coderH   T)rG   rJ   rV   rU   rT   )
rL   rM   r   r"   status_line_reintr   r   rO   rA   )rD   r(   r@   rT   rU   rV   class_s   &      r,   $maybe_read_from_SEND_RESPONSE_serverrZ   ^   s     ##%E}::<<$%;<< !<==~uQx1LeTUhWG.)1w~7N  H%-S783DFgm,-K!,s!2  )%)45! r.   c                   V   a  ] tR t^zt o V 3R lR ltV 3R lR ltV 3R lR ltRtV tR# )	ContentLengthReaderc                $   < V ^8  d   QhRS[ RR/# )r'   lengthr)   N)rX   )r+   __classdict__s   "r,   r-    ContentLengthReader.__annotate__{   s     ! !s !t !r.   c                    Wn         Wn        R # N_length
_remaining)selfr^   s   &&r,   __init__ContentLengthReader.__init__{   s     r.   c                >   < V ^8  d   QhRS[ RS[S[S[R3,          /# rR   r   r   r   r   )r+   r_   s   "r,   r-   r`      s'      M eD,4L.M r.   c                    V P                   ^ 8X  d   \        4       # VP                  V P                   4      pVf   R# V ;P                   \        V4      ,          un         \	        VR7      # )r   Ndata)re   r   maybe_extract_at_mostlenr   rf   rD   rm   s   && r,   __call__ContentLengthReader.__call__   sN    ??a>!((9<3t9$r.   c                    < V ^8  d   QhRS[ /# r'   r)   r   )r+   r_   s   "r,   r-   r`      s     
 
( 
r.   c                    \        R P                  V P                  V P                  ,
          V P                  4      4      h)z]peer closed connection without sending complete message body (received {} bytes, expected {}))r    r+   rd   re   rf   s   &r,   read_eofContentLengthReader.read_eof   s4    !//5vt.0
 	
r.   rc   N	__name__
__module____qualname____firstlineno__rg   rq   rx   __static_attributes____classdictcell__r_   s   @r,   r\   r\   z   s#     ! ! 
 
r.   r\   c                   V   a  ] tR t^t o V 3R lR ltV 3R lR ltV 3R lR ltRtV tR# )	ChunkedReaderc                   < V ^8  d   QhRR/# )r'   r)   NrK   )r+   r_   s   "r,   r-   ChunkedReader.__annotate__   s     & &$ &r.   c                0    ^ V n         RV n        RV n        R# )r   r.   FN_bytes_in_chunk_bytes_to_discard_reading_trailerrw   s   &r,   rg   ChunkedReader.__init__   s      "% %r.   c                >   < V ^8  d   QhRS[ RS[S[S[R3,          /# rR   rj   )r+   r_   s   "r,   r-   r      s+     0M 0MM 0MeD,4L.M 0Mr.   c                   V P                   '       d5   VP                  4       pVf   R # \        \        \	        V4      4      R7      # V P
                  '       d   VP                  \        V P
                  4      4      pVf   R # W0P
                  R \        V4       8w  d   \        RV: RV P
                  : R24      hV P
                  \        V4      R  V n        V P
                  '       d   R # V P
                  R8X  g   Q hV P                  ^ 8X  de   VP                  4       pVf   R # \        \        VRV4      p\        VR,          ^R7      V n	        V P                  ^ 8X  d   R	V n         V ! V4      # R	pMR
pV P                  ^ 8  g   Q hVP                  V P                  4      pVf   R # V ;P                  \        V4      ,          un	        V P                  ^ 8X  d   RV n        R	pMR
p\        W6VR7      # )N)rG   zmalformed chunk footer: z (expected )r.   zillegal chunk header: {!r}
chunk_size)baseTFs   
)rm   chunk_start	chunk_end)r   rL   r   rO   rA   r   rn   ro   r   r   maybe_extract_next_liner"   chunk_header_rerX   r   )rf   rD   r(   rm   r   r@   r   r   s   &&      r,   rq   ChunkedReader.__call__   s      ++-E}-A%-H(IJJ!!!,,S1G1G-HID|--kD	::(.thk$BXBXA[[\]  &*%;%;CIK%HD"%%%%%,,,1$668L#,	G $'w|'<2#FD ##q((,%Cy KK##a'''(()=)=><D	)1$%,D"II)LLr.   c                    < V ^8  d   QhRS[ /# rt   ru   )r+   r_   s   "r,   r-   r      s     
 
( 
r.   c                    \        R 4      h)zVpeer closed connection without sending complete message body (incomplete chunked read))r    rw   s   &r,   rx   ChunkedReader.read_eof   s    !(
 	
r.   r   Nrz   r   s   @r,   r   r      s&     & &0M 0Md
 
r.   r   c                   D   a  ] tR t^t o V 3R lR ltV 3R lR ltRtV tR# )Http10Readerc                6   < V ^8  d   QhRS[ RS[S[,          /# rC   )r   r   r   )r+   r_   s   "r,   r-   Http10Reader.__annotate__   s      M htn r.   c                H    VP                  R 4      pVf   R# \        VR7      # )iɚ;Nrl   )rn   r   rp   s   && r,   rq   Http10Reader.__call__   s$    ((3<r.   c                    < V ^8  d   QhRS[ /# rt   r   )r+   r_   s   "r,   r-   r      s      , r.   c                    \        4       # rb   r   rw   s   &r,   rx   Http10Reader.read_eof   s
    ~r.   rK   N)r{   r|   r}   r~   rq   rx   r   r   r   s   @r,   r   r      s       r.   r   c                (    V ^8  d   QhR\         RR/# rR   r   )r+   s   "r,   r-   r-      s       $ r.   c                 ,    V '       d   \        R 4      hR# )zGot data when expecting EOFN)r   )rD   s   &r,   expect_nothingr      s    
 !>??r.   .chunkedzcontent-lengthzhttp/1.0c                @    V ^8  d   Qh/ ^ \         9   d
   \        ;R&   # )r'   r#   )__conditional_annotations__ReadersType)r+   s   "r,   r-   r-      s    		p  q 
r.   );r   retypingr   r   r   r   r   r   r	   r
   r   _abnfr   r   r   r   _eventsr   r   r   r   r   _receivebufferr   _stater   r   r   r   r   r   r   r   _utilr   r    r!   r"   __all__compileencoder?   r2   r:   rA   rN   rP   rW   rZ   r\   r   r   r   r   strr   r#   r-   )r   s   @r,   <module>r      s  & 
	 X X X H H Q Q )	 	 	 O N+**\009:jj$*> **\009:  K..w788
 
. **\009:>
 >
B  	$x.%XX >?
?@	(38
d3c(:#:;
;<> TN/TN8]ATNNZ.VnTNNZ.Vn=-L r.   