oi 'FdZddlmZddlZddlmZddlmZddlmZm Z ddl m Z m Z ddl mZmZmZmZdd lmZer dd lmZdd lmZd d ddddZd7dZd8dZedfd9d Zedfd:d#Z d;dd6Z dS)?z=Meeting event loop - orchestrates the multi-agent discussion.) annotationsN)datetime)Path) TYPE_CHECKINGCallable)format_scratchpad_summary run_agent) AgentConfig MeetingResult MeetingStateScratchpadEntry)run_pm)ContextManager) LLMClientzzzzz)pmagentsystemhumanresetlabelstrmessage color_keyreturnNonec t|d}td}t|d|d|d|dS)z(Print a colored message to the terminal.r[] N)_COLORSgetprint)rrrcolorrs 2/root/projects/multi-agents-meeting/src/meeting.py_print_coloredr&sQ KK 2 & &E G E U . .U . .U . .W . ./////textctjdd|}tjdd|}|dddS)z%Convert text to a filename-safe slug.z[^\w\s-]rz[\s_]+-N2)resublowerstrip)r(slugs r%_slugifyr1"sJ 6+r4::<< 0 0D 6)S$ ' 'D 9??3  r'reportsreporttopic output_dirrc|ddtjd}t |}|d|d}||z }||d|S)aSave meeting report as a Markdown file. Args: report: The Markdown report content to save. topic: The meeting topic used to name the file. output_dir: Directory where the report file is written. Returns: The Path to the saved report file. Tparentsexist_ok %Y%m%d-%H%M%Sr*z.mdutf-8encoding)mkdirrnowstrftimer1 write_text)r3r4r5 timestampr0filenamepaths r% save_reportrE)s|TD111 ''88I E??D''d'''H  DOOFWO--- Kr'resultr c|ddtjd}t |j}|d|d}||z }d|jdg}|jr|d|jd|jD]<}|d |j ||j d=| d |d |S) zSave meeting transcript as a Markdown file. Args: result: The complete MeetingResult with transcript data. output_dir: Directory where the transcript file is written. Returns: The Path to the saved transcript file. Tr7r:r*z.transcript.mdu# 会议讨论记录： u ## 背景 u ### 💬 r;r<) r>rr?r@r1r4contextappend transcript agent_namecontentrAjoin)rFr5rBr0rCrDlinesentrys r%save_transcriptrQ=sTD111 ''88I FL ! !D22d222H  DB&,BBBCE ~9 7V^777888"++ 3!133444  )))****OODIIe$$wO777 Kr'stater agent_configsdict[str, AgentConfig]clientrcontext_managerContextManager | None str | Nonec|j|jkr|xjdz c_tdd|jd|jdd|j|jkr=tddt j}|j|t|||| }td d |j d |j d kr(td dd t|j pdS|j }||}td d|d|jd |||||j|}nt!|j}t#||j||} t|| dtt|| t j} |j| |j|jkdS)aExecute one meeting loop until PM finishes or max_rounds reached. Args: state: The current MeetingState (modified in place). agent_configs: Map of agent name to AgentConfig. client: LLM client for PM and agents. context_manager: Optional ContextManager for whiteboard compression. Returns: The final report string if PM finished, or None if max_rounds reached. SYSTEMz --- Round /z ---rzRMAX ROUNDS REACHED. You MUST set next_action to FINISH and provide a final_report.rLrMrBrVPMz Analysis: rFINISHzMeeting concluded.&# Meeting Report No report generated.zCalling z: N)rR target_agent pm_promptrU)configpromptscratchpad_summaryrUr) current_round max_roundsr&r rr? scratchpadrJranalysis next_actionr# final_reportrbprompt_for_agentbuild_agent_contextrr upper) rRrSrUrV force_entrydecision target_name target_configrfagent_responserPs r%_run_meeting_loopruYs4"   0 0 0 q x!Ze.A!Z!ZEDT!Z!Z!Z\deee  %"2 2 2)#l",..K   # #K 0 0 0%XXXt=(*;==tDDD  8 + + 4!5t < < < GGG(V,V V+ %k2 tR RRx7PRRTXYYY  &!0!D!D("3 "E""  ";5;K!L!L " ,1     {((**NGDDD ""lnn    &&&a   0 0 0d 4r' rrhintrIc tj}t|||}||r||||_t dd|dt ddd|dtt||||} | d } t||t|t|j | |tj S) arExecute the full meeting loop. Args: topic: The discussion topic for the meeting. agent_configs: Map of agent name to AgentConfig for all participants. client: LLM client used by both PM and agents. max_rounds: Maximum number of PM decision rounds before forcing a finish. output_dir: Directory to save the final report (unused here; caller may use). context: Background context for the discussion. context_manager: Optional ContextManager for whiteboard compression. Returns: A MeetingResult containing the final report, transcript, and metadata. r4rhrINr[zMeeting started: rParticipants: , r^zK# Meeting Report Meeting ended after maximum rounds without PM conclusion.r4rI participantsrKrl started_at finished_at) rr?r summarize_contextcontext_summaryr&rNkeysr#rur listri) r4rSrUrhr5rIrVr~rRr3s r% run_meetingrs.J uW M M ME"w" / A A'6 R R8888(CCC8Odii 8J8J8L8L.M.MOOQYZZZ GGG umV_ ] ] ]F ~` -,,..//())LNN   r'input_fnCallable[[str], str]c tj}t|||} ||r|||| _t dd|dt ddd|dtd} t| ||| } | | } td d t| td d |d } | snztd| tj} | j | t d| dd| _t||t!|t!| j | |tjS)aPExecute an interactive meeting with human-in-the-loop feedback. Runs the meeting loop, then prompts the user for feedback. If feedback is provided, it is appended to the scratchpad and the loop continues. Args: topic: The discussion topic for the meeting. context: Background context for the discussion. agent_configs: Map of agent name to AgentConfig for all participants. client: LLM client used by both PM and agents. max_rounds: Maximum number of PM decision rounds per loop iteration. output_dir: Directory to save the final report. input_fn: Callable for getting user input (injected for testing). context_manager: Optional ContextManager for whiteboard compression. Returns: A MeetingResult containing the final report, transcript, and metadata. ryNr[zInteractive meeting started: rrzr{raTr^rHz<============================================================u1 💬 有补充内容吗？(直接回车结束): HUMANr]rrr|)rr?r rrr&rNrr#rur/r rirJrgr r)r4rIrSrUrhr5rrVr~rRr3 loop_report user_input human_entrys r%run_meeting_interactivers8J uW M M ME"w" / A A'6 R R8DUDDhOOO8Odii 8J8J8L8L.M.MOOQYZZZ GGG 7F '}fVefff  " F o8oo f  oooXRSS !!  &$$&&lnn    ,,,w 0 0 2 2G<<< / 2 -,,..//())LNN   r')rrrrrrrr)r(rrr)r3rr4rr5rrr)rFr r5rrr)N) rRr rSrTrUrrVrWrrX)r4rrSrTrUrrhrwr5rrIrrVrWrr )r4rrIrrSrTrUrrhrwr5rrrrVrWrr )!__doc__ __future__rr,rpathlibrtypingrr src.agentrr src.modelsr r r r src.pmrsrc.context_managerrsrc.llm_clientrr!r&r1rErQrurinputrr'r%rsCC"""""" ********::::::::PPPPPPPPPPPP)222222((((((       0000    =ADOO(?Cd9oo@.2 CCCCCTtI-1/////ntI%*-1JJJJJJJr'