{RibdZddlZddlZddlZddlZddlZddlZddlmZmZm Z ejjdejjejjeddlmZdZdZddd d d d d dddddddddZgdZdZdZdZddZdZedk(reyy)z Ingest Upcoming Game Schedules Creates SportsGame records for upcoming games from The Odds API. This ensures we have games to match odds against. Run: Every 4 hours N)datetimetimezone timedelta)normalize_to_fullg?zhttps://api.the-odds-api.com/v4basketball_nbaamericanfootball_nfl baseball_mlb icehockey_nhlamericanfootball_ncaafbasketball_ncaabsoccer_usa_mlsmma_mixed_martial_arts soccer_eplsoccer_spain_la_ligasoccer_italy_serie_asoccer_germany_bundesligasoccer_france_ligue_onesoccer_uefa_champs_leaguesoccer_uefa_europa_league)nbanflmlbnhlncaafncaabmlsmmaepllaligaseriea bundesligaligue1ucluel) rrrrrrrrr r!r"rcdtjjtjjtddg}|D]s} t |d5}|D]U}|j ds|jdddjjdd ccdddcS dddutjjd d jdd S#1swY=xYw#t$rYwxYw) N/var/www/html/eventheodds/.env...envrzSPORTS_DATABASE_URL==?rSPORTS_DATABASE_URL) ospathjoindirname__file__open startswithsplitstripFileNotFoundErrorenvironget env_pathsenv_pathflines $scripts/ingest_upcoming_schedules.py load_db_urlrA0s(  RWW__X.f=I h$ KKD'=>#zz#q1!4::<BB3GJJ K KK K ::>>/ 4 : :3 ? BB  K K!   s< C;C//6C/% C;1C/3C;/C8 4C;; DDcdtjjtjjtddg}|D]a} t |d5}|D]C}|j ds|jdddjccdddcS dddcy#1swY xYw#t$rY|wxYw)Nr&r'r(r)zTHE_ODDS_API_KEY=r*r+) r/r0r1r2r3r4r5r6r7r8r;s r@ load_api_keyrC@s(  RWW__X.f=I h$ ==D':;#zz#q1!4::<< = == =   = =!   s< B8B,/$B, B8B,!B8,B5 1B88 CCct}|s tdgStd|d}|dd} tj||d}|j dk(r td gS|j d k(rtd |gS|j d k7rtd |j gS|j }tdt|d|S#t$r}td|gcYd}~Sd}~wwxYw)zLFetch upcoming events from The Odds API (events only, no odds to save quota)zNo API key foundz/sports/z/eventsiso)apiKey dateFormat)paramstimeoutiz Invalid API keyiz No events for z Status: z Found z upcoming eventsz Error: N) rCprint ODDS_API_BASErequestsr: status_codejsonlen Exception) sport_keyapi_keyurlrIrespdataes r@fetch_upcoming_eventsrYPsnG   ! O8I;g 6CF ||C;   s " % &I   s " $YK0 1I   s " Jt//01 2Iyy{ T #345  !o s/3C C?(C()C C5C0*C50C5c t}|s tdtj|}|j } |j d|j |xst}d}d}|D]}tj|} | std|*td|jdt| } | D]} | jd d } | jd d } | jd d }| jd d }|r|sP tj | j#dd}t+||xs|}t+||xs|}|j,dk\r |j.n|j.dz } |j d||| |||f|j1}|r |dr|dz }n|dz }|j td|jdt3| d||dk7st5j6t8|j;|j;||dS#t$r)}td||jYd}~d}~wwxYw#tj$t&j(}YhxYw#t$r)}td||jYd}~d}~wwxYw)z4Ingest upcoming game schedules into SportsGame tablezSPORTS_DATABASE_URL not setz CREATE UNIQUE INDEX IF NOT EXISTS "SportsGame_league_externalGameId_idx" ON "SportsGame" (league, "externalGameId") WHERE "externalGameId" IS NOT NULL zNote: Index may already exist: NrzUnknown league: z Fetching z schedule...idr. commence_time home_team away_teamZz+00:00r+a INSERT INTO "SportsGame" ( league, season, "externalGameId", "gameDate", "homeTeam", "awayTeam", status, "createdAt", "updatedAt" ) VALUES (%s, %s, %s, %s, %s, %s, 'scheduled', NOW(), NOW()) ON CONFLICT (league, "externalGameId") DO UPDATE SET "gameDate" = EXCLUDED."gameDate", "homeTeam" = EXCLUDED."homeTeam", "awayTeam" = EXCLUDED."awayTeam", "updatedAt" = NOW() RETURNING (xmax = 0) AS inserted z Error inserting game: z z: z events processed)addedupdated)rA RuntimeErrorpsycopg2connectcursorexecutecommitrRrLrollbackPRIORITY_LEAGUESSPORTSr:upperrYr fromisoformatreplacenowrutcrmonthyearfetchonerQtimesleepAPI_RATE_LIMIT_DELAYclose)leaguesdb_urlconncurrXtarget_leagues total_added total_updatedleaguerSeventseventevent_idr\r]r^ game_date home_abbrev away_abbrev season_yearresults r@ingest_schedulesrrs ]F 899   F #D ++-C    0 0NKM >-JJv&  $VH- .  FLLN+<89&y1. Eyyr*H!IIor:M +r2I +r2II 7$22=3H3Hh3WX ,Iv>K)K+Iv>K)K-6OOq,@)..innWXFXK  k8Y [Y [fQi1$K!Q&MU. `  6<<>""S[M1BCD ^B' ' JJ+ ,}>-@IIKJJL ] ;;W  /s34 8 7$LL6 @ 045  s;!I%I9:J$ I6 I11I69%J!$ K-KKctjd}|jdtd|j }d}|j rD|j j dDcgc] }|jj"}}tdtdtd tjtjjtd t| }td dtd td |dtd|dtdycc}w#t $r,}td|ddl}|j%Yd}~yd}~wwxYw)Nz0Ingest upcoming game schedules from The Odds API) descriptionz --leaguesz5Comma-separated list of leagues (e.g., nba,nfl,ncaab))typehelp,z<============================================================zINGEST UPCOMING GAME SCHEDULESzTime: )ry zRESULTS:z New games added: rbz Existing updated: rczERROR: r)argparseArgumentParser add_argumentstr parse_argsryr6r7lowerrLrrprrq isoformatrrR traceback print_exc)parserargsrylrrXrs r@mainrs>  $ $1c dF  #4kl    DG ||.2ll.@.@.EF1779??$FF (O *+ F8<< -779: ;< (O !'2 6(m  &vg&789 &vi'8&9:; hG  sms*%E0AE E="E88E=__main__)N)__doc__rNrer/sysrurrrrr0insertr2abspathr3 team_namesrrwrMrlrkrArCrYrr__name__r@rs 22277??277??8#<=>(1   !   %   # $$-' & & &| C  D\<~6 zFr