WjZ UdZddlmZddlZddlZddlZddlZddlZejjddjdZ ejjddZ ejjdd Zd4d Zd Zd Zd5d Zd6dZddddddddZddddddddddddd Zd7dZd8dZd9d:d Zd;dd#Zd?d@d$ZdAd%ZdBd&ZdCd'ZdDdEd(Z dFd)Z!dGdHd*Z"dId+Z#dJd,Z$dKd-Z% dL dMd.Z&dd/d0Z'de(d1<dNd2Z)d3Z*y)OuJarvis 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_GROUPahmedchtjjdddk(ryttS)z0On only when a memory service URL is configured. MCP_MEMORY10F)osenvirongetbool_URLB/Users/ahmed/devFolder/Ultron/claude-voice/voice/memory_control.pyenabledr*s& zz~~lC(C/ :r) maybemightpossiblyperhapszi thinkznot surearoundroughly approximatelyzor soprobablyzcould bezi guess) signed confirmed definitelyzfor sureagreedpaid committed finalizedzclosed the dealz locked inc|xsdjtfdtDrytfdtDryy)uLight heuristic — hedged facts recall weaker, firm facts stronger. The service uses this in salience ranking (latest+confident wins), never to drop.rc3&K|]}|v ywNr.0wts r z_confidence..< !5a165g?c3&K|]}|v ywr(rr)s rr-z_confidence..> "6a166r/g?g?lowerany_FIRM_HEDGEtextr,s @r _confidencer98s< A !5 !! "6 "" rc|xsdjtfdtDrytfdtDryy)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&K|]}|v ywr(rr)s rr-z_importance..Gr.r/c3&K|]}|v ywr(rr)s rr-z_importance..Ir1r/r2r7s @r _importancer@Cs< A !5 !! "6 "" rr>r?)mondaytuesday wednesdaythursdayfridaysaturdaysundayr< ) januaryfebruarymarchaprilmayjunejulyaugust septemberoctobernovemberdecemberc ddlddl}|xsdj}jj }dd}dfd }|j d|}|rl jt |jdt |jdt |jd }||||fSd |vr||||fSd |vr%|jd z }||||fSd |vrF|j|j z } || || jd zfSd|vrI|j|jdz z } || || jd zfSd|vr(|jd} || ||| fSd|vrE|jdjd z } || jd|| fS|j d|}|rU|jt|jdz dzxsd} |j| z }||||fS|j d|}|rkt|jd} | |jkr |jn|jdz } j| | d} || ||| fSy#t$rY>wxYw)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.rNrc"|jSr() isoformat)ds r_isoz_temporal_range.._iso`s{{}rc|jdjdzjdjdz S)NrAday days)replace timedelta)r`_dts r _month_endz#_temporal_range.._month_endcsG a  3==b=#99BBqBImmm#$ $rz\b(\d{4})-(\d{2})-(\d{2})\brArBr>today yesterdayrfz this weekrDz last weekrLz this monthrcz 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)r` '_dt.date'returnstr)r`rnrorn)datetimerer3daterlsearchintgroup ValueErrorriweekdayrh _WEEKDAYS_MONTHSmonthyear)q_rer,rlrarkmr`ystartenddeltamor|rjs @r_temporal_rangerVs  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=B CMMuM- -AwQ DEF HA QWWQZ 5;;.uzzEJJNr1%E{DE!2333 A   sA*K44 LLdictcdd|dgiS)Ncontentr8)typer8r)msgs r_textrs 56 77rc|#tj|jnd}tjj t |z||}tr|jddt|jddtjj||5}|j}|rtj|nicdddS#1swYyxYw)N)datamethod AuthorizationzBearer z Content-Typezapplication/jsontimeout) jsondumpsencodeurllibrequestRequestr_KEY add_headerurlopenreadloads)rpathbodyrrreqrraws r_reqrs(,(84::d  " " $dD .. 4 GC  '$(89NN>#56   W  5ffh"%tzz#2 6 5 5s #)CCctjjt|d}t dd|j dgS)z5Newest-first raw brain contents (browse, not search).)rvlimitGETz /memories?memoriesrparse urlencode_GROUPrrrqss r list_recentrs<   &5 A BB B4( ) - -j" ==rctjjt|dd}t dd|j dgS)zFUnsurfaced findings from the nightly reflection engine (newest first).true)rvrunsurfaced_onlyrz /insights?insightsrrs rfetch_insightsrsC   &54:!< =B B4( ) - -j" ==rc2|rtdd|tdyy)z7Mark an insight surfaced so Jarvis raises it only once.POST /insight/seenidrvNrr) insight_ids rmark_insight_seenrs V_Z&&IJrctjj||td}t dd|j dgS)Nr}krvr/search?factsr)r}rrs r search_factsrs=   aa& A BB " ' + +GR 88rc,tdd|tdy)z"Permanently delete a wrong memory.rz/forgetrNr)mem_ids rforgetrs6F;A A?%A::A?ctrjsyddl}dfd }|j|dj y)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).Nrc j}g}tjjdddk7r ddlm}|j |}|tdt|t|d} r |d< r |d <|r||d <tjjd ddk(rvtjjd ddk7rSd} dd lm }|j|t|d}|r+||d<tdd|td|ddd|dddytdd|y#t$rYwxYw#t$rd}YWwxYw#t$r$}tdt!|ddYd}~yd}~wwxYw)N MEM_ENTITIESr r r)memory_entitiesr)r8rvrr confidence importancertoneentitiesMEM_SERVER_PIPELINE MEM_SUPERSEDE)memory_supersederD)rrrrz [memory: superseded r<u ← "2z"] /rememberz# [memory] background save failed: x)rrrrvoicerextractrrr9r@rfind_supersededrrrrp) r,rrrrrrrr8rrs r_gozfire_save.._gos' H A Hzz~~nc2c95.66q9H(D"-a. APD#V #V #+Z zz~~3S9S@ <C"6-==<Q/1F%+DNt426"1:,gafXSQR d +7!(!"!F" H 7At ~F G G Hse5E D+A.memory_rememberss488FB'(..0;< < D 6=N &"!56<<>H&"#%Dxx"4<0668V 488J34::3?N?-.CD779QWWY'? N#'Z ))$ TJJC)u-B72$c$s)56 6 NK D3CF4CL>BC C DsS7FBE)E 7$EE-E F E E>E93E>4F9E>>F 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.)rr8rrc4Kt|jddj}t|jddj}|r|s tdS ||td|jdxsdd}|jd rt|d |d <j t d d |d{}td |jd ddS7##t$r$}tdt|ddcYd}~Sd}~wwxYww)Nrrr8z3memory_update failed: need old_id and the new text.rrr)rr8rvrrrrrzUpdated (new id r?z).zmemory_update failed: r)rprrrrrrr)r rr8rrrr"s rr#z#build_server..memory_updates TXXh+,224488FB'(..0TNO O B$dV&&1A1KVNDxx"4<0V ))$ dKKC+CGGD#,>+?rBC CL B1#a&#,@A A BsIA"D&AC(C&"C(%D&C(( D1D D DDD 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 Kt|jddj}|s tdS ddlm}|j | tdtt|jdxsdd }||td }t|\}}|r||d <|r||d <tjj|}j!t"d d|d{}|jdg} g} | D]j} | jdrdnd} | jdxsddd} | j%d| d| | rd| dndzd| jdddzl tjj|dtd }j!t"d d|d{jdgD]^}| j%d|jdddj!t"d d!|jddtd"d{` ddl}hd#|gt)fd$|j+d%|j-Dt.d&'ddz}|D]}tjj|td(}j!t"d d)|d{jd*g}t1d+|Dd}|sq|jd,r| j%d-|d.d/|d,dn/|jd0r| j%d1|d.d/|d0dn| s td2Std3j3| S#t$rY*wxYw777c#t$rYjwxYw7#t$rY]wxYw#t$r$}td4t|dd5cYd}~Sd}~wwxYww)6Nr'rzmemory_search failed: no query.r) entity_showrArrNr when_fromwhen_torrrrz [connected]rz- rz (re: )z [id rr%]rBz/insights/search?ru{- (a reflection of yours that may be relevant here — mention it ONLY if it genuinely fits, briefly, as your own thought: r8rrr>costdealdoesfromhavemuchtellthatthiswhatrwithaboutthinkclientshouldapproachc3*K|] }|vr| ywr(r)r*r+stops rr-z6build_server..memory_search..s ' E1  Esz [a-z]{4,}T)keyreverse)rrvz/entity?rc3dK|](}|jds|jdr|*yw)rsummaryN)r)r*rs rr-z6build_server..memory_search..s- F4a#$55=AEE)4D!"4s.0rz- (your read on rz: rDz- (on z (nothing relevant in memory yet) zmemory_search failed: r)rprrrrr)show_for_queryrmaxminrurrrrrrrappendrrsortedfindallr3lennextjoin)r r}_esrparamswfwtrrrlinesrtagriqsit_re2triesreqsr!hitrr@r"s @rr&z#build_server..memory_searchs  "% & , , .:; ;  0   q !? BAs3txx}23R89A1v6F$Q'FB&({#$&y!''/B))$"GGCGGGR(EE()hnRk*0b#26 r!F)SE259'$q 1rC!'dC(8'9;<= ll,,11v-NO!(!2!2e'8%>"@@ADZQSATUBLL((*vr(:';1>?"++D&/3566$3Cf,UWWW U !Bf' \1779 E',/??ACC"D ,,00$1PQC")"3"3exu%5#778;J8K F4 FGKMC776?!LL+;CK=,/K=*;< WWY/!LL6#f+bY@PPQ)RS"?@@5)* *   H@ W  7    B1#a&#,@A A Bs7OM1BN+(N)BN+1AN 5N6A.N $N%N +N+-BN=N>)N(A"N N+ON+0O1 M>:O=M>>ON+N N NN+NN+N N(%N+'N((N++ O4O OOOOmemoryz1.0.0)rversiontools)r rror)r"claude_agent_sdkrrrpru)rrrr#r&r"s @r build_serverr_fs<  G Sc B DDDD( / 3 #sC @ B BB B / - c "$KB$KBZ !  }= r)ror)r8rprofloat)r8rproru)r}rproztuple[str | None, str | None])rrpror)N)rrprrprz dict | Nonerru)()rruro list[dict])rA)rrpror ))r}rprrurorc)rrpror )rrpr8rprorp)rrcrorc)r)r}rpror )ror)related)rrprrprrpror )rrprrpror )rrcrorcr)rNN) r8rprrpr str | Nonerrfror )rorp)+__doc__ __future__rrr urllib.errorr urllib.parseurllib.requestrrrstriprrrrr6r5r9r@ryrzrrrrrrrrrrrrrrrrr r__annotations__rr_rrrrnsP8#  zz~~&+2237 zz~~&+  0 ! C QQAa1 6 QQqa11bb : 6r8."> >K 9 =  %($JA 5 % *AE!%<6<6*.<6~ s+ T+,Wr