(self)
| 28 | self.handler.state.start_precheck_step(self.STEP_NAME) |
| 29 | |
| 30 | async def do(self): |
| 31 | if not CONFIG.is_memory_enabled(): |
| 32 | await self.handler.state.precheck_step_done(self.STEP_NAME) |
| 33 | logger.info("Memory is disabled in config, skipping") |
| 34 | return |
| 35 | response = await self.run_prompt(self.MEMORY_PROMPT_NAME, level="high") |
| 36 | if (not response): |
| 37 | logger.warning("No response from DetectMemoryRequestPrompt, skipping memory step") |
| 38 | await self.handler.state.precheck_step_done(self.STEP_NAME) |
| 39 | return |
| 40 | self.is_memory_request = response["is_memory_request"] |
| 41 | self.memory_request = response["memory_request"] |
| 42 | if (self.is_memory_request == "True"): |
| 43 | # this is where we would write to a database |
| 44 | logger.debug(f"writing memory request: {self.memory_request}") |
| 45 | message = {"message_type": "remember", "item_to_remember": self.memory_request, "content": "I'll remember that"} |
| 46 | asyncio.create_task(self.handler.send_message(message)) |
| 47 | else: |
| 48 | logger.info("Memory not required") |
| 49 | await self.handler.state.precheck_step_done(self.STEP_NAME) |
nothing calls this directly
no test coverage detected