Method memorize

methods/amem_agent.py:249–300

Store text into A-Mem memory system. This method follows the official A-Mem implementation: 1. Split text into chunks if needed 2. Pass each chunk directly to add_note() for analysis and evolution 3. No additional preprocessing is applied

(self, text: str, **kwargs)

        return truncated + "\n... [truncated]"

    def memorize(self, text: str, **kwargs) -> MemoryBuildResult:
        """Store text into A-Mem memory system.

        This method follows the official A-Mem implementation:
        1. Split text into chunks if needed
        2. Pass each chunk directly to add_note() for analysis and evolution
        3. No additional preprocessing is applied
        """
        context_id = self._get_context_id()
        memory_system = self._get_memory_system(context_id)

        # Split text into chunks to avoid context length exceeded
        chunks = self._split_text_into_chunks(text, self.amem_chunk_size_tokens)
        logger.debug("Split input into %d chunks (chunk_size=%d tokens)", len(chunks), self.amem_chunk_size_tokens)

        note_ids = []
        memory_entries = []

        for i, chunk in enumerate(chunks):
            # Directly pass chunk to A-Mem add_note (following official implementation)
            # A-Mem internally performs: content analysis, metadata extraction, evolution
            note_id = memory_system.add_note(content=chunk)
            note_ids.append(str(note_id))
            self._memory_chunks.append(chunk)

            memory_entries.append({
                "event": "ADD",
                "memory": chunk[:400],
                "id": str(note_id),
                "chunk_index": i,
            })
            logger.debug("Added chunk %d/%d to A-Mem, note_id=%s", i + 1, len(chunks), note_id)

        self._is_initialized = True

        return MemoryBuildResult(
            success=True,
            method="amem",
            action="add_note",
            input_content=text,
            stored_content=text,
            memory_entries=memory_entries,
            all_passages=list(memory_entries),
            chunk_count=len(self._memory_chunks),
            extra={
                "context_id": context_id,
                "retrieve_num": self.retrieve_num,
                "chunks_created": len(chunks),
                "note_ids": note_ids,
                "inserted_count": len(note_ids),
            },
        )

    def query(
        self,