feat: distributed hive mind with DHT sharding + improved eval recall (51.2% → ≥83.9%)

.claude/context/PROJECT.md

@@ -29,6 +29,7 @@ Development framework for Claude Code, GitHub Copilot CLI, and Microsoft Amplifi
 - **Language**: Python
 - **Language**: JavaScript/TypeScript
 - **Language**: Rust
+- **Language**: Go
 - **Framework**: [Main framework if applicable]
 - **Database**: [Database system if applicable]
 

.claude/tools/amplihack/hooks/agent_memory_hook.py

@@ -112,7 +112,7 @@ async def inject_memory_for_agents(
     try:
         # Import memory coordinator (lazy import to avoid startup overhead)
         from amplihack.memory.coordinator import MemoryCoordinator, RetrievalQuery
-        from amplihack.memory.types import MemoryType
+        from amplihack.memory.models import MemoryType
 
         # Initialize coordinator with session_id
         coordinator = MemoryCoordinator(session_id=session_id or "hook_session")
@@ -198,7 +198,7 @@ async def extract_learnings_from_conversation(
     try:
         # Import memory coordinator (lazy import)
         from amplihack.memory.coordinator import MemoryCoordinator, StorageRequest
-        from amplihack.memory.types import MemoryType
+        from amplihack.memory.models import MemoryType
 
         # Initialize coordinator with session_id
         coordinator = MemoryCoordinator(session_id=session_id or "hook_session")

.claude/tools/amplihack/hooks/session_stop.py

@@ -31,7 +31,7 @@ def main():
     try:
         # Import memory coordinator
         from amplihack.memory.coordinator import MemoryCoordinator
-        from amplihack.memory.types import MemoryType
+        from amplihack.memory.models import MemoryType
 
         # Get session context from environment or stdin
         session_context = json.loads(sys.stdin.read()) if not sys.stdin.isatty() else {}

amplifier-bundle/modules/hook-session-stop/amplifier_hook_session_stop/__init__.py

@@ -179,7 +179,7 @@ async def __call__(self, event: str, data: dict[str, Any]) -> HookResult | None:
                 coordinator = self._get_memory_coordinator(session_id)
                 if coordinator:
                     try:
-                        from amplihack.memory.types import MemoryType
+                        from amplihack.memory.models import MemoryType
 
                         # Store learning as SEMANTIC memory (reusable knowledge)
                         learning_content = f"Agent {agent_type}: {agent_output[:500]}"

amplifier-bundle/tools/amplihack/hooks/agent_memory_hook.py

@@ -112,7 +112,7 @@ async def inject_memory_for_agents(
     try:
         # Import memory coordinator (lazy import to avoid startup overhead)
         from amplihack.memory.coordinator import MemoryCoordinator, RetrievalQuery
-        from amplihack.memory.types import MemoryType
+        from amplihack.memory.models import MemoryType
 
         # Initialize coordinator with session_id
         coordinator = MemoryCoordinator(session_id=session_id or "hook_session")
@@ -187,7 +187,7 @@ async def extract_learnings_from_conversation(
     try:
         # Import memory coordinator (lazy import)
         from amplihack.memory.coordinator import MemoryCoordinator, StorageRequest
-        from amplihack.memory.types import MemoryType
+        from amplihack.memory.models import MemoryType
 
         # Initialize coordinator with session_id
         coordinator = MemoryCoordinator(session_id=session_id or "hook_session")

amplifier-bundle/tools/amplihack/hooks/session_stop.py

@@ -31,7 +31,7 @@ def main():
     try:
         # Import memory coordinator
         from amplihack.memory.coordinator import MemoryCoordinator
-        from amplihack.memory.types import MemoryType
+        from amplihack.memory.models import MemoryType
 
         # Get session context from environment or stdin
         session_context = json.loads(sys.stdin.read()) if not sys.stdin.isatty() else {}

deploy/azure_hive/Dockerfile

@@ -0,0 +1,35 @@
+FROM python:3.11-slim
+
+WORKDIR /app
+
+# System dependencies
+RUN apt-get update && apt-get install -y --no-install-recommends \
+    curl git build-essential ca-certificates \
+    && rm -rf /var/lib/apt/lists/*
+
+# Copy full source tree and install from source so agents/ is included
+COPY . /build
+RUN cd /build && pip install --no-cache-dir . && \
+    pip install --no-cache-dir kuzu && \
+    pip install --no-cache-dir sentence-transformers && \
+    pip install --no-cache-dir azure-servicebus redis pyyaml
+
+# Create non-root user (security best practice for Container Apps)
+RUN useradd -m -s /bin/bash amplihack-agent \
+    && mkdir -p /data \
+    && chown -R amplihack-agent:amplihack-agent /app /data
+
+# Copy entrypoint
+COPY deploy/azure_hive/agent_entrypoint.py /app/agent_entrypoint.py
+
+USER amplihack-agent
+ENV HOME=/home/amplihack-agent
+
+# Data directory for Kuzu persistence (mounted as Azure File Share)
+VOLUME ["/data"]
+
+# Health check via process existence
+HEALTHCHECK --interval=30s --timeout=10s --start-period=30s --retries=3 \
+    CMD python3 -c "import os, sys; sys.exit(0 if os.path.exists('/tmp/.agent_ready') else 1)"
+
+CMD ["python3", "/app/agent_entrypoint.py"]