o )å²i×Øã@sddZddlZddlZddlZddlZddlZddlZddlZddlZddl m Z m Z m Z ddl m Z e d¡Ze dee eƒ ¡jjdƒ¡Zee eƒ ¡jjdd ƒZe d d ¡Ze d d ¡Ze d d ¡Ze dd ¡ZdZdZdZdZdZdZ dZ!dZ"e dee  #¡ddƒ¡Z$ee  #¡dƒee  #¡ddddƒee eƒjdƒgZ%Gdd„dƒZ&dS)u Dashboard Scheduler — automated data refreshes, proactive WhatsApp nudges, weekly reports, health data ingestion (Oura API + Health Connect fallback), Gmail briefing integration, and 'on this day' insights. Runs as a background thread inside the Flask app. Health data pipeline: PRIMARY: Oura API v2 → sleep, steps, exercise, HRV, readiness (direct API pull) FALLBACK: Google Drive API → Health Connect zip → weight, body fat, blood pressure FALLBACK2: Filesystem watcher on local Google Drive sync + ~/clawd/health-imports/ éN)ÚdatetimeÚdateÚ timedelta)ÚPathÚ schedulerÚDASHBOARD_DATA_PATHzdashboard-data.jsonÚmemoryz chatgpt-kb.dbÚTWILIO_ACCOUNT_SIDÚÚTWILIO_AUTH_TOKENÚTWILIO_PHONE_NUMBERÚBILL_PHONE_NUMBERééééé éi,ÚHEALTH_CONNECT_DIRz Google DrivezMy DriveÚLibraryÚ CloudStoragezGoogleDrive-syrros@gmail.comzhealth-importsc@seZdZdZdd„Zdd„Zdd„Zdd „Zd d „Zd d „Z dd„Z dd„Z dd„Z dd„Z dd„Zdd„Zdd„Zdd„Zdd„ZeZd d!„Zd"d#„Zd$d%„Zd&d'„Zd(d)„Zd*d+„Zd,d-„Zd.d/„Zd0d1„Zd2d3„Zd4d5„Zd6d7„Zd8d9„Z d:d;„Z!dd?„Z#d@dA„Z$dBS)CÚDashboardSchedulerzCBackground scheduler that runs data refreshes and proactive nudges.cCsl||_d|_d|_d|_d|_d|_d|_d|_d|_t ƒ|_ d|_ d|_ d|_ i|_d|_d|_d|_dS)NFr)ÚdmÚrunningÚthreadÚ _last_refreshÚ _last_morningÚ _last_eveningÚ _last_weeklyÚ_last_briefing_updateÚ_last_health_checkÚsetÚ_ingested_filesÚ_gdrive_connectorÚ_gmail_briefingÚ_gdrive_last_file_idÚ_last_email_nudgesÚ_last_new_musicÚ_last_health_dailyÚ_last_pregame_rapid)ÚselfÚdashboard_manager©r,úD/sessions/festive-kind-sagan/mnt/clawd/whatsapp-agent/./scheduler.pyÚ__init__Bs" zDashboardScheduler.__init__cCs:|jrdSd|_tj|jdd|_|j ¡t d¡dS)z+Start the scheduler in a background thread.NT)ÚtargetÚdaemonzScheduler started)rÚ threadingÚThreadÚ _run_looprÚstartÚloggerÚinfo©r*r,r,r-r4Us  zDashboardScheduler.startcCsd|_t d¡dS)zStop the scheduler.FzScheduler stoppedN)rr5r6r7r,r,r-Ústop^szDashboardScheduler.stopc Csät d¡| ¡|jrpz:t ¡}t ¡|jtkr%| ¡t ¡|_|j t krF|j t krF|j t dkrF|j | ¡krF| ¡| ¡|_ |j tkrg|j tkrg|j tdkrg|j| ¡krg| ¡| ¡|_| ¡tkr‡|j tkr‡|j dkr‡|j| ¡kr‡| ¡| ¡|_d|j kr’dkr¦nnt ¡|jtkr¦| ¡t ¡|_|j dkrÀ|j dkrÀ|j| ¡krÀ| ¡| ¡|_gd¢}|j |vrç|j dkrç|j |j ¡| ¡krç|  |j ¡| ¡|j|j <| ¡dkr |j dkr |j dkr |j!| ¡kr | "¡| ¡|_!|j#|j kr| ¡|j |_#t ¡|j$d krGz| %|¡Wnt&yF}zt' (d |›¡WYd }~nd }~wwWnt&ye}zt'j)d |›d dWYd }~nd }~wwt d¡|js d Sd S)u0Main scheduler loop — checks every 30 seconds.é érré©ré ééri„z*Rapid pregame check error (non-critical): NzScheduler loop error: T©Úexc_infor)*ÚtimeÚsleepÚ_update_briefing_datarrÚnowrÚDATA_REFRESH_INTERVALÚ _refresh_dataÚhourÚMORNING_NUDGE_HOURÚminuteÚMORNING_NUDGE_MINrrÚ_send_morning_nudgeÚEVENING_NUDGE_HOURÚEVENING_NUDGE_MINrÚ_send_evening_nudgeÚweekdayÚWEEKLY_REPORT_DOWÚWEEKLY_REPORT_HOURrÚ_send_weekly_reportr ÚHEALTH_CHECK_INTERVALÚ_check_health_connectr(Ú_daily_health_grabr&ÚgetÚ_send_email_digestr'Ú_send_new_musicrr)Ú_maybe_rapid_pregame_refreshÚ Exceptionr5ÚdebugÚerror)r*rEÚEMAIL_NUDGE_HOURSÚer,r,r-r3cs€                      €ÿ€ €ÿ ¯zDashboardScheduler._run_loopc CsÌzÈt d¡|j ¡}d}| ¡}|r5d|vri|d<||dd<t ¡ ¡|dd<d}t d|›¡t  ¡ ¡}|  d¡|krH||d<d}|  |¡}|rU||d <d}z"|  ¡}|d urv|t ¡ ¡d œ|d <d}t d t |ƒ›d¡Wnty‘}zt d|›¡WYd }~nd }~ww|rÆddlm}|t|jjƒddd} | |j |¡Wd ƒn1s¹wYt d¡Wd SWd Styå}ztjd|›ddWYd }~d Sd }~ww)z?Refresh live data in dashboard-data.json (crypto prices, etc.).z!Running scheduled data refresh...FÚcryptoÚ cro_priceÚ cro_updatedTzCRO price refreshed: $rÚ nextEventN©ÚgamesÚupdatedÚbettingzBetting picks refreshed: z gamesz-Betting picks refresh failed (non-critical): r)ÚFileLockz.lockr9)ÚtimeoutzDashboard data refreshedzData refresh failed: r@)r5r6rÚreadÚ_fetch_cro_pricerrEÚ isoformatrÚtodayrWÚ_get_next_eventÚ_fetch_betting_picksÚlenr[r\ÚfilelockrhÚstrÚ file_pathÚ_writer]) r*ÚdataÚchangedraÚ today_strÚupcomingÚpicksr_rhÚlockr,r,r-rG¿sZ       þ€€ÿ ÿú"€ÿz DashboardScheduler._refresh_datac Csvztjddddœdd}|jdkr| ¡ di¡ d¡WSWd Sty:}zt d|›¡WYd }~d Sd }~ww) zFetch CRO price from CoinGecko.z-https://api.coingecko.com/api/v3/simple/pricezcrypto-com-chainÚusd)ÚidsÚ vs_currenciesr9)ÚparamsriéÈzCRO price fetch failed: N)ÚrequestsrWÚ status_codeÚjsonr[r5Úwarning)r*Úrespr_r,r,r-rkôsý ÿþ€þz#DashboardScheduler._fetch_cro_pricec Csjt ¡}| ¡}| dg¡D]$}| dd¡|kr2|d|d| dd¡| dd¡| dd¡dœSqd S) zFind the next upcoming event.Úschedulerr ÚtitlerBÚlocationÚnote)r†rrBr‡rˆN)rrmrlrW)r*rurmÚnow_strÚeventr,r,r-rns    ûÿz"DashboardScheduler._get_next_eventc Cór|jdur/z ddlm}|ƒ|_Wnty.}zt d|›¡d|_WYd}~nd}~ww|jdur7|jSdS)z%Lazy-load the Google Drive connector.Nr)Ú get_connectorz&Google Drive connector not available: F)r#Ú gdrive_healthrŒr[r5r\)r*rŒr_r,r,r-Ú_get_gdrive_connectoró   €þz(DashboardScheduler._get_gdrive_connectorc Cr‹)z$Lazy-load the Gmail briefing module.Nr)Úget_gmail_briefingzGmail briefing not available: F)r$Úgmail_briefingrr[r5r\)r*rr_r,r,r-Ú_get_gmail_briefingrz&DashboardScheduler._get_gmail_briefingc Cslz| ¡}|r|jr| |¡WdS| ¡WdSty5}ztjd|›ddWYd}~dSd}~ww)uÙ Watch for new Health Connect zip files. Strategy: 1. PRIMARY: Google Drive API — search for files, download, parse 2. FALLBACK: Filesystem watcher on local sync folders NzHealth Connect check failed: Tr@)rŽÚ availableÚ_check_health_connect_gdriveÚ _check_health_connect_filesystemr[r5r])r*Úgdriver_r,r,r-rU)s  "€ÿz(DashboardScheduler._check_health_connectc Cs6zy|jdd}|s WdS|d}|d}||jkrWdS|ddkr5t d|d ›d |d›d ¡WdSt d |d ›¡| ||d ¡}|sUt d ¡| ¡WdS| |¡}|rq||_|j   |¡|  d|›¡|  ¡|j ddWdStyš}ztjd|›dd| ¡WYd}~dSd}~ww)z8Check Google Drive for new Health Connect files via API.é©Ú max_age_hoursNrÚidÚsizeézSkipping small Drive file: Únameú (ú bytes)z"New Health Connect file in Drive: u.Download failed — falling back to filesystemu5Luke here — health data auto-imported from Drive! r©Ú max_age_daysz"Google Drive health check failed: Tr@)Úsearch_health_connect_filesr%r5rƒr6Ú download_filer]r•Ú_ingest_health_filer"ÚaddÚ_send_whatsapprDÚcleanup_old_downloadsr[)r*r–ÚfilesÚlatestÚfile_idÚ local_pathÚresultr_r,r,r-r”>s:       €ýz/DashboardScheduler._check_health_connect_gdrivec Csôtgt}|D]p}tj |¡sqtj |d¡tj |d¡tj |dd¡g}|D]O}tj|ddD]E}||jvr8q0tj |¡}t   ¡|d}|dkrKq0tj  |¡dkrTq0t   d |›¡|  |¡}|ru|j |¡| d |›¡| ¡q0q'qd S) z9Fallback: watch local filesystem for Health Connect zips.úHealth Connect*.zipúhealth_connect*.zipú**T©Ú recursiverr—rœz/New Health Connect file detected (filesystem): u*Luke here — health data auto-imported! N)rÚHEALTH_CONNECT_ALT_DIRSÚosÚpathÚisdirÚjoinÚglobr"ÚgetmtimerBÚgetsizer5r6r¤r¥r¦rD) r*Ú search_dirsÚ search_dirÚpatternsÚpatternÚzip_pathÚmtimeÚ age_hoursr¬r,r,r-r•js8    ý    €ïÿöz3DashboardScheduler._check_health_connect_filesystemc CsVz ddlm}|||jƒWSty*}ztjd|›ddWYd}~dSd}~ww)z!Ingest a Health Connect zip file.r)Úingest_health_connectz!Health Connect ingestion failed: Tr@N)Úhealth_connectrÁrr[r5r])r*r¾rÁr_r,r,r-r¤Œs €þz&DashboardScheduler._ingest_health_filec Csüt d¡g}z(ddlm}||jƒ}|r&d| ¡vr&| |¡t d¡nt d|›¡WntyK}ztjd|›dd WYd }~nd }~ww|  ¡}|rW| |¡|rr|  ¡d   |¡}|  d |›d ¡t d¡d St d¡|  d¡d S)uX Daily 8 AM health data pull. Pipeline: 1. Oura API → sleep, steps, exercise, HRV, readiness 2. Health Connect (Drive) → weight, body fat, blood pressure Each part is independent — Oura failure doesn't block HC and vice versa. Sends a WhatsApp summary of what was updated. z)=== Daily health grab starting (8 AM) ===r©Úingest_oura_dataúnot configuredu#Daily health grab — Oura: SUCCESSuDaily health grab — Oura: u#Daily health grab — Oura failed: Tr@Nz u)Good morning! 📊 Health data updated. u Dashboard updated. — LukezDaily health grab: SUCCESSz"Daily health grab: no data updatedu±Morning check-in — no new health data today. Oura data will pull automatically if configured. For weight, upload a Health Connect export to Drive or text me 'health'. — Luke) r5r6Úoura_apirÄrÚlowerÚappendr[rƒÚ_daily_health_connect_pullrDr¶r¦)r*Ú summariesrÄÚ oura_resultr_Ú hc_resultÚcombinedr,r,r-rV—s<     € €ÿ  ÿÿ ÿz%DashboardScheduler._daily_health_grabc Csº| ¡}|r©|jr©tddƒD]š}zq|jdd}|rw|d}|d}||jkr4t d|d›¡Wd S|d d krLt d |d›d |d ›d¡Wq| ||d¡}|rv|  |¡}|rv||_|j   |¡|j ddt d¡|WSn t d|›d¡Wnt yž}zt d|›d|›¡WYd }~nd }~ww|dkr¨t d¡qz| ¡}|r¼d|vr¿t d¡|WSWd SWd St yÜ}zt d|›¡WYd }~d Sd }~ww)z« Pull weight/body fat from Health Connect via Google Drive. Retries up to 3 times with 2-minute intervals. Returns summary string or None. ér?r—r˜rršz"Already ingested today's HC file: rNr›rœzSkipping small file: ržrŸrr zDaily HC pull: SUCCESS (Drive)zDaily HC pull attempt z/3: no files found yetz /3 failed: ééxzNo Health Connectz#Daily HC pull: SUCCESS (filesystem)z*Daily HC pull filesystem fallback failed: )rŽr“Úranger¢r%r5r6rƒr£r¤r"r¥r§r[rBrCÚtrigger_health_ingest) r*r–Úattemptr¨r©rªr«r¬r_r,r,r-rÉÈs^          €€"€ÿ €  þúý€ýz-DashboardScheduler._daily_health_connect_pullc CsìzØ| ¡}|r |js WdS| ¡}| d¡sWdSddddœ}| |d¡}|›dg}| d¡| d ¡}|rG| d |d ›d |d ›d¡| dg¡}|rq| d¡| d¡|D]} | d| d›d| ddd…›¡q[| dg¡} | r¡|s¡| d¡| d¡| dd…D]} | d| d›d| ddd…›¡q‹| dg¡} | r³| dt| ƒ›¡|rÎ|d dkrÎ| d |¡¡t  |›d¡WdSt  |›d¡WdSt yõ} ztj d| ›d d!WYd} ~ dSd} ~ ww)"z4Send a Gmail digest via WhatsApp at scheduled times.Nr“ÚMorningÚMiddayÚEveningr<r u Inbox Update — LukeÚunreadzUnread: Ú total_unreadržÚprimaryz primary)Ú needs_replyz Needs reply:u — Úfromz: Úsubjecté2Ú importantz Important:rÏÚmeetingsz Meeting invites: rÚ z email digest sentu+ email digest skipped — no primary unreadzEmail digest failed: Tr@) r’r“Úgenerate_briefingrWrÈrpr¦r¶r5r6r\r[r]) r*rHÚgmailruÚlabelsÚlabelÚlinesr×rÚr_rÞrßr,r,r-rXsJ           (   ( "€ÿz%DashboardScheduler._send_email_digestc Csœz0ddl}| ¡s WdS|jdd}|r)d|vr)d|vr)| |¡t d¡WdSt d¡WdStyM}ztjd |›d d WYd}~dSd}~ww) z*Send new music releases on Friday morning.rNé©Úlimitz No new dropsz not connectedzNew Music Friday sentz'New Music Friday: nothing new this weekzNew Music Friday failed: Tr@) Úspotify_moduleÚ is_availableÚ new_releasesr¦r5r6r\r[r])r*réÚmusicr_r,r,r-rY6s  "€ÿz"DashboardScheduler._send_new_musicc spz˜|j ¡}|d}t ¡‰| dg¡}t|ƒdkr5|d|d}|dkr)dnd›d t|ƒd ›d }nd }‡fd d„| dg¡Dƒ}‡fdd„| dg¡Dƒ}| di¡ dd¡}t|tt fƒrgd|›nt |ƒ} dˆ  d¡›dg} |   d¡|   d|d›d|›d¡|   d| dd¡›d| d d!¡›d"¡|   d#| ›¡| d$i¡} |  d%¡rÏ|   d&| d%›d'|  d(d!¡›d)|  d*d!¡›d+|  d,d¡›d- ¡|rú|   d¡|   d.¡|D]} |  d/¡rëd | d/›nd} |   d0| d1›| ›¡qÝ|r |   d¡|   d2¡|d3d4…D]} |   d0| d5›d6| d1›¡q |  ¡}|rj|jrjz#| ¡}| d7¡rM| d8¡rM|   d¡|   d9¡|   |d8¡Wntyi} zt d:| ›¡WYd3} ~ nd3} ~ ww| ¡}|r~|   d¡|   d;|›¡|   d¡|   d<¡d= | ¡}| |¡t d>¡Wd3Sty·} ztjd?| ›d@dAWYd3} ~ d3Sd3} ~ ww)Bz#Send morning briefing via WhatsApp.ÚweightÚ series30dréÿÿÿÿéùÿÿÿrÚdownÚupú ú.1fú lb this weekÚtrackingcó"g|] }| d¡ˆ ¡kr|‘qS©r©rWrl©Ú.0r_©rmr,r-Ú Yó ÿz:DashboardScheduler._send_morning_nudge..r…csBg|]}ˆ ¡| dd¡krˆtdd ¡krnn|‘qS)rr rÏ©Údays©rlrWrrúrür,r-rý]s 2ÿr`raúN/Aú$u*Good morning Bill — Luke here with your ú %A, %B %-dz briefing:r zWeight: Úcurrentz lb (ú)z Goal pace: Úpacez lb/wk | ETA: ~ÚetaWeeksú?ú weekszCRO: rCÚ total_hourszSleep: zh (Úbedtimeuâ†’Ú wake_timeu ) · HRV: Úavg_hrvz mszTODAY:rBú r†z COMING UP:NrÏrõ — r“Ú summary_textzEMAIL:z(Gmail briefing in morning nudge failed: ú ON THIS DAY: uReply anytime — Luke's here.ràzMorning nudge sentzMorning nudge failed: Tr@)rrjrrmrWrpÚabsÚ isinstanceÚintÚfloatrrÚstrftimerÈr’r“rár[r5r\Ú_get_on_this_dayr¶r¦r6r])r*ruÚwÚseriesÚ week_changeÚtrendÚ events_todayÚevents_upcomingÚcroÚcro_strrårCr_Útime_strrâÚ email_dataÚinsightÚmessager,rür-rLIs|   $  ÿ  ÿ  (  @    "  €€ÿ     "€ÿz&DashboardScheduler._send_morning_nudgec sfz|j ¡}|d}t ¡}d| d¡›g}| d¡| d|d›d| dd ¡›d ¡|td d ‰‡fd d„| dg¡Dƒ}|rv| d¡| dˆ d¡›d¡|D]}| d¡rfd|d›nd}| d|d›|›¡qXn| d¡| dˆ d¡›d¡| di¡ dg¡}|D]e} |  dd¡} zRt  | d|j ›d¡ ¡} || kr¹|tdd krìnn1|  dd¡} t | t t fƒrÎ|d| nd } | d krÖd!nd"›d#| ›d$}| d%| ›d&| ›d'|›¡Wq“ttfyøYq“w| d¡| d(¡d) |¡}| |¡t d*¡Wd.Sty2}ztjd+|›d,d-WYd.}~d.Sd.}~ww)/uWSend evening check-in via WhatsApp. No weight nagging — Bill weighs in mornings only.ríuEvening check-in from Luke — rr zToday's weight: rú lb | Pace: rrú lb/wkrÎrÿcr÷rørùrú©Útomorrowr,r-rýªrþz:DashboardScheduler._send_evening_nudge..r…z TOMORROW (z%Az):rBrórr†z Nothing scheduled for tomorrow (z).Ú healthPlanÚweeklyCheckpointsrú %A, %B %d %Yér/r rÚabovez on track forz target ú lbz Checkpoint alert: z target is u lb — you're u?Anything to update? (BP, events, signals, supplements) — LukeràzEvening nudge sentzEvening nudge failed: Tr@N)rrjrrmrrÈrWrrÚstrptimeÚyearrrrÚ ValueErrorÚ TypeErrorr¶r¦r5r6r[r])r*rurrmråÚtomorrow_eventsr_r!Ú checkpointsÚcpÚ cp_date_strÚcp_dater/ÚdiffÚstatusr$r,r'r-rOsV  $  ÿ þ  " €ÿ    "€ÿz&DashboardScheduler._send_evening_nudgec s"zñ|j ¡}|d}|d}t ¡‰| dg¡}t|ƒdkrRt|ƒdkr)|dn|d}|d}||}t|dd…ƒd}t|ƒd krI|dn|d} || } nd}|d }d} ˆtdd  ¡‰‡‡fd d „| dg¡Dƒ} ˆtdd  ¡‰‡‡fdd „| dg¡Dƒ} dˆ  d¡›g} |   d¡|   d¡|   d¡|   d|d ›d¡|   d|d›d¡|   d|d›d¡|   d| d›d¡|   d|d›d| dd ¡›d!¡|   d"| d#d$¡›d%¡|   d¡|   d&¡|   d|d ›d'|d›d(¡|   d)| d*d¡d›d+¡| d,i¡}|   d¡|   d-¡|   d.| d/d$¡›d0| d1d$¡›d2| d3d4¡›d5¡|   d6| d7d ¡›¡| d8i¡ d9¡}|r`|   d¡|   d:|›¡| rs|   d¡|   d;t| ƒ›d<¡| rŸ|   d¡|   d=t| ƒ›d>¡| dd?…D]}|   d@|d7›dA|dB›¡qŒzddl }|j d?dC}|r·|   d¡|   |¡Wn t yÂYnw| ¡}|r×|   d¡|   dD|›¡|   d¡|   dE¡dF | ¡}| |¡t dG¡WdSt y}ztjdH|›dIdJWYd}~dSd}~ww)Kz,Send weekly trend summary on Sunday morning.ríÚbodyFatrîrrðrrïNérrÿcs4g|]}ˆ| dd¡krˆ ¡krnn|‘qS©rr rùrú)Úpast_week_startrmr,r-rýîó $ÿz:DashboardScheduler._send_weekly_report..r…cs4g|]}ˆ ¡| dd¡krˆkrnn|‘qSr<)rlrWrú)Ú next_week_endrmr,r-rýõr>u(WEEKLY DASHBOARD REPORT — Week ending z %B %-d, %Yz(========================================r ÚWEIGHTz Current: r.z This week: z+.1fz 7-day avg: rôz 30-day change: z Goal: Úgoalr%rrr&z ETA: ~rr r zBODY FATz % (goal: z%)z Change: Ú deltaVsLastú%Ú bloodPressurezBLOOD PRESSUREz Last reading: Úsystolicú/Ú diastolicržr9Úunknownrz Date: rr`razCRO: $z THIS WEEK: z events completedz NEXT WEEK (z events):r:rrr†rçruHave a great week! — LukeràzWeekly report sentzWeekly report failed: Tr@)rrjrrmrWrpÚsumrrlrrÈréÚweekly_music_summaryr[rr¶r¦r5r6r])r*rurÚbfrÚ week_startÚweek_endrÚ weekly_avgÚ month_startÚ month_changeÚ past_eventsÚ next_eventsråÚbprr_rérìr#r$r,)r?r=rmr-rSÔsœ      ÿ  ÿ   $      6   "   €ÿ     "€ÿz&DashboardScheduler._send_weekly_reportc Cs,zztj t¡s WdSt t¡}| ¡}t ¡}g}dD]Q}zF|j |j |d}|  ¡dd…}|  d|df¡|  ¡}|rb|d} |d  d d ¡dd …} |j |} | d | ›d | ›d| ›d¡WqtylYqw| ¡|rx|dWSWdSty•} zt d| ›¡WYd} ~ dSd} ~ ww)zEQuery knowledge base for conversations from this date in prior years.N)rÎr,rÏ)r0r9aÁ SELECT c.title, substr(m.content, 1, 150), c.create_time FROM messages m JOIN conversations c ON c.id = m.conversation_id WHERE m.role = 'user' AND c.create_time LIKE ? AND length(m.content) > 50 ORDER BY length(m.content) DESC LIMIT 1 rCrrÎràróédú(z) You were working on 'u' — "z..."zOn This Day lookup failed: )r³r´ÚexistsÚKNOWLEDGE_DB_PATHÚsqlite3ÚconnectÚcursorrrmÚreplacer0rlÚexecuteÚfetchonerÈr1Úcloser[r5rƒ) r*ÚconnÚcrmÚinsightsÚ year_offsetÚ past_dateÚ date_prefixÚrowr†Úsnippetr0r_r,r,r-rAsB   ÷  € ÿ €þz#DashboardScheduler._get_on_this_dayc s2zùddlm}|ƒ}|jst d¡WdSgd¢}g}|D]O}|j|dd}|s1|j|dd}|D]9}|d|d | d d ¡| ¡d œ}|d krð|  |d|d ¡} |  |¡} | dkrƒd|d<dg} | rp|   | ›d¡n|   d¡|   d¡| |d<d|d<nå| dkrÐddlm } |  |di¡} |  d¡dkr |dn|d }d|›d|d<dg} | rº|   | ›d¡n|   |›d¡|   d¡| |d<d|d<n˜| d krâd!|d<d"g|d<d#|d<n†d$|d<dg|d<d%|d<nx|  |¡}| d&d'¡}| d(| ¡¡}||d)<|  |¡} |dkr7d*|d<d+g} | r$|   | ›d,¡n|   d-¡|   d.¡| |d<d|d<n1|d'krVd/|d<d+g} |   d0¡|   d.¡| |d<d|d<n|d1krhd2|d<d3g|d<d#|d<|  |¡q3qddd'd1d4œ‰|j‡fd5d6„d7z#dd8lm}||ƒ}t d9t|ƒ›d:td;d<„|Dƒƒ›d=¡W|WStyÉt d>¡t d9t|ƒ›d?td@d<„|Dƒƒ›d=¡Y|WStyú}z%t dA|›¡t d9t|ƒ›dBtdCd<„|Dƒƒ›d=¡WYd}~|WSd}~wwty}ztjdD|›dEdFWYd}~dSd}~ww)Gz• Fetch today's betting picks using Bill's Predictable Tempo strategy. Returns structured data for the dashboard Bet365 card. r)Ú get_analystz0Betting picks: Odds API not configured, skippingN© ÚnhlÚeplÚserieaÚligue1ÚlaligaÚ liga_portugalÚeuropaÚ conferenceÚuclrΩÚ days_aheadÚ home_teamÚ away_teamÚ game_timer )ÚhomeÚawayrBÚsportriÚ controlledu★ CONTROLLEDÚtagzUnder 6.5 total goalsz ML (moneyline)z1st period Under 1.5z!Under 3.5 goals (1st two periods)ÚlegsÚprimeÚratingÚmixed)ÚNHL_TEAM_PROFILESÚtempoÚlowu MIXED — z anchorsz Under 3.5 team totalÚplayableÚchaoticu âš¡ CHAOTICu"Skip unders — high-event matchupÚavoidz ~ NEUTRALÚneutralÚtierr,räryu ★ TIER 1zUnder 2.5 goalsz to win (ML)zBTTS No (both teams to score)zUnder 8.5 cornersuTIER 2 — filterzBTTS NorÏu âš  AVOIDuSkip — unpredictable tempo)r}rƒr†r…csˆ | dd¡d¡S)Nr~r†r,©rW)Úp©Ú rating_orderr,r-ÚÕsz9DashboardScheduler._fetch_betting_picks..©Úkey)Úvalidate_picks_batchzBetting picks: z games processed + validated, csó"|] }| d¡dkrdVqdS©r~r}rÎNrˆ©rûr‰r,r,r-Ú Þó€ z:DashboardScheduler._fetch_betting_picks..z prime targetsu3pregame_validator not found — skipping validationz games processed (unvalidated), csrr‘rˆr’r,r,r-r“âr”u>Pregame validation failed — picks pass through unvalidated: z% games processed (validation error), csrr‘rˆr’r,r,r-r“ær”zBetting picks fetch failed: Tr@)Úsports_bettingrgr“r5r6Úget_upcoming_gamesÚget_upcoming_eventsrWÚupperÚclassify_nhl_matchupÚ_extract_favoriterÈr€Úclassify_soccer_matchupÚsortÚpregame_validatorrrprIÚ ImportErrorrƒr[r])r*rgÚanalystÚsportsryÚsreÚgÚpickrÚfavr|r€Úhome_pÚanchorÚ league_classr‡rärr_r,rŠr-rossÐ     ü                         ¶M  ÿ ÷  ÿûÿ€û€þz'DashboardScheduler._fetch_betting_picksc CsêzÙddlm}m}|ƒ}|jsWdSd}gd¢}|D]Z}|j|dd}|s,|j|dd}|D]A} z4|  dd ¡} | s;Wq.t |   d d ¡¡j dd } | t  ¡  ¡d } d| kr\dkrcnnd}Wn Wq.t t fyoYq.w|rtnq|szWdSt d¡t ¡|_zddlm} t| ƒ}|  ¡t d|›d¡Wn ty¦Ynw| ¡}|dur×|j ¡}|t ¡ ¡dœ|d<|j |¡t dt|ƒ›d¡| ¡WdSWdStyô}zt d|›¡WYd}~dSd}~ww)u+ Rapid pregame validation cycle — runs every 15 min when any game starts within 90 minutes. Clears the validation cache so fresh data (Claude analysis, scraping) is fetched for imminent games. Then re-fetches betting picks and updates briefing + dashboard. r)rgÚ SPORT_KEYSNFrhrÎrrÚ commence_timer ÚZz+00:00)Útzinfoé<éZTuERAPID PREGAME: Games within 90 min — running fresh validation cycle)Ú_validation_cachezRAPID PREGAME: Cleared z cached validationsrdrgz&RAPID PREGAME: Dashboard updated with z re-validated pickszRapid pregame refresh failed: ) r•rgr¨r“r–r—rWrÚ fromisoformatr[ÚutcnowÚ total_secondsr1r2r5r6rBr)rr®rpÚclearržrorrjrErlÚwriterDr[rƒ)r*rErgr¨rŸÚ has_imminentr r¡rer¢ÚctrvÚ minutes_untilr®Ú cache_sizeryrur_r,r,r-rZîsl €ÿÿ    ÿ   þ ö €ÿz/DashboardScheduler._maybe_rapid_pregame_refreshc Cshz&| d¡r!|ddd dg¡}|r$t|dd„d}|dWSWd SWd Stttfy3Yd Sw) zGExtract the favorite team name from bookmaker data (internal use only).Ú bookmakersrÚmarketsÚh2hcSs|dS)NÚpricer,)Úxr,r,r-rŒ9sz6DashboardScheduler._extract_favorite..rrN)rWÚminÚKeyErrorÚ IndexErrorr2)r*Úgamerºr¤r,r,r-rš3s  üûþþz$DashboardScheduler._extract_favoritec"s®z·|j ¡}|d}t ¡‰t ¡}|j}|dkrd}n |dkr$d}nd}| dg¡}t|ƒdkrR|d |d }|d kr@d nd }|›dt |ƒd›d} |d k} nd} d} ‡fdd„| dg¡Dƒ} ‡fdd„| dg¡Dƒdd…} d} | di¡ dg¡}|D]O}zB| dd¡}t  |dˆj ›d¡ ¡}ˆ|kr¨ˆt ddkrÅnn| d d ¡}t |d!|d"ƒ}||||d#kd$œ} Wn Wq‚ttfyÑYq‚w| d%i¡ d&¡}| ¡}d}| ¡}|r|jrz| ¡}Wnty }zt d'|›¡WYd}~nd}~ww| ¡}|r|jnd(|r|jnd(d)œ}| ¡}| ¡|ˆ d*¡|d!| | | d+d ¡| d,d ¡d-œ| | | ||| d.d¡| d/¡|||rWd0|indd1œ}ttƒjd2}d dl}|jt |jƒd3d4\}} z1t! "|d5¡}!t#j$||!dd(d6Wdƒn 1sŽwYt! %| t |ƒ¡t &d7¡WWdSty¸t!j' (| ¡r·t! )| ¡‚wtyÖ}ztj*d8|›dd9WYd}~dSd}~ww):z;Generate briefing data JSON for the dashboard morning card.rír=z Good morningézGood afternoonz Good eveningrîrrïrðrrñròrórôrõröTcs>g|]}| d¡ˆ ¡kr|d| dd¡| dd¡dœ‘qS)rr†rBr r‡)r†rBr‡rùrúrür,r-rý\s þz.r…csZg|])}ˆ ¡| dd¡krˆtdd ¡krnn|d|d| dd¡dœ‘qS)rr rÏrÿr†rB)r†rrBrrúrür,r-rýcs 2þNr:r)r*rr r+r,rÿr/rrÎgð?)rr/r8Úon_trackr`raz%Gmail briefing for dashboard failed: F)Údriverârrr)rrÚtrend_positiverÚ eta_weeksÚfocusrCre)Ú generatedÚgreetingÚ date_displayrírrÚ checkpointraÚ on_this_dayrÆrCÚemailÚ google_statusrgú briefing.jsonz .json.tmp)ÚdirÚsuffixr)ÚindentÚ ensure_asciizBriefing data updatedzBriefing update failed: r@)+rrjrrmrrErHrWrprr/r0rÚroundr1r2rr’r“rár[r5r\rŽrorlrrrÚparentÚtempfileÚmkstemprrr³Úfdopenr‚Údumpr[r6r´rVÚunlinkr])"r*rurrErHrÈrrÚtrend_directionÚ trend_textrÄrrÚcheckpoint_alertr4r5r6r7r/r8rarËÚemail_briefingrâr_r–rÍÚ betting_picksÚbriefingÚ briefing_pathrÕÚfdÚtmp_pathÚfr,rür-rD?sÈ      þ  þü " ü€ÿ €ÿþ  û ìÿ ý"€ÿz(DashboardScheduler._update_briefing_datac CsÚtttttgƒst d¡dSzBdt›d}tj|ttfdt›dt›|dœdd}|j d vr>t  d t |ƒ›d ¡WdSt  d |j ›d |j dd…›¡WdStyl}zt  d|›¡WYd}~dSd}~ww)z'Send a WhatsApp message via Twilio API.u<Twilio credentials not configured — skipping WhatsApp sendNz+https://api.twilio.com/2010-04-01/Accounts/z/Messages.jsonz whatsapp:)ÚFromÚToÚBodyræ)Úauthruri)réÉzWhatsApp message sent (z chars)zWhatsApp send failed: rrzWhatsApp send error: )Úallr r r r r5rƒr€Úpostrr6rpr]Útextr[)r*r$Úurlr„r_r,r,r-r¦Às*  ýø (€ÿz!DashboardScheduler._send_whatsappcCó | ¡dS)z;Manually trigger morning briefing (callable from WhatsApp).zMorning briefing sent!)rLr7r,r,r-Útrigger_morning_briefingÛóz+DashboardScheduler.trigger_morning_briefingcCrí)z8Manually trigger weekly report (callable from WhatsApp).zWeekly report sent!)rSr7r,r,r-Útrigger_weekly_reportàrïz(DashboardScheduler.trigger_weekly_reportcCs| ¡}|pdS)z1Get on-this-day insight (callable from WhatsApp).z8No conversations found from this date in previous years.)r)r*r#r,r,r-Úget_on_this_dayåsz"DashboardScheduler.get_on_this_dayc Cs¾t d¡z2ddlm}t d¡||jƒ}t dt|ƒdd…›¡|r3d| ¡vr3| ¡|WS|p6d WSty^}ztj d |›d d d t|ƒdd…›WYd}~Sd}~ww)zsL   þ    þý