o Tj=@s UddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl mZmZmZmZmZmZmZmZmZddlmZmZmZmZddlmZddlmZmZddl m!Z!m"Z"ddl#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)ddl*Z*ddl+m,Z,dd l-m.Z.dd l/m0Z0dd l1m2Z2m3Z3m4Z4dd l5m6Z6m7Z7dd l8m9Z9m:Z:m;Z;mZ>m?Z?m@Z@mAZAmBZBmCZCmDZDmEZEmFZFddlGmHZHddlImJZJmKZKmLZLmMZMmNZNddlOmPZPmQZQmRZRmSZSmTZTddlUmVZVmWZWddlXmYZYmZZZm[Z[m\Z\ddl]m^Z^ddl_m`Z`ddlambZbmcZcddldmeZemfZfddlgmhZhmiZimjZjddlkmlZlddlmmnZnddlompZpmqZqmrZrmsZsmtZtddlumvZvmwZwmxZxmyZymzZzddlum{Z{ddl|m}Z}ddl~mZmZmZmZmZmZdd lmZdd!lmZd"eengeesesBfd#efd$d%Zd"eegedfd#efd&d'Ze(d(ZGd)d*d*eeZd+ee%gee%e%e%ffd#ee%gee%ffd,d-Zd.ee%d/ee%d#ee%fd0d1ZGd2d3d3ZiZeeeJfed4<d"e%d#eJfd5d6Zdddd7d8d8d8d7dd8d9 d:e2dBd;e%ded?ed@edAedBedCeJdBdDed#e%fdEdFZdGe9dHeee%fdBed#e%fdIdJZdKedBdLe%d#eee%ffdMdNZdde6epdddd7d8d8d8dd8e6d7dd8fdGe9dOe2dBdKedBdPeese7BdQe2dBdReWdBdSeWdBdTedUedVedWedXe%dBdYedZee7Bd[e2dBd\ed#eengee%e%esfff"d]d^Z  8ddGe9dXe%dBdYed#eegee%e%e%fffd_d`ZGdadbdbe^jZdcZddZdeZdfZdgZedhddiZee%dBedj<eZddkdlZdmednedoe%fdpee0jd#ee9ee2effdqdrZGdsdtdte'Zdued#eee%ffdvdwZduedxed#dfdydzZdued#e%dBfd{d|Zdued#e%dBfd}d~Zdued#edBfddZduedede%d#dfddZGddde'Ze6ddddddddddddddd7d8d8d8d7e6epddde6eZe6d7dddedmededoe%fde%dKedBdeee!BdBdpee0jdBdedBdedBdedeeeBeee%ffdBdedBdedBdeeeeBdBdedBdReWdBdSeWdBdTedUedVedWededPeese7BdXe%dBdeevdBdeee%fdBdee%gefe7BdZee7Bde%dBd#df response`, and returns an ASGI application. scopereceivesendraNcsJt|||dtdtdtddffdd }t||||IdHdS)Nrbrcrdrac sd}t4IdHB}||d<t4IdH}||d<IdH}WdIdHn 1IdHs2wY||||IdHd}WdIdHn 1IdHsRwY|s]tddS)NFfastapi_inner_astackfastapi_function_astackTarResponse not awaited. There's a high chance that the application code is raising an exception and a dependency with yield has a block with a bare except, or a block with except Exception, and is not raising the exception again. Read more about it in the docs: https://fastapi.tiangolo.com/tutorial/dependencies/dependencies-with-yield/#dependencies-with-yield-and-except)r r1)rbrcrdresponse_awaited request_stackfunction_stackresponse)frequestR/home/dinkstrade/pdmp-scanner/venv/lib/python3.10/site-packages/fastapi/routing.pyapps ((z*request_response..app..app)rJr[rZr\rArbrcrdrork)rlrnros  zrequest_response..app)rC functoolspartialrEr[rZr\r`rormrqrnrequest_responseys   rucs"dtdtdtddffdd }|S)zM Takes a coroutine `func(session)`, and returns an ASGI application. rbrcrdraNcsLt|||ddtdtdtddffdd }t||||IdHdS)N)rcrdrbrcrdrac st4IdH8}||d<t4IdH}||d<IdHWdIdHn 1IdHs0wYWdIdHdS1IdHsFwYdS)Nrerf)r )rbrcrdrhri)r`sessionrmrnros*.z+websocket_session..app..app)r^r[rZr\rArpr`)rvrnros zwebsocket_session..app)r[rZr\rtrmrwrnwebsocket_sessions rx_Tc @sdeZdZdZdeeddfddZdefddZd ee dBd e dBd e j dBde dBfd d Z dS)_AsyncLiftContextManagerz Wraps a synchronous context manager to make it async. This is vendored from Starlette to avoid importing private symbols. cmraNcC ||_dSN)_cm)selfr{rmrmrn__init__ z!_AsyncLiftContextManager.__init__cs |jSr})r~ __enter__rrmrmrn __aenter__s z#_AsyncLiftContextManager.__aenter__exc_type exc_value tracebackcs|j|||Sr})r~__exit__)rrrrrmrmrn __aexit__sz"_AsyncLiftContextManager.__aexit__)__name__ __module__ __qualname____doc__r ryrrtype BaseExceptiontypes TracebackTypeboolrrmrmrmrnrzs rzlifespan_contextcs2t|tdtdttffdd }|S)z Wrap a generator-based lifespan context into an async context manager. This is vendored from Starlette to avoid importing private symbols. roracs t|Sr})rzrocmgrrmrnwrappers z+_wrap_gen_lifespan_context..wrapper) contextlibcontextmanagerrrwrapsrrz)rrrmrrn_wrap_gen_lifespan_contexts roriginal_contextnested_contextcs0tdtdttttfdBffdd }|S)Nrorac s|4IdHA}|4IdH"}|dur|durdVn i|p#i|p'iVWdIdHn 1IdHs:wYWdIdHdS1IdHsPwYdSr}rm)romaybe_original_statemaybe_nested_staterrrmrnmerged_lifespans*.z0_merge_lifespan_context..merged_lifespan)rrWrr strr)rrrrmrrn_merge_lifespan_contexts rc@sLeZdZdZdddZddd Zd eddfd d Zd ededefddZ dS)_DefaultLifespanaX Default lifespan context manager that runs on_startup and on_shutdown handlers. This is a copy of the Starlette _DefaultLifespan class that was removed in Starlette. FastAPI keeps it to maintain backward compatibility with on_startup and on_shutdown event handlers. Ref: https://github.com/Kludex/starlette/pull/3117 router APIRouterraNcCr|r})_router)rrrmrmrnrrz_DefaultLifespan.__init__c|jIdHdSr})r_startuprrmrmrnrz_DefaultLifespan.__aenter__exc_infocrr})r _shutdown)rrrmrmrnr rz_DefaultLifespan.__aexit__rrocCs|Sr}rm)rrormrmrn__call__z_DefaultLifespan.__call__)rrraNraN) rrrrrrobjectrryrrmrmrmrnrs  r_endpoint_context_cachecCst|}|tvr t|Sz.i}t|}dur||d<t|d}dur+||d<t|dd}dur9||d<Wn tyFt}Ynw|t|<|S)zAExtract endpoint context with caching to avoid repeated file I/O.Nfilelinerfunction)idrinspect getsourcefilegetsourcelinesgetattr Exceptionr0)r`func_idctx source_file line_number func_namermrmrn_extract_endpoint_contexts"  rTF) rincludeexcludeby_alias exclude_unsetexclude_defaults exclude_none is_coroutine endpoint_ctx dump_jsonrresponse_contentrrrrrrrrrc  s|r?|r|j|idd\} } nt|j|iddIdH\} } | r,| p$t} t| || d| r1|jn|j}|| ||||||dSt|S)Nrjlocerrorsbodyrrrrrrr)validaterEr0r3serialize_json serializer/)rrrrrrrrrrrvaluerr serializerrmrmrnserialize_response-s2   r dependantvaluescsF|jdus Jd|r|jdi|IdHSt|jfi|IdHS)N!dependant.call must be a functionrm)callrErrrrmrmrnrun_endpoint_functionXs r status_code solved_resultcCsBd|ji}|r |n|jj}|dur||d<|jjr|jj|d<|S)N backgroundr)background_tasksrjr)rr response_argscurrent_status_codermrmrn_build_response_argses r body_fieldresponse_classresponse_fieldresponse_model_includeresponse_model_excluderesponse_model_by_aliasresponse_model_exclude_unsetresponse_model_exclude_defaultsresponse_model_exclude_nonedependency_overrides_providerembed_body_fieldsstrict_content_typestream_item_fieldis_json_streamcsjdus Jdtjotjtjt tr jn tt  t| tr0| jn| dt dt f fdd }|S)Nrrlrac sjd}|jd}t|tsJd jrt jnt jr7|jddd}|j d| jd<z_d}r rL| IdH}| |j nI| IdH}|rt}|jd}|sish|IdH}n#tj}||d<|d kr|} | d ks| d r|IdH}|tkr|}n|}Wn@tjy} ztd d | jfdid| jidg| jd} | | d} ~ wtyty} z tddd} | | d} ~ wwg} |jd}t|tsJdt| tt t!t"ft#Bt$BdB| | dIdH}|j%} js J| sdt"dt$ffdd r jd;i|j&dt"dt$ffdd t' jrB(nt)t*dt+t,t$ffdd }|-|IdH}| |j.d!t,t$dt+t$fd"d#}||}t/|d$}t0|fd%d&i|}d'|jd(<d)|jd*<|jj12|j3jj1nr jd;i|j&dt"dt$ffd+d, t' jrdt+t$ffd-d. }|}ndt4t$ffd/d0 }|}t/|d$}t0|fd%d1i|}|jj12|j3jj1nt' jst5 jr9 jd;i|j&t' jrd2t+t"dt+t"fd3d4}|t/|d$}d;d5i|}|jj12|j3jj1nit6 |j& d6IdH}t|t7rW|j8durT|j9|_8|}nKt/|d$}duoftt:}t;| |d7 IdH}|rt7d;|d8d9|}n|fi|}t<|j=sd:|_ |jj12|j3jj1| rt| |d} | |sJ|S).app.._serialize_dataitemcst|tr7|jdur|j}n|jdur(t|jdr|j}n tt|j}nd}t ||j |j |j |j dSt |ddS)Nmodel_dump_json)data_streventrretrycommentr)r ) isinstancer8raw_datarhasattrr rrr/r9r rrrdecode)r r r rmrn_serialize_sse_item s$      z=get_request_handler..app.._serialize_sse_itemc stjtdd\dfdd }tjtdd\}dfdd }t4IdH}|||||V|jWdIdHdS1IdHsRwYdS) Nr)max_buffer_sizerac sh4IdH 2z3dHW}|IdHq 6WdIdHdS1IdHs-wYdSr})rd)raw_item)r send_stream sse_aiterrmrn _producerDs .zMget_request_handler..app.._sse_producer_cm.._producerc s4IdHm4IdHPz: z&ttIdH}Wdn1s)wY|IdHWntyHtIdHYnwqtjySYnwWdIdHn 1IdHsdwYWdIdHdS1IdHszwYdS)zrRead from the producer and forward to the output, inserting keepalive comments on timeout.N)anyio fail_afterr5rcrd TimeoutErrorr6 EndOfStream)r)receive_streamsend_keepalivermrn_keepalive_inserterMs$  XzWget_request_handler..app.._sse_producer_cm.._keepalive_inserterr)rcreate_memory_object_streambytescreate_task_group start_soon cancel_scopecancel)rreceive_keepaliver!tg)rr)rr rrn_sse_producer_cm.s     .z:get_request_handler..app.._sse_producer_cmstreamcS0|2z3dHW}|VtdIdHq6dSNrrsleep)r+rrmrmrn_sse_with_checkpointsms z?get_request_handler..app.._sse_with_checkpoints)rr media_typeztext/event-streamzno-cachez Cache-ControlnozX-Accel-Bufferingcs |dS)N rmr rrmrn_serialize_item z9get_request_handler..app.._serialize_itemcs42z3dHW}|VtdIdHq6dSr-r.r4r5genrmrn_async_stream_jsonls  z=get_request_handler..app.._async_stream_jsonlc3sD]}|VqdSr}rmr4r7rmrn_sync_stream_jsonls z.app.._sync_stream_jsonlzapplication/jsonl async_gencSr,r-r.)r;chunkrmrmrn_async_stream_raws z;get_request_handler..app.._async_stream_rawcontentr) rrrrrrrrrrrzapplication/json)r>r1rm)>rbgetrr rrr0rrstripmethodformpush_async_callbackcloserrheadersremailmessageMessageget_content_maintypeget_content_subtypeendswithJSONDecodeErrorr2posrdocrIrr.rdictrrrGr#rrr# __aiter__rDrrrenter_async_contextacloserrOrawextendrjrr%rrNrrr!rr?r)rlrj file_stack mount_pathr body_bytes json_bodycontent_type_valuerHsubtypeevalidation_error http_errorrrrr*sse_receive_streamr0sse_stream_contentrr9jsonl_stream_contentr:r= raw_response use_dump_jsonr>actual_response_classactual_strict_content_typerrrr is_body_formrr is_sse_streamrrrrrrrrrr)r r5rrr8rrnros             $  7                z get_request_handler..app) rr$r field_inforFormr!rrr7rJrN)rrrrrrrrrrrrrrrrrormrdrnget_request_handlerws    <erkcsdtddffdd }|S)N websocketracsjr tjnt}jr#|jddd}d|j|d<|jd}t|ts2Jdt ||dIdH}|j rHt |j |d jdusQJd jd i|j IdHdS) NrrrzWS rrerrlrrrr)rrrm) rrr0rrbr@rArr r.rr4r)rlrrWrrrrrrmrnros4    zget_websocket_app..appr])rrrrormrnrnget_websocket_appsroc steZdZdddddededefdedBdeejdBdedBd df d d Z d e d e e e fffd d Z ZS)APIWebSocketRouteN)name dependenciesrrendpoint.rqrrrracCs~||_||_|durt|n||_t|pg|_t|\|_|_|_ t |j|j|jd\|_ }|_ t t|j ||j d|_dS)Nrrrrrn)rrsrTrqlistrrrS path_regex path_formatparam_convertors0_build_dependant_with_parameterless_dependenciesr_embed_body_fieldsrxroro)rrrsrqrrr_rmrmrnr"s*  zAPIWebSocketRoute.__init__rbcs*t|\}}|tjkr||d<||fSNroute)supermatchesrQNONE)rrbmatch child_scope __class__rmrnrAs zAPIWebSocketRoute.matches)rrrrrrr rDependsrr[tuplerQr __classcell__rmrmrrnrp!s$   &rpfastapieffective_route_context frontend_pathfrontend_specificityincluded_routerfastapi_effective_route_context)default_effective_route_context_varcCsdSr}rmrmrmrmrn_frontend_dependency_endpointSrrrr.rrcCsRt||dd}|dddD] }|jdt||dqt|}t|}|||fS)Nr)rrrbr)dependsr)r*rrinsertr+r(r))rrrrrr body_paramsrrmrmrnryWs  ryc@seZdZUeed<dS)_RouteWithPathrN)rrrr__annotations__rmrmrmrnrhs rrbcCs|ti}t|ts J|Sr}) setdefault_FASTAPI_SCOPE_KEYrrP)rb fastapi_scopermrmrn_get_fastapi_scopels rrcCsL|t}|D] \}}|tkr|||<q t|tr$t||dSdSr})r@ritemsrrPrupdate)rbrfastapi_child_scopekeyrrmrmrn _update_scopers  rcC|titSr})r@r$_FASTAPI_EFFECTIVE_ROUTE_CONTEXT_KEYrbrmrmrn"_get_scope_effective_route_context{rcCrr})r@r_FASTAPI_INCLUDED_ROUTER_KEYrrmrmrn_get_scope_included_routerrrcCs$|tit}t|tr|SdSr})r@r!_FASTAPI_FRONTEND_SPECIFICITY_KEYrint)rb specificityrmrmrn_frontend_scope_specificitys  rrpreviouscCs<|t}t|ts dS|tur||ddS|||<dSr})r@rrrP_SCOPE_MISSINGpop)rbrrrrmrmrn_restore_fastapi_scope_keys   rc@seZdZUeed<edefed<edBed<eed<edBed<eed<edBed <edBed <edBed <edBed <eed <eed<eed<eed<eed<e e e Bed<edBed<e e dBed<eeefdBed<eegefe Bed<ee Bed<e eeBed<eeeBeeeffed<eed<eed<eed<eeefed<eeed<eed<edBed <edBed!<edBed"<e ejed#<eed$<eeeBefed%<eed&<eed'<edBed(<eed)<eed*<dS)+ _APIRouteLiker.rsNstream_item_typeresponse_modelsummaryresponse_descriptionr_ operation_idrrrrrrinclude_in_schemarr callbacks openapi_extragenerate_unique_id_functionrtags responsesrqrvrwrxmethods unique_idrrrrr descriptionresponse_fieldsrrzrrhr)rrrrrrrrr;rrNr!rurPrPrrsetrrrr"rmrmrmrnrsR               rSuccessful Response)rrrrrrrrrr_rqrrrrrrrrrrrrrrrrr}rsrrrrrrr_rqrrrrrrrc)CsH||_||_||_||_| |_| |_||_||_||_||_ ||_ ||_ ||_ ||_ ||_||_||_||_||_||_|p?g|_| pDi|_| durNt|n| |_t|\|_|_|_| durbdg} dd| D|_t|trs|j}n|}|jp{|||_ t|t!rt"|}||_#t$|pg|_%|pt&'|jj(pd|_)|j)*dd+|_)i}|j,D]4\}} t| t-sJd| .d}!|!rt/|sJd |d d |d |j }"t0|"|!d d}#|#||<q|r||_1ni|_1t2|sJdt3|j|j|j%d\|_4}$|_5t6|$|j |j5d|_7t8|j4j9pt:|j4j9}%|%o!t;|t<|_=|%o*t|t|_>t|tret?|}&t;|&t@r?d}n&tA|&}'|'durc|%rct|tsWt;|t<r`t;|'tBs`|'|_d}n|&}||_C|jCrt/|syJd |d d |j }"t0|"|jCd d|_Dnd|_D|jrd|j }(t0|(|jd d|_EdSd|_EdS)NGETcSsh|]}|qSrm)upper).0rBrmrmrn sz,_populate_api_route_state..r rz%An additional response must be a dictmodelz Status code z must not have a response body Response_r{ serialization)rqtype_modezAn endpoint must be a callablert)rrqr StreamItem_)Frrsrrrr_rrrrrrrrrrrrrrrrrTrqrSrvrwrxrrr!rrrrrrurrrcleandocrrsplitstriprrPr@r?r<rcallableryrrzr'rr#rr%rr7rhrr-rNr,r8rrr))r}rrsrrrrrrrrrr_rqrrrrrrrrrrrrrrrrcurrent_generate_unique_idradditional_status_coderjr response_namerr is_generatorreturn_annotation stream_itemstream_item_namermrmrn_populate_api_route_states"               rc9sXeZdZUedBed<eed<edBed<eed<edBed<edBed<edBed<edBed <eed <eed <eed <eed <eed<ee e Bed<edBed<e e dBed<e eefdBed<eegefe Bed<ee Bed<e eeBed<e eeBe eeffed<eed<edBed<edBed<edBed<e ejed<eed<e eeBefed<eed<eed<edBed <eed!<eed"<eddddddd#dddddddd$d%d%d%d$eedddeeed$d&d'ed(ed)efdededBde eeBdBdeejdBdedBdedBdede eeBe eeffdBdedBd*edBd+eee eBdBdedBdedBd edBd ed ed ed ededee e BdedBde e dBde eefdBdedgefe Bdee Bd,df8d-d.Zd,eegeeee fffd/d0Zd1ed,ee efffd2d3 Z!d1ed4e"d5e#d,dffd6d7 Z$Z%S)8APIRouteNrrrrr_rrrrrrrrrrrrrrrrrrrrrrrrrrzrrhrrTF)rrrrrrrrrr_rqrrrrrrrrrrrrrrrrrs.rqrracCsttt|||fid|d|d|d|d|d|d| d| d | d | d | d |d |d|d|d|d|d|d|d|d|d|d|d|d|t||_dS)Nrrrrrrrrrr_rqrrrrrrrrrrrrrrr)rrrruget_route_handlerro)rrrsrrrrrrrrrr_rqrrrrrrrrrrrrrrrrmrmrnrsp      zAPIRoute.__init__cCstt|}t}|dur|j|urtt|}tdid|jd|jd|jd|j d|j d|j d|j d|j d |jd |jd |jd |jd |jd|jd|jd|jS)Nrrrrrrrrrrrrrrrrrm)rrrr@original_routerkrrrrrrrrrrrrrzrrr)rr}effective_contextrmrmrnrsJ       zAPIRoute.get_route_handlerrbcsTt|}|dur|j|ur||\}}nt|\}}|tjkr&||d<||fSr|)rrrr~rQr)rrbrrrrrmrnrs zAPIRoute.matchesrcrdc st|}|dur`|j|ur`|j}|r<|d|vr z_RouterIncludeContext.default_response_classrrNr_TrcCrr}r r=rmrmrmrnrrrcCtdSNTr rmrmrmrnrrrr rrrrrrrr_rr parent_routerrac Cs~|||j|g|j|p gg|j|pgt||ji|j|p"ig|j|p*g| p/|j|jo3| t| |j |j |j d SN) rrrrrrrrr_rrrr) rrrrr>rrrr_rrrr) clsrrrrrrrrrr_rrrmrmrn for_includes$z!_RouterIncludeContext.for_include child_contextcCst|j|j|jg|j|jg|j|jt|j|ji|j|jg|j|j|j p/|j |j o4|j t|j |j t|j |j |j d Sr)rrrrrrr>rrrr_rrrr)rrrmrmrncombine?s,  z_RouterIncludeContext.combiner}cCs |j|jSr}rrrr}rmrmrnpath_forYr6z_RouterIncludeContext.path_for)rrrar)(rrrrrrrrurrrrrrrrrNr!rPrrrrrPr_rrrrrrr classmethodr rKr=r rrrrrmrmrmrnrs  &        % rc@s\eZdZUeed<dZedBed<dZeed<dZeed<dZ e de fdBed<dZ e dBed <dZ e ed <dZedBed <d Zeed <dZedBed<dZedBed<dZedBed<dZedBed<dZeed<dZeed<dZeed<dZeed<dZeed<edddZeeeBed<dZ e dBed<dZ!e"edBed<dZ#e$ee fdBed<ed ddZ%e e gefeBed!<ed"ddZ&eeBed#<ee"dZ'e"ee(Bed$<ee$dZ)e$e*eBe$ee ffed%<dZ+eed&<dZ,e ed'<dZ-eed(<ee$dZ.e$ee fed)<ee/dZ0e/eed*<dZ1eed+<dZ2e*dBed,<dZ3e4dBed-<dZ5e4dBed.<ee"dZ6e"e7j8ed/<dZ9eed0<ee$dZ:e$e*eBe4fed1<dZ;ee4dBed4<dZ?eed5<dZ@eed6<eAdeBd7eCd8dfd9d:ZDeAdd;d7eCd8dfdeFd8eGeHeFffd?d@ZId&edAe d8e fdBdCZJdS)D_EffectiveRouteContextrNstarlette_routerfrontend_prefixr.rsrrrrrr_rrrTrFrrrrcCrr}rrmrmrmrnrrrz_EffectiveRouteContext.rrrrrcCrr}rrmrmrmrnrxrrcCrrrrmrmrmrnr{rrrrrqrvrwrxrrrrrrrrrrrzrrhrinclude_contextracCshtt|}||d}ttt||||jfid|jd|jdg|j|jdg|j|jd|j d|j d|j d i|j |j d |j pL|j d |jd |jd |jd|jd|jd|jd|jd|jd|jos|jdt|j|jj|jd|jd|jdg|j|jpgd|jdt|j|jj|jdt|j |jj |j d|j!|S)N)rrrrrrrrrrr_rrrrrrrrrrrqrrrrrr)"rrrrrsrrrrrrrrrr_rrrrrrrrrr>rrrrqrrrrrr)rrrr}contextrmrmrnfrom_api_routes        %*,z%_EffectiveRouteContext.from_api_route_FrontendRouteGroupcCs@g|j|j}|||j||jd}tdt|d\|_}|_|S)N)rrrrrrrt)rrrrryrrrz)rrrrrrr{rmrmrnfrom_frontend_route_groups" z0_EffectiveRouteContext.from_frontend_route_grouprbc Cst|jtr|j||jSt|jts!|jdusJ|j|S|ddkr,tj ifSt |}|j |}|s=tj ifS| }|D]\}}|j||||<qEt|di}|||j|d}|j} | rw|d| vrwtj|fStj|fS)Nrhttp path_params)rsrrB)rrrmatches_with_prefixrrrrrQrrBrvr groupdictrrxconvertrPr@rrsrPARTIALFULL) rrb route_pathrmatched_paramsrrrrrrmrmrnrs*           z_EffectiveRouteContext.matchesrcKst|jts|jdus J|jj|fi|St|}|j}t|}||jks/||kr5t ||t |j ||\}}|rCJt |ddS)Nr)rprotocol)rrrr url_path_forrkeysrxrqr@rRreplace_paramsrwrH)rrqr seen_paramsrxexpected_paramsrremaining_paramsrmrmrnr s     z#_EffectiveRouteContext.url_path_for)KrrrrPrrrrrrsrrrrrrr_rrrr;rrrrrrrrrrNr!rrrurrPrrrrrrrqrvrwrxrrrrrrrrrrrrrrr"rzrrhrrrrrrr[rrQrr rmrmrmrnr]s          &         6 r)frozenc@seZdZUeed<edddZedBed<edefddZ edeeBfd d Z ede dBfd d Z ede dBfd dZ ede dBfddZedee dBfddZededefdBfddZde defddZdS) RouteContextr}NF)rrepr_route_contextracCs|jdur |jjS|jSr})rrr}rrmrmrnr s zRouteContext.original_routecCs|jdur|jS|jSr})rr}rrmrmrn_effective_routes zRouteContext._effective_routecCt|jddS)NrrrrrmrmrnrzRouteContext.pathcCr)NrwrrrmrmrnrwrzRouteContext.path_formatcCr)Nrqrrrmrmrnrq!rzRouteContext.namecCr)Nrrrrmrmrnr%rzRouteContext.methods.cCr)Nrsrrrmrmrnrs)rzRouteContext.endpointrqcCs t|j|Sr}r)rrqrmrmrn __getattr__-r6zRouteContext.__getattr__)rrrrPrrrrpropertyrrrrrwrqrrrrrsrrmrmrmrnrs$ rc @sXeZdZUded<eed<eejdddZe ed<ee dZ e ded <d Z e d Bed <ee dZe d ed <d Ze d Bed<de dfddZde d fddZdeded BfddZdedeeeed Bed BffddZdedeeeffddZdedededd fddZdedededd fd d!Zdeefd"d#Zd$e d%e de fd&d'Z!d S)(_IncludedRouterroriginal_routerrF)rrcompare_effective_routes_lockrz(_EffectiveRouteContext | _IncludedRouter_effective_candidatesN_effective_candidates_versionr_effective_low_priority_routes&_effective_low_priority_routes_versionracCs|j}||jkr |jS|jT|j}||jkr%|jWdSg}|jjD])}t|trF|j |j}t|j|d}| |q+| |}|durT| |q+||_||_|WdS1sgwYdSNrr) r_get_routes_versionr!r rroutesrrrrappend_build_effective_context)rroutes_versioneffective_candidatesr}r child_branch route_contextrmrmrnr+As4         $z$_IncludedRouter.effective_candidatescCs|j}||jkr |jS|j\|j}||jkr%|jWdSg}|jjD]}||}|dur;||q+|jjD]}t |t r\|j |j }t |j|d}| |q@||_||_|WdS1sowYdSr$)rr&r#r"r_low_priority_routesr)r(r'rrrrrUeffective_low_priority_routes)rr*r/r}r-rr,rmrmrnr/Zs:         $z-_IncludedRouter.effective_low_priority_routesr}cCst|tr tj||jdSt|trtj||jdSt|tjr s   z(_IncludedRouter.effective_route_contextsrqrc KsF|D]}z |j|fi|WStjyYqwt||r})r>r r@rR)rrqrr-rmrmrnr s  z_IncludedRouter.url_path_for)"rrrrrr threadingLockrrrur r!rr"r#r+r/rPrr)r[rrQr;rrZr\rr=rr>rr rmrmrmrnr1sN  K $ rr'ccs:t|D]\}}|dur|jdur|jVq|VqdSr})_iter_routes_with_contextrr'r}r-rmrmrn_iter_included_route_candidatess  rCccsV|D]%}t|tr|Vqt|gD]\}}|dur!t|Vqt||VqqdSr})rrrA)r'r}rr-rmrmrniter_route_contexts$s  rDccs@|D]}t|tr|D]}|j|fVqq|dfVqdSr})rrr>rrBrmrmrnrA2s   rAcCs4|std|dstd|dkr|d}|S)NzA frontend path cannot be emptyrz#A frontend path must start with '/')AssertionError startswithrArrmrmrn_normalize_frontend_path=s  rHrcCs|s|S|dkr |S||S)Nrrmrrmrmrn_join_frontend_pathsGs rIcCs|dkrdSt|S)Nrr)lenrGrmrmrn_frontend_path_specificityOsrKcCstjt|Sr})osrrealpathfspathrGrmrmrn_get_resolved_absolute_pathUrrO directory check_dirautocCsP|dkr|StjddkrdStj|s&tjd|dt|ddd d S) NrR FASTAPI_ENV developmentTFrontend directory '+' does not exist. Resolved absolute path: '') stacklevelF)rLenvironr@risdirwarningswarnrOrPrQrmrmrn_resolve_frontend_check_dirYs r_cseZdZdeejeBdeddBdeddffdd Zdeddfd d Z defd d Z d e defddZ d e de fddZded e de fddZdedeeejdBffddZdedeeejefdBfddZdedefddZded e dede fddZZS)_FrontendStaticFilesrPfallbackrR index.html404.htmlNrQracsf||_|rtj|std|dt|dtj|d|dd|r/|dvr1||dSdSdS)NrUrVrWTF)rPhtmlrQfollow_symlink>rdrc) rarLrr[ RuntimeErrorrOr~r_check_fallback_file)rrPrarQrrmrnrls  z_FrontendStaticFiles.__init__cCsH||\}}|dust|js"td|d|jd|ddS)NFrontend fallback file '' does not exist in directory '!'. Resolved absolute directory: 'rW) lookup_pathstatS_ISREGst_modergrP_get_resolved_directoryrrar{ stat_resultrmrmrnrhsz)_FrontendStaticFiles._check_fallback_filecCs|jdusJt|jSr})rPrOrrmrmrnrps z,_FrontendStaticFiles._get_resolved_directoryrbcCs8t|td}t|tsJtjtjj| dS)Nrr) rr@_FASTAPI_FRONTEND_PATH_KEYrrrLrnormpathrr)rrbrrmrmrnget_pathsz_FrontendStaticFiles.get_pathcs4|js|IdHd|_||||IdHSr)config_checked check_config get_responserurrbrmrmrnget_response_for_scopes z+_FrontendStaticFiles.get_response_for_scopercs|ddvr||IdHdurtddtdd||IdH}|durO|\}}}|rH|ddsHt|d}|j|jdd }t|d S||||S|jd ks^|jd kri| d ri|j d |ddIdHS|jd ksx|jd kr| d rt |r|j d |ddIdHStdd)NrB)rHEADrrrrrrGurlrdrRrc) _lookup_static_resourcerIrLrFreplacerrM file_responsera_fallback_file_exists_fallback_response_is_frontend_navigation_request)rrrbstatic_resource full_pathrris_directory_indexrrmrmrnrxs,         z!_FrontendStaticFiles.get_responsec s|z t|j|IdHWStytdddty1}z|jtjkr+tddd|d}~wty=tdddw)Nir|r})rErlPermissionErrorrIOSErrorerrno ENAMETOOLONG ValueError)rrexcrmrmrn _lookup_paths      z!_FrontendStaticFiles._lookup_pathcs||IdH\}}|durdSt|jr||dfSt|jrBtj|d}||IdH\}}|durBt|jrB||dfSdS)NFrcT)rrmrnroS_ISDIRrLrr)rrrrr index_pathrmrmrnrs    z,_FrontendStaticFiles._lookup_static_resourcecCs"||\}}|duot|jSr})rlrmrnrorqrmrmrnrsz*_FrontendStaticFiles._fallback_file_existsrcs`t|j|IdH\}}|dust|js'td|d|jd|d|j||||dS)NrirjrkrWr|) rErlrmrnrorgrPrpr)rrarbrrrrrmrmrnrsz'_FrontendStaticFiles._fallback_response)rrrrrLPathLikerrrrhrpr[rurNrzrxrrrrrrrrrrmrmrrnr`ks>      r`acceptc cs|dD]7}tj}||d<|d}d}t|tr/zt|}Wn t y.Ynw| d| |fVqdS)N,rqg?r) rrGrHrIr get_paramrrfloatrrJrK)r raw_valuerHrqualityrmrmrn_iter_accept_media_typess       rcCs>t|}t|jddD]\}}|dvr|dkrdSq dS)Nrr> text/htmlapplication/xhtml+xmlrTF)rJrrFr@)rbrlr1rrmrmrnrs  rc @seZdZdddedeejeBdeddBded df d d Zd e d e e e ffd dZ d e ded e e e ffddZ deded edBfddZd e deded dfddZdeded efddZdS)_FrontendRouterRrarrPrarbNrQracCs8|dvrtdt||_ddh|_t|||d|_dS)N>NrRrdrcz:fallback must be 'auto', 'index.html', '404.html', or Nonerr{rPrarQ)rErHrrr`rorrrPrarQrmrmrnrs   z_FrontendRoute.__init__rbcCs|||jSr})matches_with_pathrryrmrmrnrsz_FrontendRoute.matchescCsn|ddkr tjifS||t|}|durtjifStt|tt|ii}|d|jvr2tj |fStj |fS)NrrrB) rQr_get_frontend_pathrBrrsrrKrrr)rrbrrrrmrmrnrs     z _FrontendRoute.matches_with_pathr cCsD|dkr |dS||krdS|d}||r |t|dSdS)Nrr)lstriprFrJ)rrr rrmrmrnr%s  z!_FrontendRoute._get_frontend_pathrcrdcs*|j|IdH}||||IdHdSr})rorz)rrbrcrdrjrmrmrnr/sz_FrontendRoute.handlerqrcK t||r}rRrrqrrmrmrnr 3rz_FrontendRoute.url_path_for)rrrrrLrrrrr[rrQrrrrZr\rrrHr rmrmrmrnrs$    rc@s,eZdZddddeejdBdedBddfddZdd d ed ee j eBd e d dBde ddf ddZ dedeeeffddZdededeeeffddZdededeeeedBffddZdedededdfddZdededefdd Zedededed!ededBd"e deefd#d$ZdS)%rNrrrrrrracCs8g|_t|pg|_||_tdt|jd\|_}|_dS)Nrrt)r'rurrrryrrrz)rrrrr{rmrmrnr8sz_FrontendRouteGroup.__init__rRrrrPrarbrQcCs|jt||||ddS)Nr)r'r(rrrmrmrnadd_frontend_routeKsz&_FrontendRouteGroup.add_frontend_routerbcCs|j|dd\}}}||fS)Nrrr;)rrbrrr{rmrmrnr\z_FrontendRouteGroup.matchesrcCs|j||d\}}}||fS)Nrr)rrbrrrr{rmrmrnr`rz'_FrontendRouteGroup.matches_with_prefixc Csd}d}|jD]=}t||j}|||\}}t|} |tjkr0|dus*| |dkr/||| f}q|tjkrD|dus?| |dkrD||| f}q|durT|\}}} tj||fS|durc|\}}} tj||fStjidfS)N) r'rIrrrKrQrrr) rrbrfullrsr}rrrrr{rmrmrnr;ds*           z_FrontendRouteGroup._matchrcrdc sNt|}t|tr|j|ur|j}|j}|j}|j}n d}|j}|j}|j}|j||d\} } } | t j ks:| dur?t ddt || | t j kr|r|jr|j||||||d4IdH1} | j|IdH} | jdurp| j| _| jj| jjj| |||IdHWdIdHdS1IdHswYdS| |||IdHdS)Nrrr}r|rn)rrrrrrrrzr;rQrrIrrrr_solve_dependenciesrorzrrrFrTrUrjr)rrbrcrdrrrrrrrr}rrjrmrmrnr{sL      z_FrontendRouteGroup.handlerqrcKrr}rrrmrmrnr rz _FrontendRouteGroup.url_path_forrrc Cs\t|||}|dt}|dt} z{t4IdHG} | |d<t4IdH&} | |d<t|||| |dIdH} | jr@t| j| VWdIdHn 1IdHsSwYWdIdHn 1IdHshwYW|tury|ddn||d<| tur|dddS| |d<dS|tur|ddn||d<| tur|ddw| |d<w)Nrerfrm)rJr@rr r.rr2r) rrbrcrdrrrrlprevious_inner_astackprevious_function_astackrhrirrmrmrnrsD    *(   z'_FrontendRouteGroup._solve_dependencies)rrrr rrrrrrLrrrrr[rrQrrrr;rZr\rrHr rr"rr&rrmrmrmrnr7sb      & rc9s~eZdZdZdddeeddddddedddddeeedddee e dfdee e e BdBe d fd ee ejdBe d fd eeee d fdeeee Bee effdBe dfdee edBe dfdee edBe dedfdeee dfdeedBe dfdeedBe dfdeeee dfdee egefdBe dfdee egefdBe d fd!eeedBe d"fd#eedBe d$fd%eee d&fd'eeege fe d(fd)eee d*fd+df&fd,d-Zdd.d/Zdd0eedBd+efd1d2Z dd3dd0eedBd+efd4d5Z   dd6e d7ee ge!eeBfd8e"e dBd9e dBd%ed+df fd:d; Z# dd6e d7ee$ge!dfd9e dBd+dffdd>d?d6ee e d@fdAee e&j'e Be dBfdCee(dDdBe dEfdFeee(d>Be dGfd+df dHdIZ)dJe*dKe+dLe,d+dfdMdNZ-dJe*dKe+dLe,d+dfdOdPZ.dJe*d+e/e0e*ffdQdRZ1d+e2ee3BfdSdTZ4dJe*d+e/e0e*edBe3dBffdUdVZ5dWe*dXe*d+efdYdZZ6   dd6e d8e"e dBd9e dBd%ed+ee7ge7ff d[d\Z8eddddddd]dddddddd^d^d^deeddddeeedd_d6e d7ed`efdaedbedBde e e BdBd e ejdBdce dBdde dBdee deee Bee effdBd#edBd8ee e e BdBdfe dBdge9dBdhe9dBdiedjedkedled%edmeee:Bd9e dBdneedBde edBdoee efdBd'eege fe:Bd)ee:Bd+df8dpdqZ;eddddddd]dddddddd^d^d^deedddeedrd6e daedbedBde e e BdBd e ejdBdce dBdde dBdee deee Bee effdBd#edBd8e e dBdfe dBdge9dBdhe9dBdiedjedkedled%edmeed9e dBde edBdoee efdBd'eege fd+ee7ge7ff2dsdtZ< dddud6e d7ed`efd9e dBd e ejdBd+df dvdwZ= dddud6ee e dxfd9ee dBe dyfd ee ejdBe dzfd+ee7ge7ffd{d|Z> dd6e d9e dBd+ee7ge7ffd}d~Z?dddeeddddeed d3ede dfdee e dfdee e e BdBe d fd ee ejdBe d fd eeee d fdeeee Bee effdBe dfdee edBe dfd#eedBe d$fd%eee dfd'eeege fe d(fd+dfddZ@eddddddd]ddddddd^d^d^deedddeedd6ee e dfdaeee dfdbeedBe dfdee e e BdBe dfd ee ejdBe dfdcee dBe dfddee dBe dfdeee e dfdeeee Bee effdBe dfd#eedBe dfdfee dBe dfdgee9dBe dfdhee9dBe dfdieee dfdjeee dfdkeee dfdleee dfd%eee dfdmeeee dfd9ee dBe dfdee edBe dfdoeee efdBe dfd'eeege fe d(fd+ee7ge7ff0ddZAeddddddd]ddddddd^d^d^deedddeedd6ee e dfdaeee dfdbeedBe dfdee e e BdBe dfd ee ejdBe dfdcee dBe dfddee dBe dfdeee e dfdeeee Bee effdBe dfd#eedBe dfdfee dBe dfdgee9dBe dfdhee9dBe dfdieee dfdjeee dfdkeee dfdleee dfd%eee dfdmeeee dfd9ee dBe dfdee edBe dfdoeee efdBe dfd'eeege fe d(fd+ee7ge7ff0ddZBeddddddd]ddddddd^d^d^deedddeedd6ee e dfdaeee dfdbeedBe dfdee e e BdBe dfd ee ejdBe dfdcee dBe dfddee dBe dfdeee e dfdeeee Bee effdBe dfd#eedBe dfdfee dBe dfdgee9dBe dfdhee9dBe dfdieee dfdjeee dfdkeee dfdleee dfd%eee dfdmeeee dfd9ee dBe dfdee edBe dfdoeee efdBe dfd'eeege fe d(fd+ee7ge7ff0ddZCeddddddd]ddddddd^d^d^deedddeedd6ee e dfdaeee dfdbeedBe dfdee e e BdBe dfd ee ejdBe dfdcee dBe dfddee dBe dfdeee e dfdeeee Bee effdBe dfd#eedBe dfdfee dBe dfdgee9dBe dfdhee9dBe dfdieee dfdjeee dfdkeee dfdleee dfd%eee dfdmeeee dfd9ee dBe dfdee edBe dfdoeee efdBe dfd'eeege fe d(fd+ee7ge7ff0ddZDeddddddd]ddddddd^d^d^deedddeedd6ee e dfdaeee dfdbeedBe dfdee e e BdBe dfd ee ejdBe dfdcee dBe dfddee dBe dfdeee e dfdeeee Bee effdBe dfd#eedBe dfdfee dBe dfdgee9dBe dfdhee9dBe dfdieee dfdjeee dfdkeee dfdleee dfd%eee dfdmeeee dfd9ee dBe dfdee edBe dfdoeee efdBe dfd'eeege fe d(fd+ee7ge7ff0ddZEeddddddd]ddddddd^d^d^deedddeedd6ee e dfdaeee dfdbeedBe dfdee e e BdBe dfd ee ejdBe dfdcee dBe dfddee dBe dfdeee e dfdeeee Bee effdBe dfd#eedBe dfdfee dBe dfdgee9dBe dfdhee9dBe dfdieee dfdjeee dfdkeee dfdleee dfd%eee dfdmeeee dfd9ee dBe dfdee edBe dfdoeee efdBe dfd'eeege fe d(fd+ee7ge7ff0ddZFeddddddd]ddddddd^d^d^deedddeedd6ee e dfdaeee dfdbeedBe dfdee e e BdBe dfd ee ejdBe dfdcee dBe dfddee dBe dfdeee e dfdeeee Bee effdBe dfd#eedBe dfdfee dBe dfdgee9dBe dfdhee9dBe dfdieee dfdjeee dfdkeee dfdleee dfd%eee dfdmeeee dfd9ee dBe dfdee edBe dfdoeee efdBe dfd'eeege fe d(fd+ee7ge7ff0ddZGeddddddd]ddddddd^d^d^deedddeedd6ee e dfdaeee dfdbeedBe dfdee e e BdBe dfd ee ejdBe dfdcee dBe dfddee dBe dfdeee e dfdeeee Bee effdBe dfd#eedBe dfdfee dBe dfdgee9dBe dfdhee9dBe dfdieee dfdjeee dfdkeee dfdleee dfd%eee dfdmeeee dfd9ee dBe dfdee edBe dfdoeee efdBe dfd'eeege fe d(fd+ee7ge7ff0ddZHdddZIdddZJde degefd+dfddZKeddee e dfd+ee7ge7ffddZLZMS)ra `APIRouter` class, used to group *path operations*, for example to structure an app in multiple files. It would then be included in the `FastAPI` app, or in another `APIRouter` (ultimately included in the app). Read more about it in the [FastAPI docs for Bigger Applications - Multiple Files](https://fastapi.tiangolo.com/tutorial/bigger-applications/). ## Example ```python from fastapi import APIRouter, FastAPI app = FastAPI() router = APIRouter() @router.get("/users/", tags=["users"]) async def read_users(): return [{"username": "Rick"}, {"username": "Morty"}] app.include_router(router) ``` rNT)rrrrrrrr'redirect_slashesrr route_class on_startup on_shutdownlifespanr_rrrrz'An optional path prefix for the router.ra A list of tags to be applied to all the *path operations* in this router. It will be added to the generated OpenAPI (e.g. visible at `/docs`). Read more about it in the [FastAPI docs for Path Operation Configuration](https://fastapi.tiangolo.com/tutorial/path-operation-configuration/). rra A list of dependencies (using `Depends()`) to be applied to all the *path operations* in this router. Read more about it in the [FastAPI docs for Bigger Applications - Multiple Files](https://fastapi.tiangolo.com/tutorial/bigger-applications/#include-an-apirouter-with-a-custom-prefix-tags-responses-and-dependencies). ra  The default response class to be used. Read more in the [FastAPI docs for Custom Response - HTML, Stream, File, others](https://fastapi.tiangolo.com/advanced/custom-response/#default-response-class). ra* Additional responses to be shown in OpenAPI. It will be added to the generated OpenAPI (e.g. visible at `/docs`). Read more about it in the [FastAPI docs for Additional Responses in OpenAPI](https://fastapi.tiangolo.com/advanced/additional-responses/). And in the [FastAPI docs for Bigger Applications](https://fastapi.tiangolo.com/tutorial/bigger-applications/#include-an-apirouter-with-a-custom-prefix-tags-responses-and-dependencies). rao OpenAPI callbacks that should apply to all *path operations* in this router. It will be added to the generated OpenAPI (e.g. visible at `/docs`). Read more about it in the [FastAPI docs for OpenAPI Callbacks](https://fastapi.tiangolo.com/advanced/openapi-callbacks/). r'a  **Note**: you probably shouldn't use this parameter, it is inherited from Starlette and supported for compatibility. --- A list of routes to serve incoming HTTP and WebSocket requests. a5 You normally wouldn't use this parameter with FastAPI, it is inherited from Starlette and supported for compatibility. In FastAPI, you normally would use the *path operation methods*, like `router.get()`, `router.post()`, etc. rz Whether to detect and redirect slashes in URLs when the client doesn't use the same format. rz Default function handler for this router. Used to handle 404 Not Found errors. rz Only used internally by FastAPI to handle dependency overrides. You shouldn't need to use it. It normally points to the `FastAPI` app object. ra4 Custom route (*path operation*) class to be used by this router. Read more about it in the [FastAPI docs for Custom Request and APIRoute class](https://fastapi.tiangolo.com/how-to/custom-request-and-route/#custom-apiroute-class-in-a-router). rz A list of startup event handler functions. You should instead use the `lifespan` handlers. Read more in the [FastAPI docs for `lifespan`](https://fastapi.tiangolo.com/advanced/events/). ra A list of shutdown event handler functions. You should instead use the `lifespan` handlers. Read more in the [FastAPI docs for `lifespan`](https://fastapi.tiangolo.com/advanced/events/). ra' A `Lifespan` context manager handler. This replaces `startup` and `shutdown` functions with a single context manager. Read more in the [FastAPI docs for `lifespan`](https://fastapi.tiangolo.com/advanced/events/). r_aa Mark all *path operations* in this router as deprecated. It will be added to the generated OpenAPI (e.g. visible at `/docs`). Read more about it in the [FastAPI docs for Path Operation Configuration](https://fastapi.tiangolo.com/tutorial/path-operation-configuration/). ra To include (or not) all the *path operations* in this router in the generated OpenAPI. This affects the generated OpenAPI (e.g. visible at `/docs`). Read more about it in the [FastAPI docs for Query Parameters and String Validations](https://fastapi.tiangolo.com/tutorial/query-params-str-validations/#exclude-parameters-from-openapi). ra Customize the function used to generate unique IDs for the *path operations* shown in the generated OpenAPI. This is particularly useful when automatically generating clients or SDKs for your API. Read more about it in the [FastAPI docs about how to Generate Clients](https://fastapi.tiangolo.com/advanced/generate-clients/#custom-generate-unique-id-function). ra Enable strict checking for request Content-Type headers. When `True` (the default), requests with a body that do not include a `Content-Type` header will **not** be parsed as JSON. This prevents potential cross-site request forgery (CSRF) attacks that exploit the browser's ability to send requests without a Content-Type header, bypassing CORS preflight checks. In particular applicable for apps that need to be run locally (in localhost). When `False`, requests without a `Content-Type` header will have their body parsed as JSON, which maintains compatibility with certain clients that don't send `Content-Type` headers. Read more about it in the [FastAPI docs for Strict Content-Type](https://fastapi.tiangolo.com/advanced/strict-content-type/). racs|dur t|}nt|rt|}n t|rt|}n|}||_tj||| |d|r@| ds7Jd| dr@Jd| durFgnt | |_ | durQgnt | |_ ||_|p\g|_t |pbg|_||_||_|pni|_|psg|_| |_| |_||_||_||_d|_g|_d|_dS)N)r'rrrr!A path prefix must start with '/'FA path prefix must not end with '/', as the routes will start with '/'r)rrisasyncgenfunctionrisgeneratorfunctionrrr~rrFrLrurrrrrrr_rrrrrrrr_routes_versionr._frontend_routes)rrrrrrrrr'rrrrrrrr_rrrrrrmrnrsNp          zAPIRouter.__init__cCs|jd7_dS)Nr)rrrmrmrn_mark_routes_changed rzAPIRouter._mark_routes_changedseencCs^|durt}t|}||vr|jS|||j}|jD]}t|tr,||j|7}q|Sr}) rrraddr'rrrr&)rr router_idversionr}rmrmrnr& s   zAPIRouter._get_routes_versionrcCsl|durt}t|}||vrdS|||jD]}t|ts!q|j|ur)dS|j||r3dSqdS)NFT)rrrr'rrr_contains_router)rrrrr}rmrmrnr s    zAPIRouter._contains_routerrrsrrqcs"tj|||||d|dSN)rrqr)r~ add_router)rrrsrrqrrrmrnr, s zAPIRouter.add_routecstj|||d|dSNr1)r~add_websocket_router)rrrsrqrrmrnr= s zAPIRouter.add_websocket_routerR)rarQz` The URL path prefix where the frontend build should be served. rPz\ The directory containing the static frontend build output. rarbzX The fallback file behavior for missing frontend paths. rQa` Check that the frontend directory exists when the app is created. When set to `"auto"`, skip the check with a warning when `FASTAPI_ENV` is `"development"`, and check it otherwise. The `fastapi dev` command sets `FASTAPI_ENV` to `"development"` if it is not already set. cCsft||d}t|}|jdurt|j|jd|_|j|j|jjt |j ||||d| dS)uh Serve a static frontend build as low-priority routes. Use this for frontend tools that build static files into a directory, such as `dist`. **FastAPI** path operations are checked first, and the frontend files are checked only if no normal route matched. A typical project could look like this: ```text . ├── pyproject.toml ├── app │ ├── __init__.py │ └── main.py └── dist ├── index.html └── assets └── app.js ``` Then in `app/main.py`: ```python from fastapi import APIRouter, FastAPI app = FastAPI() router = APIRouter() router.frontend("/", directory="dist") app.include_router(router) ``` r^Nrr) r_rHrrrrrr.r(rrIrr)rrrPrarQnormalized_pathrmrmrnfrontendF s"G   zAPIRouter.frontendrbrcrdcs4|ddvs Jd|vr||d<|ddkr#||||IdHdSd}|jD]-}||\}}|tjkrH||||||IdHdS|tjkrU|durU||f}q(|duro|\}}||||||IdHdSt|}|ddkr|j r|dkrt |} | dr| d d| d<n| dd| d<|jD]&}|| \}} |tj krt| d} tt| d } | |||IdHdSq||\} }}}| tj kr|durt|||dur|t|t<|j}t|tr||d <||||IdHdS||||IdHdS||||IdHdS) Nr)rrlrrrrrrrr~r})rr'rrQrrrrrBrrPrLrArrFrMr_match_low_priorityrrrrrrr)rrbrcrdrsr}rrr redirect_scoper{ redirect_urlrjlow_priority_matchlow_priority_scopelow_priority_routelow_priority_contextrrmrmrnro sn              z APIRouter.appcsNt|}t|tr|j|ur||||IdHdS||||IdHdSr})rrrrr=ro)rrbrcrdrrmrmrnr s zAPIRouter.handlecCs@t|}t|tr|j|ur||\}}}}||fStjifSr})rrrrr;rQr)rrbrrrr{rmrmrnr s  zAPIRouter.matchesccs6|jEdH|jD]}t|tr|EdHq dSr})r.r'rrr/rrmrmrn_iter_low_priority_routes s   z#APIRouter._iter_low_priority_routesc Cs\d}d}|D]~}t|trN|}|j}t|trAt|}|tt}||t<z| |\} } Wt |t|nt |t|w|} n| |\} } |j pL|} n d}| |\} } |} | t j krp|dusj|| |dro| | |f}q| t jkr|dus|| |dr| | |f}q|dur|\} } }t j | | |fS|dur|\} } }t j| | |fSt jiddfSr-)rrrrrrr@rrrrrrQr _frontend_match_is_more_specificrr) rrbrrsr9r-rrr:rrr}rmrmrnr s`            zAPIRouter._match_low_priorityrprevious_child_scopecCs,t|}t|}|dus|durdS||kSNF)r)rrrrprevious_specificityrmrmrnr- s z*APIRouter._frontend_match_is_more_specificcs"dtdtffdd }|S)Nr`racsj|d|Sr)rrwrrrqrrrmrn decorator= sz"APIRouter.route..decoratorr:)rrrrqrrrmrrnr}6 s zAPIRouter.routerF)rrrrrrrrrr_rrrrrrrrrrrqroute_class_overriderrrr.rrrrrrrrrrrrrrrc$Cs|p|j}| pi} i|j| }t||j}|j}|r"|||j} |r.| ||j}!|r:|!|t||j }"||j |fid|d|d|d|d| d|d|d| d |d | pg|j d | d | d |d|d|d|d|d|d|o|j d|d|d|j d|!d|d|"dt||j}#|j|#|dSd|d|d|j d|!d|d|"dt||j}#|j|#|dS)Nrsrrrrrrrrrr_rrrrrrrrrrrqrrrrr)rrr>rrr4rUrrrrrr_rrrr'r(r)$rrrsrrrrrrrrrr_rrrrrrrrrrrqrrrrrrcombined_responsescurrent_response_class current_tagscurrent_dependenciescurrent_callbacksrr}rmrmrn add_api_routeI s                 zAPIRouter.add_api_route)rrrrrrrrrr_rrrrrrrrrrrqrrrcsJdtdtf fdd }|S)Nr`racsj |fid dddddd dd d d d d dddddd dddd|S)Nrrrrrrrrrr_rrrrrrrrrrrqrrr)rrwrrrr_rrrrrqrrrrrrrrrrrrrrrrrrmrnr sf     z&APIRouter.api_route..decoratorr)rrrrrrrrrrrr_rrrrrrrrrrrqrrrrrmrrn api_route sFzAPIRouter.api_route)rrcCsJ|j}|r ||t|j|||||jd}|j||dS)Nr0) rrr4rUrprrr'r(r)rrrsrqrrrr}rmrmrnadd_api_websocket_route s    z!APIRouter.add_api_websocket_routez1 WebSocket path. zQ A name for the WebSocket. Only used internally. a A list of dependencies (using `Depends()`) to be used for this WebSocket. Read more about it in the [FastAPI docs for WebSockets](https://fastapi.tiangolo.com/advanced/websockets/). cs dtdtffdd }|S)a Decorate a WebSocket function. Read more about it in the [FastAPI docs for WebSockets](https://fastapi.tiangolo.com/advanced/websockets/). **Example** ## Example ```python from fastapi import APIRouter, FastAPI, WebSocket app = FastAPI() router = APIRouter() @router.websocket("/ws") async def websocket_endpoint(websocket: WebSocket): await websocket.accept() while True: data = await websocket.receive_text() await websocket.send_text(f"Message text was: {data}") app.include_router(router) ``` r`racsj|d|S)N)rqrr)rrwrrrqrrrmrnr, sz&APIRouter.websocket..decoratorr)rrrqrrrrmrrnrl s;zAPIRouter.websocketcsdtdtffdd }|S)Nr`racsj|d|Sr)rrwrqrrrmrnr7 sz,APIRouter.websocket_route..decoratorr)rrrqrrmrrnwebsocket_route4 szAPIRouter.websocket_routerzThe `APIRouter` to include.z Include (or not) all the *path operations* in this router in the generated OpenAPI schema. This affects the generated OpenAPI (e.g. visible at `/docs`). c  CsR||usJd||rJd|r&|dsJd|dr%JdnCt|jD]=\} } | dur@t| dd} t| dd }n| jdurTt| jdd} t| jdd }n| j} | j}| durh| sht d |d q+t j |||||||||| | d }|j t ||d ||jD]}|d|q|jD]}|d|qt|j|j|_dS)a| Include another `APIRouter` in the same current `APIRouter`. Read more about it in the [FastAPI docs for Bigger Applications](https://fastapi.tiangolo.com/tutorial/bigger-applications/). ## Example ```python from fastapi import APIRouter, FastAPI app = FastAPI() internal_router = APIRouter() users_router = APIRouter() @users_router.get("/users/") def read_users(): return [{"name": "Rick"}, {"name": "Morty"}] internal_router.include_router(users_router) app.include_router(internal_router) ``` zcCannot include the same APIRouter instance into itself. Did you mean to include a different router?zsCannot include an APIRouter instance that already includes this router. Did you mean to include a different router?rrrNrrqunknownz6Prefix and path cannot be both empty (path operation: )) rrrrrrrrrr_rrr%startupshutdown)rrFrLrAr'rrrrqr1rrr(rrradd_event_handlerrrr)rrrrrrrrrr_rrr}r-rrqrhandlerrmrmrninclude_router= sf           zAPIRouter.include_router)rrrrrrrrrr_rrrrrrrrrrqrrrz The URL path to be used for this *path operation*. For example, in `http://example.com/items`, the path is `/items`. a The type to use for the response. It could be any valid Pydantic *field* type. So, it doesn't have to be a Pydantic model, it could be other things, like a `list`, `dict`, etc. It will be used for: * Documentation: the generated OpenAPI (and the UI at `/docs`) will show it as the response (JSON Schema). * Serialization: you could return an arbitrary object and the `response_model` would be used to serialize that object into the corresponding JSON. * Filtering: the JSON sent to the client will only contain the data (fields) defined in the `response_model`. If you returned an object that contains an attribute `password` but the `response_model` does not include that field, the JSON sent to the client would not have that `password`. * Validation: whatever you return will be serialized with the `response_model`, converting any data as necessary to generate the corresponding JSON. But if the data in the object returned is not valid, that would mean a violation of the contract with the client, so it's an error from the API developer. So, FastAPI will raise an error and return a 500 error code (Internal Server Error). Read more about it in the [FastAPI docs for Response Model](https://fastapi.tiangolo.com/tutorial/response-model/). aM The default status code to be used for the response. You could override the status code by returning a response directly. Read more about it in the [FastAPI docs for Response Status Code](https://fastapi.tiangolo.com/tutorial/response-status-code/). ac A list of tags to be applied to the *path operation*. It will be added to the generated OpenAPI (e.g. visible at `/docs`). Read more about it in the [FastAPI docs for Path Operation Configuration](https://fastapi.tiangolo.com/tutorial/path-operation-configuration/#tags). a[ A list of dependencies (using `Depends()`) to be applied to the *path operation*. Read more about it in the [FastAPI docs for Dependencies in path operation decorators](https://fastapi.tiangolo.com/tutorial/dependencies/dependencies-in-path-operation-decorators/). aL A summary for the *path operation*. It will be added to the generated OpenAPI (e.g. visible at `/docs`). Read more about it in the [FastAPI docs for Path Operation Configuration](https://fastapi.tiangolo.com/tutorial/path-operation-configuration/). a A description for the *path operation*. If not provided, it will be extracted automatically from the docstring of the *path operation function*. It can contain Markdown. It will be added to the generated OpenAPI (e.g. visible at `/docs`). Read more about it in the [FastAPI docs for Path Operation Configuration](https://fastapi.tiangolo.com/tutorial/path-operation-configuration/). z The description for the default response. It will be added to the generated OpenAPI (e.g. visible at `/docs`). z Additional responses that could be returned by this *path operation*. It will be added to the generated OpenAPI (e.g. visible at `/docs`). z Mark this *path operation* as deprecated. It will be added to the generated OpenAPI (e.g. visible at `/docs`). a Custom operation ID to be used by this *path operation*. By default, it is generated automatically. If you provide a custom operation ID, you need to make sure it is unique for the whole API. You can customize the operation ID generation with the parameter `generate_unique_id_function` in the `FastAPI` class. Read more about it in the [FastAPI docs about how to Generate Clients](https://fastapi.tiangolo.com/advanced/generate-clients/#custom-generate-unique-id-function). a\ Configuration passed to Pydantic to include only certain fields in the response data. Read more about it in the [FastAPI docs for Response Model - Return Type](https://fastapi.tiangolo.com/tutorial/response-model/#response_model_include-and-response_model_exclude). aW Configuration passed to Pydantic to exclude certain fields in the response data. Read more about it in the [FastAPI docs for Response Model - Return Type](https://fastapi.tiangolo.com/tutorial/response-model/#response_model_include-and-response_model_exclude). a| Configuration passed to Pydantic to define if the response model should be serialized by alias when an alias is used. Read more about it in the [FastAPI docs for Response Model - Return Type](https://fastapi.tiangolo.com/tutorial/response-model/#response_model_include-and-response_model_exclude). a Configuration passed to Pydantic to define if the response data should have all the fields, including the ones that were not set and have their default values. This is different from `response_model_exclude_defaults` in that if the fields are set, they will be included in the response, even if the value is the same as the default. When `True`, default values are omitted from the response. Read more about it in the [FastAPI docs for Response Model - Return Type](https://fastapi.tiangolo.com/tutorial/response-model/#use-the-response_model_exclude_unset-parameter). a Configuration passed to Pydantic to define if the response data should have all the fields, including the ones that have the same value as the default. This is different from `response_model_exclude_unset` in that if the fields are set but contain the same default values, they will be excluded from the response. When `True`, default values are omitted from the response. Read more about it in the [FastAPI docs for Response Model - Return Type](https://fastapi.tiangolo.com/tutorial/response-model/#use-the-response_model_exclude_unset-parameter). a~ Configuration passed to Pydantic to define if the response data should exclude fields set to `None`. This is much simpler (less smart) than `response_model_exclude_unset` and `response_model_exclude_defaults`. You probably want to use one of those two instead of this one, as those allow returning `None` values when it makes sense. Read more about it in the [FastAPI docs for Response Model - Return Type](https://fastapi.tiangolo.com/tutorial/response-model/#response_model_exclude_none). a Include this *path operation* in the generated OpenAPI schema. This affects the generated OpenAPI (e.g. visible at `/docs`). Read more about it in the [FastAPI docs for Query Parameters and String Validations](https://fastapi.tiangolo.com/tutorial/query-params-str-validations/#exclude-parameters-from-openapi). ae Response class to be used for this *path operation*. This will not be used if you return a response directly. Read more about it in the [FastAPI docs for Custom Response - HTML, Stream, File, others](https://fastapi.tiangolo.com/advanced/custom-response/#redirectresponse). zW Name for this *path operation*. Only used internally. a List of *path operations* that will be used as OpenAPI callbacks. This is only for OpenAPI documentation, the callbacks won't be used directly. It will be added to the generated OpenAPI (e.g. visible at `/docs`). Read more about it in the [FastAPI docs for OpenAPI Callbacks](https://fastapi.tiangolo.com/advanced/openapi-callbacks/). ah Extra metadata to be included in the OpenAPI schema for this *path operation*. Read more about it in the [FastAPI docs for Path Operation Advanced Configuration](https://fastapi.tiangolo.com/advanced/path-operation-advanced-configuration/#custom-openapi-path-operation-schema). cC|jdid|d|d|d|d|d|d|d|d | d | d d gd | d| d| d|d|d|d|d|d|d|d|d|d|S)ax Add a *path operation* using an HTTP GET operation. ## Example ```python from fastapi import APIRouter, FastAPI app = FastAPI() router = APIRouter() @router.get("/items/") def read_items(): return [{"name": "Empanada"}, {"name": "Arepa"}] app.include_router(router) ``` rrrrrrrrrrr_rrrrrrrrrrrrqrrrNrmrrrrrrrrrrrrr_rrrrrrrrrrqrrrrmrmrnr@ f `     z APIRouter.getcCr)a% Add a *path operation* using an HTTP PUT operation. ## Example ```python from fastapi import APIRouter, FastAPI from pydantic import BaseModel class Item(BaseModel): name: str description: str | None = None app = FastAPI() router = APIRouter() @router.put("/items/{item_id}") def replace_item(item_id: str, item: Item): return {"message": "Item replaced", "id": item_id} app.include_router(router) ``` rrrrrrrrrrr_rPUTrrrrrrrrrrqrrrNrmrrrmrmrnputsf e     z APIRouter.putcCr)a Add a *path operation* using an HTTP POST operation. ## Example ```python from fastapi import APIRouter, FastAPI from pydantic import BaseModel class Item(BaseModel): name: str description: str | None = None app = FastAPI() router = APIRouter() @router.post("/items/") def create_item(item: Item): return {"message": "Item created"} app.include_router(router) ``` rrrrrrrrrrr_rPOSTrrrrrrrrrrqrrrNrmrrrmrmrnpostrzAPIRouter.postcCr)a Add a *path operation* using an HTTP DELETE operation. ## Example ```python from fastapi import APIRouter, FastAPI app = FastAPI() router = APIRouter() @router.delete("/items/{item_id}") def delete_item(item_id: str): return {"message": "Item deleted"} app.include_router(router) ``` rrrrrrrrrrr_rDELETErrrrrrrrrrqrrrNrmrrrmrmrndeleteorzAPIRouter.deletecCr)a Add a *path operation* using an HTTP OPTIONS operation. ## Example ```python from fastapi import APIRouter, FastAPI app = FastAPI() router = APIRouter() @router.options("/items/") def get_item_options(): return {"additions": ["Aji", "Guacamole"]} app.include_router(router) ``` rrrrrrrrrrr_rOPTIONSrrrrrrrrrrqrrrNrmrrrmrmrnoptionsrzAPIRouter.optionscCr)a0 Add a *path operation* using an HTTP HEAD operation. ## Example ```python from fastapi import APIRouter, FastAPI from pydantic import BaseModel class Item(BaseModel): name: str description: str | None = None app = FastAPI() router = APIRouter() @router.head("/items/", status_code=204) def get_items_headers(response: Response): response.headers["X-Cat-Dog"] = "Alone in the world" app.include_router(router) ``` rrrrrrrrrrr_rr{rrrrrrrrrrqrrrNrmrrrmrmrnheadarzAPIRouter.headcCr)a  Add a *path operation* using an HTTP PATCH operation. ## Example ```python from fastapi import APIRouter, FastAPI from pydantic import BaseModel class Item(BaseModel): name: str description: str | None = None app = FastAPI() router = APIRouter() @router.patch("/items/") def update_item(item: Item): return {"message": "Item updated in place"} app.include_router(router) ``` rrrrrrrrrrr_rPATCHrrrrrrrrrrqrrrNrmrrrmrmrnpatchrzAPIRouter.patchcCr)a Add a *path operation* using an HTTP TRACE operation. ## Example ```python from fastapi import APIRouter, FastAPI from pydantic import BaseModel class Item(BaseModel): name: str description: str | None = None app = FastAPI() router = APIRouter() @router.trace("/items/{item_id}") def trace_item(item_id: str): return None app.include_router(router) ``` rrrrrrrrrrr_rTRACErrrrrrrrrrqrrrNrmrrrmrmrntrace]rzAPIRouter.tracec.|jD]}t|r|IdHq|qdS)z Run any `.on_startup` event handlers. This method is kept for backward compatibility after Starlette removed support for on_startup/on_shutdown handlers. Ref: https://github.com/Kludex/starlette/pull/3117 N)rrCrrrmrmrnr  zAPIRouter._startupcr)z Run any `.on_shutdown` event handlers. This method is kept for backward compatibility after Starlette removed support for on_startup/on_shutdown handlers. Ref: https://github.com/Kludex/starlette/pull/3117 N)rrCrrmrmrnrrzAPIRouter._shutdown event_typer`cCs4|dvsJ|dkr|j|dS|j|dS)a  Add an event handler function for startup or shutdown. This method is kept for backward compatibility after Starlette removed support for on_startup/on_shutdown handlers. Ref: https://github.com/Kludex/starlette/pull/3117 )rrrN)rr(r)rrr`rmrmrnrs zAPIRouter.add_event_handlerz on_event is deprecated, use lifespan event handlers instead. Read more about it in the [FastAPI docs for Lifespan Events](https://fastapi.tiangolo.com/advanced/events/). zM The type of event. `startup` or `shutdown`. csdtdtffdd }|S)a Add an event handler for the router. `on_event` is deprecated, use `lifespan` event handlers instead. Read more about it in the [FastAPI docs for Lifespan Events](https://fastapi.tiangolo.com/advanced/events/#alternative-events-deprecated). r`racs||Sr})rrwrrrmrnr+s z%APIRouter.on_event..decoratorr)rrrrmrrnon_eventszAPIRouter.on_eventrr})NNT)Nrrrrr rKrr=rrrrurr rrrrNrPrrrPr_rrXrrYrrrr&rrJrrrr^rrLrrrr[rZr\rorrrQrrrrrrr:r}r;r!rrrrlrrr@rrrrrrrrrrrrrmrmrrnrs          )9 G  ]foz! -:H Wn "   #    & Y@    2                 X          B   '    D        *: HU` o l              /<I Ubt~ '3?K]n " 2>  M *              /<I Ubt~ '3?K]n " 2>  M /              /<I Ubt~ '3?K]n " 2>  M /              /<I Ubt~ '3?K]n " 2>  M *              /<I Ubt~ '3?K]n " 2>  M *              /<I Ubt~ '3?K]n " 2>  M /              /<I Ubt~ '3?K]n " 2>  M /              /<I Ubt~ '3?K]n " 2>  M      rrr)rr4 email.messagerGrrrrrrLrmr?rr\collections.abcrrrrrrrr r r r r r contextvarsr dataclassesrrenumrrtypingrrrrrrr annotated_docr anyio.abcrrrfastapi._compatrrrfastapi.datastructuresr r!fastapi.dependencies.modelsr"r#r$r%fastapi.dependencies.utilsr&r'r(r)r*r+r,r-r.fastapi.encodersr/fastapi.exceptionsr0r1r2r3r4 fastapi.sser5r6r7r8r9 fastapi.typesr:r; fastapi.utilsr<r=r>r? starletter@starlette._exception_handlerrAstarlette._utilsrBrCstarlette.concurrencyrDrEstarlette.datastructuresrFrGrHstarlette.exceptionsrIstarlette.requestsrJstarlette.responsesrKrLrMrNrOstarlette.routingrPrQrRrSrTrUstarlette.staticfilesrVstarlette.typesrWrXrYrZr[r\starlette.websocketsr^typing_extensionsr_rurxryrzrrrrrPrrrrrrrrrrkror3rprrrsrrrrrrrrruryrrrrrrrrrrr2rrrrrrCrDrArHrIrKrrOr_r`rrrrrr6rrmrmrmrns ,     ,           ,        +              %'      0          ! &X+(k        y 8