Merge branch 'dev-20260302-v2.0.8' into fix/unicode-sanitization-embedders

Author: endxxxx

README.md

@@ -64,6 +64,17 @@ Get Free API: [Try API](https://memos-dashboard.openmem.net/quickstart/?source=g
 
 <br>
 
+## 🦞 Enhanced OpenClaw with MemOS Plugin
+![](https://cdn.memtensor.com.cn/img/1770612303123_mnaisk_compressed.png)
+
+- [**72% lower token usage**](https://x.com/MemOS_dev/status/2020854044583924111) – intelligent memory retrieval instead of loading full chat history
+- [**Multi-agent memory sharing**](https://x.com/MemOS_dev/status/2020538135487062094) – multi-instance agents share memory via same user_id. Automatic context handoff.  
+
+🦞 Your lobster now has a working memory system.
+
+Get your API key: [MemOS Dashboard](https://memos-dashboard.openmem.net/cn/login/)  
+Try it: Full tutorial → [MemOS-Cloud-OpenClaw-Plugin](https://github.com/MemTensor/MemOS-Cloud-OpenClaw-Plugin)
+
 ## 📌 MemOS: Memory Operating System for AI Agents
 
 **MemOS** is a Memory Operating System for LLMs and AI agents that unifies **store / retrieve / manage** for long-term memory, enabling **context-aware and personalized** interactions with **KB**, **multi-modal**, **tool memory**, and **enterprise-grade** optimizations built in.

docker/Dockerfile.krolik

@@ -0,0 +1,65 @@
+# MemOS with Krolik Security Extensions
+# 
+# This Dockerfile builds MemOS with authentication, rate limiting, and admin API.
+# It uses the overlay pattern to keep customizations separate from base code.
+
+FROM python:3.11-slim
+
+# Install system dependencies
+RUN apt-get update && apt-get install -y --no-install-recommends \
+    gcc \
+    g++ \
+    build-essential \
+    libffi-dev \
+    python3-dev \
+    curl \
+    libpq-dev \
+    && rm -rf /var/lib/apt/lists/*
+
+# Create non-root user
+RUN groupadd -r memos && useradd -r -g memos -u 1000 memos
+
+WORKDIR /app
+
+# Use official Hugging Face
+ENV HF_ENDPOINT=https://huggingface.co
+
+# Copy base MemOS source
+COPY src/ ./src/
+COPY pyproject.toml ./
+
+# Install base dependencies
+RUN pip install --upgrade pip && \
+    pip install --no-cache-dir poetry && \
+    poetry config virtualenvs.create false && \
+    poetry install --no-dev --extras "tree-mem mem-scheduler"
+
+# Install additional dependencies for Krolik
+RUN pip install --no-cache-dir \
+    sentence-transformers \
+    torch \
+    transformers \
+    psycopg2-binary \
+    redis
+
+# Apply Krolik overlay (AFTER base install to allow easy updates)
+COPY overlays/krolik/ ./src/memos/
+
+# Create data directory
+RUN mkdir -p /data/memos && chown -R memos:memos /data/memos
+RUN chown -R memos:memos /app
+
+# Set Python path
+ENV PYTHONPATH=/app/src
+
+# Switch to non-root user
+USER memos
+
+EXPOSE 8000
+
+# Healthcheck
+HEALTHCHECK --interval=30s --timeout=10s --retries=3 --start-period=60s \
+    CMD curl -f http://localhost:8000/health || exit 1
+
+# Use extended entry point with security features
+CMD ["gunicorn", "memos.api.server_api_ext:app", "--preload", "-w", "2", "-k", "uvicorn.workers.UvicornWorker", "--bind", "0.0.0.0:8000", "--timeout", "120"]

examples/mem_agent/deepsearch_example.py

@@ -179,7 +179,7 @@ def factory_initialization() -> tuple[DeepSearchMemAgent, dict[str, Any]]:
 
 
 def main():
-    agent_factory, components_factory = factory_initialization()
+    agent_factory, _components_factory = factory_initialization()
     results = agent_factory.run(
         "Caroline met up with friends, family, and mentors in early July 2023.",
         user_id="locomo_exp_user_0_speaker_b_ct-1118",

examples/mem_scheduler/memos_w_scheduler.py

@@ -84,7 +84,9 @@ def init_task():
     return conversations, questions
 
 
-working_memories = []
+default_mem_update_handler = mem_scheduler.handlers.get(MEM_UPDATE_TASK_LABEL)
+if default_mem_update_handler is None:
+    logger.warning("Default MEM_UPDATE handler not found; custom handler will be a no-op.")
 
 
 # Define custom query handler function
@@ -100,24 +102,11 @@ def custom_query_handler(messages: list[ScheduleMessageItem]):
 
 # Define custom memory update handler function
 def custom_mem_update_handler(messages: list[ScheduleMessageItem]):
-    global working_memories
-    search_args = {}
-    top_k = 2
-    for msg in messages:
-        # Search for memories relevant to the current content in text memory (return top_k=2)
-        results = mem_scheduler.retriever.search(
-            query=msg.content,
-            user_id=msg.user_id,
-            mem_cube_id=msg.mem_cube_id,
-            mem_cube=mem_scheduler.current_mem_cube,
-            top_k=top_k,
-            method=mem_scheduler.search_method,
-            search_args=search_args,
-        )
-        working_memories.extend(results)
-        working_memories = working_memories[-5:]
-        for mem in results:
-            print(f"\n[scheduler] Retrieved memory: {mem.memory}")
+    if default_mem_update_handler is None:
+        logger.error("Default MEM_UPDATE handler missing; cannot process messages.")
+        return
+    # Delegate to the built-in handler to keep behavior aligned with scheduler refactor.
+    default_mem_update_handler(messages)
 
 
 async def run_with_scheduler():

examples/mem_scheduler/try_schedule_modules.py

@@ -167,7 +167,8 @@ def add_msgs(
             label=MEM_UPDATE_TASK_LABEL,
             content=query,
         )
-        # Run one session turn manually to get search candidates
-        mem_scheduler._memory_update_consumer(
-            messages=[message],
-        )
+        # Run one session turn manually via registered handler (public surface)
+        handler = mem_scheduler.handlers.get(MEM_UPDATE_TASK_LABEL)
+        if handler is None:
+            raise RuntimeError("MEM_UPDATE handler not registered on mem_scheduler.")
+        handler([message])

pyproject.toml

@@ -4,7 +4,7 @@
 ##############################################################################
 
 name = "MemoryOS"
-version = "2.0.4"
+version = "2.0.6"
 description = "Intelligence Begins with Memory"
 license = {text = "Apache-2.0"}
 readme = "README.md"

src/__init__.py

@@ -1,4 +1,4 @@
-__version__ = "2.0.4"
+__version__ = "2.0.6"
 
 from memos.configs.mem_cube import GeneralMemCubeConfig
 from memos.configs.mem_os import MOSConfig

src/memos/__init__.py

@@ -0,0 +1,13 @@
+# MemOS API
+
+## Default entry and deployment
+
+- Use **`server_api.py`** as the API service entry for **public open-source usage**.
+- You can deploy via **`docker/Dockerfile`**.
+
+The above is the default, general way to run and deploy the API.
+
+## Extensions and reference implementations
+
+- **`server_api_ext.py`** and **`Dockerfile.krolik`** are one developer’s extended API and deployment setup, **for reference only**. They are not yet integrated with cloud services and are still in testing.
+- If you need extensions or custom behavior, you can refer to these and use or adapt them as you like.