
    Wh<              
          d dl Z ddlT ddlmZmZ ddlmZmZmZm	Z	m
Z
 ddlmZ ddlT ddlmZ ddlmZmZmZmZmZmZmZ d	d
lmZ eef eddddg          dfeef eddgd          dfeef edg d          dfeef e ddgd          dfeef e dg d          dfgZ!d Z"d Z#d Z$d Z%d Z&d  Z'd! Z(d" Z)d# Z*d$ Z+d% Z,d4d'Z-d( Z.d) Z/d* Z0d+ Z1d, Z2d- Z3d. Z4d/ Z5d0 Z6d1 Z7d2 Z8d3 Z9dS )5    N   )*)Headersnormalize_and_validate)_obsolete_line_foldChunkedReaderContentLengthReaderHttp10ReaderREADERSReceiveBuffer)LocalProtocolError)ChunkedWriterContentLengthWriterHttp10Writerwrite_any_responsewrite_headerswrite_requestWRITERS   )normalize_data_eventsGETz/aHostfoo
Connectionclosemethodtargetheaderss1   GET /a HTTP/1.1
Host: foo
Connection: close

      OK)status_coder"   reasons&   HTTP/1.1 200 OK
Connection: close

s   HTTP/1.1 200 OK

e   )Upgrade	websockets   Upgrades,   HTTP/1.1 101 Upgrade
Upgrade: websocket

s   HTTP/1.1 101 Upgrade

c                 R    g } | ||j                    d                    |          S )N    )appendjoin)writerobjgot_lists      W/var/www/html/movieo_spanner_bot/venv/lib/python3.11/site-packages/h11/tests/test_io.pydowriter2   =   s-    H
F3   88Hr+   c                 6    t          | |          }||k    sJ d S N)r2   )r.   r/   expectedgots       r1   twr7   C   s"    
&#

C(??????r+   c                 ,    t                      }|| z  }|S r4   r   )databufs     r1   makebufr;   H   s    
//C4KCJr+   c                    fd}t          |          } | | |                     |rJ t                      }t          t          |                    D ]} | |          J ||||dz            z  }  | | |                     t          |          }|dz  } | | |                     t	          |          dk    sJ d S )Nc                     | k    sJ t          | dg           D ]E\  }}t          ||           t          |          t          u sJ t          |          t          u sJ Fd S )Nr"   )getattrprinttypebytes)r6   namevaluer5   s      r1   checkztr.<locals>.checkO   s|    h #3	266 	( 	(KD%$::&&&&;;%'''''	( 	(r+   r      trailing)r;   r   rangelenrA   )readerr9   r5   rD   r:   is     `   r1   trrJ   N   s   ( ( ( ( ( $--C	E&&++NN7 //C3t99  vc{{"""tAAI	E&&++ $--C;C	E&&++::$$$$$$r+   c                  d    t           D ]'\  \  } }}}t          t          | |f         ||           (d S r4   )SIMPLE_CASESr7   r   rolestateeventbinarys       r1   test_writers_simplerR   k   sD    *6 0 0&$v
74;////0 0r+   c                  d    t           D ]'\  \  } }}}t          t          | |f         ||           (d S r4   )rL   rJ   r   rM   s       r1   test_readers_simplerT   p   sD    *6 0 0&$v
74;////0 0r+   c            
         t          t          t          ddg          d           t          t          t          g           d           t	          j        t                    5  t          t          t          ddddgd	
          d            d d d            n# 1 swxY w Y   t	          j        t                    5  t          t          t          ddgd	          d            d d d            d S # 1 swxY w Y   d S )Nr   bar)bazquuxs   foo: bar
baz: quux

s   
r   /r   r   1.0r    r!   r"   http_versionr#   )r%   r"   r]   )r7   r   r   r   pytestraisesr   r   Requestr   Response r+   r1   test_writers_unusualrc   u   s   @AA(  
 }gbkk7+++ 
)	*	* 

 


(*AB"	   		
 		
 		


 

 

 

 

 

 

 

 

 

 

 

 

 

 

 
)	*	* 
 

*A)BQV   	
 	
 	

 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
s$   "*BBB<(C11C58C5c            
         t          t          t          t          f         dt	          dddgd                     t          t          t          t          f         dt	          ddg d                     t          t          t
          t          f         dt          d	dgdd
                     t          t          t
          t          f         dt          d	dgdd
                     t          t          t
          t          f         dt          d	dgdd
                     t          t          t
          t          f         dt          d	dgdd
                     t          t          t
          t          f         dt          d	dgdd                     t          t          t
          t          f         dt          d	dgdd                     t          t          t
          t          f         dt          d	ddgdd                     t          t          t
          t          f         dt          d	ddgdd                     t          t          t          t          f         dt	          ddg d                     t          j	        t                    5  t          t          t          t          f         dd            d d d            n# 1 swxY w Y   t          j	        t                    5  t          t          t          t          f         d d            d d d            n# 1 swxY w Y   t          j	        t                    5  t          t          t          t          f         d!d            d d d            n# 1 swxY w Y   t          j	        t                    5  t          t          t          t          f         d!d            d d d            n# 1 swxY w Y   t          j	        t                    5  t          t          t          t          f         d"d            d d d            d S # 1 swxY w Y   d S )#Ns$   HEAD /foo HTTP/1.0
Some: header

HEAD/fooSomeheaderr[   r\   s   HEAD /foo HTTP/1.0

s!   HTTP/1.0 200 OK
Some: header

r#   r$   )r%   r"   r]   r&   s$   HTTP/1.0 200 OK
Foo: a a a a a 

)Fooz	a a a a as   HTTP/1.0 200 OK
Foo:

)rj    s   HTTP/1.0 200 OK
Foo: 	 	 

s   HTTP/1.0 200
Foo: bar

)rj   rW   r+   s#   HTTP/1.1 200 OK
SomeHeader: val

)
SomeHeadervalz1.1OKs5   HTTP/1.1 200 OK
SomeHeader1: val1
SomeHeader2: val2

)SomeHeader1val1)SomeHeader2val2s7   HTTP/1.1 200 OK
SomeHeader1: val1
SomeHeader2: val2

s   HEAD /foo HTTP/1.1
Host: example.com
Some: multi-line
 header
	nonsense
    	   		I guess
Connection: close
More-nonsense: in the
    last header  

)r   zexample.com)rh   z"multi-line header nonsense I guessr   )zMore-nonsensezin the last headerr   s&   HEAD /foo HTTP/1.1
  folded: line

s#   HEAD /foo HTTP/1.1
foo  : line

s"   HEAD /foo HTTP/1.1
foo	: line

s   HEAD /foo HTTP/1.1
: line

)rJ   r   CLIENTIDLEr`   SERVERSEND_RESPONSEra   r^   r_   r   rb   r+   r1   test_readers_unusualrx      s   5'(		
 	
 	
	 	 	 %vfbuMMM   %&2'(		
 	
 	
	 	 	 %&9)*		
 	
 	
	 	 	 %&.k]u	
 	
 	
   %&5k]u	
 	
 	
   %&/n%5ERU	
 	
 	
   %&3*+		
 	
 	
	 	 	 %&D,.EF		
 	
 	
	 	 	 %&H,.EF		
 	
 	
	 	 	 	% 	  		
 		
 		
  . 
)	*	* 
 

FDL!?	
 	
 	

 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
)	*	* 
 

FDL!<	
 	
 	

 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
)	*	* 
 

FDL!<	
 	
 	

 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
)	*	* 
 

FDL!<	
 	
 	

 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
)	*	* U U
764< "MtTTTU U U U U U U U U U U U U U U U U UsZ   )KKK2)L''L+.L+)N  NN$)OO O=)P33P7:P7c                  n    t          t          g d                    dt          d          dgk    sJ d S )N)   aaas   bbbs     ccc   dddrz   s   bbb cccr{   )listr   	bytearrayrb   r+   r1   test__obsolete_line_fold_bytesr~   4  sT     #$F$F$FGGHH*M      r+   c              #      K   	  | |          }|n|V  t          |          t          u rn*|r|rJ |                                 V  d S d S r4   )r@   EndOfMessageread_eof)rH   r:   do_eofrP   s       r1   _run_reader_iterr   A  s}      s= ;;,&&   woo   r+   c                  L    t          t          |            }t          |          S r4   )r|   r   r   )argseventss     r1   _run_readerr   P  s#    "D)**F (((r+   Fc                 N   t          d           t          |          }t           |             ||          |k    sJ t          d            |             }t                      }g }t	          t          |                    D ]&}|t          ||d          z  }||||dz            z  }'|t          |||          z  }t          |          |k    sJ t          d |D                       }|r3|s3t          |dz             }t           |             |d          |k    sJ d S d S d S )NzTest 1zTest 2Fr   c              3   B   K   | ]}t          |          t          u V  d S r4   )r@   r   ).0rP   s     r1   	<genexpr>z t_body_reader.<locals>.<genexpr>f  s-      HHed5kk\1HHHHHHr+   rE   )r?   r;   r   r   rF   rG   r   any)	thunkr9   r5   r   r:   rH   r   rI   is_completes	            r1   t_body_readerr   U  sU   	(OOO
$--CuuwwV,,8888 
(OOOUWWF
//CF3t99  +fc5111tAAI
k&#v...F ((H4444HHxHHHHHK <6 <d[())5577C//8;;;;< < < <;;r+   c                      t          d dt                      g           t          d dt          d          t                      g           d S )Nc                       t          d          S )Nr   r	   rb   r+   r1   <lambda>z*test_ContentLengthReader.<locals>.<lambda>m  s    -a00 r+   r+   c                       t          d          S )N
   r   rb   r+   r1   r   z*test_ContentLengthReader.<locals>.<lambda>p  s    #B'' r+   s
   0123456789r9   )r   r   Datarb   r+   r1   test_ContentLengthReaderr   l  s[    00#7GHHH''	=	!	!	!<>>2    r+   c                     t          t          dt                      gd           t          t          dt          d          gd           t          t          dt          d          t                      gd           d S )Nr+   T)r   s   asdfr   F)r   r
   r   r   rb   r+   r1   test_Http10Readerr   v  s    ,lnn%5dCCCC,$G*<*<*<)=eLLLLg' 2 2 2LNNCD     r+   c                  h   t          t          dt                      g           t          t          dt          dg          g           t          t          dt          d          t          dg          g           t          t          dt          d          t                      g           t          t          d	t          d
          t                      g           t	          j        t                    5  t          t          dt          d          g           d d d            n# 1 swxY w Y   t	          j        t                    5  t          t          dd            d d d            n# 1 swxY w Y   t          t          dt          d          t                      g           d S )N   0

s   0
Some: header

rg   r"   s3   5
01234
10
0123456789abcdef
0
Some: header

s   012340123456789abcdefr   s%   5
01234
10
0123456789abcdef
0

s   aA
xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx
0

s   xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxsi   9999999999999999999999999999999999999999999999999999999999999999999999999999999999999999999999999999
xxxs   xxxs   10 
xxxsG   5; hello=there
xxxxx
0; random="junk"; some=more; canbe=lonnnnngg

s   xxxxx)r   r   r   r   r^   r_   r   rb   r+   r1   test_ChunkedReaderr   ~  sF   -/?@@@$	12	3	3	34   	"
 .///"4!5666	

 
 
 H	+	,	,	,lnn=   8	;			0   
)	*	* S S 	m%<t?P?P?P>QRRRS S S S S S S S S S S S S S S 
)	*	* = =m%5t<<<= = = = = = = = = = = = = = = 	B 
8			lnn-    s$   <&D..D25D2E55E9<E9c                     t          d          } t          | t          d                    dk    sJ t          | t          d                    dk    sJ t          | t                                dk    sJ t          d          } t	          j        t                    5  t          | t          d                     d d d            n# 1 swxY w Y   t          d          } t          | t          d                     t	          j        t                    5  t          | t          d                     d d d            n# 1 swxY w Y   t          d          } t          | t          d                     t	          j        t                    5  t          | t                                 d d d            n# 1 swxY w Y   t          d          } t          | t          d                    dk     t          | t          d                    dk     t	          j        t                    5  t          | t          dg	                     d d d            d S # 1 swxY w Y   d S )
N   s   123r   s   45r+   s   123456s   456Etagasdfr   )r   r2   r   r   r^   r_   r   ws    r1   test_ContentLengthWriterr     s:   AA1d'''((F22221d&&&''500001lnn%%,,,,AA	)	*	* ) )4Y'''((() ) ) ) ) ) ) ) ) ) ) ) ) ) ) 	AAAt   !!!	)	*	* & &4V$$$%%%& & & & & & & & & & & & & & & 	AAAt   !!!	)	*	* # #<>>"""# # # # # # # # # # # # # # # 	AAAt   !!V++At  E))	)	*	* = =<)9(:;;;<<<= = = = = = = = = = = = = = = = = =sH   "CCCE		EEGG
G: I''I+.I+c                     t                      } t          | t          d                    dk    sJ t          | t          d                    dk    sJ t          | t          d                    dk    sJ t          | t                                dk    sJ t          | t          dd	g
                    dk    sJ d S )Nrz   r   s   3
aaa
s   aaaaaaaaaaaaaaaaaaaas   14
aaaaaaaaaaaaaaaaaaaa
r+   r   r   )abr   s   0
Etag: asdf
a: b

)r   r2   r   r   r   s    r1   test_ChunkedWriterr     s    A1d'''((O;;;;1d	***++/NNNNN1dnnn%%,,,,1lnn%%5555 	<)9:(FGGGHH-	. 	. 	. 	. 	. 	.r+   c                  P   t                      } t          | t          d                    dk    sJ t          | t                                dk    sJ t	          j        t                    5  t          | t          dg                     d d d            d S # 1 swxY w Y   d S )Ns   1234r   r+   r   r   )r   r2   r   r   r^   r_   r   r   s    r1   test_Http10Writerr     s    A1d((())W44441lnn%%,,,,	)	*	* = =<)9(:;;;<<<= = = = = = = = = = = = = = = = = =s   . BB"Bc                      t          j        t                    5  t          t          t
          t          f         dd            d d d            d S # 1 swxY w Y   d S )Ns   HTTP/1.0 200 OK xxxx

)r^   r_   r   rJ   r   rv   rw   rb   r+   r1   &test_reject_garbage_after_request_liner     s    	)	*	* U U
76=()+MtTTTU U U U U U U U U U U U U U U U U U   )AAAc                      t          j        t                    5  t          t          t
          t          f         dd            d d d            d S # 1 swxY w Y   d S )Ns&   HEAD /foo HTTP/1.1 xxxxxx
Host: a

r^   r_   r   rJ   r   rt   ru   rb   r+   r1   'test_reject_garbage_after_response_liner     s    	)	*	* 
 

FDL!?	
 	
 	

 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
r   c                      t          j        t                    5  t          t          t
          t          f         dd            d d d            d S # 1 swxY w Y   d S )Ns%   HEAD /foo HTTP/1.1
Host: foo bar

r   rb   r+   r1   "test_reject_garbage_in_header_liner     s    	)	*	* 
 

FDL!A	
 	
 	

 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
r   c                  4   dD ]} t          d          }|                    |            |                    d           t          j        t
                    5  t          t          t          t          f         |d            d d d            n# 1 swxY w Y   d S )Ns     s   HEAD /s    HTTP/1.1
Host: foobar

)
r}   r,   extendr^   r_   r   rJ   r   rt   ru   )bad_charmessages     r1   test_reject_non_vchar_in_pathr     s    ' 5 5I&&x   ;<<<]-.. 	5 	5wvt|$gt444	5 	5 	5 	5 	5 	5 	5 	5 	5 	5 	5 	5 	5 	5 	5	5 5s   )BB	B	c            
      z    t          t          t          t          f         dt	          ddddg                     d S )Ns\   HEAD /foo HTTP/1.1
Host: foo
Set-Cookie: ___utmvafIumyLc=kUdUpAt; path=/; Max-Age=900

re   rf   r   )z
Set-Cookiez-___utmvafIumyLc=kUdUpAt; path=/; Max-Age=900r   )rJ   r   rt   ru   r`   rb   r+   r1   "test_allow_some_garbage_in_cookiesr   	  sT    	 	R	
 	
 	
    r+   c                  P    t          t          t          ddg          d           d S )NrV   rs   s   Host: example.com
foo: bar

)r7   r   r   rb   r+   r1   test_host_comes_firstr     s5    0GHII0    r+   )F):r^   _events_headersr   r   _readersr   r   r	   r
   r   _receivebufferr   _state_utilr   _writersr   r   r   r   r   r   r   helpersr   rt   ru   r`   rv   rw   ra   InformationalResponserL   r2   r7   r;   rJ   rR   rT   rc   rx   r~   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   rb   r+   r1   <module>r      s        6 6 6 6 6 6 6 6              + * * * * *     & & & & & &                  + * * * * * 
$&=>	
 	
 	

 	E 
S+B*CERRR7 
S"U;;;" 
&>%?
	
 	
 	
 	> 
#r*MMM'7 F    
  % % %:0 0 0
0 0 0

 
 
>]U ]U ]U@
 
 
     ) ) )
< < < <.    4 4 4n= = =6  = = =U U U

 
 

 
 
5 5 5  $    r+   