+ Uj; Rt^RIHt^RIt^RIt^RIt^RIt^RIt^RI t^RI t^RI H t ^RI H t ^RIHt] !]4P#4P$P$t] !]P(P+R]!]P$R, 444t]P(P+RR 4t] !]P(P+R ]!] P2!4R , R , R , R, 444tRtRRltRRltR1RRlltRRltRRlt RRlt!]"!R4t#]"!R4t$RRlt%R R!lt&R"R#lt'R$R%lt(R2R&R'llt)R(R)lt*R2R*R+llt+R,R-lt,R.R/lt-R0t.R#)3u~Storage HUD — a fast, lazy file browser over Supabase Storage. The bucket 'jarvis-files' (on Ahmed's Supabase) is the WRITABLE shared file store that any Jarvis / Claude on any device can read, save, and delete from. This module is the engine side of the HUD's "pull up the storage" panel. DESIGN RULE (the whole point): the LIST is METADATA-ONLY. `list()` / `show()` fetch names + type + size + updated timestamp and NOTHING ELSE — no file bodies. A file is downloaded ONLY when Ahmed actually opens it (`open_file` / `download`), and even then it's cached to disk and re-fetched ONLY when the remote copy is newer. This is deliberately unlike the memory graph, which was slow because it bulk-loaded everything. Ports the proven REST logic from jarvis-tools-service/storage.py (stdlib urllib, no new deps). Endpoints under {SUPABASE_URL}/storage/v1/...: POST /object/list/{bucket} → metadata list (name, updated_at, metadata.size…) GET /object/{bucket}/{name} → the file body (only on open) POST /object/{bucket}/{name} → upload (x-upsert) DELETE /object/{bucket}/{name} Creds come from the process env, else the Ultron repo's .env (the single source of truth — SUPABASE_URL + SUPABASE_SECRET, the service_role key). MCP_STORAGE=0 disables the whole thing. Engine → HUD event (voice.events.emit): storage {files:[{name,type,size,updated}]} — open / refresh the panel ) annotationsN)datetime)Path)emit ULTRON_ENVz.envSTORAGE_BUCKETz jarvis-filesJARVIS_STORAGE_CACHELibraryzApplication SupportJarvisstoragez.emptyFolderPlaceholdercV^8dQhRR/#)returnztuple[str, str] | None)formats"C/Users/ahmed/devFolder/Ultron/claude-voice/voice/storage_control.py __annotate__r;s  & c\PPRR4p\PPRR4pV'd V'g\P 4'd\P 4P 4FpVP4pVPR4'gRV9dK3VPR4wr4pVP4VP4rSVR8Xd V'gTpKyVR8XgKV'dKTpK V'd V'gR#VPR4V3# \dL2i;i)zG(base_url, service_key) from env, falling back to the Ultron repo .env. SUPABASE_URLSUPABASE_SECRET#=N/) osenvironget _ULTRON_ENVexists read_text splitlinesstrip startswith partition Exceptionrstrip)urlkeylinek_vs r_credsr-;s **.. ,C **..*B /C C[//11 #--/::<zz|??3''3d?..-awwy!'')1&sC++CCC= C ::c?C     s%,BEEEE EEcV^8dQhRR/#)r rboolr)rs"rrrRs   rch\PPRR4R8XdR#\4RJ#)zBOn when the Supabase service creds are available and not disabled. MCP_STORAGE10FN)rrrr-rrrenabledr4Rs) zz~~mS)S0 84 rc 0V^8dQhRRRRRRRRRR R R /#) r methodstrpathbodyz bytes | Noneheadersz dict | Nonetimeoutintrbytesr)rs"rrr]sAJJJ3JlJJ.1J;@Jrc \4pV'g \R4hVwrg\PP V RV 2VVR7pVP RRV 24VP RV4T;'g/P 4FwrVP W4K \PPWR7;_uu_4p V P4uuRRR4# +'giR#;i \PPdFp \RT P R T P4R ,PR R 4 24hRp ? ii;i) z/storage not configured (no SUPABASE_URL/SECRET)z /storage/v1)datar6 AuthorizationzBearer apikey)r;NzHTTP z: :NNutf-8ignore) r- RuntimeErrorurllibrequestRequest add_headeritemsurlopenreaderror HTTPErrorcodedecode) r6r8r9r:r;credsbaser(reqr*r,res &&&&& r_dorV]s$ HE LMMID .. D6TF!;$(. ! 0CNN?gcUO4NN8S!B%%' q(J ^^ # #C # 9 9Q668: 9 9 9 << ! !JU166("ffhtn33GXFGIJ JJs7%(C< C( C<( C9 3C<9C<<E AEE cV^8dQhRR/#r rz list[dict]r)rs"rrrqs @ @: @rc@^RIp\RR\ 2VPRRRRRR R R R //4P 4R R/4pVP V4pVUu.uF:pVP R 4'gKVP R 4\8wgK8VNK< up#uupi)uARaw Supabase list rows (METADATA ONLY — never the file bodies).NPOSTz /object/list/prefixrlimitisortBycolumnnameorderasc Content-Typezapplication/json)jsonrVBUCKETdumpsencodeloadsr _PLACEHOLDER)rcr?rJis r _raw_listrjqs vvh/zz8R$#h%GI"FH 23  5D JJt E @u!uuV} !"v,!> Au @@ @sB6BBc$V^8dQhRRRRRR/#)r r_r7metadictrr)rs"rrr~s!66646C6rcP\V4PPR4P4pV'dV#T;'g/P R4;'g(\ P !V4^,;'gRpRV9dVPR4R,#R#)zA short type tag for the row icon: the extension if any, else the mime subtype (e.g. 'pdf', 'png', 'plain'). Lowercased, no dot..mimetyperr)rsuffixlstriplowerr mimetypes guess_typesplit)r_rlextmimes&& r_kindrz~s t*   " "3 ' - - /C  JJB  J ' N N9+?+?+Ea+H N NBD"%+4::c?2 525rc V^8dQhRRRR/#)r isor7rfloatr)rs"rrrsrcV'gR#\P!VPRR44P4# \dR#i;i)zjParse an ISO-8601 timestamp (with 'Z' / fractional seconds) to epoch seconds. 0.0 on anything unparseable.gZz+00:00)r fromisoformatreplace timestampr%)r|s&r_epochrsF %%ckk#x&@AKKMM s3A AAzCabcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789.-() 0123456789abcdefc V^8dQhRRRR/#r r_r7rr)rs"rrrs223232rc\V4P4PR4pRPRVP R444#)rrc3l"TF*p\V4\9d \V4MRVR 2xK, R#5i)r+02xN)chr_KEEP).0bs& r _enc_key..s220q!Vu_3q6AaW+=0s24rC)r7r"rsjoinrfr_s&r_enc_keyrsD t9??  # #C (D 772 KK02 22rc V^8dQhRRRR/#)r r(r7rr)rs"rrrs ( (3 (3 (rc\4p^\V4r2W#8dW,R8XduV^,V8:dgW^,,\9dOW^,,\9d7VP\ W^,V^,^44V^, pKVP\ W,4^,4V^, pKVP RR4#)r+rCr) bytearraylen_HEXappendr<ordrP)r(rrins& r _dec_namers A c#hq % 6S=QUaZC!H,<qSTAQ HHSqS1r* + FA HHS[4' ( FA 88GY ''rcV^8dQhRR/#rXr)rs"rrrsjrc .p\4FpVPR4;'g/pVPR4pVfVPR4p\VR,4pTPRTR\ WB4R\ V\ \34'd \ V4M^RVPR4;'gVPR4;'gR /4K V#) z`Metadata-only listing: [{name, type, size, updated}] sorted by name. NEVER fetches file content.metadatasize contentLengthr_typeupdated updated_at lastModifiedr)rjrrrrz isinstancer<r})outrirlrdisplays rlistrsC [uuZ &&Bxx <88O,DAfI& G E'( D3,!?!?CIQ quu\*LLdhh~.FLL"    Jrc V^8dQhRRRR/#rr)rs"rrrs##rc \V4p\4FjpVPR4V8XgKVPR4;'g/pVPR4;'gVPR4;'gRu# R#)z*BHHb H rc$V^8dQhRRRRRR/#)r r_r7r str | Nonerr)rs"rrrs!3src \V4P4PR4pV'g \R4h\V, pVeTM \ V4p\ V4pVP4'd:V'd2VP4PV^, 8d \V4#\RR\ R\PP\V4RR7 24pVP P#RRR7VP%V4V'd\&P(!W$V34\V4# \*dLi;i)zDownload ONE file to the local cache and return its path. Re-downloads only when the remote copy is newer than the cached one (compared via the remote updated_at vs the cached file's mtime). This is the ONLY path that ever pulls bytes.rzdownload: need a file nameGET/object/safeT)parentsexist_ok)r7r"rs ValueErrorCACHErris_filestatst_mtimerVrdrFparsequoterparentmkdir write_bytesrutimeOSError)r_rdest remote_iso remote_tsr?s&& rdownloadrs t9??  # #C (D 566 4D: <<8 #   fd^ , K WW_ LL  K   j$/ 0 K : )#a&,899 K:s"-B+B)B B8B33B8c$V^8dQhRRRRRR/#)r local_pathr7r_rrr)rs"rrrs!  s *  rc \PP\V4P 44pV'd&\PP V4'g\ RV: 24hV'd)\V4P 4PR4MR;'g \PPV4p\P!V4^,;'gRp\VR4;_uu_4pVP4pRRR4\RR\ R\P P#\%V4RR 7 2XR VR R /4V# +'giLV;i) zrUpload a LOCAL file into the bucket (upsert). `name` defaults to the file's own basename. Returns the stored name.z no file at rrzapplication/octet-streamrbNrZrrrbzx-upserttrue)rr8 expanduserr7r"isfileFileNotFoundErrorrsbasenamerurvrrLrVrdrFrrr)rr_lpryfr9s&& ruploadrs    C O113 4B RWW^^B''+bV 455-1CIOO  $ $S )r R Rbgg>N>Nr>RD    %a ( F F,FD b$1vvx (6(!FLL$6$6x~C$6$P#QRTX z624 K s E&& E6 c V^8dQhRRRR/#rr)rs"rrrs    rc X\V4P4PR4pV'g \R4h\ RR\ R\ PP\V4RR7 24\V, PRR7V# \dT#i;i)z8Remove a file from the bucket. Returns the deleted name.rzdelete: need a file nameDELETErrT) missing_ok) r7r"rsrrVrdrFrrrrunlinkrrs&rdeleters t9??  # #C (D 344HVHAfll&8&8$c&8&R%STU . K   K s;B B)(B)cV^8dQhRR/#rXr)rs"rrrs  j rc\4p\RVR7V# \d8p\R\ T4R, 24\R.R7.uRp?#Rp?ii;i)uList (metadata only) and push a `storage` event so the HUD opens/refreshes the file panel. Returns the same list for the caller. Never raises — a viewer refresh must not crash the assistant.r )filesz" [storage] panel refresh failed: rN)rrr%rr7)rrUs rshowrsT Ye$  23q6$<.AB Yb! s A,AAAc,aa^RIo^RIHpHpRRloV!RR/4RVV3Rll4pV!R R R \/4R VV3R ll4pV!RRR\R \/4RVV3Rll4pV!RRR \/4RVV3Rll4pV!RRW#WE.R7#)rN)toolcreate_sdk_mcp_serverc V^8dQhRRRR/#)r msgr7rrmr)rs"rr"build_server..__annotate__-s<<3<4._text-sVVVS9:;;r storage_showuBPull up Ahmed's file storage on the HUD and list what's there. Use for 'pull up the storage', 'show my files', 'open storage', 'what files do I have'. Opens a fast panel (names + types only — nothing is downloaded) and returns the list. He can then open/delete files there, or you can with storage_open / storage_delete.c V^8dQhRRRR/#r argsrmrr)rs"rrr6s A A A$ Arc<"SP\4GRjxL pV'g S!R4#VUu.uF:pRVR, 2VPR4'dRVR, R2MR,NK< ppS!\V4 R2R P V4,4#Luupi \ d&pS!R \ T4R , 24uRp?#Rp?ii;i5i) NzStorage is empty.z- r_rz (z bytes)rz# file(s) in storage (panel is up):  zstorage_show failed: NN) to_threadrrrrr%r7)rrrlinesrUrasyncios& rr"build_server..storage_show0s A!++D11E011$%#!F)%45EE&MM#ai[0rKK# %CJ<'KL99U+,- - 2%  A0Q?@ @ AsjCB)B" B)B)CB)&B$B$6+B)!C"B)$B)) C4CCCCC storage_openuOpen ONE stored file by name — downloads it (cached; only re-fetched if it changed) and opens it in its default app so Ahmed can view or edit it. `name` is the exact file name from storage_show.r_c V^8dQhRRRR/#rr)rs"rrrHsAAA$Arc><"\VPRR44P4pV'g S!R4#SP\V4GRjxL S!RV R24#L \ d&pS!R\T4R, 24uRp?#Rp?ii;i5i)r_rz&storage_open failed: need a file name.NzOpened rozstorage_open failed: r)r7rr"rrr%rr_rUrrs& rr"build_server..storage_openCs 488FB'(..0AB B A##It4 4 474&*+ + 5 A0Q?@ @ AsF:BA*A(A*'B(A** B5BBBBBstorage_uploadzUpload a LOCAL file (by absolute path on this Mac) into Ahmed's storage so it syncs everywhere. `local_path` = the path; `name` = optional name to store it as (defaults to the file's own name). Refreshes the HUD panel.rc V^8dQhRRRR/#rr)rs"rrrWs C C4 CD Crc <"\VPRR44P4pV'g S!R4#SP\T\VPRR44P4;'gR4GRjxL pSP\ 4GRjxL S!RV R24#L-L \ d&pS!R\T4R, 24uRp?#Rp?ii;i5i) rrz)storage_upload failed: need a local_path.r_Nz Uploaded z to storage.zstorage_upload failed: r)r7rr"rrrr%)rrr_rUrrs& rr$build_server..storage_uploadRs ,+ , 2 2 4DE E C **C 45;;=EEGGD##D) ) )9TF,78 8G ) C23q6$<.AB B Cs_:C.AB;? B; B7 B;&B9'B;6C.7B;9B;; C+C& C+!C.&C++C.storage_deletezXDelete a file from Ahmed's storage by name (from storage_show). Refreshes the HUD panel.c V^8dQhRRRR/#rr)rs"rrrfs C C4 CD Crc|<"\VPRR44P4pV'g S!R4#SP\V4GRjxL SP\ 4GRjxL S!RV R24#L-L \ d&pS!R\T4R, 24uRp?#Rp?ii;i5i)r_rz(storage_delete failed: need a file name.NzDeleted z from storage.zstorage_delete failed: r)r7rr"rrrr%rs& rr $build_server..storage_deletecs488FB'(..0CD D C##FD1 1 1##D) ) )8D689 9 2 ) C23q6$<.AB B CsX:B<B BB 4B5B B<B B B9B4.B9/B<4B99B<r z1.0.0)r_versiontools)rclaude_agent_sdkrrr7)rrrrrr rrs @@r build_serverr(s<< . ;=? @ A A @ A . F 3-  AA  A  %(4S&#&F H C C H C  %'-sm5 C C5 C ! >J r)NN)N)/__doc__ __future__rrurrr urllib.errorrF urllib.parseurllib.requestrpathlibr voice.eventsr__file__resolver_PROJECTrrr7rrdhomerrhr-r4rVrjrzr frozensetrrrrrrrrrrrrrrrrsF6#   > ! ! # * * 1 12::>>,"%hoo&>"?AB (. 9 RZZ^^ i"77(BYNOQ R)  . J( @6 I K#$2 ("&0    $Lr