o ڒiEF@sldZddlZddlZddlZddlZddlmZmZddlmZddl m Z m Z e e ZGdddZdS)u| Dashboard data manager — reads and writes dashboard-data.json with file locking and atomic writes to prevent corruption. N)datetimedate)Path)FileLockTimeoutc@seZdZdefddZdefddZdefdd Zd d Zd e defd dZ d e defddZ de de defddZ  dMdededededededefddZdNdededefd d!ZdOd"eded#ed$edef d%d&Zd'edefd(d)Z dPd*ed+ed,ed-ededef d.d/Zd0edefd1d2Zd3ed4edefd5d6Zd3ed7edefd8d9ZdNd:e defd;d<Zdefd=d>Zdefd?d@ZdefdAdBZdQdDe defdEdFZdefdGdHZdefdIdJZdefdKdLZdS)RDashboardManager file_pathcCs.t||_t|jd|_t|jdd|_dS)Nz.lock )timeout)rrstr lock_pathrlock)selfrrdashboard_manager.py__init__s zDashboardManager.__init__returnc Cst|j-t|jddd}t|WdWdS1s#wYWddS1s3wYdS)z(Read and return the full dashboard data.rutf-8encodingN)r openrjsonload)rfrrrreads"zDashboardManager.readdatacCs|jj}tjt|dd\}}z2tj|ddd}tj||dddWd n1s,wYt |t|jt d Wd St yTtj |rSt|w) z.Atomic write: write to temp file, then rename.z .json.tmp)dirsuffixwrrF)indent ensure_asciiNz#Dashboard data written successfully)rparenttempfilemkstempr osfdopenrdumpreplaceloggerinfo Exceptionpathexistsunlink)rrdir_pathfdtmp_pathrrrr_write!s   zDashboardManager._writec Cs~|j2t|jddd }t|}Wdn1swY||}||||fWdS1s8wYdS)zDRead data, apply updater function, write back. Returns updated data.rrrN)r rrrrr3)rupdaterrrresultrrr_read_and_write/s  $z DashboardManager._read_and_writevaluecfdd}||\}}|S)zHUpdate weight with new value, rotate series, recalculate derived fields.c sl|d}|d}t|d|d<|d<|dg}|t|dkr,|dd}||d<t|dkr<|d dn|}tt|t|d|d <|d d }|d d}tddd}tt|jdd}|} t| |d} | |d<|} | dkrt| | nd|d<t} | d|d<| d|d<dd|d|ddd| d|d|dd S)!Nweightcurrent deltaVsLast series30diavg7dbaselinegn@goalir pacerietaWeeksz%B %-d lastWeighInz%Y-%m-%drzWeight updated to z lb (was z ). Change: +.1fz lb. Pace: z lb/wk. ETA to z: ~z weeks.) roundgetappendlensumrmaxnowdaysstrftime) rroldserieslast7rBrC baseline_date weeks_elapsed total_lostrE remainingtodayr7rrr4<s0       4z/DashboardManager.update_weight..updaterr6rr7r4_msgrrZr update_weight:s "zDashboardManager.update_weightcr8)z*Update body fat percentage, rotate series.cs~|d}|d}t|d|d<|d<|dg}|t|dkr,|dd}||d<dd |d |dd d S) NbodyFatr:r;r<r=r>r?zBody fat updated to z% (was z %). Change: rHz%.)rIrJrKrL)rbfrRrSrZrrr4es    z1DashboardManager.update_body_fat..updaterr[r\rrZrupdate_body_fatcs z DashboardManager.update_body_fatsystolic diastolicc fdd}||\}}|S)zUpdate blood pressure reading.c s|d}|d|d}}|d<|d<t|d<dkr*dkr*d|d<nd kr7dkr7d |d<nd ks?d krDd |d<nd|d<ddd|dd|d|d S)N bloodPressurercrdrxPnormalstatuselevatedZz high-stage1z high-stage2zBP updated to / (z). Was .)rrY isoformat)rbpold_sold_drdrcrrr4zs   (z7DashboardManager.update_blood_pressure..updaterr[)rrcrdr4r]r^rrvrupdate_blood_pressurexsz&DashboardManager.update_blood_pressureN event_datetimetitlelocationnoteend_datec s<ddlmmfdd}||\}} | S)zAdd event to schedule. event_date should be YYYY-MM-DD. If end_date is provided, creates a multi-day event spanning the range.r)r timedeltac srVkrV}}d}|}||kr8|d}|d||d7}|dd7}||ks|djdddd d d d |d pRdd Sd}|d||djdddd dddp|dd S)Nr)rrzr{r|r}scheduler;)rPcS |ddSNrrxrJerrr z=DashboardManager.add_event..updater..)keyzAdded:  from z to rpz days). Location: TBDrqcSrrrrrrrrrz on z at z . Location: ) fromisoformatrrrKsort)rstartend days_addedr:eventdt_dater~ryr|r}rzrr{rrr4s6    ("z+DashboardManager.add_event..updater)rrrr6) rryrzr{r|r}r~r4r]r^rrr add_events zDashboardManager.add_eventtitle_fragmentcre)zMRemove event(s) matching title (case-insensitive). Optionally filter by date.csbt|d}fdd|dD|d<|t|d}|r+d|ddSddS)Nrcs4g|]}|dvrdus|dks|qS)r{Nrlower.0r)ry title_lowerrr s zBDashboardManager.remove_event..updater..zRemoved z event(s) matching ''.zNo events found matching ')rLr)rbeforeremovedryr)rrr4s    z.DashboardManager.remove_event..updaterr[)rrryr4r]r^rrr remove_eventszDashboardManager.remove_eventcatwhysourcecs$fdd}||\}}|S)z,Add a curated signal to the top of the list.csbd}|ddd|t|dd<|dddd|dd<ddS) N)rr{rrsignalscuratedrupdatedzSignal added: [] )insertrrYrr)rsignalrrr{rrrr4s z,DashboardManager.add_signal..updaterr[)rrr{rrr4r]r^rrr add_signalszDashboardManager.add_signaltextcr8)zUpdate the focus/goal text.cs"|d}|d<dd|dS)NfocuszFocus updated to: 'z ' (was: 'z').r)rrRrrrr4sz.DashboardManager.update_focus..updaterr[)rrr4r]r^rrr update_focuss zDashboardManager.update_focustimingnamedosebrandc s&fdd}||\}}|S)z?Add a supplement. timing is 'morning', 'evening', or 'anytime'.csPd}|dvrg|d<|d|ddddS)N)rrrr} supplementszAdded rpz) to z supplements.rK)rsupprrrr}rrrr4s   z0DashboardManager.add_supplement..updaterr[) rrrrrr}r4r]r^rrradd_supplementszDashboardManager.add_supplement name_fragmentcr8)zIRemove supplement matching name (case-insensitive) from any timing group.csg}dD]5}t|d|g}fdd|d|gD|d|<|t|d|}|r=||d|q|rLddd|d Sd d S) Nmorningeveninganytimercs g|] }|dvr|qS)rr)rs name_lowerrrrs zGDashboardManager.remove_supplement..updater..rzRemoved supplement 'z': z, rqzNo supplement found matching 'r)rrLrJrKjoin)rrrrdiffrrrr4s  z3DashboardManager.remove_supplement..updaterr[)rrr4r]r^rrrremove_supplements z"DashboardManager.remove_supplementcategoryfoodscre)zIReplace a viome food category. category: superfoods/enjoy/minimize/avoid.cs6dvr ddS|d<ddtdS)N) superfoodsenjoyminimizeavoidInvalid category 'z+'. Use: superfoods, enjoy, minimize, avoid.viomezViome 'z' updated with z items.)rLrrrrrr4s  z.DashboardManager.update_viome..updaterr[)rrrr4r]r^rrr update_viomeszDashboardManager.update_viomefoodcre)z&Add a single food to a viome category.cs^|dvr ddS|dvr&|ddddSdddS) NrrrzAdded 'z ' to viome rq'z' is already in viome rrrrrrr4s  z0DashboardManager.add_viome_food..updaterr[)rrrr4r]r^rrradd_viome_foodszDashboardManager.add_viome_foodpricec sddl}durHz|jdddddd}||ddWn&tyG}ztd |d t|dd d WYd}~Sd}~wwfd d}||\}}|S)zSReset the CRO swing-trade anchor to the given price (or live price from CoinGecko).rNz-https://api.coingecko.com/api/v3/simple/pricezcrypto-com-chainusd)ids vs_currenciesr )paramsr zFailed to fetch CRO price: zCouldn't fetch live CRO price: rhz;. Try again or text 'cro anchor 0.085' with a manual price.c s|dididi}|dd}td|d<|dd}|d d }td |d }td |d }d dd|dd|d|d S)Ncryptopositionstrategy anchorPricer sellTriggergQ? buyTriggerg?r;zCRO anchor reset to $z.4fz (was $u). New targets — Sell: $z | Buy: $z' Dashboard will update on next refresh.)rJrI)rstrat old_anchorsell_pctbuy_pct sell_target buy_targetrrrr4=s   z3DashboardManager.update_cro_anchor..updater) requestsrJraise_for_statusrr,r*errorr r6)rr http_requestsresprr4r]r^rrrupdate_cro_anchor+s$$ z"DashboardManager.update_cro_anchorcCsn|}|d}d|dd|dd|dd|d d |d d |d d|dd|dd|dS)Nr9zWeight: r:z lb (7-day avg: rAz) Goal: rCz lb | Baseline: rBz lb ( baselineDatez) Pace: rE paceUnitz | ETA: ~rFz weeks Last weigh-in: rGr)rrrrrr query_weightRs$zDashboardManager.query_weightc Cs@|}|d}d|dd|dd|dd|d d d S) Nr`z Body Fat: r:z % (goal: rCz %) Baseline: rBz% | Change vs last: r<rH%r)rrrarrrquery_body_fat\szDashboardManager.query_body_fatc Cs<|}|d}d|dd|dd|dd|d S) NrfzBP: rcrordrprju) — measured rr)rrrsrrrquery_blood_pressureds,z%DashboardManager.query_blood_pressure days_aheadc Cs|}t}g}|dD]1}z$t|d}||kr,|jt|j|ddkr3nn||Wqtt fy?Yqw|sHd|dSd|dg}|dd D]1}| d rcd |d nd }| d rqd|d nd } |d|d|d|d| qUd |S)Nrr)dayzNo events in the next z days.zUpcoming events (next z days):r rzrrxr|z @ u•  — r{ ) rrrYrr)minrrK ValueErrorKeyErrorrJr) rrrrYupcomingredatelinestime_strloc_strrrrquery_scheduleis,   ( zDashboardManager.query_schedulec Csx|}|d}dg}dD])}||g}|r6|d|d|D]}|d|dd|d q$q d|S) Nrz Supplements:rr:u • rrr)rrJrKupperr)rrrrritemsitemrrrquery_supplementss   z"DashboardManager.query_supplementscCsd|}|dddd}d|dddg}|D]}|d|dd |d qd |S) NrrzLatest signals (updated rz):[rrr{r)rrKr)rrsigsrrrrr query_signalss   zDashboardManager.query_signalscCs|}|d}|d}|d}tdd|dD}d|dd |d d |d d |dd|d d|d d|dd|dd|dd|dd|dt|dddS)zFull dashboard summary.r9r`rfcSs(g|]}|ddtkr|qS)rrx)rJrrYrrrrrrrs z2DashboardManager.query_summary..rzDashboard Summary (rz ): Weight: r:z lb (goal rCz ) | Pace: rEz lb/wk Body Fat: z% (goal z%) BP: rcrordrprjz ) Focus: rz Upcoming events: z Signals: rrz curated)rrL)rrrrars sched_countrrr query_summarys> zDashboardManager.query_summary)rxrxN)N)rx)rxrx)r)__name__ __module__ __qualname__r rdictrr3r6floatr_rbintrwrrrrrrlistrrrrrrrr r rrrrrrsR ) *     '  r)__doc__rr&r$loggingrrpathlibrfilelockrr getLoggerrr*rrrrrs