o ih @s@dZddlZddlZddlZddlmZejdejeje ddl m Z m Z m Z mZddlmZddlmZddlmZddlmZmZdd lmZdd lmZdd lmZeeej d rfej j!ne"d #ej j!Z$ej%j&dddej'e(eej)ej*de+ej%de,gde-dZ.e e/Z0eej Z1ee1Ze0j2ddZ3dZ4e.5de.5de4de.5de.5dee"ddgddrdnd e.5dd!e6fd"d#Z7d$ed!e6fd%d&Z8id'd(d)d*d+d)d,d-d)d.d/d)d0d1d)d2d3d)d4d5d)d6d7d)d8d9d)d:d;d)dd?d)d@dAd)dBdCd)dDdEd)dFdGd)dHdId)idJdKd)dLdMd)dNdOd)dPdQd)dRdSd)dTdUd)dVdWd)dXdYd)dZd[d)d\d]d)d^d_d)d`dad)dbdcd)ddded)dfdgd)dhdid)djdkd)idldmd)dndod)dpdqd)drdsd)dtdud)dvdwd)dxdyd)dzd{d)d|d}d)d~dd)ddd)ddd)ddd)ddd)ddd)ddd)ddd)Z9dddZ:ddZ;ddZd!efddZ?dddZ@ded!e6fddZAded!efddZBe0jCddgdddZDe0jCddgddd8ZEe0jCddgdddZFe0CdddZGe0CdddZHe/dkre.5dzeIWn"eJeKfyZLze.MdeLeNdWYdZL[LndZL[Lwwe.5de$e.5dej e.5dejOddlPZPddlQZRzBePjSgdddTZUeUVdD]%ZWeWTZWeWreWeeXkre.5deWePjYddeWgddqe.5deRZd¡Wn ePj[yYnwddl\m]Z]e]j^Z_ddńZ`e`e]_^e.5dơeae.5dǡe0jYddddˍdSdS)u WhatsApp Dashboard Agent — Flask webhook server. Receives Twilio WhatsApp messages, parses via Claude API, updates dashboard-data.json, and responds via WhatsApp. Includes: background scheduler for proactive nudges, data refresh, weekly reports, and 'on this day' insights. N)datetime)Flaskrequestsend_from_directoryjsonify)MessagingResponse)RequestValidator)Config) parse_messageconversation_memory)DashboardManager)DashboardScheduler)ingest_health_connectparentpathlibTparentsexist_okz1%(asctime)s [%(levelname)s] %(name)s: %(message)szwhatsapp-agent.log)levelformathandlerszwhatsapp-agentcCs>|jrd|jvstjdrd|jd<d|jd<d|jd<|S) zTPrevent browser caching for JSON/API responses so dashboard always shows fresh data.jsonz/api/#no-cache, no-store, must-revalidate Cache-Controlno-cachePragma0Expires) content_typerpath startswithheaders)responser#app.pyadd_no_cache_headers4s    r%z2.4.0-scale-visionz<============================================================z LUKE vz starting upz; Features: media-handler, conversation-memory, personalityz Context file: claude_parser _BILL_CONTEXT)fromlistloadedmissingreturncCs6ttj}|jdd}|jdd}|||j|S)z-Verify the request actually came from Twilio.zhttp://zhttps://zX-Twilio-Signature) rr TWILIO_AUTH_TOKENurlreplacer!getvalidateform)req validatorr. signaturer#r#r$validate_twilio_requestHs r6phonecCs.ddl}|dd|}|ddtj}||kS)z+Check if the sender is Bill's phone number.rNz[^0-9]r,)resubr BILL_PHONE_NUMBER)r7r8cleanexpectedr#r#r$ is_authorizedQsr=briefingcCtSN schedulertrigger_morning_briefingr#r#r#r$]rDmorningcCr?r@rAr#r#r#r$rD^rEweeklycCr?r@rBtrigger_weekly_reportr#r#r#r$rD_rEz weekly reportcCr?r@rHr#r#r#r$rD`rEreportcCr?r@rHr#r#r#r$rDarEz on this daycCr?r@rBget_on_this_dayr#r#r#r$rDbrEotdcCr?r@rKr#r#r#r$rDcrEhistorycCr?r@rKr#r#r#r$rDdrEhealthcCr?r@rBtrigger_health_ingestr#r#r#r$rDerEingestcCr?r@rPr#r#r#r$rDfrEouracCr?r@rBtrigger_oura_ingestr#r#r#r$rDgrEz oura ringcCr?r@rTr#r#r#r$rDhrEemailcCtSr@_get_email_summaryr#r#r#r$rDiinboxcCrWr@rXr#r#r#r$rDjrZgmailcCrWr@rXr#r#r#r$rDkrZslatecCrWr@_get_todays_slater#r#r#r$rDlrZgamescCrWr@r^r#r#r#r$rDmrZz games todaycCrWr@r^r#r#r#r$rDnrZtonightcCrWr@r^r#r#r#r$rDorZzwhats oncCrWr@r^r#r#r#r$rDprZz what's oncCrWr@r^r#r#r#r$rDqrZz whats goodcCrWr@_get_best_targetsr#r#r#r$rDrrZz what's goodcCrWr@rbr#r#r#r$rDsrZzwhats good todaycCrWr@rbr#r#r#r$rDtrZzwhat's good todaycCrWr@rbr#r#r#r$rDurZzwhats good tonightcCrWr@rbr#r#r#r$rDvrZzwhat's good tonightcCrWr@rbr#r#r#r$rDwrZz cro anchorcCr?r@dmupdate_cro_anchorr#r#r#r$rDyrEz reset anchorcCr?r@rdr#r#r#r$rDzrEanchorcCr?r@rdr#r#r#r$rD{rEz reset crocCr?r@rdr#r#r#r$rD|rEz now playingcCtdSN now_playing_spotifyr#r#r#r$rD~rEzwhat's playingcCrhrirkr#r#r#r$rDrEz whats playingcCrhrirkr#r#r#r$rDrEzrecently playedcCrhNrecentrkr#r#r#r$rDrErncCrhrmrkr#r#r#r$rDrEpausecCrhNrorkr#r#r#r$rDrEz stop musiccCrhrprkr#r#r#r$rDrEresumecCrh)Nrqrkr#r#r#r$rDrEskipcCrhNrrrkr#r#r#r$rDrEnextcCrhrsrkr#r#r#r$rDrEz next songcCrhrsrkr#r#r#r$rDrEz top artistscCrh)N top_artistsrkr#r#r#r$rDrEz top trackscCrhN top_tracksrkr#r#r#r$rDrEz top songscCrhrvrkr#r#r#r$rDrEz new musiccCrhN new_releasesrkr#r#r#r$rDrEz new releasescCrhrxrkr#r#r#r$rDrEz new dropscCrhrxrkr#r#r#r$rDrEz whats newcCrhrxrkr#r#r#r$rDrEz what's newcCrhrxrkr#r#r#r$rDrEznew music fridaycCrhrxrkr#r#r#r$rDrEc Cs$zsddl}|dkr|WS|dkr|WS|dkr |WS|dkr)|WS|dkr2|WS|dkr;|WS|d krD|WS|d krM|WS|d krY|rY| |WS|d kre|re| |WS|d krq|rq| |WSWdSt y}zdt |dddWYd}~Sd}~ww)zQuick command: Spotify control.rNrjrnrorqrrrurwryplayqueueplaylistu_Not sure what to do with Spotify. Try 'now playing', 'pause', 'skip', or 'play [song]' — LukezSpotify error: d — Luke)spotify_modulerjrecently_playedrorqrrrurwry play_search add_to_queue play_playlist Exceptionstr)actionquerysper#r#r$rls:              $rlc CZzddlm}|}|WSty,}zdt|dddWYd}~Sd}~ww)z(Quick command: get today's sports slate.r get_analystSports module error: Nr}r~)sports_bettingrget_todays_slaterrranalystrr#r#r$r_  $r_c Cr)zCQuick command: get only the games that pass Bill's strategy filter.rrrNr}r~)rrget_best_targetsrrrr#r#r$rcrrcc Csz%ddlm}|}|jsWdS|}|dr#d|ddWSWdStyB}zd t|d d WYd }~Sd }~ww) z*Quick command: get Gmail briefing summary.rget_gmail_briefinguRGmail not connected yet. Run 'python setup_google_auth.py' to hook me up. — Luke availablezEMAIL SUMMARY summary_textz No new emailszCouldn't fetch email data.z Gmail error: Nr})gmail_briefingrrgenerate_briefingr0rr)rr\datarr#r#r$rYs  "rYparsedc Cs|dd}|dd}|di}|dd}zb|dkrs|dkr,tt|d WS|d kr:tt|d WS|d krMtt|d t|d WS|dkrYt|dWS|dkrp|d }|durjt|}t|WS|WS|dkr|dkrtj |dd|dd|dd|dd|dd|ddWS|dkrtj |dd|dd|d d|d!dd"WS|d#krtj |d$d%|d&d|d'd|d(d|ddd)WS|d*krtj |d+d,|d-dd.WS|WS|d/kr"|dkrtj |d0d|dd1WS|d#krtj|d2dd3WS|WS|d4krz|dkr1tWS|d kr;tWS|d krEtWS|dkrY|d5d6}tjt|d7WS|d#krctWS|dkrmtWS|d8krwtWS|WS|d9krzAd:d;lm}|}|dd} | d?kr|WWS| d@kr|dA} || WWS| r|| WWS|WWSty} ztjdB| dCdD|WYd} ~ WSd} ~ ww|dEkr|dFdG} |d4d}t| |WS|dHkrq|dHd}dIdJdKdJdLdJdMdJdNdJdOdJdPdJdQ}||}|rfz|}|r.|WWSdR|dSWWStye} z#tjdR|dT| dCdDdU|dVt| ddWdXWYd} ~ WSd} ~ wwt dY||WS|dZkry|WS|WSt!y} ztd[| d\| d]WYd} ~ Sd} ~ wty} ztjd^| dCdDd_t| ddWWYd} ~ Sd} ~ ww)`z8Execute the parsed intent and return a response message.intentunknownfieldvalues response_textzDone.updateweightvaluebodyFat bloodPressuresystolic diastolicfocustext crypto_anchorNaddscheduledater,timetitleUntitledlocationnoteend_date) event_daterrrrrsignalscataiwhysource)rrrr supplementstimingrFnamedosebrand)rrrrrviomecategoryavoidfood)rrremovetitle_fragment)rr name_fragment)rr days_ahead)rsummarybettingrrtypeanalysisteamtargetsr]sportzBetting handler error: Texc_infospotifyrrjmodulecSr?r@rTr#r#r#r$rDRrEz execute_action..cSrWr@rXr#r#r#r$rDSrZcSr?r@rAr#r#r#r$rDTrEcSr?r@rPr#r#r#r$rDUrEcSrWr@r^r#r#r#r$rDVrZcSr?r@rHr#r#r#r$rDWrEcSr?r@rKr#r#r#r$rDXrE)rSrVr>rOr]rGrMzModule 'u' returned no data. — Luke ' failed: zHit a snag pulling z data: r}r~zUnknown module requested: chatzMissing value for action: zMissing data for that update: z'. Could you try again with more detail?zAction execution failed: zSomething went wrong: )"r0re update_weightfloatupdate_body_fatupdate_blood_pressureint update_focusrf add_event add_signaladd_supplementadd_viome_food remove_eventremove_supplement query_weightquery_body_fatquery_blood_pressurequery_schedulequery_supplements query_signals query_summaryrrrrgenerate_analysisrloggererrorrlrwarningKeyError)rrrrr"pricedaysrrbet_typerrrrrrMODULE_DISPATCHhandlerresultr#r#r$execute_actions      {                ^    Q                              , "rr,c Csddl}ddl}t|D]}|jd|}|jd|d}td|d|d||d rzt j }t j } |j||| fd d } | | j } td t| d ddddlm} m} m}| | |}|dd}|dkr|drtd| |t}|rt|dt||d|dWS|dkr|drtdt|dd||t}|rt|dt||d|dWS|dvr Wd Std!|d"Wnty}ztjd#|d$d%WYd}~nd}~wwq d&|vp d'|v}|std(|q zt j }t j } |j||| fd d }| |jd)d*}tj|d+td,d-}t |d.}|!|j Wdn 1sZwYt|j d }td/|d0|ddddl"}|#|st$d1|Wd2St%|t}t j&j'd3td4}|j(d$d$d5ddl)}|*||d6|j+|d$d7d|d}|rt|d8t|||WSty}ztjd9|d$d%d:t,|dd;d<WYd}~Sd}~wwdS)=u Handle incoming WhatsApp media attachments. - Images → scale screenshot detection (iHealth, etc.) via Claude Vision - Zip files → Health Connect ingestion Returns a response string, or None if the media wasn't handled. rNMediaUrlMediaContentTyper,zMedia attachment z: type=z, url=zimage/)authtimeoutzDownloaded image (iz.0fz KB))parse_health_screenshotapply_scale_data apply_bp_datarrscale weight_lbz$Scale screenshot detected and parsedz[Sent scale screenshot]Got it! 📊  Dashboard updated. — Lukeblood_pressurereadingsuBP screenshot detected — z readingsz [Sent blood pressure screenshot]uGot it! 💓 )rrujI can see that's a health screenshot but couldn't read the numbers clearly. Try sending it again? — Lukez Image type 'u.' — not a health screenshot, passing throughzImage processing failed: Trzipz octet-streamzSkipping unhandled media: zclawd-whatsapp-)prefixhealth_connect_z %Y%m%d_%H%M%S.zipwbzDownloaded media to z (zFile is not a valid zip: uuThat file doesn't look like a valid zip. Send me a Health Connect export zip and I'll update your dashboard. — LukerOz%Y-%m-%drzhealth_connect_export.zip) ignore_errorsz[Sent Health Connect zip file]zMedia processing failed: z5I received your file but hit an error processing it: r}u . Try sending it again? — Luke)-requeststempfileranger2r0rinfolowerr r TWILIO_ACCOUNT_SIDr-raise_for_statuscontentlen scale_visionrrrrer add_user_messageadd_system_eventrrmkdtemposrjoinrnowstrftimeopenwritezipfile is_zipfilerrDASHBOARD_DATA_PATHrmkdirshutilcopy2rmtreer)r3 num_mediasender http_requestsr i media_urlr twilio_sid twilio_tokenimg_resp image_datarrr extracted data_typerris_zipr"temp_dirzip_pathfsize_kbrr archive_dirr result_msgr#r#r$_handle_media_attachmentws                    (r4bodycCsL|}d|vrd|vp%d|vp%|dkp%|dkp%d|vo%d|vo%d|vS) z>Detect if the message body is a Health Connect file reference.zhealth connectrexportzhealth connect.zipzhealth_connect.ziprOconnectr)r strip)r5br#r#r$_is_health_connect_mentions r:r#c Cstdz3t}|r-d|vr-td||r&t|dt||d|dWStd|W d StyV}ztjd|d d WYd }~ d Sd }~ww) u Handle Health Connect file references detected in message body. Uses scheduler's comprehensive search: Drive API (72h) → multiple filesystem paths → health-imports → dashboard dir. uSHealth Connect file detected in message text — triggering ingestion via schedulerzNo Health Connectz!Health Connect ingestion result: z&[Sent Health Connect zip via WhatsApp]rrz*Scheduler ingest returned nothing useful: z!Health Connect ingestion failed: TrNuI see you're sharing a Health Connect export — nice! WhatsApp doesn't pass zip files through to me though. Your export should sync to Google Drive automatically — once it lands, just text me 'health' and I'll grab it. Or AirDrop it to ~/clawd/health-imports/ on your Mac. — Luke) rr rBrQr rrrr)r#rrr#r#r$_handle_health_connect_texts$    r;z/webhook/whatsappPOST)methodsc CsBtjdks tdddkrttstddStj dd}tj dd }tj d d }t d |d |d ||d krZtjD]}| drYt d|dtj|qDt |sttd|t}|dt|dfSttj d d}|dkrtt||d}|rt}||t|dfS|rt|rt|}t}||t|dfS|st}|dt|dfSddl}|d| } | rzt| d} t| } Wnttfy} zd} WYd} ~ nd} ~ wwt||t || t}|| t d| ddt|dfS| } | t!vrzt!| } Wn/ty]} z"tj"d| d| dd d!| d"t| dd#d$} WYd} ~ nd} ~ ww| sgd!| d%} t||t || t}|| t d| d&t| ddt|dfSzt#}Wn)ty} zt"d'| t}|d(t|dfWYd} ~ Sd} ~ wwt$|||d}t d)| d*d+| d,d-| d.d/| d.d0kr| d*d1krt}|| d2d3t|dfSt%|} t}|| t d4| dd5t|dfS)6z.Handle incoming WhatsApp messages from Twilio.z 127.0.0.1VALIDATE_TWILIOtrueu.Invalid Twilio signature — rejecting request) ForbiddeniFromr,BodyNumMediarz Message from z: body='z ', NumMedia=Mediaz Twilio media field: =zUnauthorized sender: zLuke only responds to Bill.r)r#u?Empty message — send me anything and I'll handle it. — LukeNz3^(?:cro\s+anchor|reset\s+anchor|anchor)\s+([\d.]+)$u;Couldn't parse that price. Try: 'cro anchor 0.085' — LukezCRO anchor command with price: PzQuick command 'rTrz Command 'z' hit an error: xr~u1' returned no output. Check server logs. — Lukez ' executed: zFailed to read dashboard data: z4Couldn't read dashboard data. Check the server logs.zParsed intent: rz / rz (confidence: confidence)lowrrzCould you rephrase that?zResponse sent: r})&r FLASK_HOSTrgetenvr6rrrr2r0r8r r r=rmessagerrr4r:r;r8matchr rgrouprerf ValueErrorrr radd_assistant_messageQUICK_COMMANDSrreadr r)r#r5 num_media_rawkeyrespr" media_result hc_result_re_appcro_anchor_match anchor_pricerr body_lowerdashboard_datarr#r#r$whatsapp_webhook)s                  *    "   0    r`z/healthGETc Cs.i}z ddlm}||d<Wn tyd|d<Ynwzddlm}|}|j|d<Wn ty:d|d<Ynwzddlm}|}|j|d<Wn tyXd|d<Ynwd}z dd lm }|j}Wn typYnwd}z dd l } | }Wn tyYnwd t j |||td d fS)z5Health check endpoint with Google integration status.r) is_configuredauth_configuredF) get_connectordriverr\) get_clientNok)statusrBgooglerSr timestamprF) google_authrbr gdrive_healthrdrrroura_apirfr is_availablerBrunningrr isoformat) google_statusrbrdgdriverr\ oura_statusrfspotify_statusrr#r#r$rOsX               z /api/briefingcCs$t}|r t|StddidfS)z/Return current briefing data for the dashboard.rzNo briefing data available yeti)rBget_briefing_datar)r>r#r#r$ api_briefingsrvz/cCs6tt|}|drd|jd<d|jd<d|jd<|S)z+Serve dashboard static files from ~/clawd/.z.jsonrrrrrr)r DASHBOARD_DIRendswithr!)filenamerXr#r#r$serve_dashboards     rz/cCs ttdS)z-Serve dashboard-standalone.html as the index.zdashboard-standalone.html)rrwr#r#r#r$ serve_indexs r|__main__zCStarting WhatsApp Dashboard Agent + Dashboard Server + Scheduler...zConfig error: rGzDashboard dir: zDashboard data: zClaude model: )lsofz-tiz:8080)r z+Killing leftover process on port 8080: PID killz-9)capture_outputz#Waiting for port 8080 to release...)BaseWSGIServercOs2ddl}d|jj_d|_t|g|Ri|dS)NrT) http.serverserver HTTPServerallow_reuse_address_original_init)selfargskwargshttpr#r#r$ _patched_inits rzListening on 0.0.0.0:8080z[Background scheduler started (morning nudge, evening check-in, weekly report, data refresh)z0.0.0.0iF)hostportdebugr@)r,)b__doc__sysrloggingrrinsertdirnameabspath__file__flaskrrrrtwilio.twiml.messaging_responsertwilio.request_validatorrconfigr r&r r dashboard_managerr rBr health_connectrrhasattrrr __import__PathrwLOG_DIRr basicConfiggetattr LOG_LEVELINFO FileHandler StreamHandler getLoggerr__name__appre after_requestr%_VERSIONr boolr6r=rTrlr_rcrYdictrr4r:r;router`rOrvrzr|r1rRFileNotFoundErrorrrexit CLAUDE_MODEL subprocessr_time check_outputr8pidssplitpidgetpidrunsleepCalledProcessErrorwerkzeug.servingr__init__rrstartr#r#r#r$s        *     (         "#$%&'()*+,-./012345 9     $ q -