commit updates

agent/Dockerfile

@@ -0,0 +1,10 @@
+FROM python:3.11-slim
+
+WORKDIR /app
+
+COPY requirements.txt .
+RUN pip install --no-cache-dir -r requirements.txt
+
+COPY main.py .
+
+CMD ["python", "main.py"]

agent/main.py

@@ -0,0 +1,77 @@
+import os
+import time
+import json
+import requests
+from datetime import datetime
+
+MCP_URL = os.getenv("MCP_URL", "http://mcp:8000/mcp")
+API_KEY = os.getenv("MCP_API_KEY", "dev-key-123")
+POLL_INTERVAL = int(os.getenv("AGENT_POLL_INTERVAL", "30"))
+
+def call_mcp(tool, params=None):
+    response = requests.post(
+        MCP_URL,
+        headers={"X-API-Key": API_KEY, "Content-Type": "application/json"},
+        json={"tool": tool, "params": params or {}}
+    )
+    return response.json()
+
+def main():
+    print(f"[{datetime.now()}] Agent starting, polling every {POLL_INTERVAL}s")
+    
+    while True:
+        try:
+            # Get next instruction
+            result = call_mcp("get_next_instruction")
+            instruction = result.get("instruction")
+            
+            if instruction:
+                print(f"[{datetime.now()}] Found instruction: {instruction['id']}, type: {instruction['type']}")
+                
+                # Update status to executing
+                call_mcp("query_graph", {
+                    "query": "MATCH (i:Instruction {id: $id}) SET i.status = 'executing'",
+                    "parameters": {"id": instruction['id']}
+                })
+                
+                # Create dummy execution for now
+                exec_result = call_mcp("write_graph", {
+                    "action": "create_node",
+                    "label": "Execution",
+                    "properties": {
+                        "id": f"exec-{instruction['id']}-{int(time.time())}",
+                        "started_at": datetime.now().isoformat(),
+                        "completed_at": datetime.now().isoformat(),
+                        "result": "Dummy execution completed"
+                    }
+                })
+                
+                # Link execution to instruction
+                call_mcp("query_graph", {
+                    "query": """
+                        MATCH (i:Instruction {id: $iid}), (e:Execution {id: $eid})
+                        CREATE (i)-[:EXECUTED_AS]->(e)
+                    """,
+                    "parameters": {
+                        "iid": instruction['id'],
+                        "eid": exec_result['created']['id']
+                    }
+                })
+                
+                # Mark complete
+                call_mcp("query_graph", {
+                    "query": "MATCH (i:Instruction {id: $id}) SET i.status = 'complete'",
+                    "parameters": {"id": instruction['id']}
+                })
+                
+                print(f"[{datetime.now()}] Completed instruction: {instruction['id']}")
+            else:
+                print(f"[{datetime.now()}] No pending instructions")
+                
+        except Exception as e:
+            print(f"[{datetime.now()}] Error: {e}")
+        
+        time.sleep(POLL_INTERVAL)
+
+if __name__ == "__main__":
+    main()

agent/requirements.txt

@@ -0,0 +1,2 @@
+requests==2.31.0
+python-dotenv==1.0.0

docker-compose.yml

@@ -40,6 +40,17 @@ services:
     depends_on:
       - neo4j
 
+  agent:
+    build: ./agent
+    container_name: agent
+    environment:
+      - MCP_URL=http://mcp:8000/mcp
+      - MCP_API_KEY=dev-key-123
+      - AGENT_POLL_INTERVAL=${AGENT_POLL_INTERVAL:-30}
+    depends_on:
+      - mcp
+      - neo4j
+
 volumes:
   neo4j_data:
   postgres_data:

ops/health/neo4j.sh

@@ -0,0 +1,2 @@
+#!/bin/bash
+docker-compose exec neo4j cypher-shell -u neo4j -p password "MATCH (n) RETURN count(n) LIMIT 1" && echo "✅ Neo4j healthy"

ops/scripts/seed.py

@@ -0,0 +1,73 @@
+import requests
+import json
+
+MCP_URL = "http://mcp:8000/mcp"
+API_KEY = "dev-key-123"
+
+def call_mcp(tool, params=None):
+    response = requests.post(
+        MCP_URL,
+        headers={"X-API-Key": API_KEY, "Content-Type": "application/json"},
+        json={"tool": tool, "params": params or {}}
+    )
+    return response.json()
+
+# Create demo workflow
+workflow = call_mcp("write_graph", {
+    "action": "create_node",
+    "label": "Workflow",
+    "properties": {
+        "id": "demo-workflow-1",
+        "name": "Entity Resolution Demo",
+        "status": "active",
+        "max_iterations": 10,
+        "current_iteration": 0
+    }
+})
+print(f"Created workflow: {workflow}")
+
+# Create three instructions
+instructions = [
+    {"id": "inst-1", "sequence": 1, "type": "discover_schema", "status": "pending", "pause_duration": 300},
+    {"id": "inst-2", "sequence": 2, "type": "generate_sql", "status": "pending", "pause_duration": 300},
+    {"id": "inst-3", "sequence": 3, "type": "review_results", "status": "pending", "pause_duration": 300}
+]
+
+for inst in instructions:
+    result = call_mcp("write_graph", {
+        "action": "create_node",
+        "label": "Instruction",
+        "properties": inst
+    })
+    print(f"Created instruction: {inst['id']}")
+    
+    # Link to workflow
+    call_mcp("query_graph", {
+        "query": """
+            MATCH (w:Workflow {id: $wid}), (i:Instruction {id: $iid})
+            CREATE (w)-[:HAS_INSTRUCTION]->(i)
+        """,
+        "parameters": {"wid": "demo-workflow-1", "iid": inst['id']}
+    })
+
+# Create instruction chain
+call_mcp("query_graph", {
+    "query": """
+        MATCH (i1:Instruction {id: 'inst-1'}), (i2:Instruction {id: 'inst-2'})
+        CREATE (i1)-[:NEXT_INSTRUCTION]->(i2)
+    """
+})
+
+call_mcp("query_graph", {
+    "query": """
+        MATCH (i2:Instruction {id: 'inst-2'}), (i3:Instruction {id: 'inst-3'})
+        CREATE (i2)-[:NEXT_INSTRUCTION]->(i3)
+    """
+})
+
+# Create indexes
+call_mcp("query_graph", {"query": "CREATE INDEX workflow_id IF NOT EXISTS FOR (w:Workflow) ON (w.id)"})
+call_mcp("query_graph", {"query": "CREATE INDEX instruction_id IF NOT EXISTS FOR (i:Instruction) ON (i.id)"})
+call_mcp("query_graph", {"query": "CREATE INDEX instruction_status_seq IF NOT EXISTS FOR (i:Instruction) ON (i.status, i.sequence)"})
+
+print("✅ Seeding complete!")