$i,SrSSKJr SSKrSSKJrJr SSKrSSKJ r SSK J r \ "\ 5r \(aSSKJr "SS \5r"S S \5r"S S 5rSSjrg)zTAB Affiliates API client with retry logic. Handles retries, rate limiting, and error handling for the public TAB API. No authentication required - this is a public API. ) annotationsN) TYPE_CHECKINGAny) get_logger) get_settings MockTABClientc\rSrSrSrSrg)TABClientErrorz%Base exception for TAB client errors.N__name__ __module__ __qualname____firstlineno____doc____static_attributes__r ?/root/tipsharks/tipsharks-elo-api/packages/tab_client/client.pyr r s/rr c\rSrSrSrSrg)TABRateLimitErrorzRate limit exceeded.r Nrr rrrrsrrc\rSrSrSrSrSrSrSrSr SSS jjr SSS jjr SS jr SS jr SSS jjrSrg) TABClient#aClient for TAB Affiliates API with retry logic. The TAB Affiliates API is a public API that provides racing data for NZ and international racing. No authentication is required. Example: >>> async with TABClient() as client: >>> meetings = await client.get_meetings("2024-01-01", "2024-01-07") >>> for meeting in meetings: >>> event_id = meeting["races"][0]["id"] >>> event = await client.get_event(event_id) cf[5UlURRUlSUlg)z$Initialize TAB client with settings.N)rsettingstab tab_config_clientselfs r__init__TABClient.__init__1s#$ --++15 rcB# UR5IShvN U$N7f)zAsync context manager entry.N)_ensure_clientr"s r __aenter__TABClient.__aenter__7s!!!###  $s c@# UR5IShvN gN7f)zAsync context manager exit.N)close)r#exc_typeexc_valexc_tbs r __aexit__TABClient.__aexit__<sjjls c# URc/[R"URRSS9Ulgg7f)z"Ensure HTTP client is initialized.NT)timeoutfollow_redirects)r!httpx AsyncClientr r2r"s rr'TABClient._ensure_client@s6 <<  ,,//!%DL s>Ac~# URb*URR5IShvN SUlggN 7f)zClose HTTP client.N)r!acloser"s rr+TABClient.closeHs4 << #,,%%' ' 'DL $ 's +=;=Nc# UR5IShvN URRSU3n[R SUSU3UUS.S9 UR R XUS9IShvN n[R SUR3URUS .S9 URS :Xa}X@RR:a [S 5eS U-n[RS US35 [R"U5IShvN URXX4S-5IShvN $URS:Xa;UR5nURSUR 5n [%SU 35eURS:Xa[%SU35eUR'5 UR5$GNGNLNN!["a UR n Nnf=f![(R*an X@RR:a[%SU 35U eSU R,Rs=::aS:azO OwS U-n[RSU R,RSUS35 [R"U5IShvN URXX4S-5IShvN sSn A $[%SU 35U eSn A f[(R.an X@RR:a[%SU 35U eS U-n[RSUS35 [R"U5IShvN URXX4S-5IShvN sSn A $Sn A ff=f7f)a)Make HTTP request with retry logic. Args: method: HTTP method (GET, POST, etc.) endpoint: API endpoint path (without base URL) params: Query parameters retry_count: Current retry attempt Returns: Response JSON data Raises: TABClientError: If request fails after retries N/zMaking z request to )endpointparams)extra)r=zResponse status: ) status_coder<iz(Rate limit exceeded, max retries reachedzRate limited, waiting zs before retryierrorz Bad request: izResource not found: z HTTP error: iiXz Server error z , waiting zRequest error: zRequest failed, waiting )r'r base_urlloggerdebugr!requestr? max_retriesrwarningasynciosleep_request_with_retryjsongettext Exceptionr raise_for_statusr4HTTPStatusErrorresponse RequestError) r#methodr<r= retry_counturlrR wait_time error_body error_msges rrKTABClient._request_with_retryNsL*!!###))*!H:6  fX\# /$   @ !\\11&f1MMH LL#H$8$8#9:&.&:&:Q   ##s*//"="==+,VWW{N !7 {.QRmmI...!55fAo ##s*.!)J *w FI%}YK%@AA##s*$';H:%FGG  % % '==? "a $N/!. ( I.$$ <oo999$|A3%78a?ajj,,2s2{N #AJJ$:$:#;<(k9mmI...!55fAo!<s!34! ;!! oo999$qc%:;B;I NN5i[O P-- * * *11&/  sM-F:>> async with TABClient() as client: >>> meetings = await client.get_meetings( >>> "2024-01-01", "2024-01-07", category="H", country="NZ" >>> ) Nz Fetching z meetings from  to z in ) date_fromdate_tocategorycountryGETzracing/meetingsmeetingszFound z meetings)r default_categorydefault_countryrDinforKrMlen)r#r^r_r`rar=rRrcs r get_meetingsTABClient.get_meetingss4  77H ?oo55G z 4yI  #   11%9JFSS<< B/ fS]O956 TsA1B03B.4;B0c# [RSU35 URSSU35IShvN nURS/5nU(d[ SU35eUS$N07f)a;Fetch single meeting details with race summaries. Args: meeting_id: TAB meeting ID (string) Returns: Meeting data dictionary with 'races' array (summaries only) Note: The races in this response only contain summary info (id, race_number). Use get_event() to fetch full race details with runners. zFetching meeting rbzracing/meetings/NrczMeeting not found: r)rDrfrKrMr )r# meeting_idrRrcs r get_meetingTABClient.get_meetingst  ' |4511 %j\2   << B/ #6zl!CD D{ s1A&A$1A&c# [RSU35 URSSU35IShvN nURS05nU(d[R SUS35 U$N87f)aRFetch race/event details with runners and results. Args: event_id: TAB event ID (string) Returns: Event data dictionary with: - race: Race information (distance, start_type, etc.) - runners: List of runners with horse, driver, trainer info - results: List of results with positions (if race is finished) - dividends: Dividend information (if available) Example: >>> async with TABClient() as client: >>> event = await client.get_event("abc123") >>> runners = event.get("runners", []) >>> results = event.get("results", []) zFetching event rbzracing/events/NdatazEvent z returned empty data)rDrfrKrMrH)r#event_idrRros r get_eventTABClient.get_eventsl&  ohZ0111%>(9TUU||FB' NNVH:-AB C Vs1A.A,9A.c # UcURRnUcURRn[R SUSUSUSUS3 5 UUUU[ US5S.nUR S S U5IShvN nU$N7f) aEFetch list of races with pagination. This is an alternative to get_meetings() that returns races directly with more filtering options. Args: date_from: Start date (YYYY-MM-DD) date_to: End date (YYYY-MM-DD) meet_types: Racing type filter - "T", "H", "G" (can be combined) countries: Country filter - "NZ", "AUS", etc. limit: Maximum results per page (max 200) Returns: Dictionary with: - races: List of race data - page_token: Token for next page (if more results) Note: For paginated results, use page_token in subsequent requests. NzFetching race list from r]z (types=z , countries=))r^r_ meet_types countrieslimitrbz racing/list)r rdrerDrfminrK)r#r^r_rvrwrxr=rRs rget_races_listTABClient.get_races_lists8  99J  77I &ykgY? \i[ ; #$"_  11%OOPsA=B?BB)r!rr )Nr) rTstrr<r|r=zdict[str, Any] | NonerUintreturndict[str, Any])NN) r^r|r_r|r` str | Nonerarr~zlist[dict[str, Any]])rkr|r~r)rpr|r~r)NNd) r^r|r_r|rvrrwrrxr}r~r)rrrrrr$r(r/r'r+rKrhrlrqrzrr rrrr#s 6   )- bbb& b  b  bP $" 000 0  0  0d4H"& $ /// /  /  / //rrc[5nURR(a"SSKJn [ R S5 U"5$[5$)zGet TAB client (real or mock based on settings). Returns: TABClient or MockTABClient instance Example: >>> async with get_client() as client: >>> meetings = await client.get_meetings("2024-01-01", "2024-01-07") rrz(Using MockTABClient (TAB_MOCK_MODE=true))rr mock_modepackages.tab_client.mock_clientr rDrfr)rr s r get_clientrPs8~H||A >?{r)r~zTABClient | MockTABClient)r __future__rrItypingrrr4packages.core.common.loggingrpackages.core.common.settingsrrrDrr rOr rrrr rrrsX #% 36 H = Y   jjZ r