(self, prompt, speech_module)
| 53 | return prompt |
| 54 | |
| 55 | async def process(self, prompt, speech_module) -> str: |
| 56 | if self.enabled == False: |
| 57 | return "MCP Agent is disabled." |
| 58 | prompt = self.expand_prompt(prompt) |
| 59 | self.memory.push('user', prompt) |
| 60 | working = True |
| 61 | while working == True: |
| 62 | animate_thinking("Thinking...", color="status") |
| 63 | answer, reasoning = await self.llm_request() |
| 64 | exec_success, _ = self.execute_modules(answer) |
| 65 | answer = self.remove_blocks(answer) |
| 66 | self.last_answer = answer |
| 67 | self.status_message = "Ready" |
| 68 | if len(self.blocks_result) == 0: |
| 69 | working = False |
| 70 | return answer, reasoning |
| 71 | |
| 72 | if __name__ == "__main__": |
| 73 | pass |
nothing calls this directly
no test coverage detected