#/in dZddlZddlZddlZddlmZddlmZejeZ edZ e dz Z e dz Z e dz Z dad Zd ed ed efd ZdedefdZdedededefdZddedefdZy)a7 Handoff MCP Tools ================== Structured auto-handoff when an agent finishes a block of work. Enables seamless context transfer between Claude and Antigravity agents. Tools: - handoff_push: Write structured handoff + publish event - handoff_pull: Read latest handoff(s) + recent events since last sync N)datetime)Pathz+/mnt/e/genesis-system/data/antigravity-synchandoffsz events.jsonlzcurrent_state.jsoncvt{ tjjddtjjddddlm}ddlm}||jdatjtStS#t$r'}tjd |Yd}~tSd}~wwxYw) zLazy load AgentBus.Nrz/mnt/e/genesis-systemz)/mnt/e/genesis-system/data/genesis-memory)AgentBus) AgentTypeF) agent_type enable_auditz#AgentBus unavailable for handoffs: ) _agent_bussyspathinsertAIVA.agents.agent_busrAIVA.agents.message_schemasrCLAUDEconnect Exceptionloggerwarning)rres 5/mnt/e/genesis-system/genesis_v2/mcp/handoff_tools.py_get_agent_busrs F HHOOA6 7 HHOOAJ K 6 =!Y-=-=ERJ     : F NN@D E E  FsA4B B8B33B8source event_typedatac tjj|||d}tjj ddt td5}|jtj|dzdddy#1swYyxYw#t$r"}tjd|Yd}~yd}~wwxYw)zAppend event to events.jsonl.) timestamprtyperTparentsexist_oka NzFailed to log event: ) rutcnow isoformat EVENTS_FILEparentmkdiropenwritejsondumpsrrerror)rrreventfrs r _log_eventr0.s 2!*446      = +s # .q GGDJJu%, - . . . 2 ,QC0112s6AB(B B BBB C B==Cagenthandoff_summaryc6 i}tjr.ttd5}tj|}dddt j j|d<d|vri|d<||ddt j jd|dd<ttd5}tj||d dddy#1swYxYw#1swYyxYw#t$r"}tjd |Yd}~yd}~wwxYw) z3Update current_state.json with latest handoff info.rN last_updated coordinationi)r1summaryr last_handoffwindentz Failed to update current state: ) STATE_FILEexistsr)r+loadrr$r%dumprrr-)r1r2stater/rs r_update_current_staterB>s=    j#& %! !  %!) 1 ; ; =n  &$&E. !&t,!*4461 nn- *c " *a IIeQq ) * * % % * * = 7s;<<=sL&C-CA5C-3C! C-CC-!C*&C-*C-- D6DDr7files_changed_jsonnext_actions_jsonreturnc  |rtj|ng} |rtj|ng}d}tjj }||||gg|dddd}t jddt d|dz }t |d |jd d dz } t|d 5} tj|| d dddt| d 5} tj|| d dddt} | rL ddlm} m}| |j$dd||ddt'|t'|dd}| j)d|t-||t/|d|ddt'|t'|dtj0|d |dt3|t'|t'|dS#tj$rg}YwxYw#tj$rg}YwxYw#1swY4xYw#1swYxYw#t$r#} tjd| Yd} ~ >d} ~ wwxYw#t$r#} tj+d| Yd} ~ d} ~ wwxYw)aG Push a structured handoff when an agent finishes a block of work. Args: summary: What was done (text description) files_changed_json: JSON array of file paths that were changed next_actions_json: JSON array of recommended next actions Returns: JSON with handoff ID and status claudeN) session_id token_usage)r1rr7 files_changedtasks_completed tasks_created next_actionscontext_snapshotTrLATEST_.json_:-r9r:r;zFailed to write handoff file: r) EventMessagerz aiva:eventshandoff_pushed)r1r7 files_count actions_countinfo)senderchannelrpayloadseverityzRedis handoff event failed: )r7rJrMpushed) handoff_idstatusfilerJrM)r+loadsJSONDecodeErrorrr$r% HANDOFFS_DIRr(replacer)r@rrr-rrrTrrlenpublishdebugrBr0r,str)r7rCrDrJrMr1nowhandoff latest_file archive_filer/rbusrTrmsgs r handoff_pushrpVs:L #56RT 8Itzz"34r  E //  % % 'C&$  Gtd375'!77KUG1S[[c-B,C5"IIL; +s # ,q IIgq + , , $ , IIgq + ,  C  = K ''%+"&t}#&}#5%(%6    C KK s + %)u&4C=]+L)) ::q&K ]+L)  K        4 , , , , ; 5aS9::;* = LL7s; < < =sG G&+ H7HH$H=HA I G#"G#&G?>G?H HHH I%II I7I22I7cg}tjdd|r|g}nddg}|D]\}td|dz }|js! t|d5}t j |}|j |ddd^g}t|xsdd z } d} | jr< t| d5}t j |} | jd } dddtjr ttd5}|D]e} | j} | s t j| } | r'| jd d| kDr#|j | n|j | g ddd|dd}t!j"j%} | j&jddt| d5}t j(d |i|dddt j*||t-||| dS#1swYxYw#t$r&}tjd |d |Yd}~%d}~wwxYw#1swYxxYw#t$rYwxYw#tj$rYywxYw#1swYxYw#t$r#}tjd|Yd}~@d}~wwxYw#1swYxYw#t$r#}tjd|Yd}~ d}~wwxYw)a Pull latest handoff(s) and recent events since last sync. Args: agent: Filter by agent name (empty = all agents). Common values: "claude", "antigravity" Returns: JSON with latest handoffs, recent events, and sync timestamp TrrG antigravityrOrPr4NzFailed to read handoff for z: z_last_sync.json last_syncrzFailed to read events: ir9z!Failed to update sync timestamp: )r recent_events events_count synced_atrs)rdr(r>r)r+r?appendrrr-SYNC_DIRgetr&striprbrcrr$r%r'r@r,rf)r1ragents_to_checkr"rlr/ handoff_datarru sync_filers sync_dataliner.rjs r handoff_pullrsHtd3  '#]3 E"wqc%77     E+s+2q#'99Qtd; )S ! -Q II{C(! , - ::&M*  e22 E :1#RsCDD E 7 7   " //! ! ! ! 8 LL21#6 7 7 8 - - > 8<==>s H!'H;H!* I 6'II :J J $AI03J 6J&)KK(KH H!! I*I  III I-,I-0JJ JJ  JJ K J>>KK K K>K99K>)rt)__doc__r+r loggingrpathlibr getLogger__name__rryrdr&r=r rridictr0rBrprrrs     8 $ = >*$ ' , ,    2s 2 24 2 ==s=0Y#Y3Y3YSVYxPPSPr