OjHdZddlmZddlZddlZddlZddlZddlm Z ejjddjdZ ejjddZejjd d Zdd Zdd Zddd ZdddZddZddZddZdZy)uTasks & reminders — thin client to the shared Railway brain, with HUD cards. Jarvis can add/list/complete tasks and reminders; they live in the SAME Railway service as long-term memory (:Task nodes), so they SYNC across every device. Adding one also pops a card on the HUD (like the email/calendar confirm cards), and Ahmed can tick a task off there — the HUD writes control/card_action.json, the ControlWatcher marks it done on Railway and tells Jarvis. Jarvis (voice) -> task_add / task_list / task_done Ahmed (HUD) -> ticks a checkbox -> card_action.json {kind:"task", ...} Reuses MEMORY_API_URL / MEMORY_API_KEY (same service). MCP_TASKS=0 disables. Engine → HUD events (voice.events.emit): task_added {id, text, due} — one new task/reminder tasks {tasks:[{id,text,due,done}]} — full current list (panel refresh) task_done_evt {id} — a task was completed (remove from panel) ) annotationsN)emitMEMORY_API_URL/MEMORY_API_KEY MEMORY_GROUPahmedchtjjdddk(ryttS)N MCP_TASKS10F)osenvirongetbool_URLA/Users/ahmed/devFolder/Ultron/claude-voice/voice/tasks_control.pyenabledr!s& zz~~k3'3. :rcdd|dgiS)Ncontenttext)typerr)msgs r_textr's 56 77rc|#tj|jnd}tjj t |z||}tr|jddt|jddtjj||5}|j}|rtj|nicdddS#1swYyxYw)N)datamethod AuthorizationzBearer z Content-Typezapplication/json)timeout) jsondumpsencodeurllibrequestRequestr_KEY add_headerurlopenreadloads)r pathbodyr"rreqrraws r_reqr3+s(,(84::d  " " $dD .. 4 GC  '$(89NN>#56   W  5ffh"%tzz#2 6 5 5s #)CCctjjtt |j d}t dd|jdgS)N)group include_doneGETz/tasks?tasks)r&parse urlencode_GROUPstrlowerr3r)r6qss r fetch_tasksr?6sP   &14\1B1H1H1J!L MB ~ & * *7B 77rctjjdti}t dd|j dgS)z}Reminders whose time has passed and haven't been announced yet. The server marks each 'fired' so it's returned only once.r5r7z/reminders/due?due)r&r9r:r;r3r)r>s r fetch_duerB<s>   & 1 2B - . 2 25" ==rc tdty#t$r$}tdt |ddYd}~yd}~wwxYw)z1Push the current open task list to the HUD panel.r8r8z [tasks] panel refresh failed: Nd)rr? Exceptionprintr<)es r refresh_panelrICsCA WKM* A 0Q?@@As AAAcFtdd|tdtd|y)zEComplete a task on Railway; used by the ControlWatcher on a HUD tick.POSTz /task/done)idr5 task_done_evt)rLdone)r3r;r)task_ids r mark_donerPKs g?@W% rcddlddlm}m}|ddttddfd }|ddidfd }|d d d tidfd }|dd|||gS)Nr)toolcreate_sdk_mcp_servertask_adduKAdd a task or reminder to Ahmed's shared list (syncs to all his devices) and pop it on his HUD. Use for 'remind me to…', 'add a task', 'I need to…'. `due` = ISO local time (2026-07-08T17:00:00) for a timed reminder — he'll be told when it's due; omit for a plain to-do. Keep `text` short and imperative ('Call the supplier').)rrAc tKt|jddj}|s tdS |tdd}|jdrt|d|d<j t dd|d{}td |jd d||jdd j td{td ||jdrd |ddzSdzS777#t$r$}tdt|ddcYd}~Sd}~wwxYww)Nrrztask_add failed: no task text.jarvis)rr5sourcerArKz/task task_addedrL)rLrrAzAdded: z (reminder set for )ztask_add failed: ) r<rstriprr; to_threadr3rrIrF)argsrr/outrHasyncios rrTzbuild_server..task_addVs<488FB'(..09: : = 6XFDxx!$u+.U ))$FFC #''$"3$XXeR( *##M2 2 274&)#xx2$u+a@89 94689 9 G 3 =,SVDS\N;< < =sf7D8ADDA DD,D;D8<DD8DD D5D0*D5+D80D55D8 task_listzzList Ahmed's open tasks and reminders (also refreshes the HUD panel). Use for 'what are my tasks', 'what do I have to do'.c K jtd{}td||s tdSg}|D]Q}|j drd|dddj ddd nd }|j d |d |d |ddStdj|S7#t$r$}tdt|ddcYd}~Sd}~wwxYww)Nr8rDzNo open tasks.rAz (due T rYrz- rz [id rL] ztask_list failed: rZ) r\r?rrrreplaceappendjoinrFr<)r]r8linestrArHr_s rr`zbuild_server..task_listos >!++K88E  &-..EuuU| %" 5 5c# >?qA)+ r!F)SE$yBC5)* *9 >-c!fTcl^<= = >sOC B0B.B0C A1B0-C .B00 C9CCC CC  task_donezdMark a task/reminder complete by its id (from task_list). Ahmed can also tick it on the HUD himself.rLc0Kt|jddj}|s tdS j t |d{tdS7#t $r$}tdt|ddcYd}~Sd}~wwxYww)NrLrztask_done failed: no task id.z Marked done.ztask_done failed: rZ)r<rr[rr\rPrF)r]tidrHr_s rrlzbuild_server..task_dones$((4$%++-89 9 >##Is3 3 3( ( 4 >-c!fTcl^<= = >sF7BA&A$A&#B$A&& B/BB BBBr8z1.0.0)nameversiontools)r]dictreturnrr)r_claude_agent_sdkrRrSr<)rRrSrTr`rlr_s @r build_serverruRs< * K s # %=%=$ + IJLN >N > + -/3Sk;>;> ! gI. r)rsr)rr<rsrr)N)r r<r.r<r/z dict | Noner"int)F)r6rrs list[dict])rsrx)rsNone)rOr<rsr<)__doc__ __future__rr#r urllib.parser&urllib.request voice.eventsrrrrstriprr)r;rrr3r?rBrIrPrurrrrs$#  zz~~&+2237 zz~~&+  0 8.8 >A?r