+ WjZa0t$Rt^RIHt^RIt^RIt^RIt^RIt^RI t]PPRR4PR4t ]PPRR4t]PPRR4tR R ltRLtRMtR R ltR RltR^R^R^R^R^R^R^/tR^R^R^R^R^R^R^R^R^ R^ R ^ R!^ / tR"R#ltR$R%ltRNR&R'lltROR(R)lltRPR*R+lltR,R-ltRQR.R/lltR0R1ltR2R3ltR4R5lt RRR6R7llt!R8R9lt"RSR:R;llt#R<R=lt$R>R?lt%R@RAlt&RTRBRCllt'RDRRERF/t(RG])RH&RIRJlt*RKt+R#)UuJarvis long-term memory — thin client to the Railway brain. This is the CLIENT side: it does NO heavy work. It calls the always-on memory service (a FalkorDB-backed fact graph deployed on Railway — see memory-service/) over HTTPS. The SERVER now owns the whole WRITE pipeline: on /remember it dedups against what's already stored and decides add / update (supersede) / no-op (Mem0-style) via DeepSeek, extracts the event date (``when``) and entities + relations from the text, and cleans raw utterances into atomic facts. So the client just ships the note (fire-and-forget) and the graph does the thinking; searching returns ranked, linked context in ~100ms, with reinforcement-on-access and optional temporal (`when_from`/`when_to`) filtering. This is the cross-device brain: the Mac, the Windows box, and the phone all point at the SAME MEMORY_API_URL, so a fact learned on one device is known on all of them, and linked to everything else. Runs IN-PROCESS via the Agent SDK MCP server (key ``"memory"``; Claude sees ``mcp__memory__``). Pure stdlib HTTP — no heavy deps on the device. Config (``.env``): MEMORY_API_URL the deployed service, e.g. https://jarvis-memory.up.railway.app MEMORY_API_KEY the shared bearer key (matches the service) MEMORY_GROUP namespace (default "ahmed") — lets one brain serve many users MEM_SERVER_PIPELINE set 0 to fall back to the OLD client-side supersede path (the server owns dedup/supersede by default) Set ``MCP_MEMORY=0`` to disable. ) annotationsNMEMORY_API_URL/MEMORY_API_KEY MEMORY_GROUPahmedcV^8dQhRR/#)returnbool)formats"voice/memory_control.py __annotate__r*scn\PPRR4R8XdR#\\4#)z0On only when a memory service URL is configured. MCP_MEMORY10F)osenvirongetr _URLr rrenabledr*s& zz~~lC(C/ :rc V^8dQhRRRR/#)r textstrr floatr )rs"rrr8scercdaT;'gRP4o\;QJd#V3Rl\4F 'gK RM RM!V3Rl\44'dR#\;QJd#V3Rl\4F 'gK RM RM!V3Rl\44'dR#R#) uLight heuristic — hedged facts recall weaker, firm facts stronger. The service uses this in salience ranking (latest+confident wins), never to drop.rc3,<"TF qS9xK R#5iNr .0wts& r _confidence..< !5a65TFg?c3,<"TF qS9xK R#5ir!r r"s& rr&r'> "6a66r)g?g?lowerany_FIRM_HEDGErr%s&@r _confidencer28sd A s !5 !sss !5 !!! s "6 "sss "6 """ rc V^8dQhRRRR/#)r rrr intr )rs"rrrCs  c c rcdaT;'gRP4o\;QJd#V3Rl\4F 'gK RM RM!V3Rl\44'd^#\;QJd#V3Rl\4F 'gK RM RM!V3Rl\44'd^#^#)z1-10 importance the server weighs in dedup/salience. Reuses the FIRM/HEDGE heuristic: firm/committed facts matter more (8), hedged guesses less (3).rc3,<"TF qS9xK R#5ir!r r"s& rr&_importance..Gr(r)TFc3,<"TF qS9xK R#5ir!r r"s& rr&r7Ir+r)r,r1s&@r _importancer9Csd A s !5 !sss !5 !!! s "6 "sss "6 """ rmondaytuesday wednesdaythursdayfridaysaturdaysundayjanuaryfebruarymarchaprilmayjunejulyaugust septemberoctobernovemberdecemberc V^8dQhRRRR/#)r qrr ztuple[str | None, str | None]r )rs"rrrVs66s6<6rc a^RIo^RIpT;'gRP4pSPP 4pRRlpRV3RllpVP RV4pV'dmSP\ VP^44\ VP^44\ VP^444pV!V4V!V43#RV9dV!V4V!V43#R V9d*VSP^R 7, pV!V4V!V43#R V9dOVSPVP4R 7, p V!V 4V!V SP^R 7,43#R V9dVVSPVP4^,R 7, p V!V 4V!V SP^R 7,43#R V9d)VP^R7p V!V 4V!V!V 443#RV9dJVP^R7SP^R 7, p V!V P^R74V!V 43#VP RV4pV'dlVP4\VP^4,, ^,;'g^p VSPV R 7, pV!V4V!V43#VP RV4pV'dt\VP^4,p WP8:d VPMVP^, p SPW^4p V!V 4V!V!V 443#R# \dELi;i)u Best-effort: turn a relative-time phrase in the query into an ISO date window (when_from, when_to) for /search. English phrases + ISO numeric dates only — deliberately simple, no deps, returns (None, None) if nothing time-like is present. Kept in sync with the copy in gateway/tools.py.Nrc V^8dQhRRRR/#)r d '_dt.date'r rr )rs"rr%_temporal_range..__annotate__`s src"VP4#r!) isoformat)rQs&r_iso_temporal_range.._iso`s{{}rc V^8dQhRRRR/#)r rQrRr r )rs"rrrScs$$j$Z$rc<VP^R7SP^ R7,P^R7SP^R7, #)daydays)replace timedelta)rQ_dts&r _month_end#_temporal_range.._month_endcsG a  3==b=#99BBqBImmm#$ $rz\b(\d{4})-(\d{2})-(\d{2})\btoday yesterdayr]z this weekz last weekz this monthr[z last monthzH\b(?:on\s+)?(monday|tuesday|wednesday|thursday|friday|saturday|sunday)\bz`\bin\s+(january|february|march|april|may|june|july|august|september|october|november|december)\b)NN)datetimerer-daterdsearchr4group ValueErrorr`weekdayr_ _WEEKDAYS_MONTHSmonthyear)rN_rer%rdrVrbmrQystartenddeltamorpras& @r_temporal_rangerxVs  bA HHNN E$$ 115A QWWQZ#aggaj/3qwwqz?KA7DG# #!|E{DK''a CMMqM) )AwQa 5==? ;;E{DA)>!>???a 5==?Q+> ??E{DA)>!>???q ! $E{DE!2333qmmm"S]]]%::CKKAK&'c22 )*+ -A9QWWQZ#88A=BB CMMuM- -AwQ DEF HA QWWQZ ;;.uzzEJJN1%E{DE!2333 A   s(A*M M-,M-c V^8dQhRRRR/#)r msgrr dictr )rs"rrrs88s8t8rcRRRRV/./#)contenttyperr )rzs&r_textrs 56 77rc(V^8dQhRRRRRRRR/#)r methodrpathbodyz dict | Nonetimeoutr4r )rs"rrrs(...C.{.C.rc Ve%\P!V4P4MRp\PP \ V,W@R7p\'dVPRR\ 24VPRR4\PPWSR7;_uu_4pVP4pV'd\P!V4M/uuRRR4# +'giR#;i)N)datar AuthorizationzBearer z Content-Typezapplication/jsonr) jsondumpsencodeurllibrequestRequestr_KEY add_headerurlopenreadloads)rrrrrreqrraws&&&& r_reqrs(,(84::d  " " $dD .. 4 GC t '$(89NN>#56     5 5ffh"%tzz#2 6 5 5 5s 60C11 D c V^8dQhRRRR/#r limitr4r list[dict]r )rs"rrrs>>s>J>rc\PPR\RV/4p\ RRV 24P R.4#)z5Newest-first raw brain contents (browse, not search).rjrGETz /memories?memoriesrparse urlencode_GROUPrrrqss& r list_recentrs@   &'5 A BB B4( ) - -j" ==rc V^8dQhRRRR/#rr )rs"rrrs>>#>j>rc\PPR\RVRR/4p\ RRV 24P R.4#)zFUnsurfaced findings from the nightly reflection engine (newest first).rjrunsurfaced_onlytruerz /insights?insightsrrs& rfetch_insightsrsI   &'5!2F!< =B B4( ) - -j" ==rc V^8dQhRRRR/#)r insight_idrr Noner )rs"rrrsKK#K$KrcDV'd\RRRVR\/4R#R#)z7Mark an insight surfaced so Jarvis raises it only once.POST /insight/seenidrjNrr)rs&rmark_insight_seenrs V_tZ&&IJrc$V^8dQhRRRRRR/#)r rNrkr4r rr )rs"rrrs!99C9C99rc\PPRVRVR\/4p\ RRV 24P R.4#)rNrrjr/search?factsr)rNrrs&& r search_factsrsC   aa& A BB " ' + +GR 88rc V^8dQhRRRR/#)r mem_idrr rr )rs"rrrs==3=4=rc0\RRRVR\/4R#)z"Permanently delete a wrong memory.rz/forgetrrjNr)rs&rforgetrsT67F;A B)BBc ,V^8dQhRRRRRRRRRR/#) r rrrrz str | Nonetoner rr )rs"rrrs1<6<6C<6s<6:<6<6*.<6rcaaaa\4'dSP4'gR#^RIpRVVVV3RllpVPVRR7P 4R#)uFire-and-forget save — POSTs in a daemon thread and returns instantly, so the conversation NEVER pauses to remember. Used by the inline … path (the brain drops the note mid-reply; the engine ships it here without a tool round-trip). Failures are logged, not raised. `when` = the event date (ISO) if the caller knows it (else the server extracts it from the text); `tone` = the vocal delivery the fact was said with. The SERVER now owns dedup/supersede/cleanup (Mem0-style add/update/no-op), so the default path is a plain /remember. Set MEM_SERVER_PIPELINE=0 to restore the old client-side supersede round-trip (see memory_supersede.py).NcV^8dQhRR/#rr )rs"rrfire_save..__annotate__s(H(H(Hrcd<SP4p.p\PPRR4R8wd^RIHpVP V4pRVR\RRRSR \V4R \V4/pS 'dS VR &S 'dS VR &V'dWR &\PPRR4R8Xd\PPRR4R8wdbRp^RIH pVPV\V^R74pV'd4WCR&\RRV4\RVR, RVR, R24R#\RRV4R# \dELi;i \dRpLki;i \d*p\R\!T4R, 24Rp?R#Rp?ii;i) MEM_ENTITIESrr)memory_entitiesrrjrrr confidence importancerrentitiesMEM_SERVER_PIPELINE MEM_SUPERSEDEN)memory_supersede)rrrrz [memory: superseded :NNu ← ":N2Nz"] /rememberz# [memory] background save failed: :NxN)rrrrvoicerextractrrr2r9rfind_supersededrrrr) r%rrrrrrrrrrs r_gofire_save.._gos' H A Hzz~~nc2c95.66q9HAw(FD +a., APD#V #V #+Z zz~~3S9S@ <C"6-==<Q/1F%+Nt426":,gafXSQR d +7!(!"!F" H 7At ~F G G Hsw6E;E8E; E;AE;)#E( E;1E; E; E%!E;$E%%E;( E85E;7E88E;; F/F**F/T)targetdaemon)rr threadingThreadrt)rrrrrrsffff r fire_saversG 99DJJLL(H(HXC-335rratgr{ _CORE_CACHEcV^8dQhRR/#)r r rr )rs"rrrPsrc\4'gR#^RIpVP4p\R,'d'V\R,, R8d\R,#\PP R\ /4p\RRV 2^R 7pVPR4;'gRP4pT\R&T\R&T# \d\R,u#i;i) u(The ~200-word pinned profile of Ahmed the nightly reflection maintains server-side (GET /core_block → {text, updated_at}). Cached 30 min; returns "" on ANY error and never blocks more than ~2s — safe to call while building the voice brain's system prompt without stalling or crashing startup.rNrrirjrz /core_block?r) rtimerrrrrrrrr)rnowrrrs rget_core_blockrPs 99 ))+C6s[%66=6""# \\ # #Wf$5 65L-q9%%2,,.KK K #6""#s!A C/CC/.C/c 2a^RIo^RIHpHpV!RRR\R\R\R\/4R V3R ll4pV!R R R \R\R\R\/4RV3Rll4pV!RRR\R\ /4RV3Rll4pV!RRW#V.R7#)z6Build and return the in-process ``memory`` MCP server.N)toolcreate_sdk_mcp_servermemory_rememberuBEXPLICITLY save one durable fact to Ahmed's shared memory — for memory CURATION work (dossier-card corrections, merges, backfills), NOT for conversational saving (that happens passively). `entities` = comma-separated people/companies/projects the fact is about; `when` = ISO date the fact refers to (event time), if any.rrrrc V^8dQhRRRR/#r argsr{r r )rs"rr"build_server..__annotate__zsDDDDTDrc x<"\VPRR44P4pV'g \R4#RTR\RRR\VPRR44P4;'gRR^/pVPR 4'd$\VR ,4P4VR &\VPR R44P R 4Uu.uF-pVP4'gKR VP4/NK/ ppV'dWBR &SP \R RV4GRjxL pT;'g/PRR4p\RV RVR, 24#uupiL= \d)p\R\T4R, 24uRp?#Rp?ii;i5i)rrz memory_remember failed: no text.rjrzjarvis-curationrrrrr,namerr Nopaddzsaved (z): :NPNzmemory_remember failed: NN) rrrrrsplit to_threadrr)r#rrrentsrr(asyncios& rr %build_server..memory_rememberss488FB'(..0;< < DD'68=NS&"!56<<>HH& !%Dxx"4<0668V 488J34::3?N?-.CD779(VQWWY'? N#'Z ))$ TJJC))u-B72$c$s)56 6 NK D3CF4L>BC C Dsl=F::F<FAF(E=E=)FF F*F<F:=F F7F2,F7-F:2F77F: memory_updateu6Use when something CHANGED — a fact is now different from what was saved (client changed, a plan moved, a preference flipped). Retires the old memory (kept as history, hidden from recall) and saves the new current one, linked to what it replaced. `old_id` from a search result; `text` = the new current fact.rc V^8dQhRRRR/#r"r )rs"rrr$s B B$ B4 Brc <"\VPRR44P4p\VPRR44P4pV'd V'g \R4#RTRTR\RRRVPR4;'gR/pVPR 4'd\VR ,4VR &SP \ R R V4GR jxL p\R VPRR4 R24#L# \d)p\R\T4R, 24uR p?#R p?ii;i5i)rrrz3memory_update failed: need old_id and the new text.rjrrrrrrrNzUpdated (new id r?z).zmemory_update failed: r+)rrrrrr.rr)r#rrrrrr0s& rr2#build_server..memory_updatesTXXh+,224488FB'(..0TNO O BffdGVh&1A1K1KVNDxx"4<0V ))$ dKKC+CGGD#,>+?rBC CL B1#a&,@A A BsZA"D>& D>2$DD20D"D#"DD>D D;D60D;1D>6D;;D> memory_searchuoSearch Ahmed's long-term memory by MEANING (not keywords) and get back connected facts — use this whenever the answer might depend on something he told you before ('what should I research for my meeting', 'what did the supplier quote', 'how do I like my coffee'). Returns up to `k` facts (default 10) — READ THEM ALL; the specific/detailed one is often not first.queryrc V^8dQhRRRR/#r"r )rs"rrr$s"KBKB$KB4KBrc <a"\VPRR44P4pV'g \R4#^RIHpVP V4\^\\VPR4;'g^ 4^44pRVRVR\/p\V4wrVV'dWTR&V'dWdR&\PPV4pSP!\"R R V 24GR jxL pVPR .4p .p V Fp V PR 4'dRMRp V PR4;'gRR,p T P%RV R, V 2V 'dRV R2MR,RV PRR4 R2,4K \PPRVR^R\/4pSP!\"R RV 24GR jxL PR.4F`pV P%RVPRR4 R24SP!\"RRRVPRR4R\/4GR jxL Kb ^R Ip0R1moV.\)V3RlVP+R VP-444\.R!R"7R#,,pVFp\PPR$VR\/4pSP!\"R R%V 24GR jxL PR&.4p\1R'V4R 4pV'gKyVPR(4'd(V P%R)VR$, R*VR(, R24M=VPR+4'd'V P%R,VR$, R*VR+, R24M V 'g \R-4#\R.P3V 44# \dELi;iELELEL \dELi;iEL \dLji;i \d)p\R/\T4R0, 24uR p?#R p?ii;i5i)2r8rzmemory_search failed: no query.) entity_showrrNrj when_fromwhen_torrNrrz [connected]rrz- rz (re: )z [id rr5]z/insights/search?ru{- (a reflection of yours that may be relevant here — mention it ONLY if it genuinely fits, briefly, as your own thought: rrrc3:<"TFpVS9gK VxK R#5ir!r )r#r$stops& rr&6build_server..memory_search..s!' E1 Q Es  z [a-z]{4,}T)keyreverse:Nr Nr'z/entity?rc3"TF7pVPR4'gVPR4'gK3VxK9 R#5i)rsummaryN)r)r#rs& rr&rBs0 F4a#$55==AEE)4D!"4sAA Arz- (your read on z: rFz- (on z (nothing relevant in memory yet) zmemory_search failed: r+>costdealdoesfromhavemuchtellthatthiswhatrwithaboutthinkclientshouldapproach)rrrrr r;show_for_queryrmaxminr4rrxrrrr.rappendrgsortedfindallr-lennextjoin)r#rN_esrparamswfwtrrrlinesrtagriqsit_re2triesr'eqsr/hitrrAr0s& @rr7#build_server..memory_searchs! "% & , , .:; ;  0   q !? BAs3txx}223R89A1c1gv6F$Q'FB&({#$&y!''/B))$"GGCGGGR(EE()hnRk*00b#6 r!F)SE259'$q 1rC!'dC(8'9;<= ll,,c1c1gv-NO!(!2!2e'8%>"@@ADZQSATUBLL((*vr(:';1>?"++D&/-1266$3CWf,UWWW U !Bf' \1779 E',/??ACC"D ,,00&$1PQC")"3"3exu%5#778;J8K F4 FGKMCs776??!LL+;CK=,/K=*;< WWY//!LL6#f+bY@PPQ)RS"?@@5)* *   H@ W  7    B1#a&,@A A Bs%=QO%A$P&?AP&?O7AP&)P&:1P&,AP2O:3A/P"O=#P,BPP,P8P=P 'P4P&5P7P& P& Q P&$Q% O40Q3O44Q7P&:P=P P P&PP&P P# P&"P##P&& Q1QQQQQmemoryz1.0.0)r'versiontools)r0claude_agent_sdkrrrr4)rrr r2r7r0s @r build_serverrrfs<  G 3VS*c B DDDD( / 3 S&#vsFC @ B BB B / - Cc "$KB$KBZ ! }= r) maybemightpossiblyperhapszi thinkznot surearoundroughly approximatelyzor soprobablyzcould bezi guess) signed confirmed definitelyzfor sureagreedpaid committed finalizedzclosed the dealz locked in)N)()rZ))r)related)rNN),__conditional_annotations____doc__ __future__rrr urllib.errorr urllib.parseurllib.requestrrrstriprrrrr0r/r2r9rmrnrxrrrrrrrrrrrrrrrrr__annotations__rrr)rs@rrsa8#  zz~~&+2237 zz~~&+  0 ! C q)Q Q A q*a1 6 aQGQq 1fa1k1 b*b*b : 6r8."> >K 9 =  %($JA 5 % *<6~Rs+ T+,Wr