B Khh @sddlZddlZddlmZmZddlmZddlmZddlm Z ddl m Z m Z yddl mZdd lmZWn<ek rZzed ed d d dWddZ[XYnXddlZddlZddlmZddlmZeZdZdZdZdZdZ dZ!dZ"dZ#dZ$eeeee e!e"e#e$g Z%dZ&Gddde'Z(ej)dddgidej*d e+d!d"d#ej*d$e,d%d&d#ej-ejde+e,dd'd(d)Z.ej/d*d+d,Z0ej1eej2d-d.d/Z3e+e e4e ej5fd0d1d2Z6dd*d3d4Z7e8d5kre7dS)6N)ExecutorProcessPoolExecutor)datetime)partial)freeze_support)SetTuple)web)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_install_uvloopzX-Protocol-Versionz X-Line-LengthzX-Python-VariantzX-Skip-Source-First-LinezX-Skip-String-NormalizationzX-Skip-Magic-Trailing-Commaz X-PreviewzX-Fast-Or-SafezX-DiffzX-Black-Versionc@s eZdZdS)InvalidVariantHeaderN)__name__ __module__ __qualname__rr2/tmp/pip-install-vv81h98y/black/blackd/__init__.pyr8srZhelp_option_namesz-hz--help)Zcontext_settingsz --bind-hostzAddress to bind the server to. localhost)typehelpdefaultz --bind-portzPort to listen oni) bind_host bind_portreturncCsNtjtjdt}tj}td|d|d|tj|||ddddS)N)levelzblackd version z listening on z port T)hostportZhandle_signalsprint) logging basicConfigINFOmake_appblack __version__outr Zrun_app)rrappverrrrmain<s r()rc Cs>tjttddgd}t}|tdtt|dg|S)N Content-Type)Z allow_headers) middlewares/)executor)r)) r Applicationr BLACK_HEADERSrZ add_routespostrhandle)r&r,rrrr"Js r")requestr,rc s2tti}y|jtddkr,tjdddSyt|jtt j }Wnt k rbtjdddSXt |jkr|jt }yt |\}}Wqtk r}z tjddt d|jd dSd}~XYqXn d }t}t|jtd }t|jtd } t|jtd } t|jtd } d } |jtd d kr8d } t j|||| | | | d} |jIdH}|jdk rv|jnd}||}t}d}| r|dd}|d|}||d}t }|!|t"t j#|| | dIdH}||dddkr|$dd}||krt j%||}||}t|jt&d }|rt}d|d}d|d}t }|!|t"t j'||||IdH}tj|j(|||dSt j%k rtjd|dSt j)k r}ztjd|t*|dSd}~XYn>t+k r,}zt,-dtjd|t*|dSd}~XYnXdS)N1iz,This server only supports protocol version 1)statustextiz Invalid line length header valuezInvalid value for z: rFsafefastT)Ztarget_versionsZis_pyi line_lengthskip_source_first_lineZstring_normalizationZmagic_trailing_commapreviewutf8 r )r6mode z zIn z +0000zOut ) content_typecharsetheadersr4)r3rA)r3rAr4z#Exception during handling a requesti).BLACK_VERSION_HEADERr$rAgetPROTOCOL_VERSION_HEADERr ResponseintLINE_LENGTH_HEADERr#ZDEFAULT_LINE_LENGTH ValueErrorPYTHON_VARIANT_HEADERparse_python_variant_headerrargssetbool SKIP_STRING_NORMALIZATION_HEADERSKIP_MAGIC_TRAILING_COMMASKIP_SOURCE_FIRST_LINEPREVIEWFAST_OR_SAFE_HEADERZFileModecontentreadr@decoderutcnowfindasyncioZget_event_loopZrun_in_executorrZformat_file_contentsreplaceZNothingChanged DIFF_HEADERZdiffr?Z InvalidInputstr Exceptionr exception)r1r,rAr7valuepyiversionseZskip_string_normalizationZskip_magic_trailing_commar8r9r6r=Z req_bytesr@Zreq_strZthenheaderZfirst_newline_positionZloopZ formatted_strZ only_diffnowsrc_namedst_namerrrr0Ss   *         r0)r_rc CsV|dkrdtfSt}x.|dD]}|drF|tdd}d|kr^|d^}}n&|d}t|dkr|ddgng}yt|}|dkrtd t|dkrt|d}|d krtd n|d krd nd }d||}|d krttj|std|d| tj|Wq&t t fk rDtddYq&Xq&Wd|fSdS)Nr`T,py.rr )zmajor version must be 2 or 3rjzPython 2 is not supportedrkZPYz3.z is not supportedzexpected e.g. '3.7', 'py3.5'F) rMsplit startswithlenrGrhasattrr# TargetVersionaddKeyErrorrI)r_rar Z major_strrestmajorminor version_strrrrrKs4     rKcCsttttdS)N)r rr#Z patch_clickr(rrrr patched_mainsrx__main__)9rYrconcurrent.futuresrrr functoolsrmultiprocessingrtypingrrZaiohttpr r*r ImportErrorZieZclickr#Z_black_versionr r$Zblack.concurrencyr EventZ _stop_signalrErHrJrQrOrPrRrSr[r.rCr]rcommandoptionr\rGZversion_optionr(r-r"RequestrFr0rNrqrKrxrrrrrsd         g!