a  dj@sZddlZddlZddlZddlZddlZddlmZddlm Z m Z ddl m Z m Z mZmZmZmZmZmZmZmZmZddlmZddlmZmZddlmZddlmZm Z m!Z!m"Z"m#Z#dd l$m%Z%m&Z&m'Z'dd l(m)Z)m*Z*dd l+m,Z,dd l-m.Z.m/Z/m0Z0m1Z1m2Z2dd l3m4Z4ddl5m6Z6m7Z7ddl8m9Z9m:Z:ddl;mZ>ddl?m@Z@ddlAmBZBddlCmDZDddlEmFZFmGZGddlHmIZImJZJddlHmKZKddlHmLZLmMZMmNZNmOZOddlPmQZQddlRmSZSmTZTmUZUddlVmWZWddde eXeXeXe ddd ZYdddd!dddd!d"ee9e eee&e%feee&e%feXeXeXeXeXe d# d$d%ZZeee[e feXe d&d'd(Z\ddeeFdddd!ddddf eee9ee]eeeGefee9eee&e%feee&e%feXeXeXeXee e eDgee e eGffd) d*d+Z^d5eee e eWgee e e ffd,d-d.Z_Gd/d0d0e>j`ZaGd1d2d2e>jbZcGd3d4d4e>jdZedS)6N)AsyncExitStack)EnumIntEnum) AnyCallable CoroutineDictListOptionalSequenceSetTupleTypeUnion)params)DefaultDefaultPlaceholder) Dependant)get_body_field get_dependantget_parameterless_sub_dependantget_typed_return_annotationsolve_dependencies) DictIntStrAny SetIntStrjsonable_encoder)RequestValidationErrorWebSocketRequestValidationErrorDecoratedCallable)create_cloned_fieldcreate_response_fieldgenerate_unique_idget_value_or_defaultis_body_allowed_for_status_code) BaseModel) ErrorWrapperValidationError) ModelField Undefined)lenient_issubclass)routing)run_in_threadpool) HTTPException)Request) JSONResponseResponse) BaseRouteMatch)Mount) compile_pathget_namerequest_responsewebsocket_session)WS_1008_POLICY_VIOLATION)ASGIAppLifespanScope WebSocketF)exclude_defaults exclude_none)res exclude_unsetr>r?returncst|tr2t|jdd}|r |S|jddSt|trRfdd|DSt|trvfdd|DSt|rt |S|S)Nread_with_orm_modeT)by_aliasrAr>r?csg|]}t|dqSrAr>r?_prepare_response_content).0itemr>r?rAX/var/www/html/stable-diffusion-webui/venv/lib/python3.9/site-packages/fastapi/routing.py Vsz-_prepare_response_content..c s"i|]\}}|t|dqSrErG)rIkvrKrLrM `sz-_prepare_response_content..) isinstancer%getattrZ __config__dictlistitems dataclassesZ is_dataclassZasdict)r@rAr>r?rCrLrKrMrH@s*     rHT)fieldincludeexcluderDrAr>r? is_coroutine) rXresponse_contentrYrZrDrAr>r?r[rBc s|rg} t||||d}|r2|j|idd\} } nt|j|iddIdH\} } t| trd| | nt| trx| | | rt| |j t | ||||||dSt |SdS)NrF)response)loc)rYrZrDrAr>r?) rHvalidater,rRr&appendrUextendr'type_r) rXr\rYrZrDrAr>r?r[errorsvalueZerrors_rLrLrMserialize_responsens:        re) dependantvaluesr[rBcsH|jdusJd|r,|jfi|IdHSt|jfi|IdHSdS)N!dependant.call must be a function)callr,rfrgr[rLrLrMrun_endpoint_functionsrk) rf body_field status_coderesponse_classresponse_fieldresponse_model_includeresponse_model_excluderesponse_model_by_aliasresponse_model_exclude_unsetresponse_model_exclude_defaultsresponse_model_exclude_nonedependency_overrides_providerrBc sxjdusJdtjo.tjtjt|trB|jn|t t d fdd } | S)Nrh)requestrBc shzd}r҈rD|IdH}|jd}t|ts6J||jn|IdH}|rt}|j d}|sz| IdH}nFt j }||d<|dkr|}|dks|dr| IdH}|tkr|}n|}Wnt jy}z*tt|d|jfg|jd|WYd}~nPd}~0ty.Yn4ty`}ztdd d |WYd}~n d}~00t||d IdH} | \} } } } }| rt| |dnt| d IdH}t|tr|jdur| |_|Sd | i} r n| j}|dur||d<| jr | j|d<t|  d IdH}|fi|}t|jsNd|_|j j | j j|SdS)NZfastapi_astackz content-typeZ applicationjsonz+jsonbody)ryiz#There was an error parsing the body)rmZdetail)rwrfryrvrj backgroundrm) rXr\rYrZrDrAr>r?r[)!formscopegetrRrpush_async_callbackcloseryr)headersrxemailmessageMessageget_content_maintypeget_content_subtypeendswithJSONDecodeErrorrr&posdocr- Exceptionrrkr0rzrmrer$rawra)rwrystackZ body_bytesZ json_bodyZcontent_type_valuersubtypee solved_resultrgrcZbackground_tasksZ sub_response_Z raw_responseZ response_argsZcurrent_status_codecontentr]Zactual_response_classrlrfrvZ is_body_formr[rorrrqrtrursrprmrLrMapps            z get_request_handler..app) riasyncioiscoroutinefunctionrRZ field_inforZFormrrdr.r0) rfrlrmrnrorprqrrrsrtrurvrrLrrMget_request_handlers  .Rr)rfrvrBcstddfdd }|S)N) websocketrBcslt|dIdH}|\}}}}}|r@|jtdIdHt|jdusRJdjfi|IdHdS)N)rwrfrv)coderh)rrr8rri)rrrgrcrZ_2Z_3rfrvrLrMrs zget_websocket_app..appr<)rfrvrrLrrMget_websocket_apps rcsZeZdZdddeedefeeeeddddZee e efdfdd Z Z S) APIWebSocketRouteN)namerv.)pathendpointrrvrBcCs`||_||_|durt|n||_t|\|_|_|_t|j|jd|_ t t |j |d|_ dS)Nrrir) rrr5rr4 path_regex path_formatparam_convertorsrrfr7rr)selfrrrrvrLrLrM__init__'szAPIWebSocketRoute.__init__r}rBcs*t|\}}|tjkr"||d<||fSNroutesupermatchesr2NONErr}matchZ child_scope __class__rLrMr;s zAPIWebSocketRoute.matches) __name__ __module__ __qualname__strrrr rr;r r2r __classcell__rLrLrrMr&s  rcseZdZedddddddddddddddddddeedddeedeedefee e e e e ee fe eeje ee eee ee e efeeeffe ee ee e eee efe ee e eefe e eefeeeeee eeefe ee e ee eeefe edgefefdddd Zeegeeeeffd d d Zeee efd fdd Z!Z"S)APIRouteNSuccessful ResponseTF)response_modelrmtags dependenciessummary descriptionresponse_description responses deprecatedrmethods operation_idrprqrrrsrtruinclude_in_schemarnrv callbacks openapi_extragenerate_unique_id_function.)rrrrmrrrrrrrrrrrprqrrrsrtrurrnrvrrrrBc$Cs||_||_t|tr2t|}t|tr.d}n|}||_||_| |_ | |_ ||_ ||_ ||_ ||_||_||_||_||_||_||_||_||_||_|pg|_| pi|_| durt|n| |_t|\|_|_|_| durdg} dd| D|_ t|tr|j!}n|}|j p|||_"t|t#r2t$|}||_%|jrt&|sZJd|dd|j"}t'||jd|_(t)|j(|_*n d|_(d|_*|rt+||_,ng|_,|pt-.|jj/pd|_0|j01d d 2|_0i}|j3D]n\}} t| t4sJd | 5d }!|!rt&|s,Jd|dd|d |j"}t'||!d}"|"||<q|rd||_6ni|_6t7|s|Jdt8|j|jd|_9|j,dddD] }#|j9j,:d t;|#|jdqt<|j9|j"d|_=t>|?|_@dS)NGETcSsh|] }|qSrL)upper)rImethodrLrLrM r{z$APIRoute.__init__..z Status code z must not have a response bodyZ Response_)rrb rz%An additional response must be a dictmodelrzAn endpoint must be a callabler)dependsr)rfr)ArrrRrrr*r0rrrrrrprqrrrsrtrurrnrvrrrrrr5rr4rrrrrdZ unique_idrintrmr$r!ror secure_cloned_response_fieldrUrinspectcleandoc__doc__rsplitstriprVrTr~response_fieldscallablerrfinsertrrrlr6get_route_handlerr)$rrrrrmrrrrrrrrrrrprqrrrsrtrurrnrvrrrreturn_annotationcurrent_generate_unique_idZ response_namerZadditional_status_coder]rrorrLrLrMrCs"               zAPIRoute.__init__)rBcCs8t|j|j|j|j|j|j|j|j|j |j |j |j d S)N) rfrlrmrnrorprqrrrsrtrurv) rrfrlrmrnrrprqrrrsrtrurv)rrLrLrMrszAPIRoute.get_route_handlerrcs*t|\}}|tjkr"||d<||fSrrrrrLrMrs zAPIRoute.matches)#rrrrr/r"rrrr rr rrr rDependsrboolr rrrr0rr1rr.rrr;r r2rrrLrLrrMrBsx    "rcs eZdZdddeeddddddedddddeedeee e ee fee e jeeeee eefeeeffee eee ejeeeeeeeee egefee egefeeeeeeegefddfddZd7eee eeeeeegefdd d Zeddddddd dddddddd d d deeddddeed eedefeeeee e ee fee e jeeeeeeee eefeeeffeeee eee efeeee eefee eefeeeeee eee feeeeeee eeeeefe eegefe fddddZ!eddddddd dddddddd d d deedddeedeeeeee e ee fee e jeeeeeeee eefeeeffeeee eeeee eefee eefeeeeeeeeeee eeeeefeegefeegefdddZ"d8eedefeeddddZ#d9eeeeegefdddZ$d:ee edfeegefdddZ%dddeeddddeed deee e ee fee e jeeeee eefeeeffee eeeeeegefdd d d!Z&eddddddd ddddddd d d deedddeed"eeeeee e ee fee e jeeeeeeee eefeeeffeeeeee eefee eefeeeeeeeeeee eeeeefeegefeegefd#d$d%Z'eddddddd ddddddd d d deedddeed"eeeeee e ee fee e jeeeeeeee eefeeeffeeeeee eefee eefeeeeeeeeeee eeeeefeegefeegefd#d&d'Z(eddddddd ddddddd d d deedddeed"eeeeee e ee fee e jeeeeeeee eefeeeffeeeeee eefee eefeeeeeeeeeee eeeeefeegefeegefd#d(d)Z)eddddddd ddddddd d d deedddeed"eeeeee e ee fee e jeeeeeeee eefeeeffeeeeee eefee eefeeeeeeeeeee eeeeefeegefeegefd#d*d+Z*eddddddd ddddddd d d deedddeed"eeeeee e ee fee e jeeeeeeee eefeeeffeeeeee eefee eefeeeeeeeeeee eeeeefeegefeegefd#d,d-Z+eddddddd ddddddd d d deedddeed"eeeeee e ee fee e jeeeeeeee eefeeeffeeeeee eefee eefeeeeeeeeeee eeeeefeegefeegefd#d.d/Z,eddddddd ddddddd d d deedddeed"eeeeee e ee fee e jeeeeeeee eefeeeffeeeeee eefee eefeeeeeeeeeee eeeeefeegefeegefd#d0d1Z-eddddddd ddddddd d d deedddeed"eeeeee e ee fee e jeeeeeeee eefeeeffeeeeee eefee eefeeeeeeeeeee eeeeefeegefeegefd#d2d3Z.eeegefd4d5d6Z/Z0S); APIRouterrNT)prefixrrdefault_response_classrrroutesredirect_slashesdefaultrv route_class on_startup on_shutdownlifespanrrr)rrrrrrrrrrvrrrrrrrrBcstj||| | | |d|r@|ds.Jd|dr@Jd||_|pLg|_t|pXgp^g|_||_||_ |pti|_ |p~g|_ | |_ | |_ ||_||_dS)N)rrrrrr/!A path prefix must start with '/'FA path prefix must not end with '/', as the routes will start with '/')rr startswithrrrrUrrrrrrvrrr)rrrrrrrrrrrvrrrrrrrrrLrMrs4   zAPIRouter.__init__)rrrrrBcs ttdfdd }|S)NfuncrBcsj|d|S)N)rrr) add_routerrrrrrrLrM decoratorsz"APIRouter.route..decoratorr)rrrrrrrLrrMrs zAPIRouter.routerFrrmrrrrrrrrrrprqrrrsrtrurrnrroute_class_overriderrr.)rrrrmrrrrrrrrrrprqrrrsrtrurrnrrrrrrBc#Cs|p|j}| pi} i|j| }t||j}|j}|rD|||j}|r\|||j} |rt| |t||j }!||j ||||||||| || p|j | | |||||||o|j |||j | ||!d}"|j|"dS)N)rrrmrrrrrrrrrrprqrrrsrtrurrnrrvrrr)rrr#rrcopyrarrrrrrrvrr`)#rrrrrmrrrrrrrrrrprqrrrsrtrurrnrrrrrrcombined_responsesZcurrent_response_class current_tagscurrent_dependenciescurrent_callbacksrrrLrLrM add_api_route"s^"       zAPIRouter.add_api_routerrmrrrrrrrrrrprqrrrsrtrurrnrrrr)rrrmrrrrrrrrrrprqrrrsrtrurrnrrrrrBcsHttd fdd }|S)Nrcs@j |    d|S)Nr)rrrrrrrrrrrrrrnrrrrrqrtrursrprrrmrrrLrMrs8z&APIRouter.api_route..decoratorr)rrrrmrrrrrrrrrrprqrrrsrtrurrnrrrrrrLrrM api_routetsDzAPIRouter.api_route)rrrrBcCs(t|j||||jd}|j|dS)N)rrrv)rrrvrr`)rrrrrrLrLrMadd_api_websocket_routesz!APIRouter.add_api_websocket_route)rrrBcsttdfdd }|S)Nrcsj|d|SNr)rrrrrrLrMrsz&APIRouter.websocket..decoratorrrrrrrLrrMrszAPIRouter.websocketcsttdfdd }|S)Nrcsj|d|Sr)add_websocket_routerrrLrMrsz,APIRouter.websocket_route..decoratorrrrLrrMwebsocket_routeszAPIRouter.websocket_route) rrrrrrrrr) routerrrrrrrrrrrBc Cs|r*|dsJd|drhJdn>|jD]6} t| d} t| dd} | dur0| s0td| dq0|durti}|jD]}t|tri||j}t|j |j ||j }g}|r| ||j r| |j g}|r| ||j r| |j g}|r | ||jr| |jt|j|j| |j}|j||j|j|j|j|||j|j|j||jpn|pn|j|j|j|j|j|j|j|j|j |j!o|j!o| ||j"t#|||j$|d qzt|t%j&rt'|jpg}|j(||j|j||j!|j"d qzt|t)r$|j*||j|j|j"d qzt|t%j+rz|j,||j|j|j"d qz|j-D]}|.d |qR|j/D]}|.d |qldS)Nrrrrrunknownz6Prefix and path cannot be both empty (path operation: )r)rrrrZstartupshutdown)0rrrrSrrRrrr#rnrrarrrrrrrrrmrrrrrrrprqrrrsrtrurrtyperr+RouterUrrrWebSocketRouterradd_event_handlerr)rrrrrrrrrrrrrrrrZuse_response_classrrrrrhandlerrLrLrMinclude_routers                 zAPIRouter.include_router)rrmrrrrrrrrrprqrrrsrtrurrnrrrr)rrrmrrrrrrrrrprqrrrsrtrurrnrrrrrBcCs<|j||||||||| | dg| | | ||||||||||dS)NrrrrmrrrrrrrrrrprqrrrsrtrurrnrrrrrrrrrmrrrrrrrrrprqrrrsrtrurrnrrrrrLrLrMr~@s4z APIRouter.getcCs<|j||||||||| | dg| | | ||||||||||dS)NPUTrrrrLrLrMputxs4z APIRouter.putcCs<|j||||||||| | dg| | | ||||||||||dS)NPOSTrrrrLrLrMposts4zAPIRouter.postcCs<|j||||||||| | dg| | | ||||||||||dS)NDELETErrrrLrLrMdeletes4zAPIRouter.deletecCs<|j||||||||| | dg| | | ||||||||||dS)NOPTIONSrrrrLrLrMoptions s4zAPIRouter.optionscCs<|j||||||||| | dg| | | ||||||||||dS)NHEADrrrrLrLrMheadXs4zAPIRouter.headcCs<|j||||||||| | dg| | | ||||||||||dS)NPATCHrrrrLrLrMpatchs4zAPIRouter.patchcCs<|j||||||||| | dg| | | ||||||||||dS)NTRACErrrrLrLrMtraces4zAPIRouter.trace) event_typerBcsttdfdd }|S)Nrcs||S)N)r rr rrLrMrs z%APIRouter.on_event..decoratorr)rr rrLr!rMon_eventszAPIRouter.on_event)NNT)N)N)N)1rrrrr/rr"rr r rrr rrrr0rrrr1r+rr9rr:rrrr rrrrrrrrrr~rrrrrrrr"rrLrLrrMrs    3       V     ?        u    <    <    <    <    <    <    <    9 r)N)frrW email.messagerrrx contextlibrenumrrtypingrrrrr r r r r rrZfastapirZfastapi.datastructuresrrZfastapi.dependencies.modelsrZfastapi.dependencies.utilsrrrrrZfastapi.encodersrrrZfastapi.exceptionsrrZ fastapi.typesrZ fastapi.utilsr r!r"r#r$Zpydanticr%Zpydantic.error_wrappersr&r'Zpydantic.fieldsr(r)Zpydantic.utilsr*Z starletter+Zstarlette.concurrencyr,Zstarlette.exceptionsr-Zstarlette.requestsr.Zstarlette.responsesr/r0Zstarlette.routingr1r2r3r4r5r6r7Zstarlette.statusr8Zstarlette.typesr9r:r;Zstarlette.websocketsr=rrHrerrkrrrr rr rZRouterrrLrLrLrMs 4             0 .  l