commit cleanup

graph-agentic-system/docker-compose.yml

@@ -1,29 +0,0 @@
-version: '3.8'
-
-services:
-  neo4j:
-    image: neo4j:5.15-community
-    container_name: neo4j
-    ports:
-      - "7474:7474"
-      - "7687:7687"
-    environment:
-      - NEO4J_AUTH=-Force{NEO4J_AUTH}
-      - NEO4J_BOLT_URL=-Force{NEO4J_BOLT_URL}
-    volumes:
-      - neo4j_data:/data
-
-  postgres:
-    image: postgres:15
-    container_name: postgres
-    ports:
-      - "5432:5432"
-    environment:
-      - POSTGRES_PASSWORD=-Force{POSTGRES_PASSWORD}
-      - POSTGRES_DB=testdb
-    volumes:
-      - postgres_data:/var/lib/postgresql/data
-
-volumes:
-  neo4j_data:
-  postgres_data:

graph-agentic-system/mcp/Dockerfile

@@ -1,12 +0,0 @@
-FROM python:3.11-slim
-
-WORKDIR /app
-
-COPY requirements.txt .
-RUN pip install --no-cache-dir -r requirements.txt
-
-COPY . .
-
-EXPOSE 8000
-
-CMD ["uvicorn", "main:app", "--host", "0.0.0.0", "--port", "8000"]

graph-agentic-system/mcp/main.py

@@ -1,62 +0,0 @@
-from fastapi import FastAPI, Header, HTTPException
-from neo4j import GraphDatabase
-import os
-import json
-from datetime import datetime
-
-app = FastAPI()
-driver = GraphDatabase.driver(
-    os.getenv("NEO4J_BOLT_URL"),
-    auth=("neo4j", os.getenv("NEO4J_AUTH").split("/")[1])
-)
-
-VALID_API_KEYS = os.getenv("MCP_API_KEYS", "").split(",")
-
-@app.get("/health")
-def health():
-    return {"ok": True, "timestamp": datetime.now().isoformat()}
-
-@app.post("/mcp")
-async def execute_tool(request: dict, x_api_key: str = Header(None)):
-    # Verify API key
-    if x_api_key not in VALID_API_KEYS:
-        raise HTTPException(status_code=401, detail="Invalid API key")
-    
-    tool = request.get("tool")
-    params = request.get("params", {})
-    
-    if tool == "get_schema":
-        # Return node labels and relationships
-        with driver.session() as session:
-            result = session.run("CALL db.labels() YIELD label RETURN collect(label) as labels")
-            return {"labels": result.single()["labels"]}
-    
-    elif tool == "query_graph":
-        # Execute parameterized query
-        query = params.get("query")
-        query_params = params.get("parameters", {})
-        with driver.session() as session:
-            result = session.run(query, query_params)
-            return {"data": [dict(record) for record in result]}
-    
-    elif tool == "write_graph":
-        # Structured write operation
-        action = params.get("action")
-        if action == "create_node":
-            label = params.get("label")
-            properties = params.get("properties", {})
-            with driver.session() as session:
-                result = session.run(f"CREATE (n:{label} ) RETURN n", props=properties)
-                return {"created": dict(result.single()["n"])}
-    
-    elif tool == "get_next_instruction":
-        # Get next pending instruction
-        with driver.session() as session:
-            result = session.run("""
-                MATCH (i:Instruction {status: 'pending'})
-                RETURN i ORDER BY i.sequence LIMIT 1
-            """)
-            record = result.single()
-            return {"instruction": dict(record["i"]) if record else None}
-    
-    return {"error": "Unknown tool"}

graph-agentic-system/mcp/requirements.txt

@@ -1,4 +0,0 @@
-fastapi==0.104.0
-uvicorn==0.24.0
-neo4j==5.14.0
-pydantic==2.4.0

graph-agentic-system/neo4j/Dockerfile

@@ -1,4 +0,0 @@
-FROM neo4j:5.23.0
-ENV NEO4J_PLUGINS='["apoc"]'
-ENV NEO4J_apoc_export_file_enabled=true
-ENV NEO4J_apoc_import_file_enabled=true

graph-agentic-system/ops/health/neo4j.ps1

@@ -1,2 +0,0 @@
-docker-compose exec neo4j cypher-shell -u neo4j -p password "MATCH (n) RETURN count(n) LIMIT 1"
-if (1 -eq 0) { echo " Neo4j healthy" }

graph-agentic-system/ops/health/neo4j.sh

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

graph-agentic-system/ops/scripts/seed.py

@@ -1,83 +0,0 @@
-import requests
-import json
-
-MCP_URL = "http://localhost: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 {}}
-    )
-    if response.status_code == 200:
-        return response.json()
-    else:
-        print(f"Error: {response.status_code} - {response.text}")
-        return {"error": f"HTTP {response.status_code}: {response.text}"}
-
-# Clear existing data
-print("Clearing existing data...")
-call_mcp("query_graph", {"query": "MATCH (n) DETACH DELETE n"})
-
-# Create demo workflow
-print("Creating 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
-print("Creating 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']}")
-
-# Create relationships
-print("Creating relationships...")
-call_mcp("query_graph", {
-    "query": "MATCH (w:Workflow {id: 'demo-workflow-1'}), (i:Instruction {id: 'inst-1'}) CREATE (w)-[:HAS_INSTRUCTION]->(i)"
-})
-
-call_mcp("query_graph", {
-    "query": "MATCH (w:Workflow {id: 'demo-workflow-1'}), (i:Instruction {id: 'inst-2'}) CREATE (w)-[:HAS_INSTRUCTION]->(i)"
-})
-
-call_mcp("query_graph", {
-    "query": "MATCH (w:Workflow {id: 'demo-workflow-1'}), (i:Instruction {id: 'inst-3'}) CREATE (w)-[:HAS_INSTRUCTION]->(i)"
-})
-
-# 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
-print("Creating 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!")

ops/scripts/fresh_start.ps1

@@ -47,7 +47,7 @@ if ($ApiKey -ne "") {
     (Get-Content ".env") -replace "LLM_MODEL=.*", "LLM_MODEL=$Model" | Set-Content ".env"
     Write-Host "✅ Updated LLM configuration in .env" -ForegroundColor Green
 } else {
-    Write-Host "⚠️ No API key provided. You'll need to edit .env manually" -ForegroundColor Yellow
+    Write-Host "⚠️ No API key provided. You will need to edit .env manually" -ForegroundColor Yellow
     Write-Host "   Add your OpenAI or Anthropic API key to the LLM_API_KEY variable" -ForegroundColor Gray
 }
 
@@ -158,7 +158,7 @@ Write-Host "  • Check health: docker-compose ps" -ForegroundColor White
 Write-Host ""
 Write-Host "🎯 Quick Test:" -ForegroundColor Yellow
 Write-Host "  1. Open http://localhost:3000" -ForegroundColor White
-Write-Host "  2. Ask: 'How many customers do we have?'" -ForegroundColor White
+Write-Host "  2. Ask: ""How many customers do we have?""" -ForegroundColor White
 Write-Host "  3. Watch the agent process the workflow!" -ForegroundColor White
 Write-Host ""
 
@@ -167,4 +167,4 @@ if ($ApiKey -eq "") {
     Write-Host ""
 }
 
-Write-Host "System is ready for use! 🚀" -ForegroundColor Green
+Write-Host "System is ready for use!" -ForegroundColor Green