CuiJ"dZddlZddlZddlZddlZddlZddlZddlmZddl m Z dZ dZ e Z dZddZd Zd Zd Zd Zd ZdZedk(reyy)zx Sync MMA events and fights from BallDontLie API to SportsDB. This supplements the Kaggle data with more recent events. N)datetime)Pathcbtd}|jrjt|5}|D]P}|jds|j dddj j dccdddS dddt jjdS#1swY(xYw)z(Load BallDontLie API key from .env file./var/www/html/eventheodds/.envzBALLDONTLIE_API_KEY=="NBALLDONTLIE_API_KEY rexistsopen startswithsplitstriposenvironget)env_pathflines 9/var/www/html/eventheodds/scripts/sync_mma_balldontlie.py load_api_keyrs45H (^ Dq D??#9:::c1-a0668>>sCC D D D D ::>>/ 00  D DsB%3B%<B%%B.ctd}|jrt|5}|D]j}|jds|j dddj j d}d|vr|j ddn|ccdddS dddt jjd d j ddS#1swY;xYw) z!Load database URL from .env file.rzSPORTS_DATABASE_URL=rrr z?schema=rNSPORTS_DATABASE_URLr )rrrurls r load_db_urlrs45H (^ Rq R??#9:**S!,Q/557==cBC7AS7H399Z03cQ  R R R R ::>>/ 4 : :: Fq II  R RsCA CCCz!https://api.balldontlie.io/mma/v1ctd|}|r'|dtjj|dzz }tjj |dt i} tjj|d5}tj|jjcd d d S#1swYy xYw#t$r}td |Yd }~y d }~wwxYw) zMake authenticated API request./?T)doseq Authorization)headers)timeoutNz API Error: )BASE_URLurllibparse urlencoderequestRequestAPI_KEYurlopenjsonloadsreaddecode Exceptionprint)endpointparamsrreqrespes r make_requestr9,s Jaz "C  sV\\++F$+??? .. .H IC ^^ # #C # 4 4::diik0023 4 4 4  A3 s6!C>1B9/ C9C>CC C&C!!C&c||dk(ryt|ttfr t|St|j dd}d|dS)zFormat value for SQL.rNULL'z'') isinstanceintfloatstrreplace)valss r sql_valuerD:sJ {cRi#U|$3x Cd#A qc8Oct}|s tdd}t|dd5}|j|dddt j d|d|gtj tj d d }|jd k7rH|jxsd j}d|vr%d|jvrtd|ddyyyy#1swYxYw)zExecute SQL against SportsDB.zSPORTS_DATABASE_URL not setz/tmp/mma_bdl_batch.sqlwzutf-8)encodingNpsqlz-fTi,)stdoutstderrtextr%rrzalready existsz duplicate keyz SQL Warning: ) r RuntimeErrorr write subprocessrunPIPE returncoderKrlowerr3)sqldb_urltmp_pathrresulterrs rrun_sqlrZDs ]F 899'H hg .!  ^^ x(  FA}}"))+ 3 &?#))++M M#ds)- .,N &s CCctdg}d} ddi}|r||d<td|}|r|jdsn\|j|d|jdijd }|rt |d k\rnt j d td t |d |Dcgc] }|jdr |ddddk\r|"}}tdt |d|D]}d|d}|jdd}|jdr|jddddnd} |jdxs|jdxsd} dt|dt|dt| dt| dttj|d } t| tdt |d |Scc}w)!z+Fetch and sync MMA events from BallDontLie.z)[mma] Fetching events from BallDontLie...Nper_pagedcursoreventsdatameta next_cursori333333?z [mma] Found z events from BallDontLiedate2024z[mma] Processing z events from 2024+bdl_idnamez Unknown Eventr locationvenueTBDzG INSERT INTO "UfcEvent" ("eventId", name, date, location, raw) VALUES (, z) ON CONFLICT ("eventId") DO UPDATE SET name = EXCLUDED.name, date = EXCLUDED.date, location = EXCLUDED.location, raw = EXCLUDED.raw; [mma] Synced z events to database) r3r9rextendlentimesleeprDr.dumpsrZ) all_eventsr^r5r7r8 recent_eventseventevent_idrirdrkrUs r sync_eventsry[s 56J F c" %F8 Hf-488F+ $v,'&"%))-8ZC/  3 " LZ))A BC 55=QvYr]f4 M c-011C DE%+'yy1-2YYv->uyy$Sb)D99Z(GEIIg,>G% 8 R $09T?2C2iPXFYEZZ\]fgkgqgqrwgx]y\z{  " M#m,--@ AB 3s4%Gctdt|dd}|D]}|d}d|}td|dd}|r|jd s1|d }|D]Q}d|d}|jd i} |jd i} d t |d t |dt | jdd t | jddt |jdd t |jddt |jdd t |jddt |jdd t |jddt t j |d} t| |dz }Ttjdtd|dy)z)Fetch fights for events from BallDontLie.z[mma] Fetching fights for events...rrhrgfights2rxr\r`fighter1fighter2z INSERT INTO "UfcFight" ( "fightId", "eventId", "fighter1Name", "fighter2Name", "weightClass", method, round, "fightTime", result1, result2, raw ) VALUES ( rn, ri weight_classmethodroundrrresult1result2a ) ON CONFLICT ("fightId") DO UPDATE SET "eventId" = EXCLUDED."eventId", "fighter1Name" = EXCLUDED."fighter1Name", "fighter2Name" = EXCLUDED."fighter2Name", "weightClass" = EXCLUDED."weightClass", method = EXCLUDED.method, round = EXCLUDED.round, "fightTime" = EXCLUDED."fightTime", result1 = EXCLUDED.result1, result2 = EXCLUDED.result2, raw = EXCLUDED.raw; rrcroz fights to databaseN) r3rqr9rrDr.rtrZrrrs) r_ total_fightsrwrx bdl_event_idr7r|fightfight_idrrrUs r sync_fightsrs &s6{m: >?L,;hZ( H8&LM488F+ f EeDk]+HyyR0HyyR0HxIl345x||F#$%R (,,v2F(G'HIuyy()*"Yuyy7J-K,LMuyy!"#2i &0A&B%CDuyy#$%R %))I2F(G'HItzz% !" #C2 CL A L? B 3Y,\ M,': ; -.]F F & 01]F  VTS T  d  )* fmmrE__main__)N)__doc__rr.rrurllib.requestr' urllib.parserPrpathlibrrrr,r&r9rDrZryrrr__name__rErrsx  1 J . . /.4n4=n39l!H zFrE