a j@s>dZddlZddlZddlZddlZddlZddlZddlmZmZej j dddddl m Z ddl mZdd lmZddlZd Zd Zd Ze d Ze dZd ZdZe dZe dZdZddZedZeddZeddZ eddZ!e dZ"e dZ#e dZ$dZ%dZ&dZ'dZ(dZ)dZ*dZ+d d!d"Z,d#Z-d$Z.d%Z/d&Z0d'Z1d(Z2d)Z3hd*Z4d+Z5d,d-Z6da7dd.d/Z8d0d1Z9d2d3Z:d4d5Z;d6d7Zdl@mAZAmBZBmCZCmDZDddlEZEd?ZFd@eiZGdAdBZHdCdDZIdEdFZJe dGZKdaLdHdIZMdJdKZNdLdMZOiZPdNZQdOZRddPdQZSddRdSZTdTZUiZVdUZWd ZXdVZYiZZdWdXZ[ddYdZZ\d[d\Z]d]d^Z^d_d`Z_dadbZ`dcddZadedfZbdgZcdhZddidjZedkdlZfgdmZgdndoZhdpdqZidrdsZjdtduZkdvdwZldxdyZmdzd{Zndd|d}Zod~dZpeqdkr:ddlrZrerjsddZtetjudeve,e-ddetw\ZxZyexjzZ-epdS)u} Live match monitor — polls API-Football for scores, detects halftime, then checks Kalshi for edge. Watchlist is read from E:\soccer\watchlist.txt and auto-reloads whenever the file changes — no restart needed. Just edit the file and save. Format: home | away | league | kickoff (HH:MM 24h) [| fixture_id] Lines starting with # are ignored. Usage: python live_monitor.py N)datedatetimeutf-8replace)encodingerrors)Path) MIMEMultipart)MIMETextZ 81b487be73030f5dec980d2a1ef2c406<i,zE:\soccer\live_dataz!E:\soccer\data\clv_kalshi_log.csvXzE:\soccer\data\watchlist.txtzE:\soccer\RECYCLE_MONITORg?cCsli}zPt|D]B}|}|r|dsd|vr|dd\}}|||<qWntyfYn0|S)N#=)openstrip startswithsplit Exception)pathenvlinekvrlive_monitor.py _load_env7s  rzE:\soccer\.envZ EMAIL_SENDEREMAIL_RECIPIENTEMAIL_APP_PASSWORDzE:\soccer\data\bankroll.jsonz#E:\soccer\data\kalshi_bankroll.jsonz!E:\soccer\data\poly_bankroll.jsongQ?g?g?zPpin-CLV [5,12)% vs Pinnacle on each book independently (original live strategy).uexclusive-low: bet the CHEAPER exchange (Kalshi vs Poly) when it is BOTH below the other book AND below Pinnacle (pin-CLV [5,12)%). Requires BOTH exchanges quoting — fires nothing on matches without live Polymarket prices.)baselinexlowr Znoneg{Gz?g$@?FT>ZUSLZCH1ZPL1c Csdtdur`zddlm}t|tBaWn:ty^}z"td|ddaWYd}~dSd}~00tS)aLeagues a real xlow bet can happen in: the live scope plus the gap set. Read from daily_signals rather than duplicated, so the two cannot drift -- a league added to the scope must not keep being polled at tracking cadence. FAILS OPEN. If the import breaks, every league is treated as tradeable and we merely spend quota at the old rate. The opposite default would quietly coarsen the leagues we actually trade, which is the expensive direction. Nr)AUTO_TRADE_LEAGUESz" [odds] cannot read trade scope (z&) -- polling every league at full rate)_TRADEABLE_CACHE daily_signalsr$set GAP_LEAGUESrprint)r$errr_tradeable_leaguess  r+cs0|pt}|dkrtnt|dkr$tntt|d|pz"_side_book_flags..r!leaguekalshi__midpolyus_ clv_polyus_r)FFFFpoly_)ACTIVE_STRATEGYEDGE_THRESH_AWAYEDGE_THRESH_HOMEEDGE_UPPER_CAP_AWAYEDGE_UPPER_CAP_HOMEfloatgetr()rowsidestrategyZclv_bZclv_kZclv_pZinbandk_midZpu_midZclv_puZ kalshi_okZ polyus_okZp_midZpoly_okrr1r_side_book_flagss2 4 6 rGcCs.zttdWSty(YdS0dSNbankroll)jsonloads BANKROLL_FILE read_textrrrrr_load_bankroll s rNcCs.zttdWSty(YdS0dSrH)rJrKKALSHI_BANKROLL_FILErMrrrrr_load_kalshi_bankrolls rPcCs.zttdWSty(YdS0dSrH)rJrKPOLY_BANKROLL_FILErMrrrrr_load_poly_bankrolls rRc CstrtstddSztd}||d<t|d<t|d<|t|dtdd.}| tt| tt| Wdn1s0Ytd |Wn2t y}ztd |WYd}~n d}~00dS) Nu& [EMAIL] Not configured — skipping.Z alternativeZSubjectZFromZTohtmlzsmtp.gmail.comiz [EMAIL] Sent: z [EMAIL] FAILED: ) EMAIL_ADDRESSrr)r rZattachr smtplibZSMTP_SSLZloginZsendmailZ as_stringr)subjectZ html_bodymsgZsrvr*rrr send_emails 0rXc+stttd[fdd dd}|p2td\fdd }|dpVd }|d pdd }|d prd } |d pd } |d pd } |dpd } |dpd } |dtv}|r|dpd }|dpd }n|dpd }|dpd }g}t|d|\}}}|s |s |r|dp.d }t|dp@d pH|}|r|t|dp`d pxt|dpvd }n*t|dpd pt|dpd }|r|| |dpd nd}|r|| ||ddnd}|rt|dpd nt|dp d }|r`|d kr`||tkr`t d d!d"dd#|d$d%|d$d& d}|rx|| ||dd'nd}| d(| | | |d|||d|||f t|d!|\}}}|s|s|rL|d)pd }t|d*pd p|}|r$t|d+pd p t|d,pd }n*t|d-p4d pLt|d.pJd }|rj|||d/pfd nd}|r||||ddnd}|rt|d,pd nt|d.pd }|r|d kr||tkrt d d!d"dd0|d$d%|d$d& d}|r ||||dd'nd}| d1| | ||d/|||d|||f d2d3|D}|sddSd4d3|D}t |d5krd6d7|Dd(d1hkrd8d9} t || d:t fd;d<|D}!t d=d d>| d?d@dA|!d d>| |!d?d@dB g}|rfzDttdC}"dDd7|"Dd(d1dEfdFd3|D}WntydYn0|spdSdG}#t|dpd }$tdHd<|Dr|$|#kr||}%dI|$}&| dJd d |%dt|&dKd|%||&|$d ddf t|d)pd }'tdLd<|Dr\|'|#kr\| |}%dI|'}&| dMd d |%dt|&dKd|%||&|'d ddf dNdO}(tdPdQrdPdRn tdP})|dSrdT|dSdU|dVdW|dXndY}*||||(|)|*dZ S)]zGCompute CLV edges for one match. Returns alert dict or None if no edge.Fcst|rn |rn}|r |r |s$dS|d}t||d||d}tt|tt|d}|dkrpt|dSdS)Nrrr")maxroundmin KELLY_MULT MAX_BET_PCT)pfodds use_kalshiuse_polybrbfstake)rIkalshi_bankroll poly_bankrollrr _kelly_stake4s z&_build_clv_alert.._kelly_stakecSs|r|dkrd|SdS)Nrrr)midrrr _kalshi_odds=sz&_build_clv_alert.._kalshi_oddscsNdkr>tdurtS|rn |r$n}|r:tt|dStS||||dS)Nr!rY)rarb)XLOW_STAKE_FIXEDr[XLOW_STAKE_PCTXLOW_STAKE_FALLBACK)r_r`rarbrc)ri_stratrIrgrhrr_stakeBs z _build_clv_alert.._stake pin_fair_homer pin_fair_draw pin_fair_awayclv_kalshi_homeclv_kalshi_away clv_b365_home clv_b365_awayr6clv_polyus_homeclv_polyus_away clv_poly_home clv_poly_awayr,kalshi_away_midkalshi_away_askpolyus_away_askpolyus_away_mid poly_away_ask poly_away_mid b365_awayNT)raz [SPREAD] home vs z away: confirming ask .3fz vs mid zG -- the mid fired on liquidity that is not there; dropping the poly leg)rbAWAY YESkalshi_home_midkalshi_home_askpolyus_home_askpolyus_home_mid poly_home_ask poly_home_mid b365_homez home: confirming ask HOME YEScSs4g|],}|ddus,|ddus,|ddur|qS)r#N r.0r*rrr r5z$_build_clv_alert..cSsg|]}|dds|qSrNOrrrrrrr5rYcSsh|] }|dqS)rrrrrr r5z#_build_clv_alert..cSs$t|dp d|dpd|dp dS)NrrrY )rZ)r*rrr_clv_maxsz"_build_clv_alert.._clv_maxkeyc3s"|]}|ddkr|VqdS)rNrr)winnerrr r5z#_build_clv_alert..u( [DEDUPE] both sides fired — keeping z (CLV d+.1fz%) over %) E:\soccer\data\pending_bets.jsoncSs(h|] }|d|d|dfqS)rr,betrBrrdrrrrr5rrcsJg|]B}dd|dfvrdd|dfvr|qS)rr,rrr)_OPP_pkeyswrrrs g333333?css|]}|ddkVqdS)rrNrrrrrrr5rzNO AWAYcss|]}|ddkVqdS)rrNrrrrrrr5zNO HOMElcrkickoffstrftimez%H:%M ETpin_homezH z D pin_drawz A pin_awayN/A) rrC mins_to_koedgesr6ko_strpin_strrIrgrh)FF)FF)rNrPrRr<rBr(rGrAMAX_ASK_MID_SPREADr)appendlenrZnextrJrKrrMranyr[hasattrrstr)+rrCrrE gate_pendingrkrppfhpfdpfaZclv_khZclv_kaZclv_bhZclv_baZ_is_gapZclv_phZclv_parZ away_b365_okZaway_kalshi_okZ away_poly_okrFZk_askp_ask b365_stake kalshi_stakeZ_p_mid poly_stakeZ home_b365_okZhome_kalshi_okZ home_poly_ok yes_sidesrZloserZ_pendZ NO_THRESHZ k_away_midZp_nopriceZ k_home_midr6rrr) rrirrorIrgrhrrr_build_clv_alert.s ,* . (,* . (&     22 *,rc1s |d|d|d}}|d}td}z|rDt|ng}Wnty`g}Yn0dt}ddd }i}d d z4ttd jd d} t | t r| n | d| } Wntyg} Yn0fdd| D} |D]} | \ } } }}}}}}}}}t |ddf| vrTt ddddddqt fdd|D}|rvq|rt fdd|Drt ddddddqd}t |ddt|p|||tvrdntdd t|d!|s0t| d"d#nd$|sFt| d"d#nd$|s\t|d"d#nd$td%|rzt|d!nd$|rt|d!nd$d&}|r||d'<||d(<|rd)vrdnd}|r|n|d*|d+d |d,<||d-<|r|rt|d!n||d.<||d/<|rqd$d$d0}|s6|s6| r~||t d1dddd|rpd2|d3nd |rd4|d3nd |rd5|d3nd t|}t|o| }|rd6}td7krtrd8d6i|d9<z\d:d$l}||} | r<| d;|d<<| d=|d><| d?|d@<dA| d;| dBdC|d9<dA}WnHty} z.t dDddddE| WYd$} ~ n d$} ~ 00|st dFddddGd8d6i|dH<zd:dIlm}!m}"|"r8|s8|!|} | r8| d;|dJ<| dK|dL<| dM|dN<| dO|dP<dA| d;| dM| dOdQdC|dH<WnHty} z.t dRddddE| WYd$} ~ n d$} ~ 00n| r~d)vrdnd}t|pd:}#d$}$d6}%zZd:d$l}&|& |dd|}'|'rdA}%|&!|'dS}(|(r|(dTrt|(dT}$Wn4tyD} zt dU| WYd$} ~ n d$} ~ 00t|d*|d+p^d:pt|d*|dVp|d:pd$})g}*|$r|#r|*d9t"|$|#|$fn4|%rtr|*dWt dXddddY|)r|#r|*dHt"|)|#|)f|*j#dZd[d\tr.|*j#d]d[d\t$rBd^d_|*D}*|*rt d`|#dadbdc%ddd|*Dde|*d:d:dfd6}+|*D]\},}-}.|+r q~|,d9krbd8d6i|d9<z\d:d$l}||} | r| d;|d<<| d=|d><| d?|d@<dA| d;| dBdC|d9<dA}+WnHty\} z.t dDddddE| WYd$} ~ n d$} ~ 00qt&}/t'd$urvt'n|/rtt(|/dgnt)}0t|.d!|d,<|0|d-<d8d6i|dH<zd:dIlm}!m}"|" r.|!|} | r.| d;|dJ<| dK|dL<| dM|dN<| dO|dP<dA| d;| dM| dOdQdC|dH<dA}+WnHt yx} z.t dRddddE| WYd$} ~ n d$} ~ 00q||<q|*tj+|dgdh|S)iaLog bets to pending_bets.json for a single alert dict from _build_clv_alert. Returns {side: {'kalshi': status_or_None, 'polyus': status_or_None}} so the caller can report real trade outcomes in the alert email -- a status dict means an order was ATTEMPTED (kill-switch/enabled gates already passed); 'placed': True carries order_id/amount, 'placed': False means it attempted but was skipped/failed downstream (excluded league, no market, drift, etc.).rrCrr6r game_daterrrcSs:|pd}|dr|Sd|vr*dSd|vr6dS|S)aCollapse the two strategies' side labels to a common key. The baseline path (daily_signals.add_to_pending) writes 'Away'/'Home' while xlow writes 'AWAY YES'/'HOME YES' -- an exact-string dedupe therefore saw them as different bets and let BOTH log, double-staking the same outcome across venues (Santos vs Chapecoense 2026-07-25: baseline $0.96 on Kalshi AND xlow $1.00 on Poly-US). Found 2026-07-24.rzNO ZAWAYHOME)rupperrsrrr _norm_sides z%_log_pending_bets.._norm_sidezE:\soccer\data\bet_history.jsonrrbetsc s@h|]8}t|ddd|d|d|dfqS)rN rr,r)rrBr)rrrrs$ z$_log_pending_bets..rr,z [DEDUPE] r z" already settled -- not re-loggingc3sH|]@}|ddko>|ddko>|dkVqdSrr,rNrr)rrDrrrrs$z$_log_pending_bets..c3sH|]@}|ddko>|ddko>|dkVqdSrrr)ropp_siderrrrs$z already pending for u — keeping first, skipping rZ xlow_polyusfidrrrN%Y-%m-%d %H:%M:%S)rrr,r6ZdivrEr fixture_idZpin_fairZ clv_kalshiZclv_b365Zclv_polyZentry_tsZ entry_k_midZ entry_p_midb365rfrr7Z_askZ kalshi_askrZpoly_askr)kalshipolyusz [PENDING] Logged: z B365 $.2fz Kalshi $z Poly $Fr!placedrrorder_idZauto_polyus_order_idZquantityZauto_polyus_qtyrZauto_polyus_priceTZdollar_committed)rramountz! [AUTO-POLYUS] hook crashed for : z! [AUTO] Poly-US could not place z -- falling back to Kalshir)place_auto_orderAUTO_TRADE_ENABLEDZ auto_order_idZ placed_atZauto_placed_atcountZ auto_countZ price_centsZauto_price_centsgY@z [AUTO] hook crashed for ZslugZbestAskz% [AUTO] Poly-US price check failed: r8)rrz" [AUTO] Poly-US has a market for z but no BBO -- trying it anywaycSs|dSNrrrrrrr4r5z#_log_pending_bets..rcSs|ddkrdnd|dfS)Nrrrrrrrrr4r5cSsg|]}|ddkr|qS)rrrrrrrrrr5z%_log_pending_bets..z [AUTO] signal(poly.com)=rz |  css:|]2\}}}|d|r,|dd|ddndVqdS)rrz (d=)zno-quoteNr)rndZpxrrrrs z -> z is closerrY)indent),rexistsrJrKrMrrBrtoday isinstancelistrr)rrmapsleague_kalshi_seriesr(r<r[rnowrrboolXLOW_PREFER_POLYUSZpoly_us_traderrr&rrApoly_us_pricesZ find_marketZget_bboabssortXLOW_KALSHI_ONLYjoinrPrlrmrnZ write_textdumps)1alertrCrr6Z pending_pathpendinggdZOPPOSITE trade_statusZ_histZsettledr*k_clvb_clvr_rrFrropp_midp_clvrralreadyZis_noentryZside_keystatusZsignal_is_kalshiZsignal_is_polyZ _placed_pusZputZrecrrZ signal_pxZ polyus_pxZpolyus_has_marketZ_pupZ_mktZ_bboZ kalshi_pxZvenuesrZvnameZ_distZvpxZkbZfallback_staker)rrrDrr_log_pending_betss       "$      ""               <$     (        <      < rc'Cs|sdS|dd}|dd}|dd}|r>d|dnd}|rRd|dnd}|rfd|dnd}d }g}|D]} | d | d | d } } } | d | d| d} }}| dpi}d }| D]}|\ }}}}}}}}}}}}|drqdd}||i} d|| dd|| d}!|d|d|ddd|ddd|ddd|dd|pndd|pzdd|pdd|rd|d ndd|rd|d ndd|rd|d ndd|!d!7}qd"d#| D}"|| d$d%| d&d'd(|"d)|d*| d$d%| d&d+| d,|d-t| d.|d/|d07}qvt|}#td1krpd2nd3}$|$d'|#d4|#d5krd6nd d7t d8}%d9|d:|d;|d<|d= }&t |%|&dS)>zCSend one email containing all CLV alerts collected this poll cycle.NrrIrgrh$z,.2frrrrr6rrrrrcSs,|dur dS|dr(d|dddSdS)N—rz&✓ $rrzz-not placedrrrrr_fmt_legOs  z&send_batch_clv_alert.._fmt_legzK: rz
PolyUS: rz z rrz% rz rrz cSs"g|]}|dds|dqSrrrrrrrhr5z(send_batch_clv_alert..rrr, (, rz!

z1

League: z  |  Kickoff: z  |  T-z: min

Pinnacle: a

z
SideKalshi CLVB365 CLVPoly CLV Pin FairB365 OddsKalshi Mid/PricePoly Ask/MidB365 KellyKalshi KellyPoly KellyReal Trade
r!z XLOW ALERTz CLV ALERTz MATCHrZESz) - z %Y%m%d:%H%MzI

B365 Bankroll: z'  |  Kalshi Bankroll: z%  |  Poly Bankroll: z'

z ) rBrrrrrEMAIL_ALERT_STRATEGYrrrrX)'ZalertsrIrgrhZbr_strZ kalshi_br_strZ poly_br_strZ match_blocksZ subject_partsrrrr6rrrZalert_trade_statusZ rows_htmlr*rDrrr_rrFrrrrrrrZ side_statusZ trade_cellrrtagrVrSrrrsend_batch_clv_alert6s             *  2r )check_halftime list_matchesget_all_prices COMEBACK_RATEz!https://v3.football.api-sports.iozx-apisports-keycCsdzJtjtdtdd}|}t|r.WdS|dd}|d|dWSty^Yd S0d S) aRequests left today. 0 when the plan's daily limit is spent. API-FOOTBALL SIGNALS EXHAUSTION WITH HTTP 200. It answers every endpoint -- /status included -- with 200, `response: []` and the reason in an `errors` object. So `r.json()['response']['requests']` raised on a list index, the bare except caught it, and this returned 9999 ("assume OK") at exactly the moment there was no quota left. The cost of that fail-open on 2026-08-29: api_ok stayed True, every score fetch came back empty, and 161 fixtures were logged status=FT with NO GOALS from the clock-based fallback, whose reason string blamed "fixture not found" 1,644 times while the real cause was never printed once. Results for a whole Saturday did not resolve and the dashboard showed them as open. A genuine network failure still returns 9999, because a transient blip should not shut off score collection; only a quota answer returns 0. z/statusr)headerstimeoutrresponserequestsZ limit_dayZcurrenti'N)rrBAF_BASE AF_HEADERSrJ_quota_exhaustedr)rjrrrrget_api_remainings  rcCs$|pid}t|tr d|vSdS)z=True when a 200 response is really 'you are out of requests'.rrF)rBrdict)rZerrsrrrrs rc Csddlm}t|}|s"dSdD]}|||d}|j|jdfD]}tjtdt ||| dd d } | d gD]t} | d d d } | d dd } | | vs| | vr| | vs| | vr| ddSqqHq&dS)z[Search API-Football for a fixture. Tries game_date and game_date+1 to handle UTC/ET offset.r timedeltaN)rrZdaysr /fixtures)r6ZseasonrrrparamsrrZteamsrnamer,fixtureid) rrrZ league_api_idrZyearrrBrr isoformatrJlower) rr, league_coderrZ league_idZdeltaZ search_dateZ season_yearrfixharrrfind_fixture_ids* r,zE:\soccer\data\af_cache.sqlitecCsRtdurNddl}tjjddd|jttddatdtdttS)NrTparentsexist_okg@)rzPRAGMA journal_mode=WALzFCREATE TABLE IF NOT EXISTS cache (k TEXT PRIMARY KEY, ts REAL, v TEXT)) _shared_connsqlite3 _SHARED_DBparentmkdirZconnectrexecutecommit)r1rrr _shared_dbs  r7cCsNz4td|f}|r0|dt|dfndWStyHYdS0dS)z2(ts, value) from the cross-process cache, or None.z!SELECT ts, v FROM cache WHERE k=?rrN)r7r5ZfetchonerJrKr)rrCrrr _shared_gets   r8cCsFz.t}|d|tt|f|Wnty@Yn0dS)Nz6INSERT OR REPLACE INTO cache (k, ts, v) VALUES (?,?,?))r7r5timerJrr6r)rvalueZdbrrr _shared_puts  r;)PSTCANCABDZSUSPZAWDZWOc Cs"|sdSddl}|durtn|}t|}|rJ||d|krJ|dStd|}|r||d|kr|d|dft|<|dSzZtjtdtd|idd}|d g}|r|dd pid pid nd}Wnt yd}Yn0||ft|<t d|||S) aVAPI-Football short status ('NS','PST',...), or None if unknown. Two cache tiers: the in-process dict avoids sqlite on the hot path (both quoters call this every 20s), the shared DB avoids the network across processes. max_age overrides the default TTL for callers that can accept a staler answer -- see fixture_playable. Nrrzstatus:r r%r!rr$rshort) r9 _STATUS_TTL _STATUS_CACHErBr8rrrrJrr;) rmax_age_tttlhitsharedrZrespstrrrfixture_statuss, .  rJcCst||dtvS)aFalse only when we KNOW it is not being played. Unknown -> True, so a lookup failure never silently stops us quoting a real match. max_age lets a caller accept a staler answer. The quoters now gate on the EXCHANGE's own view first (a delisted or non-active market is a stronger, free signal) and use this only as a backstop, so they pass a long max_age -- postponements are announced hours ahead, and re-asking every 30 min was ~2,200 calls/day for a fact that changes maybe twice a week. )rD)rJ NOT_PLAYED)rrDrrrfixture_playable"s rLi`Ti0*cCs$t|d}ttdt|dtS)zFNegative-cache TTL for this fixture: 5m doubling per consecutive miss.rrY ) _ODDS_MISSrBr\ _ODDS_NEG_TTL_ODDS_NEG_TTL_MAX)rrrrr_neg_ttl|s rRc sddl|durtn||durr|durrz t|}WnttfyNd}Yn0|dkrbtdn|dkrrtd|dur|rt}|durt||vrt9fdd}t }|durڈr||r|d SrPt d }|rPt |d t rPt|d dkrP|d|d d|d d ff} || rP| t <| d Srdt d nd} | r.|| dd| d ffr.| d } t | tr.| d r.| d r.| dr.d} t d } | rt | d t rt| d dkr| d d} td| | fft <| | fSzZtj tdtd ddd}i}| dgD]} | dgD]}|d}d|vsd|vrt| dgD]N}| dd krdd|dD}| d| d| dd ||d<qqtqdtd!d"|Dd}td#d"|Dd}|s8|rFtdnt dd t<||fft <td ||g||fWSty}zTtd$|t dd t<d%ft <td ddgWYd}~d%Sd}~00dS)&a+Fetch B365 and Pinnacle match-winner odds from API-Football (cached). Pass max_age=0 to force a fresh fetch (used by the nightly paths that want the closing line rather than a cached one). `hours_to_ko` scales the TTL. A fixture sits in a 24h pre-kickoff window and at a flat 1h TTL costs 24 calls whether or not anything moves -- and we measured (research/xlow_vs_line_age.py) that the Pinnacle line only changes about every 5.8 HOURS. The hourly resolution is only actually wanted near kickoff, where CLV is decided; twenty hours out it is re-fetching a number that will not move. Far out the TTL relaxes, inside 4h it stays hourly, so the CLV series keeps its resolution exactly where it reads it. Callers with no kickoff information get the old flat behaviour. rNrrNrrYcs:|d\}}|s|rn tt}|d|kS)zIs this (ts, (b365, pin)) entry still usable? A cached MISS expires sooner than a cached quote -- but on a backoff, not a flat 5 minutes.rr)r\rRr9)rrdplimitrErrFrr_freshs z#fetch_prematch_odds.._freshrzodds:zpinodds:r*rr+z/odds)r$rr@r!rZ bookmakersr#bet365pinnaclerr%cSs"i|]}|dt|dqS)r:Zodd)r'rArrrr sz'fetch_prematch_odds..valuesrZdrawr,)r*rr+css"|]\}}d|vr|VqdS)rWNr'rrrrrrrr5z&fetch_prematch_odds..css"|]\}}d|vr|VqdS)rXNr[r\rrrrr5z [odds] Error: NN)r9 _ODDS_TTLrA TypeError ValueErrorr+rrTRACKING_TTL_MULT _ODDS_CACHErBr8rrrrrOpoprrrrJr'ritemsr;rr))rrD hours_to_kor6r*Z_trrVrGrHrZ _pin_sharedZ_pinZ_b365Z_prevrZbooksZbkr#rZvalsrpinr*rrUrfetch_prematch_oddss     (   0(      rgcCs:d|d|d|}d||d||d||fSrr)r*rr+Zoverrrr remove_margin srhc Csn|dsdSt|dt||dd\}}|r6|sXtd|dd|dd dSt|d |d |d |d |d |d gsdSt|d |d |d \}}}d |d |d |}}}|d ||} |d ||} |d ||} g} | tkr| d| ddd| tkr:| d| ddd| tkr\| d| dddtd|dd|dd|ddtd|d d|d d|d td|dd|dd|dtd| ddd| ddd| ddd| rtd d!| d"ntd#tdd$d%t |d } d}| rz*|d&t }t| ||d|d}Wn4ty}ztd'|WYd}~n d}~00|r\td(|d)d*d|d+d*d|d,d*d-d)|fd.d+|fd/d,|ffD]^\}}}||}|r|d0kr|||}td1|d2|ddd3|d4d5|d4d qtd6t|d&t |d|d|d|d7d8|dd8|d |d |d |d |d |d t|d9t|d9t|d9t| d9t| d9t| d9| rd!| nd8|r|d)d8nd8|r,|d+d8nd8|r@|d,d8nd8|rT|d:d8nd8|rh|d;d8nd8|r||dd8nd8|r|d?d8nd8d@}t|}tdAD]}znt }ttd d8dBdC6}tj||dD}|r|||Wdn1s20YWqjWntydt !d Yn0qdS)EzMRun pre-match CLV + Kalshi price check. Logs to CLV_LOG. Call once per match.rNrrer6z [CLV] rrr,z$: odds not available on API-Footballr*rr+rzHOME+rz.1f%zDRAW+zAWAY+z [CLV] r rz B365: H=z D=z A=z Pin fair: H=rz CLV: H=rz% D=z% A=z *** EDGE: r z ***z% No CLV edge (all outcomes within .0frrz [Kalshi] Error: z Kalshi: H=Zhome_mid?Zdraw_midZaway_midHDArz Kalshi edge rz % (Kalshi rz vs Pin fair rrrrZhome_bidZdraw_bidZaway_bidZhome_askZdraw_askZaway_ask) timestamprr6rr,rrr b365_drawrrrrrqrrrsZclv_homeZclv_drawZclv_awayZclv_flagrkalshi_draw_midr|kalshi_home_bidkalshi_draw_bidkalshi_away_bidrkalshi_draw_askr}rnewliner fieldnames)"rBrg _hours_to_kor)allrh CLV_THRESHrrrrrrrrrrrrrr[rkeysrangeCLV_LOGrrcsv DictWriter writeheaderwriterowPermissionErrorr9sleep)rrrfphZpdpaZfair_hZfair_dZfair_aZclv_hZclv_dZclv_aflagsseriesrrr*ZlabelZmid_keyZfair_prjZk_edgerCZ CLV_FIELDSattempt write_headerreZw2rrr clv_checks  ,"""(& .$2&  0      * rc Cs|siSi}tdt|dD]}|||d}ddd|D}ztjtdtd|idd }|}t|rt d |WS|d gD]J}|d d }|d dd|d dd|dd|ddd||<qWqt y} zt d| WYd} ~ qd} ~ 00q|S)zVFetch live scores for multiple fixture IDs in one API call. Returns {fid: score_dict}.r-css|]}t|VqdSr/)r)rrerrrror5z%fetch_scores_batch..r Zidsrr!z_ [batch scores] API-Football daily request limit reached -- scores unavailable until it resetsrr$r%rrAelapsedZgoalsrr,)rrrr,z [batch scores] Error: N) rrrrrBrrrJrr)r) ZfidsZresultsichunkZids_strrrr)rr*rrrfetch_scores_batchhs0    &rc CsPtstgfSt}g}ttdd}|D]}|}|drtzt|dd}Wq4Yq40q4|r4|drq4dd|d D}t |d krq4|d |d |d |df\}}}}d} t |d kr|d r|d d nd} | rt | } | ||||| |dq4Wdn1s>0Y||fS)z8Parse watchlist.txt. Returns (game_date, list of dicts).rrzDATE=rwNr cSsg|] }|qSr)r)rrSrrrrr5z'load_watchlist_file..|rrrrYrr)rr,rrrr) WATCHLIST_FrrrrrrZ fromisoformatrrisdigitintr) rZmatchesrerpartsrr,rrrtokrrrload_watchlist_files8   $    *rcCsBz.t|t|d}t|dWSYdS0dS)zXMinutes elapsed since kickoff. Returns None if unparseable, negative if not yet started.%H:%Mr N)rZcombinestrptimer9r total_seconds) kickoff_strrZkorrrclock_elapsed_mins rcCsNz4t|d|dt}|dur*dn| dWStyHYdS0dS)zHours until this fixture kicks off, or None if unknown/unparseable. Only used to relax the odds cache TTL far from kickoff, so an unknown value must degrade to the old flat behaviour rather than to a guess. rrNgN@)rrBrrr)rZelrrrr|s  r|rwcCsT|ddvrdSt|d|dt}|dur:dSt |koNtkSS)abIs this watchlist entry near enough to kickoff for a live score to exist? Unparseable kickoff -> True, so a bad time string degrades to the old always-poll behaviour rather than silently going blind on a live match. A fixture already known to be in play is always in window, which covers a kickoff that ran late past the POST bound. last_status)1H2HHTZETZBTPZLIVETrrN)rBrrrSCORE_WINDOW_PRESCORE_WINDOW_POST)rr*rrr_in_score_windows rcCs*t||}|duo(d|ko$dkSS)zATrue if we're roughly in the HT window (46-62 min after kickoff).N.>)r)rrr*rrr is_ht_windows r)9rprr6rr,rr home_goals away_goalsrrrrrqrrrsrrrrtrvr|rur}rZ poly_home_bidr poly_draw_midZ poly_draw_bidZ poly_draw_askrZ poly_away_bidrrZpolyus_home_bidrpolyus_draw_midZpolyus_draw_bidZpolyus_draw_askrZpolyus_away_bidr~rqrrrsrvZ clv_b365_drawrwrtZclv_kalshi_drawrurzZ clv_poly_drawr{rxZclv_polyus_drawrycCslzPt|dpd}t|dp$d}t|dp6d}|rP|rP|rPd|d|d|}d||}d||}d||}t|d|d<t|d|d<t|d|d <d |fd |fd |ffD]H\}} t||pd} d |} | r| rd| } t| | | d|| <qd|fd|fd|ffD]R\} } t|| p@d}d| dd} |r(| r(t| || d|| <q(d|fd|fd|ffD]R\}} t||pd}d|dd} |r| rt| || d|| <qd|fd|fd|ffD]R\}} t||pd}d|dd} |r| rt| || d|| <qWntyfYn0|S)zMCompute pin_fair and CLV columns in-place. Returns row with CLV fields added.rrrrrr#rqrrrsrrqrZclv_rrrr|r-_rrrr.rrrr:)rArBr[rr)rCrZpd_rZovrrrZb_keyr_rdZclv_keyZ fair_oddsZk_keyrZp_keyrSrrr compute_clvsH      rcCs8t|dr|}nt|}tjdddt|dS)zPReturn the per-day CSV path for a given game_date (date or 'YYYY-MM-DD' string).r&Tr-z.csv)rr&r LIVE_LOG_DIRr4)rZgd_strrrr live_log_path!s   rc s*ts dSddl}ttdD]}t|dddd}|}Wdn1sV0Y|sjq"t | |}|j pgfdd t D}|sq"t d |jd |t|}t|d dddH}tj|t d }||D]|fddt DqWdq"1s0Yq"dS)z=Add any missing columns to each per-day live_data CSV header.Nrz*.csvrrrrxcsg|]}|vr|qSrr)rr0)existingrrr6r5z$migrate_live_log..z [migrate] Adding columns to rrrzcsi|]}||dqSrrrrrCrrrY?r5z$migrate_live_log..)rriosortedZglobrreadrrZ DictReaderStringIOr{ LOG_FIELDSr)r#rrrr)rrreZcontentreaderZmissingZrowsrr)rrCrmigrate_live_log*s(& rcCsXzDt|}|sWdSt||||}|s2WdSdd|DWSYdS0dS)zXFetch home/draw/away prices from Kalshi. Returns dict with kalshi_ prefix keys, or None.NcSsi|]\}}d||qS)r7rr\rrrrYJr5z fetch_kalshi..)rrrrrd)rr,r(rrrawrrr fetch_kalshiAsrcCsNz4tj||||d}|s"WdSdd|DWStyHYdS0dS)zFetch home/draw/away prices from Polymarket. Returns poly_-prefixed dict, or None. Mid/bid/ask, same shape as fetch_kalshi. Cheap single-tag fetch via league=.r6NcSsi|]\}}d||qS)r;rr\rrrrYVr5zfetch_poly..)polymarket_liverrrdr)rr,r(rrrrr fetch_polyOs rcCsVz.)rrrrdr)rr,r(rrrrrr fetch_polyus[s rc sdpt}t|}tdD]}zt| }t|ddddB}tj |t d}|rb| | fdd t DWdn1s0YWdSt ytd Yq&0q&dS) Nrrwr+rrrxrzcsi|]}||dqSrrrrrrrYrr5zlog_row..r)rBrrr&rrrrrrrrrrr9r)rCrrrrrerrrrlog_rowhs  6 rcCs|durt}tddtdtd|durdtdtd|d|d|d ntdt||||||tdddS) N z<============================================================zHALFTIME ALERT z%H:%M:%Su8Score unknown (API unavailable) — check score manuallyz(Then run: check_halftime(date.today(), 'z', 'z ', H, A, 'z'))rrr)rrrr)rr,r(Zscore_hZscore_arrrrrxs rc7Csd tdtdtdttdtdttdtdkrNtdtd ti}d }d }d }d }i}d }g}t}t rz t Wn:t y} z"td t d | dWYd} ~ nd} ~ 00tddSzt j} Wnd } Yn0trttd| |krt\} } dd| D} | D]}|d|df}||vrtd|dd|dd |dd|di|dddddddddd ||<n6dD]}|||||<q|dr@|d||d<q@d}t|D]}|| vr||}|ddur`|d |vr`d |d!<td"|dd|dn&||td#|dd|dq|std$t| }t|D]Z}||}|d!r|ds|d d%vr||td&|dd|dq|sttq|||tkr^t}|}|tkrZ|rTtd'|d(d}nd }|r||tkrd)d*|D}|rt|}|}t|D ]J\}}|drt !|d"d+krԐqt#|d|d,t}|durt|d-krt|d.kr|r|d/}|dus:t !|"d0kr|dsz&t$|d|d|d|d,|d<Wnt%y~Yn0d1\}}|drt&|dt'||dd2\}}|d,t}t(|d|d|d|}t)|d|d|d|}t*|d|d|d|}t+|}t !,d3t-||d|d|dd4|d d |rR|d5nd6|rb|d7nd6|rr|d8nd6|r|d5nd6|r|d7nd6|r|d8nd6d9}|r|.||r|.||r|.|t/|t0|t !|d/<d d:l m1} t-|d,d6t-tt-t| d;d<fv}!d}"|d=s|!rt2|||}#|#rt3|#}"d |d=<t4d>kr|"|#d?<|5|#t4dkr|d@s|!rt2|||dddA}$|$r|"pi|$d?<|5|$d |d@<|sdBn|d8dCdD}%|sdBn|d8dCdD}&|r"|dEdnd}'|'s0dBn|'dD}(tdF|dGdH|dd|ddI|%dJ|&dK|( qdLt !,dMdN|dd|d})|dOs|dr|rt#|d|d,t}|dur|d krd |dO<t6|nd |dO<d}*|r|ds|dP}+|+dus>t !|+"dQkrt !|dP<zHt$|d|d|d|d,|d<|drtdR|)dS|dWn<t%y} z"tdR|)dT| dUWYd} ~ n d} ~ 00|dr||d}*|* rX|*dV},|*d pd }-|*d pd }.|*dW}/t !}0|/|dXk r@|/|dX<|0|dY<|/ r||dY r||,dZv r||0|dY"d[}1t+|/|1}2n:|,d\v rt+t#|d|d,t pd }2n |/ pd }2tdR|)d]|-d^|.d_|,d`|2da |d,t}t(|d|d|d|}t)|d|d|d|}|ddu o6|,dbv}3|3 s|2dck r|0,d3t-||d|d|d|,|2|-|.dd }| r|.|| r|.|t0||,dek r|df sd |df<t7|d|d|d|-|.|nr|,dbv rL|d sLt !|d<|df stdR|)dg|,dhn0tdR|)d]|,di|dj8d d dj,dMdk|,|d <q|dr|d,t}t#|d|}4|4dur|4d kr|4dckr|ds| sdlndm}5|4dnk rdo}6n$|4dpk rde}6n|4dqk rdr}6nds}6t !}0t(|d|d|d|}t)|d|d|d|}|0,d3t-||d|d|d|6t+|4dddd }| rh|.|| rx|.|t0|tdR|)d]|4dtdu|5dv|dfst9|d|rtdR|)dwd |df<t7|d|d|dddq| r||dxk rt:||}g}| rTt;dydz|D rTtd{t !,dMd||<ttq|dS)}Nu === Live Match Monitor — z ===z Watchlist: z Strategy: u — rlr!zR NOTE: xlow fires ONLY on matches where BOTH Kalshi and Polymarket quote a price.uDEdit and save the file any time — picks up changes automatically. rTz [RECYCLE] cannot clear r z5) -- staying up rather than exiting into a stuck flagzO [RECYCLE] requested -- exiting; SoccerMonitorGuard will restart within ~5 minz3 [config] league_map.json / team_map.json reloadedcSs$h|]}|d|dfqS)rr,r[)rmrrrrr5zmain..rr,z + Watching: rrz) ko=rF) alerted clv_alertedrft_time clv_checkedlast_api_elapsedapi_elapsed_sincelast_prematch_logfid_last_tried)rrrr)NNSTBDr=r>r?rrZfinish_then_dropz - Removal deferred (in play): z - Removed: u% Watchlist empty — add matches to )r=r>r?z - Removed (finished): z [!] API-Football quota low (u0 left) — switching to clock-based HT detectioncSsDg|]<}|dr|dr0t|ddkst|r|dqS)rrr<)rrrrrrrrrrs(zmain..r<riiVrir]rirZPREr*rrr+)rprr6rr,rrrrrrrrrqrrrrrr}rZ xlow_alerted)rErrrror|z [PRE z+dzmin] z: Pin=z B365=z Kalshi=[rz] rrr rz : fixture ID z: lookup error (rrrrr)rrrFTAETPENr )rrrrz [rz'])rrrx) rprr6rr,rrrrrrz : finished (u#) without HT data — nothing to dou — will stop polling at )secondZ microsecondz +30minz quota lowzfixture not foundrrrsrrrkz min elapsed (u) — logged Kalshi onlyu&: clock HT window — triggering alertrMcss.|]&}|do$t|ddkVqdS)rr<N)rrrrrrrrszmain..z [u6] All matches complete — waiting for next watchlist.)=r)rrrr< STRATEGIESrBrr9 RECYCLE_FrunlinkOSErrorstatst_mtimerZchangedreloadrr'rrrcr POLL_SECSQUOTA_CHECK_SECSr AF_LOW_WATER AF_POLL_SECSrZrrdrrrrr,rrgr|rrrrrrupdaterrrrrr rrrrrr r}clear)7Z watchlistZ file_mtimeZapi_okZquota_checked_atZ af_last_pollZ af_scoresZ clv_last_sentZ clv_batchZnow_tsr*mtimerZfreshZ fresh_keysrrreZ _NOT_STARTEDrrZ remainingZ live_fidsrZlastZpre_b365Zpre_pinrrZpolyrrrCZ_tdZ_gd_okrZ clv_alertZ xlow_alertrZb365_strZkal_awayZkal_strr ZscoreZ last_triedrr*r+Z api_elapsedZnow_dtZextraZ est_elapsedZalready_terminalZclock_elreasonZ est_statusrrrmains* ,     0            $  &               (     " ,  & (      0  (        r__main__zLive match monitor)Z descriptionz --strategyz-signal rule to fire on (default: %(default)s))choicesdefaulthelp)N)NT)N)N)NNN)N){__doc__sysrr9rrUrJrrstdout reconfigurepathlibrZemail.mime.multipartr Zemail.mime.textr rZAPI_KEYrrrrrrrrr~rZ_envrBrTrrrLrOrQr=r>r?r@rr]r^rr<r rmrnrlrrr(rar+r%rGrNrPrRrXrrr Z kalshi_liverrrrrrrrrr,r2r0r7r8r;rCrBrKrJrLZPLAYABLE_BACKSTOP_TTLrbr^rPrQrOrRrgrhrrrrr|rrrrrrrrrrrrrr__name__argparseArgumentParserZ_ap add_argumentrZparse_known_argsZ_argsrrErrrrs 0          - "iO!      Y ( +