%ihSrSSKrSSKrSSKrSSKrSSKrSSKJrJrJrJ r SSK J r J r SSK Jr SSKJr SSKJrJrJrJrJrJrJrJrJrJr SSKJr SS KJrJ r J!r! SS K"J#r#J$r$ SS K%J&r& SS K'J(r(J)r)J*r* SS K+J,r,J-r- SSK.J/r/ SSK0J1r1 SSK2J3r3J4r4 SSK5J6r6J7r7 SSK8J9r9 SSK:J;r; SSKr> SSK?J@r@ SSKAJBrB SSKCJDrD SSKEJFrF SSKGJHrH SSKIJJrJJKrKJLrLJMrMJNrNJOrOJPrPJQrQ SSKRJSrS \7"5 \6"\T5rU\>"5rV\;"5rW\,"\9S9rX\"SSSS 9rY\X\YRlX\YR\/\-5 \"S!S"9r\1S#kr]\VRRS$:XaS$/OB\VRRRS%5Vs/sHoR5PM snrb\YR\\bS&S$/S$/S'9 \YRS(5S)\4S*j5re\YRS(5S)\4S+j5rf\YRS(5S)\4S,j5rg\YRS(5S)\4S-j5rh\YRS(5S)\4S.j5ri\"\j5RRS/- rl\lR5(aR\YRS0\&"\o"\lS1- 5S29S1S39 \lS1- S4- rp\pRS&S&S59 \YRS6\&"\o"\p5S&S79S8S39 \YRS95S:5rs\YRS;5S<5rt\$"5ruS=rv\"\u54S>\#4S?jjrw"S@SA\(5rx"SBSC\(5ry"SDSE\(5rz"SFSG\(5r{"SHSI\(5r|"SJSK\(5r}"SLSM\(5r~"SNSO\(5r"SPSQ\(5r"SRSS\(5r"STSU\(5r"SVSW\(5r"SXSY\(5r"SZS[\(5r"S\S]\(5r"S^S_\(5r"S`Sa\(5r"SbSc\(5r"SdSe\(5r"SfSg\(5r"ShSi\(5r"SjSk\(5r"SlSm\(5r"SnSo\(5r"SpSq\(5r"SrSs\(5r"StSu\(5r"SvSw\(5r"SxSy\(5r"SzS{\(5rS|\oS}\o4S~jrS\S\S\\oS}\\o4SjrS\S\oS\S}\S-4SjrS\S\S\S\oS\S}\4 Sjr\YGR;S\S9S5r\YGR;S65\YGR;S\S9S55r\YGR;S\S9\YGR;S\S9S55r\YGR;S\S9S\4Sj5r\YGR;S\S9S\4Sj5r\YGR;S\S9S\4Sj5r\YGR;S\S9S\4Sj5r\YGR;S\S9\YGR;S\S9S55r\YGR;S\S9S\4Sj5r\YGR;S\S9S5r\YGR;S\S9S5r\YGR;S\S9S5r\YGR;S\S9S5r\YGR;S\xS9\XGRWS5S)\4Sj55r\\GR;S\S9\XGRWS5\"SSS9\"SSS9\"SSS9\"SSS9\"SSS9\"\v54S)\S\S\S\oS-S\oS-S\oS\34Sjj55r\\GR;S\{S9\XGRWS5\"\v54S)\S\S\34Sjj55r\\GR;S\S9\XGRWS5\"SSS9\"SSS9\"\v54S)\S\S\S\34Sjj55r\\GR;S\S9\XGRWS5\"SSS9\"SSS9\"\v54S)\S\S\S\34Sjj55r\\GR;S\|S9\XGRWS5\"\v54S)\S\S\34Sjj55r\\GR;S\}S9\XGRWS5\"\v54S)\S\S\34Sjj55r\\GR;S5\XGRWS5\"\v54S)\S\S\34Sjj55r\\GR;S\S9\XGRWS5\"SSS9\"SSS9\"SSS9\"SSS9\"SSS9\"\v54S)\S\oS-S\oS-S\S\S\oS-S\34Sjj55r\\GRkS\S9\"SSS9\"\v5\"\w54S)\S\oS\3S\o4Sjj5r\\GRkS\S9\"\v5\"\w54S)\S\3S\o4Sjj5r\\GRkS\S9\"\v5\"\w54S)\S\3S\o4Sjj5r\\GR;S\S9\XGRWS5\"\w54S)\S\o4Sjj55r\\GRkS\SS9\XGRWS5\"\w54S)\S\S\o4Sjj55r\\GRwS\S9\XGRWS5\"\w54S)\S\oS\o4Sjj55r\\GRkS\SS9\"\v5\"\w54S)\S\3S\o4Sjj5r\\GR;S\S9\"SSSS9\"SSSS9\"\v5\"\w54S\S\S\3S\o4Sjj5r\\GR;S\S9\"\v5\"\w54S\oS\oS\3S\o4Sjj5r\\GR;S\S9\XGRWS5\"\v54S)\S\S\34Sjj55r\\GR;S5\XGRWS5\"SSS9\"\v54S)\S\oS-S\34Sjj55r\\GR;S5\XGRWS5\"\v54S)\S\S\34Sjj55r\\GR;S\S9\XGRWS5\"SSSS9\"\v54S)\GS\S\34GSjj55r\\GR;GS5\XGRWGS5\"SGSS9\"GSGSGSS9\"\v54S)\GS\oS-S\S\34GS jj55r\\GR;GS 5\XGRWGS5\"SGSS9\"GSGSGSS9\"\v54S)\GS\oS-S\S\34GS jj55r\\GR;GS 5\XGRWGS5\"SSS9\"SSS9\"SGS GSS9\"\v54S)\S\oS-S\oS-S\S\34 GSjj55r\\GR;GS5\XGRWGS5\"SSS9\"SSS9\"SGS GSS9\"\v54S)\S\oS-S\oS-S\S\34 GSjj55r\\GR;GS5\XGRWGS5\"\v54S)\S\S\34GSjj55r\YGRGS5GS\S\4GSj5r\YGR;GS\ S9GS5r\YGR\\5 \TGS:XaSSKr\GR"\YGSGSGS9 ggs snf(z.FastAPI application for TipSharks ratings API.N)UTCdatedatetime timedelta)BytesIOStringIO)Path)Any) APIRouterDependsFastAPI HTTPExceptionQueryRequestResponseSecurity WebSocketWebSocketDisconnect)CORSMiddleware) HTMLResponsePlainTextResponseRedirectResponse)HTTPAuthorizationCredentials HTTPBearer) StaticFiles) BaseModel ConfigDictField)Limiter_rate_limit_exceeded_handler)RateLimitExceeded)func)Session joinedload) get_logger setup_logging)get_user_rate_limit_key)TipSharksScheduler)HRNZ_ALL_CLUB_CODES get_settings parse_date)recompute_ratings) AuditLogger get_session)IngestionService)AuditLogDriver EntityTypeHorseMeetingRaceRatingSnapshotTrainer)RatingSnapshotRepository)key_funcz TipSharks APIzVAdvanced harness racing ratings and predictions powered by multi-runner Elo algorithms0.2.0)title descriptionversion/v1)prefix>/admin/races/ratings/webhook /analytics /predictions*,T) allow_originsallow_credentials allow_methods allow_headershttprequestc.# URRn[H`nURU5(dMSU3nURR(aUSURR3n[ USS9s $ U"U5IShvN $N7f)zRedirect legacy API paths to /v1/ equivalents. Handles GET, POST, and other methods transparently via 301 redirect. Preserves query string parameters. Keeps /health, /ui/*, /static, /docs/site, and root at their original paths. r@?i-)url status_codeN)rRpath_LEGACY_API_PREFIXES startswithqueryr)rO call_nextrTrAnew_paths :/root/tipsharks/tipsharks-elo-api/apps/backend/api/main.pylegacy_api_redirectsr[ls ;;  D& ??6 " "TF|H{{  &Zq):):(;<#cB B '7# ## #s4BABBBc.# U"U5IShvN nURRRS5(aTURR SS5 URR SS5 URR SS5 U$N7f) z.Avoid stale API responses in browsers/proxies.N)z /v1/ratingsz /v1/racesrDrC Cache-Control.no-store, no-cache, must-revalidate, max-age=0Pragmano-cacheExpires0)rRrTrVheaders setdefault)rOrXresponses rZadd_no_cache_headersrfsw''H{{""#UVV## M  ##Hj9##Is3 O(s BBBBc# SSKnURRS[UR 555nX0R lU"U5IShvN nX4RS'U$N7f)zAdd a unique request ID to every request and response. Reads ``x-request-id`` from the incoming request headers if present, otherwise generates a new UUID. The ID is stored on ``request.state`` and echoed back in the ``x-request-id`` response header. rNz x-request-id)uuidrcgetstruuid4state request_id)rOrXrhrmres rZadd_request_idrnsZ$$^S5FGJ)MMw''H'1^$ O(sAA,A*A,c (# SSKJn U"5nU"U5IShvN nU"5U- n[RSURURR UR [US-S5[URSS5S.S 9 U$Nt7f) zLog basic information about every API request. Records HTTP method, path, status code, duration, and the request ID (if one was assigned by the ``add_request_id`` middleware). r)timeNz API requestrm)methodrTrS duration_msrmextra) rploggerinforsrRrTrSroundgetattrrl)rOrXrpstartredurations rZ log_requestsr}s FEw''Hv~H KKnnKK$$#// D!4!'--tD    O(sBBA5Bc L# URRnURS5(d<URS5(d&URS5(dU"U5IShvN $Sn[5nUR [ R "[R55R5nUb"URcUR[S9nUnSSS5 UbNSUR;a>URSn[R "US5R[S9nX7::aU"U5IShvN nSn UR&ShvN n X- n MN!,(df  N=f![a Nf=f!["[$4a Ncf=fN[NE O![a Us$f=f[(R*"U 5R-5n S U S 3n XRS 'UbUR/S5URS 'URR1S 5n U (a?U R3S 5U :Xa*[5S U URR1S S5SSSS.S9$[5U UR6[9UR5UR:S9$7f)aTAdd ETag and Last-Modified headers to rating endpoints for conditional requests. Computes an ETag from the response body (MD5 hash) and sets Last-Modified from the most recent rating snapshot timestamp. Handles If-None-Match and If-Modified-Since request headers to return 304 Not Modified when the client's cached version is still valid. z/v1/ratings/horsesz/v1/ratings/driversz/v1/ratings/trainersN)tzinfozif-modified-sincez%a, %d %b %Y %H:%M:%S GMT"ETag Last-Modifiedz if-none-matchi0r^r`rb)rrr]r_ra)rSrc)contentrSrc media_type)rRrTrVr0rWr"maxr8 created_atscalarrreplacer Exceptionrcrstrptime ValueError TypeError body_iteratorhashlibmd5 hexdigeststrftimeristriprrSdictr)rOrXrT last_modifiedsession latest_tsims_strimsrebodychunketag_hex etag_value if_none_matchs rZrating_etag_middlewarers ;;  D ,-- ??0 1 1 ??1 2 2w'''&*M ]g dhh~/H/H&IJQQSI$##+ ) 1 1 1 =I )  %8GOO%K oo&9:G##G-HIQQRC#w''H D#11 % MDE( ]    I&   (  1  {{4 **,HXJaJ *V ,9,B,B '- ) OO''8M,,S1X="!)!1!1!5!5or!J!Q$    ((X%%&&&  sA$J$&E&'J$. E98A'E(E9'J$;=F 8 J$FJ$ F%F#F!F#F%&J$( E62E95J$6E99 FJ$FJ$ FJ$FJ$!F##F%$J$% F41J$3F44C0J$webz/staticstatic) directory)namedocs)parentsexist_okz /docs/site)rhtmlz docs-sitestartupc0# [RnUR(d[R S5 g[R 5 [R 5nU(a[R SSU0S9 g[R S5 g7f)zStart the background scheduler on application startup. Reads scheduler configuration from settings and loads default jobs. Skipped if ``scheduler.enabled`` is False. z"Scheduler is disabled via settingsNzDefault scheduler jobs loadedjob_idsruz$No default scheduler jobs configured)settings schedulerenabledrwrxr{load_default_jobs)sched_settingsrs rZstart_schedulerr"si''N  ! ! 89 OO))+G 3Iw;O P :;sBBshutdownc# [R(a)[RSS9 [R S5 gg7f)zEShutdown the background scheduler gracefully on application shutdown.T)waitz#Scheduler shut down on app shutdownN)rrunningrrwrxrrZstop_schedulerr6s3% 9:sAAc#\# [5nUv SSS5 g!,(df  g=f7f)z Dependency for database session.Nr/)rs rZget_dbrBs '  s , , ), credentialsc~UR[RR:wa [ SSS9eUR$)z+Verify admin token for protected endpoints.izInvalid authentication tokenrSdetail)rrapi admin_tokenr)rs rZverify_admin_tokenrIs4(,,":"::4RSS  " ""rcF\rSrSr%Sr\\S'\\S'\"SSSS./0S 9rS r g ) HealthResponseiQzHealth check response.statusr?exampleshealthyr<rr?json_schema_extrarN) __name__ __module__ __qualname____firstlineno____doc__rj__annotations__r model_config__static_attributes__rrrZrrQs. K L $9 Lrrc \rSrSr%Sr\\S'\\S'Sr\S-\S'\ \S'Sr \ S-\S'Sr \S-\S '\\S '\ "S S S SSSSSS./0S9r Srg)RatingResponsei_z!Rating information for an entity. entity_type entity_idN entity_nameratingrd race_count as_of_race_idrhorse* Some Delight—@33333SU@90rrrrrrrrr)rrrrrrjrintrfloatrrrrrrrrZrr_sv+N"Kt" MB !Jd ! #*!##1$"$%*   LrrcV\rSrSr%Sr\\S'\\S'Sr\S-\S'Sr \ S-\S'Sr g) RatingHistoryItemizzSingle rating history point.race_idrNr race_dater) rrrrrrrrrrrjrrrrZrrzs+& L MB  IsTz rrc\rSrSr%Sr\\S'\\S'Sr\ S-\S'Sr \ S-\S'\\S'/r \ \ \S '\"S S S S SSSS SSS.SSSSS./S./0S9rSrg)HorseDetailResponseiz/Detailed horse information with rating history.horse_idrNcurrent_rating current_rdrrating_historyrrrrrrr 2026-05-01)rrrri40g@gfffffV@z 2026-04-28rrrrrrrr)rrrrrrrrjrrrrlistrrrrrrrZrrs9M I#'NEDL'#J #O.0ND*+0  "*&,"&"$(-&,"&)5 (-&,"&)5  '  Lrrct\rSrSr%Sr\\S'\\S'Sr\ S-\S'Sr \ S-\S'\\S'/r \ \ \S 'S rg) DriverDetailResponseiz0Detailed driver information with rating history. driver_idrNrrrrrrrrrrrrrjrrrrrrrrrrZrrs@:N I#'NEDL'#J #O.0ND*+0rrct\rSrSr%Sr\\S'\\S'Sr\ S-\S'Sr \ S-\S'\\S'/r \ \ \S 'S rg) TrainerDetailResponseiz1Detailed trainer information with rating history. trainer_idrNrrrrrrrrrZrrs@;O I#'NEDL'#J #O.0ND*+0rrc`\rSrSr%Sr\\S'\\S'\\S'Sr\S-\S'Sr \S-\S'S r g) PaginationMetaiz4Pagination metadata with next/prev navigation links.totallimitoffsetNnextprevr) rrrrrrrrrjrrrrrZrrs0> J J KD#*D#*rrc j\rSrSr%Sr\\\S'\\S'\ "SSSSS S S S S ./SSSSSS.S./0S9r Sr g)PaginatedRatingResponseiz-Paginated response for rating list endpoints.datametarrrrrrrrrdrz'/v1/ratings/horses?limit=100&offset=100N)rrrrrrrrr) rrrrrrrrrrrrrrrZrrsi7 ~   ,3)++9&,"&*,-2 "#!$"# I $  Lrrc4\rSrSr%Sr\\\S'\\S'Sr g)PaginatedRaceResponseiz+Paginated response for race list endpoints.rrrN) rrrrrrrrrrrrrZrrs5 t* rrcJ\rSrSr%Sr\"SSS9r\\S'\"SSS9r \\S'S r g ) IngestionRequestizRequest to trigger ingestion..Start date (YYYY-MM-DD)r> date_fromEnd date (YYYY-MM-DD)date_torN) rrrrrrr rjrrrrrrZr r s)'3,EFIsF*ABGSBrr c^\rSrSr%Sr\\S'\\S'\\S'\\S'\"SSS S S S ./0S 9rSr g)IngestionResponseizResponse from ingestion.meetingsracesstarterserrorsrrrrrrrrrN rrrrrrrrrrrrrZrrs<"M JM K J Lrrcz\rSrSr%Sr\"SSS9r\\S'\"SSS9r \\S'\"S S S 9r \ \S '\"S S S 9r \ \S'Sr g)RecomputeRequestizRequest to trigger recompute..r r r r rFzClear existing ratings firstdefaultr>clear_existing"Learn barrier/handicap adjustmentslearn_adjustmentsrN)rrrrrrr rjrrrboolrrrrrZrrsZ'3,EFIsF*ABGSB #AND$#Gtrrc:\rSrSr%Sr\\S'\"SSS0/0S9rSr g) RecomputeResponseizResponse from recompute.snapshots_createdrirrNrrrrZr"r"s*" $d+ Lrr"c\rSrSr%Sr\"SSS9r\\S-\ S'\"SSS9r \\\-S-\ S'\"S S S 9r \\ S '\"S S S 9r \\ S'\"SSS9r \\ S'\"SSS9r\\ S'\"SSS9r\\ S'Srg) ScrapeRequesti"z&Request to trigger a scrape/ingestion.Nzr@rAr r&rr'r rrrrrZr9r9Ys)#+STHcT3,LMIsM"VFC$J#3NOHcO3NOFCO#LE4#">D$s)d $)CT#UJS D U!$z)Paginated response for audit log listing.rrrN) rrrrrrrrrrrrrZrr>s3 }  Jrrcodereturnc[U5R5nUR5(a&[U5nUS:dUS:a [ S5eUS$[ S5e)z*Normalize club codes to two-digit strings.rcz#Club code must be between 00 and 9902dzClub code must be numeric)rjrisdigitrr)rcode_strvalues rZ_normalize_club_coderHsY4y HH  19 BC C 0 11r start_dateend_dater'cUVs/sHn[U5PM nn/nUnXa::aCURS5nUHnURUUS35 M U[SS9- nXa::aMCU$s snf)z:Generate HRNZ result URLs for a date range and club codes.z%m%dzrs.htmrdays)rrappendr)rrr'rnormalized_codesr&current date_prefixs rZ_generate_hrnz_urlsrSs@JJzt,T2zJDG  &&v. $D KK;-vV4 5%9!$$   KKsA*scrapedrR default_yearc TURS5nU(aURSS5R5n[R"SU5(d=SH7n[ R "X45nURUS9R5s $ /SQnUH?n[ R "X45nSU;aURUS9nUR5s $ URS 5nU(a[R"U5$[R"S U5nU(a>[U[URS 55[URS 555$g ![a GMf=f![a Mf=f![a Nf=f![a g f=f)z.Resolve meeting date from scraped data or URL.date_raw  z \\b\\d{4}\\b) %A, %d %B%d %B)year)z %A, %d %B %Yrz%d %B %Yrz%Yrz*(?P\\d{2})(?P
\\d{2})\\d{2}rs\\.htmmmddN) rirrresearchrrrr fromisoformatrgroup) rrRrrfmtparsedformatsmeeting_date_strmatchs rZ_resolve_meeting_daterds{{:&H##FC0668yy(33-%..x=F!>>|><AACC.   C !**89s?#^^^>F{{}$ {{6* %%&67 7 IICS IE   c%++d*;&TU U ?"       sH2E':E94F )# UHupUcM USU3v M g7fN=r.0kvs rZ )_build_pagination_meta..$ #641!Jqc1#J#6 rQrNrc3># UHupUcM USU3v M g7frrrs rZrrrrr)joinitemsr) rrrrrr next_params query_string prev_offset prev_paramss rZ_build_pagination_metars(D~PP%P xx #.#4#4#6  #1\N3V V z!V^, MMM xx #.#4#4#6  #1\N3V  KV Kr/)response_classc# [SS9$7f)zRedirect to web UI home page./ui/rRrrrrZrootrs  '' z /docs/site/c# [SS9$7f)z!Redirect to the static docs site.z /static/docs/rrrrrZserve_docs_siters  00rrz/ui/index.htmlc# [S- S- nUR5(a[UR5S9$[ SSS9e7f)zServe web UI home page. templatesz index.htmlrWeb UI not foundrweb_direxistsr read_textr html_paths rZ serve_homersG+% 4II$7$7$9:: C0B CCAAz/ui/horse/{horse_id}rc# [S- S- nUR5(a[UR5S9$[ SSS9e7f)zServe horse detail page.rz horse.htmlrrrrr)rrs rZserve_horse_detailrsG+% 4II$7$7$9:: C0B CCrz/ui/driver/{driver_id}rc# [S- S- nUR5(a[UR5S9$[ SSS9e7f)zServe driver detail page.rz driver.htmlrrrrr)rrs rZserve_driver_detailrG+% 5II$7$7$9:: C0B CCrz/ui/trainer/{trainer_id}rc# [S- S- nUR5(a[UR5S9$[ SSS9e7f)zServe trainer detail page.rz trainer.htmlrrrrr)rrs rZserve_trainer_detailrsG+%6II$7$7$9:: C0B CCrz/ui/race/{race_id}rc# [S- S- nUR5(a[UR5S9$[ SSS9e7f)zServe race detail page.rz race.htmlrrrrrrrs rZserve_race_detailrsG+% 3II$7$7$9:: C0B CCrz /ui/race-cardz/ui/race-card/c# [S- S- nUR5(a[UR5S9$[ SSS9e7f)zServe race cards index page.rrace-card.htmlrrrrrrs rZserve_race_cards_indexrsH+%(88II$7$7$9:: C0B CCrz/ui/race-card/{race_id}c# [S- S- nUR5(a[UR5S9$[ SSS9e7f)z)Serve race card view for a specific race.rrrrrrrrs rZserve_race_cardrH+%(88II$7$7$9:: C0B CCrz /ui/searchc# [S- S- nUR5(a[UR5S9$[ SSS9e7f)zServe search page.rz search.htmlrrrrrrs rZ serve_searchrrrz /ui/analyticsc# [S- S- nUR5(a[UR5S9$[ SSS9e7f)zServe analytics page.rzanalytics.htmlrrrrrrs rZserve_analyticsrrrz/ui/analytics-dashboardc# [S- S- nUR5(a[UR5S9$[ SSS9e7f)zWServe analytics dashboard page with combined accuracy, ratings, and confidence metrics.rzanalytics-dashboard.htmlrrrrrrs rZserve_analytics_dashboardr"sH+%(BBII$7$7$9:: C0B CCrz/ui/data-correctionc# [S- S- nUR5(a[UR5S9$[ SSS9e7f)z$Serve data correction workflow page.rzdata-correction.htmlrrrrrrs rZserve_data_correctionr+sH+%(>>II$7$7$9:: C0B CCrz/health)response_modelz 100/minutec[SSS9$)z?Health check endpoint. Returns: Health status and version rr<r)r)rOs rZ health_checkr 4s G <Fmm8==,,\:QU&44  /H LE FN +D||~    A OO!"MMhh$$"#,,%&__   1jII7##$++C07;;3C3CCH,,-L !%, OD ">3ID3I JJrz/ratings/horses/{horse_id}c UR[5R[RU:H5R 5nU(d [ SSS9eSSKJn URU5R[UR[R:H5R[[R[R:H5RUR[R:HUR U:H5R#[R$[R&[R([R5R+5n/nUH;nUR-[/URUR0UR2S95 M= U(aUSR0OSnU(aUSR2OSn [5UUR6UU [9U5US 9$) zGet detailed horse information with rating history. Args: horse_id: Horse ID db: Database session Returns: Horse details with rating history rzHorse not foundrrr8rrrNr)rWr5rr2rrrr8rr7rr6 meeting_idrr4rrorder_by meeting_date race_datetimerXallrrrrrrr) rOrrrr8r&historyr(rrs rZget_horse_detailr9sy" HHUO " "588x#7 8 > > @E 4EFF<  dN00DGG; < gt'**4 5   & &**:*: :  $ $ 0          GG  $G  ..;;  .7Yr]))DN%.2!!DJ  ZZ%y>  rz/ratings/driversc [R"U[RSS9n/nUHnUR [ 5R [ RUR:H5R5nUR[SURU(a UROSURURUR(aURR!S5OSUR"S95 M [%U5nXRX!-n ['UR(5R+S5UR,R.-n [1UR25n [5XX*U 5n [7U [9S 0U D6S9$) zGet top driver ratings. Args: limit: Maximum results to return offset: Number of results to skip db: Database session Returns: Paginated list of driver ratings rrdriverNrrrrr)r:rr4DRIVERrWr3rr2rrrrrrrrrirrrjrr$rRrTrrrrr) rOrrrr&r'r(r<rr*rrrs rZget_driver_ratingsr>s4$)88 J  WIG&!((h6H6H)HIOOQ $",,+1FKKt;;>Fmm8==,,\:QU&44   LE FN +D7##$++C07;;3C3CCH,,-L !%, OD ">3ID3I JJrz/ratings/trainersc [R"U[RSS9n/nUHnUR [ 5R [ RUR:H5R5nUR[SURU(a UROSURURUR(aURR!S5OSUR"S95 M [%U5nXRX!-n ['UR(5R+S5UR,R.-n [1UR25n [5XX*U 5n [7U [9S 0U D6S9$) zGet top trainer ratings. Args: limit: Maximum results to return offset: Number of results to skip db: Database session Returns: Paginated list of trainer ratings rr;trainerNrrrrr)r:rr4TRAINERrWr9rr2rrrrrrrrrirrrjrr$rRrTrrrrr) rOrrrr&r'r(r@rr*rrrs rZget_trainer_ratingsrB!s4$)88 J  gIG((7#**7::9K9K+KLRRT %",,,3GLL;;>Fmm8==,,\:QU&44   LE FN +D7##$++C07;;3C3CCH,,-L !%, OD ">3ID3I JJrz/ratings/drivers/{driver_id}c UR[5R[RU:H5R 5nU(d [ SSS9eSSKJn URU5R[UR[R:H5R[[R[R:H5RUR[R:HUR U:H5R#[R$[R&[R([R5R+5n/nUH;nUR-[/URUR0UR2S95 M= U(aUSR0OSnU(aUSR2OSn [5UUR6UU [9U5US 9$) zGet detailed driver information with rating history. Args: driver_id: Driver ID db: Database session Returns: Driver details with rating history rzDriver not foundrrr0r1r2N)rrrrrr)rWr3rr2rrrr8rr7rr6r3rr4r=rr4r5r6rXr7rrrrrrr) rOrrr<r8r&r8r(rrs rZget_driver_detailrDQsz"XXf  $ $VYY)%; < B B DF 4FGG<  dN00DGG; < gt'**4 5   & &**;*; ;  $ $ 1          GG  $G  ..;;  .7Yr]))DN%.2!!DJ  [[%y>  rz/ratings/trainers/{trainer_id}c UR[5R[RU:H5R 5nU(d [ SSS9eSSKJn URU5R[UR[R:H5R[[R[R:H5RUR[R:HUR U:H5R#[R$[R&[R([R5R+5n/nUH;nUR-[/URUR0UR2S95 M= U(aUSR0OSnU(aUSR2OSn [5UUR6UU [9U5US 9$) zGet detailed trainer information with rating history. Args: trainer_id: Trainer ID db: Database session Returns: Trainer details with rating history rzTrainer not foundrrr0r1r2N)rrrrrr)rWr9rr2rrrr8rr7rr6r3rr4rArr4r5r6rXr7rrrrrrr) rOrrr@r8r&r8r(rrs rZget_trainer_detailrFsz"hhw&&wzzZ'?@FFHG 4GHH<  dN00DGG; < gt'**4 5   & &**<*< <  $ $ 2          GG  $G  ..;;  .7Yr]))DN%.2!!DJ  \\%y>  rz/races/{race_id}cSSKJn UR[5R [ [R 55R[RU:H5R5nU(d [SSS9eURU5RURU:H5R5nURURURURUR (aUR ROSUR UR"UR$UR&(aUR&R)5OS[+U5UVs/sHSnUR,UR.UR0UR2UR4UR6UR8S.PMU snS. $s snf) zpGet race details with starters. Args: race_id: Race ID db: Database session Returns: Race details rrrRace not foundrN)rrrrM handicap_mrUdid_not_finish) r2rr3rXrYrZ start_typegaitr6starters_countr)rrrWr7optionsr$meetingrr2rrrr7r3rXrYrZrKrLr6 isoformatrrrrrMrIrUrJ)rOrrrracerss rZget_racerSsW 5  DLL) * 7" #   4DEExx ''7(BCGGIHgg77oo'''+||##oooo ;?;M;M++557SWh-  JJ[[ll99ll99"#"2"2      s+AG rCz 200/minuterqr rc SSKJn U(a U"U5nO[R"5[ SS9- nU(a U"U5n O[R"5n UR [ 5R[ R5R[RU:[RU :*5n U(a"U R[RU:H5n U R5n U R[[ R55R![R[ R"[ R$[ R&5R)U5R+U5R-5n /n U HnU R/UR&UR0UR(a?URR(a$URRR35OSUR(aURROSUR$UR4UR6UR"(aUR"R35OSS.5 M [9UR:5R=S5UR>R@-n[CURD5n[GXXOU5n[IU [KS 0UD6S9$) zList races within a date range.rr+rN)rr3r5rYrXrZrKr6rrr)&packages.core.common.utilsr,rtodayrrWr7rrOrr6r5rYcountrNr$r4r6rXr2rrr7rr3rPrZrKrjrr$rRrTrrrrr)rOr rrrrYrr,rrrWrr race_listrQrrrs rZ list_racesrZ s6 * ZZ\I2$66 g&::<  dll  $$ 2G4H4HH4T U   W]]e34 KKME j./         GG  u   I77"oo|| (A(ALL--779/3||++#//"oo"oo6:6H6HD&&002d  *7##$++C07;;3C3CCH,,-L !%, OD in6Lt6L MMrz /admin/ingestr?zJData source: "tab" (TAB API directly) or "ingest" (tab-api-ingest service)r@tokenc # [UR5n[UR5n[R SUSUSUS35 [ X!S9nUR XE5IShvN upxn [UUU URSS9$N 7f) aTrigger data ingestion (admin only). Supports two data sources: - "tab" (default): fetches data directly from the TAB Affiliates API - "ingest": fetches data from the tab-api-ingest TypeScript service Args: request: Ingestion request with date range source: Data source selector db: Database session token: Admin token Returns: Ingestion statistics zAdmin triggered ingestion:  to z (source=))r@Nrr) r,r rrwrxr1ingest_date_rangerstats) rOr@rr[rrservicerrrs rZtrigger_ingestionrbWs2G--.J'//*H KK %j\hZyPQRr1G&-&?&? &U UHX }}X&  !VsA'B )B *!B z/webhook/scrapec ^^"^## SSKJnJnJnJnJnJn SSKJn SSK J n [TR5m#[TR5m"TRn U c[R Rn [#U [$5(a`U R'5S:Xa[(n OEU R+S5V s/sH)oR-5(dMU R-5PM+ n n [#U [.5(a[1SU 55(a[(n /n U (aU R3[5T#T"U 55 TR:(aU R3TR:5 U (d [9S S S 9e[/[<R?U 55n [@RCS [%T#5[%T"5TRD[GU 5S .S9 SSSSSSSS.nU "5nU "5IShvN nU GH<nURIU5IShvN n[KUUT#RL5nU(aUROS5(d[@RCSU5 MjT#Us=::aT"::dO M{URQ5US'URSU5nURUU5nURWUU5 US==S- ss'USH9nURWUUSUSUROS55 US==S- ss'M; USH3nURWUUSUROS5S9 US==S- ss'M5 USH3nURWUUSUROS5S9 US==S- ss'M5 URYUUS5n0nUH8nURWUUSU5nURZUUS'US==S- ss'M: UR]UU5nUH6nURWUUSUUROS 55 US!==S- ss'M8 UR_5 GM? SSS5IShvN Sn TRD(a&U"UU#4S&jn![fRh"U!5IShvN n [kUSUSUS!USUSUSUS"TRDU S'9 $s sn f![6an[9S [%U5S 9UeSnAff=fGNGN![`a?nURc5 US"==S- ss'[@ReS#UUS$S%9 SnAGM/SnAff=fN!,IShvN (df  GN=fN7f)(z:Webhook to trigger HRNZ Playwright scrape with parameters.r)DriverRepositoryHorseRepositoryMeetingRepositoryRaceRepositoryStarterRepositoryTrainerRepository) HRNZScraper)HRNZDataMapperNr7rIc3v# UH/n[U[5=(a UR5S:Hv M1 g7f)r7N) isinstancerjr)rrs rZr!webhook_scrape..s*V:4z$$>)>>:s79rzRProvide club_codes (or HRNZ_CLUB_CODES) to generate URLs, or pass urls explicitly.zWebhook triggered scrape)rrr(r&ru)rrrr,r-r.rrz Skipping non-meeting page for %srrrr,r2rraw_jsonr-)rr.)rrOrXrrUrrzFailed to scrape %s: %sTexc_infoc >[5n[UTTTRTRS9sSSS5 $!,(df  g=f)Nrr)r0r-rr)rrrOrs rZ_run_recompute&webhook_scrape.._run_recomputes7'(#*#9#9&-&?&? s !7 A) rrrr,r-r.rr/r#)6"packages.core.storage.repositoriesrdrerfrgrhripackages.hrnz_scraperrjpackages.hrnz_scraper.mapperrkr,r rr'rhrnzrmrjrr)splitrranyextendrrrr&rfromkeysrwrxr(rget_meeting_resultsrrrirP map_meeting map_entitiesupsert map_racesr2 map_starterscommitrrollbackerrorasyncio to_threadr+)$rOrr[rdrerfrgrhrirjrkr'rr&excr`mapperscraperrRrr5rOentitiesrr<r@r race_id_maprQrace_objrstarterr#rurrs$` @@rZwebhook_scrapers2;G--.J'//*H##J]]-- *c""     &,J*4)9)9#)>)>**,  )> *d## V:V V V,JD K KK+J*M N|| GLL! g   d# $D KK"j/H  **I   E F}}C< Q ' ; ;C @@4Wc:??S #7;;w+?+?KK BCH"l>h>"."8"8": ,,W5!..w7!((W5j!Q&!%h/E#**d f  *-  (Oq(O0'y1F$++F6Nfjj6F,)$)$ 2 ( 3G%,,GFO D8I-*%*% 4 ((')2DE !D-44R9KTRH7?{{K] 34'Na'N" "..w D'G%,, * I.  *%*% ( s}@ #*"3"3N"CC z"Gnz"Xi z"X$$+  } KCCAs J KFAp Q h1$ 6S4 PP Qw}}}ZDsB3U8R8R8(=U&R=B5U7S#8U;T7S)S&AS)&T7(S)7T79GS):T7? U T5 8UU9U= S SS  U&S)) T233T-&T7-T22T75U7U=U > U Uz/admin/recomputec[UR5n[UR5n[R SUSU35 [ UUUUR URS9n[US9$)zTrigger rating recompute (admin only). Args: request: Recompute request with date range db: Database session token: Admin token Returns: Recompute statistics zAdmin triggered recompute: r]rt)r#) r,r rrwrxr-rrr")rOrr[rrsnapshot_counts rZtrigger_recomputer+sn G--.J'//*H KK-j\hZHI& --!33 N ~ >>rz /admin/jobsz 20/minutec [RS5 [R5n[ UVs/sHn[ S0UD6PM sn[ U5S9$s snf)zList all scheduled background jobs (admin only). Returns a list of all cron jobs currently registered in the scheduler. Args: token: Admin authentication token Returns: List of scheduled jobs with their triggers and next run times zAdmin listing scheduled jobs)r7rr)rwrxr list_jobsr6r1r)rOr[r7jobs rZlist_scheduled_jobsrNsQ& KK./    D #15 6#%% 6$i  6sAr_)rrS job_requestc vUR=(d8 URS[R"[5R S53n[ RSURURUS.S9 URS:XaK[RURURURURURUS9 OURS:Xa@[RURURUR URUS 9 OsURS :XaK[R#UR$UR&URURURUS 9 O[)S S URS3S9e[+USURSURS3S9$)aAdd a new scheduled background job (admin only). Supports three job types: - ``ingest``: Scheduled data ingestion from TAB API - ``recompute``: Scheduled rating recomputation - ``scrape``: Scheduled HRNZ data scraping Args: job_request: Job configuration including cron expression and type-specific params token: Admin authentication token Returns: The job ID and confirmation message _z %Y%m%d_%H%M%SzAdmin adding scheduled job)r:r;r<ruingest)r rr>r@r;r<r()r rrAr;r<scrape)r&r'r rr;r<rozUnknown job_type 'z.'. Must be 'ingest', 'recompute', or 'scrape'.rz Scheduled z job with cron '')r<rD)r<r:rnowrrrwrxr;radd_ingest_jobr rr>r@add_recompute_jobrAadd_scrape_jobr&r'rrC)rOrr[r<s rZadd_scheduled_jobris4  S"" #1X\\#%6%?%?%P$Q R  KK$#,,$.. x'  !++'' ))%%!++ !     ,##!++''##!++ $     )  !!"--!++''!++ ! ' (<(<'==kl  #[1122B;CXCXBYYZ[ rz/admin/jobs/{job_id}r<c[RSSU0S9 [RU5nU(a[ USSUS3S9$[ SSUS 3S 9e) zRemove a scheduled background job (admin only). Args: job_id: The job identifier to remove token: Admin authentication token Returns: Confirmation of removal zAdmin removing scheduled jobr<ruTzJob 'z' removed successfully)r<rGrDrz ' not foundr)rwrxr remove_jobrFr)rOr<r[rGs rZremove_scheduled_jobrsk& KK.x6HKI""6*G)F8#9:  vhk* rz/admin/audit-logc rURR5R5nUS;a[SSURS3S9e[R "UUR URUURURURURS9nUc [SS S9e[URUR URURURURURURUR(aURR5S 9 $SS 9 $) a_Create an audit log entry (admin only). Records a data change or correction event in the audit log. This endpoint allows programmatic creation of audit entries, e.g. from the data correction UI or automated scripts. Args: request: Audit log entry details db: Database session token: Admin token Returns: The created audit log entry )INSERTUPDATEDELETECORRECTrozInvalid action 'z.'. Must be INSERT, UPDATE, DELETE, or CORRECT.r)rrrrrrrrNr z Failed to create audit log entry r2rrrrrrrr)rupperrrr. log_changerrrrrrrr2rrP)rOrr[ action_upperentrys rZcreate_audit_logrs)(>>'')//1LDD%gnn%55cd   " "%%##%%%%%%++ E }4VWW  88##//||######))383C3C5##--/  JN  rzMaximum entries to return)rr r>zNumber of entries to skip)rr r>c[R"X U-S9nXAX-n[U5nX`U-:a#UR[5R 5n[ UVs/sHn[URURURURURURURURUR (aUR R#5OSS9 PM snUS9$s snf)zList recent audit log entries (admin only). Args: limit: Maximum entries to return offset: Number of entries to skip db: Database session token: Admin token Returns: Paginated list of recent audit log entries r;Nrrr)r.get_recent_changesrrWr2rXrrr2rrrrrrrrrP)rrrr[entriesr*res rZlist_audit_logsrs$,,Rv~FG FN +D LE v~"((*    44<<++xx<<<<<<oo78||1<<113      sBC9z)/admin/audit-log/{table_name}/{record_id}rrc[R"X U5n[UVs/sHn[URUR UR URURURURURUR(aURR5OSS9 PM sn[U5S9$s snf)aGet all audit log entries for a specific record (admin only). Args: table_name: Name of the table record_id: Primary key value of the record db: Database session token: Admin token Returns: List of audit log entries for the specified record Nrr)r.get_changes_for_recordrrr2rrrrrrrrrPr)rrrr[rrs rZget_audit_log_for_recordr?s(00KG    44<<++xx<<<<<<oo78||1<<113   'l   sBCz/races/{race_id}/predictionsz 50/minutec,SSKJn SSKJn UR [ 5R [ RU:H5R5nU(d [SSS9eUR U5R URU:H5R5nU(d [SSS9eUVs0sHowRU_M nnUR(dlSSK Jn UR [ 5RU "[ R55R [ RU:H5R5nU"U5n U R!XV5n U R"V s/sHn [%U R&U R(U R*U R,U R.U R0U R2U R4U R6U R8U R:U R<U R>U R@U RBU;aXRBRDOS S 9PM n n [GUURHUR(aURRJOS URLU S 9$s snfs sn f) zGet win probability predictions for a race. Args: race_id: Race ID db: Database session Returns: Predictions for all starters rPredictionEnginerrrHrNo starters found for race)r$Nr`ra)'!packages.core.ratings.predictionsrrrrWr7rr2rrrr7rOsqlalchemy.ormr$rN predict_racer[rIrrJrrKrrLrMrNrOrPrQrRconfidence_interval_lowconfidence_interval_high starter_idrUrWrXrYrZ)rOrrrrrQrr starter_by_idr$engine predictionpredr[s rZget_race_predictionsrhs C4 88D> G!3 4 : : &get_accuracy_summary..F s a@Q>Rr)keyrOg?rhrrirjrrrrunknown)rrprrrXrYrorrzrrrbucketrcjUSS:Xa [SSSS9$[USUSUS- USUS- S9$)Nrrrrrpr)rc)rs rZ _bucket_stats+get_accuracy_summary.._bucket_stats sT '?a #!#M M/ 01F7OC[)F7O;  rg@2r)&rrrrrrWrrWr7rr2rrrUisnotr6r5r4descr6 nulls_lastdistinctrr7rrirrOrPrrtrgrcsortedkeysrlrrn)rOrrrrrrrrtotal_winner_correcttotal_top3_overlap total_brierr daily_databucketsrxrQrrprqbrierr[predicted_winner_probpredicted_winner bucket_key race_date_strrvdrrr-s rZget_accuracy_summaryr s&C4 t 44Jzz|H  gtww'//1 2 %%d+ , g $$ 2G4H4HH4T U '&&++-t/A/A/F/F/H/S/S/U V  s  b !FKJ"$JqsCEacBG "L88A  #$45!.1 =)!nn]B7 # ";4RS $45F$G ! D (J "d *!JJ G$)$  J  0 1Q 6 1 K(E1("{3 $,,2K2K LL55??AM%M  * "#)J} % =!+.%7.  } %&6 71 < 7=!'*a/*^:l*u a %i0)~~m<#0'^^K8(nn\1="0 ,$  e~Q(+!$#&'(  0%AC3O'acSQ$13#N    K JOO% &!} {+d7m;!"23d7mC7m   ' d '7  $8$E/OSUR@=(d SUR(a?URR(a$URRRC5OSURDURFURH=(d SURJ=(d SURL=(d SURN=(d SURP=(d SURR=(d SURT=(d SURVSURXS URZS UR\SUR^UR`SURbS/5 U S - n GM GMI [eU Rg5S S S 0S9$![8a GMtf=f)zExport recent predictions as CSV. Returns a CSV file with predictions for completed races. Supports filtering by date range and limit. rrrr\r)rrXrYrZrrrrJrrKrrLrMrIrNrOrPrQrRrSrTr.1fz.4frrrz&attachment; filename="predictions.csv"r)4rrrrr,rrWrrWr7rrOrr6r5r4rr6rrr7rrr,r"rr2rrr[rXrYrZrPrrrJrrKrrLrMrIrNrOrPrQrRrrrr#)rOr rrrrrrrraces_with_resultsrr+r,rrQrrrs rZexport_predictions_csvrm sC4 * ZZ\I1$55 g&::<  dll    J .  H ,  '&&++-t/A/A/F/F/H/S/S/U V u b !F ZF ZZ F OO 4L"  88G$++GOOtww,FGKKM  ,,TS?/ 55 UROU5 UROU "SSU-55 SS@K7J8nJ7n UROU"SAU Rr"U5RE5SBURtRwSCS"5SDURtRwSES"5S$3US55 URyU5 UR{5n!SFUSG3n"[}U!SHSIU"SJ3[W[KU!55SK.SL9$![a [SSS 9S ef=f)MayExport race predictions as a PDF document. Generates a PDF with a structured table showing each runner's rating, win probability, place probability, predicted placing, and confidence interval. Requires the ``reportlab`` library. Args: race_id: Race ID to export. db: Database session. Returns: PDF binary response with appropriate Content-Type and disposition. r)colors)letter)getSampleStyleSheet)inch) ParagraphSimpleDocTemplateSpacerTable TableStylerzBPDF export requires reportlab. Install with: pip install reportlabrNrrrrHr)pagesizeUnknownrzRace u — z (z)
Distance: zm | Starters: u%TipSharks — Race PredictionsTitlerrNormalr)#r5r3RatingzWin%zPlace%zPred.zCI Range)r{z.0fu–u—zID r z.1%rg?gffffff?g?gffffff?g?g333333?) colWidths repeatRows BACKGROUNDrrr2rz#1a5276 TEXTCOLOR)FONTNAMEr%r&zHelvetica-Bold)FONTSIZEr%r& )r)rrr2r2)ALIGNr%r,CENTER)r.)rr)rrr2LEFT)VALIGNr%r,MIDDLEGRIDr,ROWBACKGROUNDSr+z#f2f3f4) TOPPADDINGr%r,) BOTTOMPADDINGr%r,r6)rrz Generated: z | Field size: roz | Avg rating: avg_ratingrace_z_predictions.pdfzapplication/pdfzattachment; filename="r)rzContent-Lengthr)? reportlab.librreportlab.lib.pagesizesrreportlab.lib.stylesrreportlab.lib.unitsrreportlab.platypusrrrrrrrrrrrrWr7rr2rrNr$rOrr7rrrYr5rPrXrZrr[r enumeraterrrjrJrrKrNrOrPrRsetStyleHexColorwhitegreyrrrmetadataribuildr#r)#rOrrrrrrrrrrrrrrQrrrr docstyleselementsrYr title_text table_dataidxrci col_widthstablerr pdf_bytesfilenames# rZexport_race_predictions_pdfrQm s((2<,  C4 88D> G!3 4 : :  46#  . OOE OOF1cDj)*& OO(,,s+55789%..22<GHI%..22<GL N 8   IIh!Iwi/0H $%;H:Q#G!#i.1  C W  s &S<<Tz/ws/races/{race_id} websocketc # SSKJnJn SSKJn [ 5nUR [5R[RU:H5R5nU(d"URSSS9IShvN SSS5 gUR [5R[[R5[[R5RUR 5[[R5RUR"5[[R5RUR$55R[RU:H5R5nU(a URO/nU"Xg5nSSS5 UR-X5IShvN UR/WU5IShvN UR1U5(dUR3U5 UR55IShvN n [6R8"U 5n U R;S S5n U R;SU5n U S:Xa][=U [>5(aH[(RASSU 0S9 UR/[6RB"SU S.5U5IShvN O[(RESXS.S9 MGN[!,(df  GN==f![&a0 [(R+SS S 9 URS S S9IShvN gf=fGNiGNRGNNy![6RFa [(RISSU0S9 Nf=f![Ja [(RASSU0S9 O&[&a [(R+SSU0S S9 Of=fURMX5IShvN UROU5S:Xa)UR1U5(aURQU5 ggg!URMX5IShvN UROU5S:Xa)UR1U5(aURQU5 fff=f7f)a5WebSocket endpoint for live race updates. On connect, validates the race exists in the database and sends the initial race state (race details + starters). Broadcasts live updates as they become available via the simulation task. Args: websocket: The WebSocket connection. race_id: Race identifier. r)_build_initial_statemanagerrirH)rreasonNz%Failed to validate race for WebSocketTrqizInternal server errortyperr subscribez!Client subscribed to race updatesru subscribed)rWrzUnknown WebSocket message typez"Invalid JSON received on WebSocketzWebSocket client disconnectedzWebSocket error)rvrr))apps.backend.api.websocketrTrUrrr0rWr7rr2rcloserNr$rOrrr<r@rrwrconnectsend_personal_messageis_simulation_runningstart_simulation receive_textr loadsrirmrrxdumpsdebugJSONDecodeErrorwarningr disconnectget_connection_countstop_simulation) rRrrTrUrrrQr initial_statermsgmsg_type msg_race_ids rZwebsocket_race_endpointrm sI4 ]g==&--dgg.@AGGIDoo48HoIII ] d#t||,t}}-88Gt}}-88Ht}}-88I  7*+ )-t}}"H1@M+8 //) ---  ' ' y AAA  ( ( 1 1  )&-"//11D jj&7762.!ggi9 {*z+s/K/KKK;(+6  "77 L[#QR! LL8'/D!%GJ],  L'?Q L*+Q M"L-M"BL26L07L2;M"<L2M"K K'"K*%Q 'K**1L$LL$!Q #L$$Q *Q -M"0L22*MM"MM"" N'P N'$P&N''P*Q >O?AQ QPAQQ z/metricsc[SSS9$)aPrometheus metrics endpoint stub. Returns a placeholder response. To serve real metrics: 1. pip install prometheus-client 2. Create counters/histograms/gauges in a metrics module 3. Call generate_latest(REGISTRY) here See docs/monitoring.md for the full instrumentation guide. zN# TipSharks API metrics stub # Integrate prometheus-client for production use r)rrS)rrrrZmetricsro} s b r__main__z0.0.0.0i@)hostport)rrrrr rrrrriorrpathlibr typingr fastapir r r rrrrrrrfastapi.middleware.corsrfastapi.responsesrrrfastapi.securityrrfastapi.staticfilesrpydanticrrrslowapirr slowapi.errorsr! sqlalchemyr"rr#r$packages.core.common.loggingr%r&packages.core.common.rate_limitr'packages.core.common.schedulerr(packages.core.common.settingsr)r*rVr,packages.core.ratings.recomputer-packages.core.storage.auditr.packages.core.storage.databaser0packages.core.storage.ingestionr1rr2r3r4r5r6r7r8r9rwr:rrwrrlimiterapprladd_exception_handler api_routerrUrcors_allow_originsr{r cors_originsadd_middleware middlewarer[rfrnr}r__file__parentrrmountrj docs_site_dirmkdiron_eventrrsecurityrrrrrrrrrrrr rrr"r%r+r1r6r9rCrFrIrWrcrgrlrnrtrrrrrrrrrrrirrrrrrrrrrrrrrr r.r9r>rBrDrFrSrZpostrbrrrrdeleterrrrrrrrrr rrrQrRrmroinclude_routeruvicornrun)origins0rZrs4  33    3OOE+119,.BC=K1=36<   H H  >  2 3 h  +-IJe $ ||&&#- E'/||'F'F'L'LS'Q R'QV,,.'Q R %% $$$$    '   0X'XXx x.   & & . >>IIis7X3E/FGhIWh&/Mt4IIc-0t< i<<&j;; <DLHCU#$@# Y Y6! !#)#L1911I1YiBICyC   y   I, Y "yySYS2i(&Y&Ry Y  1i1nI( 4I 492s2s2 $26s) #Y")4)c))PT)X. . . . .  .  .d\*(+( |4151  - ,7D8.D  =DsD>D !,?DD@D #LAD3DBD l;DSD<D6 ,7D87D "<@D3DADl3D4D6D7D "<@DAD |<D=D>2|='=3= !2IJ|ss+a("4\Jd8IJ4RS&/jK jK jK jKd jK : jK  jK jKKjKZ ,=PQ|&/> >> >R>B "3JK|ss+a(&/ +K +K +K +K  +KL+K\ #4KL|ss+a(&/ +K +K +K +K  +KM+K\ .?ST|&/= == =U=@ 0AVW|&/= == =X=@ "#|&/2 2 2 2$2j )>?|"$LI,Gst,a(d8IJ&/FN FNTzFN4ZFN  FN  FN : FN FN@FNR 1BC`&/+,' ' '  ' 'D'T ">B&/+,e ee eCeP #4EF&/+,? ?? ?G?D + {+,    , *  {+,D D'D D  DN - {+,     B #MsS&/+,2 "22 2T2j "3GHss8STa5PQ&/+, ) ) ) )  )I)X /@T &/+, ### #  ##L .?UV{&/I I I IWIX !"|""A&/ . .Tz.  .#.b 01{&/   22 %oF{bQ3/&/f f f fGfX %&{$Rt>J&/R RtR  R R'Rj )*{$Rt>J&/_ _t_  _ _+_D )*{"$LI,Gt>J&/ y yTzy4Zy  y  y+yx -.{"$LI,Gt>J&/ } }Tz}4Z}  }  }/}@ ./{&/f f f f0fX$%[-Y[-[-&[-B$56 7 ": z KK)$/aa Ssv/