6*QjdZddlmZddlZddlZddlZdZdZdZ dZ eded e d e d iZ dd Z dd Z dd ZddZ d ddZddZddZddZddZddZddZy)uStructured phone-power storage on top of the memory service. Phase-2 "Jarvis runs my phone" needs a handful of small, structured, mutable collections — saved *places*, a *contacts* phonebook, an *SMS watch-list*, and *routines* — that must survive restarts. Rather than stand up a new database we persist each item as a **typed memory record in a DEDICATED group namespace** (``PHONE_STORE_GROUP``, default ``"_phone"``). That gives three things for free: * durability — the memory service is FalkorDB-backed, so records outlive any gateway restart or redeploy; * isolation — a separate ``group`` means these machine records never pollute Ahmed's semantic long-term memory (``memory_search`` / the persona memory index both read the ``ahmed`` group, not ``ahmed_phone``); * deterministic CRUD — ``GET /memories?group=&kind=`` lists newest-first and filters by an exact ``kind``, ``POST /remember`` creates, ``POST /forget`` deletes by id. No semantic ranking is ever involved, so listing/removing an item is exact, not fuzzy. One record per item. ``kind`` names the collection; the item's fields live as a compact JSON object in the record ``text``. Numbers are treated as sensitive — this module never logs a record's contents. All HTTP funnels through :func:`_mem_request` so tests monkeypatch exactly one function and never touch the network. This module deliberately does NOT import ``tools`` (which imports us), keeping its own tiny HTTP helper to avoid a circular import. ) annotationsN phone_place phone_contactphone_sms_watch phone_routinelabelnamesenderc`tjjddjdS)NMEMORY_API_URL/)osenvirongetrstripA/Users/ahmed/devFolder/Ultron/claude-voice/gateway/phone_store.py_mem_urlr4s# ::>>*B / 6 6s ;;rcBtjjddS)NMEMORY_API_KEYr rrrrrr_mem_keyr8s ::>>*B //rcBtjjddS)N MEMORY_GROUPahmedrrrr _base_groupr<s ::>>.' 22rc^tjjdxs tdzS)zThe dedicated namespace for phone-power records (kept OFF the semantic memory group so these never surface in recall or the persona index).PHONE_STORE_GROUP_phone)rrrrrrr phone_groupr"@s$ ::>>- . L;=83KLrcKddl}t}|s td||z}|r%|dtjj |zz }ddi}t } | rd| |d<|j| 4d{} | j|||||nd d{} | j| j} | rtj| nicdddd{S7k7L7 #1d{7swYyxYww) z@Call the memory service. Returns parsed JSON ({} on empty body).rNzMEMORY_API_URL not set?z Content-Typezapplication/jsonzBearer Authorization)timeout)headersjson) httpxr RuntimeErrorurllibparse urlencoder AsyncClientrequestraise_for_statuscontentr(loads) methodpathparamsbodyr&r)baseurlr'keyclientrespraws r _mem_requestr=Gs  :D 344 +C  sV\\++F33312G *C %,SE?    11V^^FC151At$MM ll"%tzz#2 211M2111sZA6C?8C$9C?<C*C&8C* C?C(C?&C*(C?*C<0C3 1C<8C?cX|xsdj}|dk(r|S|jS)zGCase/space-insensitive key for matching. ``"*"`` is preserved verbatim.r *)striplower)valuevs r_normrD`s+ "AS1'aggi'rcKtddt|ddd{}g}|jdgD]v}|jdxs|jd xsd } tj|}t|tsR|jd |d <|j|x|S7#t t f$rYwxYww) zEvery item in a collection, newest-first. Each item is the stored JSON payload plus an ``_id`` (the memory-record id, used for deletes).GETz /memories)groupkindlimit)r5Nmemoriesfacttextr id_id) r=r"rr(r2 ValueError TypeError isinstancedictappend)rIoutitemsmr<payloads r list_itemsrYgsUK.9mT.1%34 4CE WWZ $eeFm2quuV}2 jjoG gt $UU4[GEN LL !% L 4I&   s:C B4AC %B6:C  *C 6CC CC c Kt|}|syt|}t|d{D]-}tt|j |d|k(s+|cSy75w)z=Fetch one item by its key field (label/name/sender), or None.Nr )rD _KEY_FIELDrYstrr)rIr9wantfielditems rget_itemr`zs` :D  t E &&& TXXeR() *d 2K' 's&A A.A A c >Kt|}|syt|}d}t|d{D]e}tt|j |d|k(s+|j ds=t dd|dt dd{|d z }g|S7n7w) uDelete every item whose key field matches. Returns how many were removed (0 if none). Idempotent — used both to remove and to make put_item an upsert.rNr rOPOSTz/forget)rNrHr6)rDr[rYr\rr=r")rIr9r]r^removedr_s r delete_itemrfs :D  t EG &&& TXXeR() *d 2txxvy+/;$OQ Q Q qLG ' N ' Qs-(BB.BB,B B BBc Kt|}t|j|dj}|st |d|d|j Dcic]\}}|dk7s ||}}}t ||d{tddtj|d t|d d d  d{|Scc}}w7E7w)zUpsert an item (replace any existing one with the same key), then store it. Returns the stored payload (without the transient ``_id``).r z: missing required ''rONrbz /rememberF) ensure_asciiphoneg?)rMrHrIsource confidencerc) r[r\rr@rPrVrfr=r(dumpsr")rIrXr^r9krCcleans rput_itemrps t E gkk%$ % + + -C D6!5eWA>??%mmo rs:#   " &H&  <03M.2+/(,.*.(.!&.26.2(& " " r