
    ^j(                        d dl Z d dlZd dlZd dlmZmZ d dlmZmZ d dlm	Z	m
Z
 d dlmZ 	 d dlmZ d dlmZ dd	lmZ n## e$ rZ ed
e ddz   dz             ddZ[ww xY wd dlZd dlZd dlmZ d dlmZ  e j                    ZdZdZdZ dZ!dZ"dZ#dZ$dZ%dZ&dZ'dZ(eee e!e"e#e$e%e&e'e(gZ)dZ*dZ+ ej,                    pdZ- G d de.          Z/ G d d e.          Z0 ej1        d!d"d#gi$           ej2        d%e3d&d'd()           ej2        d*e4d+d,d()           ej2        d-d.d(d/0           ej2        d1 ej5        d2          e+d(d34           ej6        ej                  d5e3d6e4d.e7e3d7f         d8e4d9df
d:                                                                        Z8e	d9efd;            Z9d<e+d=d.e7e3d7f         d8e4d9ej:        fd>Z;d?ej<        d@edAe j=        d9ej>        fdBZ?dCe3dDe@dEejA        dFedGe@d@edAe j=        d9e3fdHZBdIee3         d9ejC        fdJZDdKe3d9e7e@eEejF                 f         fdLZGdOdMZHeIdNk    r eH             dS dS )P    N)ExecutorProcessPoolExecutor)datetimetimezone)cachepartial)freeze_support)web)MultiMapping   )corsz%aiohttp dependency is not installed: z. z5Please re-install black with the '[d]' extra install z.to obtain aiohttp_cors: `pip install black[d]`)version)maybe_use_uvloopzX-Protocol-VersionzX-Line-LengthzX-Python-VariantzX-Skip-Source-First-LinezX-Skip-String-NormalizationzX-Skip-Magic-Trailing-Commaz	X-Previewz
X-UnstablezX-Enable-Unstable-FeaturezX-Fast-Or-SafezX-DiffzX-Black-Versioni  P c                       e Zd ZdS )HeaderErrorN__name__
__module____qualname__     S/var/www/app.qaans.com/backend/venv/lib/python3.11/site-packages/blackd/__init__.pyr   r   ?           Dr   r   c                       e Zd ZdS )InvalidVariantHeaderNr   r   r   r   r   r   C   r   r   r   help_option_namesz-hz--help)context_settingsz--bind-hostzAddress to bind the server to.	localhostT)typehelpdefaultshow_defaultz--bind-portzPort to listen oni  z--cors-allow-origincors_allow_originszHOrigin allowed to access blackd over CORS. Can be passed multiple times.)multipler    z--max-body-size)minz#Maximum request body size in bytes.)r   r!   r"   r    	bind_host	bind_port.max_body_sizereturnc                    t          j        t           j                   t          ||          }t          j        }t	          j        d| d|  d|            t                      }	 t          j	        || |dd |           |
                                s|                                 d S d S # |
                                s|                                 w w xY w)N)levelr#   r(   zblackd version z listening on z port T)hostporthandle_signalsprintloop)loggingbasicConfigINFOmake_appblack__version__outr   r
   run_app	is_closedclose)r&   r'   r#   r(   appverr1   s          r   mainr>   G   s    > gl++++
&8
V
V
VC

C	IOOO9OOIOOPPPD	
 	
 	
 	
 ~~ 	JJLLLLL	 	t~~ 	JJLLLL	s   )B/ /+Cc                  ,    t          t                    S )N)max_workers)r   DEFAULT_WORKERSr   r   r   executorrB   y   s    ?;;;;r   r   r,   c                 P   t          j        |t          g t          dR t	          |           t
          f          g          }|                    t          j        dt          t          t                      t          j        t                                        g           |S )NzContent-Type)allow_headersallow_originsexpose_headers)client_max_sizemiddlewares/)rB   executor_semaphore)r
   Applicationr   BLACK_HEADERS	frozensetBLACK_VERSION_HEADER
add_routespostr   handlerB   asyncioBoundedSemaphorerA   )r#   r(   r<   s      r   r5   r5   ~   s    
 /%>>~>>'(:;; 46  
	 	 	C NN!#*#;O#L#L  	
 	
	 	 	 	 Jr   requestrB   rJ   c           	      |  K   t           t          i}	 | j                            t          d          dk    rt          j        dd          S d}| j                            t          d          dk    rd}	 t          | j                  }n8# t          $ r+}t          j        d	|j
        d
                   cY d }~S d }~ww xY w|                                  d {V }| j        | j        nd}|                    |          }	t          j        t           j                  }
d}|j        r,|	                    d          dz   }|	d |         }|	|d          }	t)          | j                            t*          d                    }t-          |	|||
|||           d {V }||	z   }	||z   }t          j        | j        |||          S # t0          j        $ r t          j        d|          cY S t0          j        $ r.}t          j        d	|t7          |                    cY d }~S d }~wt0          j        $ r.}t          j        d	|t7          |                    cY d }~S d }~wt
          j        $ r  t<          $ rB}t?          j         d           t          j        d|t7          |                    cY d }~S d }~ww xY w)N1i  z,This server only supports protocol version 1)statustextFsafefastTi  r   utf8 
r   )req_strrZ   modethen	only_diffrB   rJ   )content_typecharsetheadersrX      )rW   rd   )rW   rd   rX   z#Exception during handling a requesti  )!rN   r7   rd   getPROTOCOL_VERSION_HEADERr
   ResponseFAST_OR_SAFE_HEADER
parse_moder   argsreadrc   decoder   nowr   utcskip_source_first_linefindboolDIFF_HEADERformat_coderb   r6   NothingChangedInvalidInputstrSourceASTParseErrorHTTPException	Exceptionr2   	exception)rT   rB   rJ   rd   rZ   r_   e	req_bytesrc   r^   r`   headerfirst_newline_positionra   formatted_strs                  r   rQ   rQ      s[     
 $[1G7F?6<<CC<!O    ?2F;;vEED	<go..DD 	< 	< 	<<s;;;;;;;;;	<!,,..((((((	%,_%@'//f""7++|HL))& 	7*1,,t*<*<q*@"4445F4556G,,[%@@AA	)1
 
 
 
 
 
 
 
 
 7".| -	
 
 
 	
  9 9 9|3888888 F F F|3c!ffEEEEEEEEE$ F F F|3c!ffEEEEEEEEE    F F F?@@@|3c!ffEEEEEEEEEFs~   9G (G 5B
 	G 

B? B:4B?5G :B??DG %J;+J;9#H"J;"J;4#IJ;J;97J60J;6J;r^   rZ   r_   r`   ra   c                   K   |4 d {V  t          j                    }|                    |t          t          j        | ||                     d {V }|s|cd d d           d {V  S t          j        t          j	                  }	d| }
d|	 }|                    |t          t          j
        | ||
|                     d {V cd d d           d {V  S # 1 d {V swxY w Y   d S )N)rZ   r_   zIn	zOut	)rR   get_event_looprun_in_executorr   r6   format_file_contentsr   rn   r   ro   diff)r^   rZ   r_   r`   ra   rB   rJ   r1   r   rn   src_namedst_names               r   rt   rt      s      " 
 
 
 
 
 
 
 
%''"22ge8'SWXXX
 
 
 
 
 
 
 
  	! 
 
 
 
 
 
 
 
 
 
 
 
 
 
 l8<(( $== 3==))EJ(KK
 
 
 
 
 
 
 

 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
s   AC,AC
C'*C'rd   c                    	 t          |                     t          t          j                            }n# t
          $ r t          d          d w xY wt          | v rY| t                   }	 t          |          \  }}nH# t          $ r+}t          dt           d|j
        d                    d d }~ww xY wd}t                      }t          |                     t          d                    }t          |                     t          d                    }t          |                     t          d                    }t          |                     t           d                    }	t          |                     t"          d                    }
t                      }|                     t$          d                              d          }|D ]h}|                                }|rP	 |                    t          j        |                    ?# t.          $ r t          dt$           d|           d w xY wit          j        ||||| | |	|
|	  	        S )	Nz Invalid line length header valuezInvalid value for z: r   Fr\   ,)	target_versionsis_pyiline_lengthrp   string_normalizationmagic_trailing_commapreviewunstableenabled_features)intrf   LINE_LENGTH_HEADERr6   DEFAULT_LINE_LENGTH
ValueErrorr   PYTHON_VARIANT_HEADERparse_python_variant_headerr   rk   setrr    SKIP_STRING_NORMALIZATION_HEADERSKIP_MAGIC_TRAILING_COMMASKIP_SOURCE_FIRST_LINEPREVIEWUNSTABLEENABLE_UNSTABLE_FEATUREsplitstripaddPreviewKeyErrorFileMode)rd   r   valuepyiversionsr|   skip_string_normalizationskip_magic_trailing_commarp   r   r   enable_featuresenable_unstable_featurespieces                 r   rj   rj      ss   H'++&8%:STTUU H H H<==4GH ''-.	7>>MC# 	 	 	I%:IIafQiII 	
 55 $4e<<! ! !%W[[1JE%R%R S S!'++.De"L"LMM7;;w..//GGKK%0011H*-%%O&{{+BBGGMMcRR)   	##EM%$89999   !K)@KKEKK 	 > 5!::!::(
 
 
 
s-   25 A*A= =
B2&B--B2$%H

&H0r   c                 D   | dk    rdt                      fS t                      }|                     d          D ]b}|                    d          r|t          d          d          }d|v r|                    d          ^}}n(|d         }t          |          dk    r|dd          gng }	 t	          |          }|dvrt          d	          t          |          dk    r+t	          |d                   }|d
k    rt          d          n
|d
k    rdnd}d| | }|dk    r-t          t          j        |          st          d| d          |	                    t          j        |                    ?# t          t          f$ r t          d          d w xY wd|fS )Nr   Tr   py.r   r   )      zmajor version must be 2 or 3r   zPython 2 is not supported   r   PYz3.z is not supportedzexpected e.g. '3.7', 'py3.5'F)r   r   
startswithlenr   r   hasattrr6   TargetVersionr   r   r   )r   r   r   	major_strrestmajorminorversion_strs           r   r   r   )  s   ~~SUU{55{{3'' 	U 	UG!!$'' /!#d))++.g~~#*==#5#5 	DD#AJ	(+Gq(8(8}}bUI&&./MNNNt99q==QLLEzz23NOOO " "'!AAE151%11A::ge.A;&O&O:./LE/L/L/LMMMU0=>>>>j) U U U*+IJJPTTUhs   .C	E99"Fc                  >    t                       t                       d S )N)r	   r>   r   r   r   patched_mainr   J  s    FFFFFr   __main__)r)   N)JrR   r2   osconcurrent.futuresr   r   r   r   	functoolsr   r   multiprocessingr	   aiohttpr
   	multidictr   rH   r   ImportErrorieclickr6   _black_versionr   r7   black.concurrencyr   Event_stop_signalrg   r   r   r   r   r   r   r   r   ri   rs   rL   rN   DEFAULT_MAX_BODY_SIZE	cpu_countrA   rz   r   r   commandoptionrw   r   IntRangeversion_optiontupler>   rB   rK   r5   RequestrS   rh   rQ   rr   r   rt   Moderj   r   r   r   r   r   r   r   r   <module>r      sL     				 < < < < < < < < ' ' ' ' ' ' ' ' $ $ $ $ $ $ $ $ * * * * * *
&&&&&&!!!!!!!   
+6666
A	B
:	;  	   1 1 1 1 1 1 . . . . . . w} / $ * 3 #@  9 
5 &  $ ) ' ",..%A	 	 	 	 	) 	 	 		 	 	 	 	9 	 	 	 !4tX6F GHHH		)   "5uSW   	S	   	A			!	.   e/000 c3h 	
 
   10     IH22 <( < < < < +-.  c3h  	_	   8=F[=F=F  0=F 	\	=F =F =F =F@

 
 .	

 
 
 
  0
 	
 
 
 
80S) 0ej 0 0 0 0fs uT3u?R;S5S/T    B   
 zLNNNNN s   ? AAA