a "%jH@s@dZddlZddlZddlZddlZddlZddlZddlm Z ddl Z ddl m Z ej dde dddlZe dZdZed Zd Zd Zd Zgd ZddZddZddZddZddZe dZe dZdZ gdZ!ddZ"ddZ#d d!Z$d0d"d#Z%d$d%Z&d&d'Z'd(d)Z(d1d+d,Z)d-d.Z*e+d/kr (fair_home, fair_draw, fair_away). Mirrors the live pipeline's method exactly so any difference in the comparison comes from the LINE, never from the maths applied to it.g?)NNNrr)float TypeError ValueErrorZeroDivisionErrorsum)hdaimpsrmain/pin_fresh_capture.pydevigCs&rcCs(|dus|dus|dkrdS|||SNrr)fairZmidrrr_clvQsrc stjtjfdd}d|||fd|||ffD]\}}} } | r4| r4d| kr\dkr4nq4d| krtdksxq4q4t|| t|| } } | | kr|| r|| s|dS| | kr4|| r4|| s4|dSq4d S) aHWhich side/book the frozen xlow rule fires on, or '' for no signal. Reimplemented here rather than imported because live_monitor's version reads a snapshot row keyed by column name; the RULE is identical -- bet the cheaper book when its CLV is in [5%,12%) and the other book is NOT in band, home/away only. cs |duo|kokSSNr)chilorr`zxlow_verdict..r r rrz/kalshiz/poly)LMZEDGE_THRESH_HOMEZEDGE_UPPER_CAP_HOMEr) Zfair_hZfair_akhkaphpaZinbandZsiderZk_midZp_midZckZcprr"r xlow_verdictWs  6r-cCsddd|pdDS)Nr'css|]}|r|VqdSr isalnum.0Zchrrr nr&znorm..)joinlowerrrrrnormmsr6cCs*ddddd|pdDDS)NcSsh|]}t|dkr|qS)r)len)r1trrr rs ztokens..r'css|]}|r|ndVqdS) Nr.r0rrrr2rsztokens..)r3r4splitr5rrrtokensqs r<z$E:\soccer\research\pin_board_log.csvz!E:\soccer\data\pinnapi_state.jsonU revent_id league_id league_namestartsr r rrrcCs0zttjddWSty*iYS0dS)Nutf-8encoding)jsonloadsSTATE read_text Exceptionrrrr_states rKcCsDz,tjjdddtjtj|ddddWnty>Yn0dS)NT)parentsexist_okr)indentrCrD)rHparentmkdirZ write_textrFdumpsOSErrorr5rrr _save_states  rScCsBtjtjjd}|d|kr6|d|d<|d<|dtkS)zDTrue if we may spend a call today. Self-enforced -- see QUOTA above.z%Y-%m-%ddayrcalls)dtdatetimenowtimezoneutcstrftimeget DAILY_BUDGET)stZtodayrrr _budget_oksr_cCs~ts tddti}|r ||d<tjt|dtidd}|jdkrXtd|jd d || }|d g|d fS) zA(events, last_cursor). With `since`, returns only CHANGED events.zPINNAPI_KEY not set in .envZsport_idsincezx-portal-apikey-)paramsZheadersZtimeoutizrate limited: Nxeventslast) KEY RuntimeError SPORT_SOCCERrequestsr\BASEZ status_codetextZraise_for_statusrF)r`rbrjrrr fetch_freshs rnc s|di}t }d}ttdddd}tj|td}|rH||D]}|dp\id pfid ppit fd d d DsqLt |d} ddddd} || | krqL| || <|  |d|d|d|d|d|ddddd |d7}qLWdn1sP0Yt jddfdd|Dfdd|D|d<|S)aAppend events whose money line MOVED since we last saw them. Deduping here rather than logging every snapshot is what keeps a 20-minute full-board capture affordable: ~2,400 events x 72 polls would be ~170k rows a day of mostly identical numbers, where the movements are a small fraction of that. The line we did NOT log is recoverable -- it is whatever the last logged row for that event_id says. Returns rows written. seenrrr'rCnewlinerEZ fieldnamesperiodsnum_0 money_linec3s|]}|VqdSr r\r1kmlrrr2r&zlog_board..r drawr r?r /r|r r@rArBr>rNZhourscs0h|](}t|dpkrt|dqS)rBr?)_ptr\str)r1e)cutoffrXrrr9szlog_board..csi|]\}}|vr||qSrr)r1rxv)live_idsrr r&zlog_board..) setdefaultBOARDexistsopencsv DictWriter BOARD_FIELDS writeheaderr\allrwriterow isoformatrV timedeltaitems) rdrXr^ronewnfhwrZeidZsigr)rrrzrXr log_boards8  "&*rc CsPztjt|dd}Wnttfy4YdS0|jr@|S|jtjj dS)NZz+00:00tzinfo) rVrW fromisoformatrreplacerrrrYrZ)rrrrrrs rc sg}|D]}|dpidp"idp,itfdddDsFqt|d}|dur^q|||t|d t|d Bfqg}|D]6}|d }t|trtj |}zTt|d  d dd\}} tj |j |j |jt|t| ttjddd} Wnty$YqYn0t|d t|d B} d\} } |D]R\}}}t|| tdkrxqNt| |@}|| krN||f|} } qN| r| dkr||| d| d| | fq|S)aPair our watchlist fixtures to Pinnacle events. Team names differ between providers (API-Football vs Pinnacle), so match on kickoff proximity FIRST -- that is the strong, provider-independent signal -- then require some token overlap on the names. A pairing that agrees on time but shares no team token is rejected rather than guessed at; a wrong pairing would silently compare two different matches' odds, which is worse than a missing row. rsrtruc3s|]}|VqdSr rvrwryrrr2r&zmatch_events..r{rBNr r r Zkickoff:rrrr<rr)r\rrappendr< isinstancerrVdaterr;rWZyearZmonthrTintrYrrJabsZ total_secondsKO_TOLERANCE_MINr7)matchesrdidxrr^outmgdZhhmikoZoursZbestZbscoreZtoksZscorerryr match_eventss@ ",         rFc!*st\}}t}t|s:td|ddtddSt\}}tj tj j }|ddd|d<|rt||d<|r|dn t |||}|st|t||t|dd t|d |d |ddtd t|d td|rˆD]n\}} } } } td|ddd|ddddd| ddddd| d| dd| dd| dqfdd|D} | ddD]>}td|ddd|dddd |dddqztSt }ttd!d"d#d$}tj|td%}|r|D]v\}} } } } i}|d&r^z$tj|d&d'd(\}}|p@i}Wnty\i}Yn0|d)}t|trztj|}Wntyd}Yn0i}}z&t|d|d|d|pi}Wntyi}Yn0z&t |d|d|d|pi}Wnty$i}Yn0|d*|d+}}|d,|d-}}t!| d| d| d\}}}t!|d.|d/|d!\}}}t"||||||}t"||||||}||krd0} n(|r|sd1} n|r|sd2} nd3} zt|d&rh| d4krh| drh| drh| drht#d5|d&t$| dt$| dt$| dd6Wnty~Yn0|%|&|d|d|dt|d)| 'tj j &| d7| d8| d| d| d| d| d|d.|d/|d!|d&| ||||||||t(||t(||t(||t(||t(||t(||t(||t(||||| d9%qWdn1s0YtS):Nz [pinnapi] daily budget spent (rUr}z) -- skipping this pollrrre%H:%M:%Sz z events (z moved, call z), z watchlist fixtures -> z matchedz r Z5sr:r Z18sz <-> z (score z) r|r cs"g|]}|ddDvr|qS)cSsg|] }|dqS)rr)r1prrr 0r&z$cycle...r)r1rZpairsrrr0r&zcycle.. z UNMATCHED rz v rr'rCrprrr iQ)Zmax_ager Zkalshi_home_midZkalshi_away_midZ poly_home_midZ poly_away_midrrZsameZ fresh_onlyZ stale_onlyZdifferrzpinodds:)rrrr?rAr))r(Zload_watchlist_filerKr_printr\r]rnrVrWrXrYrZrrSrr7OUTrrrrFIELDSrZfetch_prematch_oddsrJrrrrrZ fetch_kalshiZ fetch_polyrr-Z _shared_putrrrZ astimezoner)!dry_rr^rdrerXZwroterrrzZscrZ unmatchedrrrZstaleZpinZgd_ZkbZpbr)r*r+r,ZffhZffaZfshZfsaZx_freshZx_stalerrrrcycles    8 <      & & $$   :  ,rc Csdtjv}dtjv}zt|dWn>ty`}z&ttjdd|WYd}~n d}~00|s||rlq|t t dqdS)Nz--oncez--dry)rrz error: r) sysargvrrJrrVrWrXtimesleep POLL_MINUTES)oncerrrrrmains  0r__main__)N)F),__doc__rrWrVrFosrrpathlibrriZdotenvrpathinsertZ live_monitorr(rrjgetenvrfrrhrrrrr-r6r<rrHr]rrKrSr_rnrrrrr__name__rrrrsP    (,