jhUdZddlmZddlZddlZddlZddlmZddlm Z m Z ddl m Z ddl mZmZddlmZmZdd lmZmZdd lmZmZmZmZmZmZd Zd ed <ej>dej@Z!ded<ddZ"ddZ#dd ddZ$ddZ%d dZ&d!dZ'dd d"dZ(d#dZ)d$dZ*y)%z2Prose-free historical event and view construction.) annotationsN) defaultdict)date timedelta)Path)FinalLiteral)HistoryBaselineParserSourceInventory)Baseline BaselineEntry)ContractCheckinContractStatusEvent EventTypeImportManifest ProvenancezT08:00:00+09:00z Final[str] KST_SUFFIXz^##\s+(D\+\d+\b[^\n]*)zFinal[re.Pattern[str]]HISTORY_HEADINGcZttj|jS)zHVerify the approved source inventory then extract only permitted fields.)r r from_manifestparse) manifest_paths l/home/cube/projects/richard/.worktrees/nutricoach-v140-impl/dualcoach/profile/checkin_cli/history_imports.pyparse_baseliners! !>!>}!M N T T VVctdtjjdD}tfd|DS)zLProduce legacy heading-only provenance events without retaining source text.c3ZK|]#}|jdj%ywNgroupstrip.0matchs r z(legacy_history_events..$u8tuEKKN((*8t)+utf-8encodingc3K|]Z}tdt|zddtjdt dt |t j\yw)history_N1.0historical_markdown source_type source_refcontent_sha256section_anchor)event_id event_typeschema_versionoccurred_at_kstrecorded_at_kst provenancestatus)r_digestrHISTORY_IMPORTEDrstrrARCHIVED)r%anchor recorded_atsource source_sha256s rr'z(legacy_history_events..s} F  (> ? DEF 11 ''!.CPSTZP[lyKQR!**  sA A#)tuplerfinditer read_text)rDrErCanchorss``` rlegacy_history_eventsrJsJu8P8PQWQaQakrQaQs8tuuG     rr0r9cDtfd|jDS)zHCreate deterministic archived events with only known historical metrics.c3:K|]}t|yw)rKN)_baseline_event)r%entryrCr9s rr'z"baseline_events..3s!raqX] NSSaqs)rFentries)baselinerCr9s ``rbaseline_eventsrR,s raiaqaqr rrrcTtj|jdddzS)z.Serialize audit coverage without source prose.FT ensure_ascii sort_keys )jsondumpsto_storage_dict)rQs rbaseline_reportr[6s% ::h..0uPT UX\ \\rctd|D}tj|jj |t ||j j ddddzS)zHRender dated historical measurements separately from live current state.c3 K|]|}|jtjur^|jR|jdd|jj |jj |jjd~yw)N )r weight_kg sleep_hours calories_kcal)r8rr?check_inr:body_weight_kgr`ra)r%events rr'z"historical_view..=sr E   y99 9enn>X ))#2.66 >>55"^^99  sBB)coverage observationsweekly_weight_trendreconciliationFTrTrW)rFrXrYrerZ_weekly_weight_trendrh)eventsrQrfs rhistorical_viewrk;st   L :: ))99;(#7 #E&55EEG      rctdtj|jdD}t j t ||||ddddzS) zESerialize old heading import provenance without historical body text.c3ZK|]#}|jdj%ywrr!r$s rr'z"legacy_manifest..Ur(r)r*r+) source_pathsha256 range_labelsection_anchorsFTrTrW)rFrrGrHrXrYr@)rDrErprIs rlegacy_manifestrrSssu8P8PQWQaQakrQaQs8tuuG ::c&k][f|CDSXdh ilp pprc t|j|j|jdj |j xsd|j dj |jxsd}|jd}|j|jztj|dz}|dk(r||z}dt|dd}t|tj ||j"t$|t'd |j(|j|j t*j,||dk(rt/|j"  Sd S) N,)rcr`ratraining_summarydigestion_summary pain_summaryT) exclude_none)rVz2.0r.r/r1r2)observation_kst_day) r7r8r9r:r;r<r=rbimport_manifest)rr_r`rajointraining_tokensdigestion_status pain_tokens model_dumprEr6rXrYr>rrr? recorded_daterrrnrrAr)rOrCr9rbpayloadevent_identityr7s rrNrNYsf %%))%"7"78@D00XXe//08D H!!t!4G((5+?+??$**W`dBeeN'.8'.1#2678H --% ../ |<#*?EL]L]nsoBoBSXSgSgh&&& u/B/B C  rcbtt}|D]s}|d}| tjt |d}|t |j z }||jjt|utdt|jDS)zFGroup observed weights by Monday without inventing missing-day values.r_r)daysc 3~K|]5\}}|t|tt|t|z dd7yw)) week_start sample_countaverage_weight_kgN)lenroundsum)r%rvaluess rr'z'_weekly_weight_trend..sD"9 J"3v;UZ[^_e[filmsit[tvwUxy"9s;=) rlistr fromisoformatr@rweekday isoformatappendfloatrFsorteditems)rfweights observationvalue observed_daters rriri}s&1$&7G# K(   ..s;v3F/GHM& 8M8M8O)PPJ J((* + 2 25< @ $ "("9 rcdtj|jjS)N)hashlibroencode hexdigest)rs rr>r>s >>%,,. ) 3 3 55r)rrreturnr )rDrrEr@rCr@rtuple[Event, ...])rQr rCr@r9Literal['1.0', '2.0']rr)rQr rr@)rjrrQr rr@)rDrrEr@rpr@rr@)rOr rCr@r9rrr)rfz/tuple[dict[str, str | float | int | None], ...]rz(tuple[dict[str, str | float | int], ...])rr@rr@)+__doc__ __future__rrrXre collectionsrdatetimerrpathlibrtypingrr checkin_cli.history_baseliner r checkin_cli.history_modelsr r checkin_cli.modelsrrrrrrr__annotations__compile MULTILINErrrJrRr[rkrrrNrir>rrrs8" #$!O>ll+ J**4"**5NPRP\P\*]']W *-2 sss* s  s]  0p-2 ! !!* !  !H 6r