iA `ddlZddlZejjejjejjeZejj dejjedejj deddlZddl m Z ddl m Z ddl mZddlZddlmZddlmZddlmZdd lmZej4d d d d Ze Zej;dej<fdZejAdZ!ejAdZ"ejAdZ#ejAdZ$ejAejJddejLdddejLdddejLdddd ejLd!d"d#fd$e'd%e'd&e'd'e'd(e'f d)Z(ejAejJd*d+ejLdd,d-ejLdd.d/ejLdddejLd0d1d2fd$e'd3e'd4e'd%e'd5e'f d6ZejAd7Z)ejAd8Z*e+d9k(reyy):Nlib)Console)Panel)Table)Path)Config)tracker)memorygenesis2⚡ Genesis System V2: Alpha Evolve Powerhouse CLIFT)namehelpadd_completioninvoke_without_commandctxc2|j tyy)r N)invoked_subcommandchat)rs ,/mnt/e/genesis-system/genesis_v2/cli/main.pymainrs % &ctdd}|jdd|jdd |jd d |jd d d|jddd|jddd|jdddtj}|jdd|dddt j t|ddy) uD 🔍 Display multi-layer system health (Core, MCP, Swarm). zGenesis System HealthNtitlebox Component bold cyanstyleStatusrightjustifyzLatency/Detailsdimz Core Enginez[bold green]ONLINE[/bold green]12mszSovereign Memoryz[bold green]LIVE[/bold green]z152.53.201.221:8001/mcpz MCP Toolsz[bold green]SYNCED[/bold green]z 5/5 Shimmedz Revenue APIz"[bold green]CONNECTED[/bold green]zGHL V2z Session Costz[bold magenta]sessionz[/bold magenta]z Gemini Flashcyanz&[bold cyan]MISSION CONTROL[/bold cyan] border_styler)r add_columnadd_row cost_tracker get_summaryconsoleprintr)tablecostss rstatusr2%s /T :E [ 4 Xw/ &e4 MM-!BFK MM$&EG`a MM+@-P MM-!ExP  $ $ &E MM.N53C2DO"TVde MM%F:bcdrc*tj}tdd}|jdd|jddd |j d |d |j d |dt j t|d dy)u) 💸 Track API usage and costs. zAPI Cost Tracker (Gemini Flash)NrMetricboldrAmountr!green)r#rzCurrent Sessionr&zTotal Lifetimetotalz$[bold green]REVENUE OPS[/bold green]r()r,r-rr*r+r.r/r)r1r0s rcostr9;s  $ $ &E 9t DE XV, Xwg> MM#U9%56 MM"E'N3 MM%G;abcrctdtdttjjjjdz dz dz g}d}|D]}|js|}n|rkt j |j }tjd|jdd tjd |jd d d tdd}|jdd|jd|jdijD]5\}}|j|jddj|7tj|tjd|jdijD] \}}tjd|d|"ytjdy)u7 👥 Display Active Agent Teams Architecture. zHE:/genesis-system/KNOWLEDGE_GRAPH/entities/agent_teams_architecture.jsonzL/mnt/e/genesis-system/KNOWLEDGE_GRAPH/entities/agent_teams_architecture.jsonKNOWLEDGE_GRAPHentitieszagent_teams_architecture.jsonNz"[bold]Active Architecture:[/bold] r Unknownz[dim]Pattern: genesis_mappingN/Az[/dim] z Agent RolesrRolerr Description components_ z [bold]Model Mapping:[/bold]model_selectionz - [cyan]z [/cyan]: zA[red]Agent Teams Architecture NOT FOUND in Knowledge Graph.[/red])r__file__parentexistsjsonloads read_textr.r/getrr*itemsr+replacer)possible_pathskg_pathpdatar0roledescmodels rteamsrVKs WX [\ X$$++225FFSVuuN G  88:G  zz'++-. :488FI;V:WXY txx0A5'I&J(STMt4 {3 '((<4::< @JD$ MM$,,sC0668$ ? @  e  5688$5r:@@B ?KD% MMJtfIeW= > ?  YZrctjd tjj t ddd}t jjd|ddlm }tjj t dd}|| }|j}|jd g}td |Dd }d}d }d} |rd|d} |d} |j| dd} | jdg} t| }| D]$} | jd}|s|t|z }&t!d| }|j#dd|j#dd|j%dd|d |j%d!d"|d#d$|j%d%d&tj|y #t&$r|}tjd'|d(t!d)}|j#dd|j#dd|j%d*d+tj|Yd }~y d }~wwxYw),uH 💰 Real-time audit of the CreatorDashboard Premium Pipeline. z>[yellow]Auditing CreatorDashboard Premium Pipeline...[/yellow]planscreatordashboardscriptsr) load_clientconfigzcreatordashboard_ghl.env)env_path pipelinesc3JK|]}d|jddvs|yw)zCreator Partnerr N)rL).0rQs r zrevenue..s$[!4EvWYIZ4ZA##Ngz Not Foundr idopend) pipeline_idr2limit opportunities monetaryValuezRevenue Snapshot: rr4r5rValuer!r"zActive Partnersz [bold cyan]z [/bold cyan]z Pending ROIz [bold green]$z,.2fz [/bold green]zStripe Bondingz[bold green]ACTIVE[/bold green]zed]Revenue Audit Failed: [/red]zRevenue Snapshot: Errorr zed]CONNECTION ERROR[/red])r.r/ospathjoinroot_dirsysinsert ghl_v2_clientr[list_pipelinesrLnextlist_opportunitieslenfloatrr*r+ Exception)ghl_pathr[r]clientpipelines_respr^ target_pipeactive_partners pending_roi pipe_namepipe_id opps_respoppsoppvalr0es rrevenuerus#  MMRS677<<'3EyQ 8$-77<<(4NOh/ ..0"&&{B7 []ab   #F+I!$'G11gf\_1`I=="5D!$iO .ggo.5:-K . 0 <= 0 '2 ';6G|)TU m}[4Fm%TU &(IJ e  3A3f=>56 0 '2 h => es D F<"BF<< IA2H<<Ilistz!Action: list, spawn, kill, attach)rz--namez-nzkimi/kimi-2.5-flashz--modelz-m openrouterz --providerz-pzProvider: google, openrouterr`z --missionz-missactionr rUprovidermissionc tjjtdd}tjj d|ddlm}ddl}|dk(r,|j}|s"tjtddd ytd } | jd d| jdd| jd| jd| jdd|D]v} | j| d| jdd| d| dt!| jdddkDr| jdddddzn| jddxtj| y|dk(r|stjd y |j#||||d!"} tjd#|d$tjd%|d&|d'|rtjd(|d'yy|d+k(r]|stjd,y|j'|rtjd#|d-ytjd.|d/y|d0k(rG|stjd1ytjd2|d3|j)d4d5d6|gytjd7|d8y#t$$r#} tjd)| d*Yd} ~ yd} ~ wwxYw)9uP 🐝 List and monitor active Gemini/Kimi swarms with tmux persistence. genesis_v2corer)swarmNrz%[dim]No active swarms detected.[/dim]z Swarm Monitormagentarr)zActive Swarm NodesrjNamerrTyper$Modelr Missionitalicr typeapirUr2rr`2...spawnz+[red]Error: --name required for spawn[/red]T)ruse_tmuxz[green]Swarm Node 'z'' spawned successfully in tmux.[/green]z [dim]Model: z | Provider: [/dim]z[dim]Mission: z[red]Spawn Failed: rlkillz*[red]Error: --name required for kill[/red]z' killed.[/green]z [red]Failed to kill Swarm Node 'z'.[/red]attachz,[red]Error: --name required for attach[/red]z[yellow]Attaching to session 'z#'... (Ctrl+B, D to detach)[/yellow]tmuxzattach-session-tz [red]Action 'z' not implemented.[/red])rmrnrorprqrrr subprocess list_nodesr.r/rrr*r+rLrw spawn_nodery kill_noderun) rr rUrr swarm_path swarm_managerrnodesr0noders rrrsh f=JHHOOAz", ((* MM% Gmvw x 45E   V;  7   V5  1   W %   X &   Yh  7  LHHVU+MN? 6  MMF G   " "4 ( MM/v5FG H MM  fX-EFG) ; MM/s&9 : : ;s A&K K<K77K<healthz"Action: health, save, search, listz--queryz-qz--textrz genesis-kinanz--groupz-gquerytextgroupc |dk(rtjdtj}d|vrtjd|ddy tjdtjdt j |d d y |d k(r|stjd y tjd|dtj |||}d|vrtjd|ddy tjdtjd|jddd y |dk(r;|stjdy tjd|dtj||}|stjdy td|d}|jdd |jd!|jd"|D]{} |j| jd#d$| jd%d&t| jd'd(d)kDr| jd'd(d d)d*zn| jd'd(}tj|y |d+k(rtjd,|dtj|} | stjd-y td.|d}|jd/d |jd0|jd1| D]H} |j| jd#d| jd2d| jd3d(d d)Jtj|y y )4u= 🧠 Interact with Sovereign Memory (Graphiti MCP). rz4[yellow]Checking Sovereign Memory health...[/yellow]errorz[red]Memory Offline: rlz[green]Memory Online![/green][dim])indentrsavez*[red]Error: --text required for save[/red]Nz [yellow]Saving memory to group 'z '...[/yellow])group_idr z[red]Save failed: z)[green]Memory saved successfully.[/green]z[dim]Episode ID: uuidr?searchz-[red]Error: --query required for search[/red]z[yellow]Searching memory for: ')rz&[dim]No matching memories found.[/dim]zMemory Search Results ()rjEntityrrrSummaryr r=rNodesummaryr`rerrz,[yellow]Fetching recent episodes for group 'z$[dim]No recent episodes found.[/dim]zRecent Episodes (rz Created AtSnippets created_at body_snippet)r.r/ memory_bridgerrIdumpsrrLrrr*r+rw get_episodes) rrrr rr2resultrr0repisodeseps rr r s LM%%' f  MM1&/1B&I J MM9 ; MME$**VA">!?vF G 6  MMF G  8}MN##D5tD f  ]]/w/@G H ]]F H ]].vzz&%/H.IP Q 8  MMI J  7wmLM$$UU; MMB C"9% BCE   X[  9   V $   Y '  HHVY/HHVV,=@)UWAX=Y\_=_DHHY+DS1E9eiememnwy{e|  MM% 6  DUG=YZ --u= ]]A B"3E7! <=E   V;  7   \ *   Z (  FF65)FF</FF>2.t4  MM% # rc tj}d|vr2tjdtjd|ddy|j di}tjdtjd|j dd d |j d d dtjd y)u7 🔄 Quick health check for Sovereign Memory. rz([red]Sovereign Memory Unreachable.[/red]rr serverInfoz*[green]Sovereign Memory Connected![/green]z [dim]Server: r r=z vversion?u0[green]Sync OK — MCP endpoint healthy.[/green]N)rrr.r/rL)r2 server_infos rsyncrBs  ! ! #F& @B fWo.f56jjr2  BD koofi&H%IKOO\egjLkKllrst HIrcddlm}|tjd<tj t jddd ddlm }tj d d |}|jr5|jjrt|jjnd}tj d |d tj  tjdj}|s(|j!dvrtj dy|j!dk(rt#tj |j!dk(r t%dtj |j!dk(r"tj t ddd|rAtj d |j'|}tj d|dntj d!C#t$r;}tj d|dtj dd}Yd}~d}~wwxYw#t$r#}tj d|d Yd}~pd}~wwxYw#t($rtj d"Yyt*$rYywxYw)#uQ 💬 Interactive agent — talk naturally and get stuff done (default). r) get_api_keyGOOGLE_API_KEYu[bold cyan]⚡ GENESIS COMMAND CENTRE ⚡[/bold cyan] [dim]Gemini 3 Flash · 18 MCP Tools · Sovereign Memory[/dim] [dim]Type naturally. I'll handle it.[/dim] [bold green]Ready for action.[/bold green] [dim](type 'status' · 'memory' · 'help' · 'quit')[/dim]z#[bold white]GENESIS V2[/bold white] bright_cyanr) create_agentz&[yellow]Initializing agent...[/yellow]rD)endu*[bold green]✅ Online[/bold green] [dim](z tools loaded)[/dim]z [red]Agent init failed: rlz/[dim]Falling back to direct model chat...[/dim]Nz[bold cyan]You:[/bold cyan] )quitexitqu[dim]Goodbye! ⚡[/dim]r2r rru[[bold]Built-in Commands:[/bold] [cyan]status[/cyan] — System health check [cyan]memory[/cyan] — Sovereign memory health [cyan]help[/cyan] — This help [cyan]quit[/cyan] — Exit [bold]Or just type naturally:[/bold] "Search memory for Sunaiva pricing" "What tools do you have?" "Save this fact: Kinan uses Vapi for MVPs"Helpr$z[dim]Thinking...[/dim]z# [bold green]Genesis:[/bold green]  z [red]Error: z[/red] zA[red]Agent not available. Use 'genesis status' to diagnose.[/red]u% [dim]Interrupted. Goodbye! ⚡[/dim])genesis_v2.core.configrrmenvironr.r/rfitgenesis_v2.agentr_agenttoolsrwryinputstriplowerr2r chat_syncKeyboardInterruptEOFError)rragent tool_countr user_inputresponses rrrRsQ 3#.=BJJ  MM%)) E 4" 1 >C H05 ASASS++,YZ  B:,Nbcd  MMO 3  'EFLLNJ!%:: 78!X- !X-x  !V+ eC!!&   67@$z:HMM$H RT"UV ab]   21#V<= GHd!@MMN1#X">??@ !  MMB C    sy BH#!%J'J/1J!2J4J J!*I* J# I',0I""I'* J3J JJJK9KK__main__),rmrqrndirnamerFrprrrotyper rich.consoler rich.panelr rich.tablerrIpathlibrrrgenesis_v2.core.costr r,genesis_v2.core.memory_bridger rTyperappr.callbackContextrcommandr2r9rVrArgumentOptionstrrrr__name__rrrs  77??277??277??8+DE F277<<%018  *8Aekk  =  )emm ee* d d'['[R<<|&v4WX"ell448#u||$99dK&%,,|\4Nlm%b+w? BH#BHBHBHBH BHBHH %..0TUdIt4 T8T2 T8T2oy$? F! F! F! F!  F!  F!F!P J JSSl zEr