feat: Establish initial FastAPI project with core configuration, API endpoints, and a basic Langgraph orchestrator.

.env.example

@@ -0,0 +1,7 @@
+OPENAI_API_KEY=your_openai_api_key_here
+REDIS_HOST=localhost
+REDIS_PORT=6379
+CHROMA_DB_PATH=./chroma_db
+NEO4J_URI=bolt://localhost:7687
+NEO4J_USER=neo4j
+NEO4J_PASSWORD=password

.gitignore

@@ -0,0 +1,15 @@
+__pycache__/
+*.py[cod]
+*$py.class
+.env
+.venv
+env/
+venv/
+ENV/
+env.bak/
+venv.bak/
+.idea/
+.vscode/
+*.swp
+*.swo
+chroma_db/

app/api/endpoints.py

@@ -0,0 +1,22 @@
+from fastapi import APIRouter, HTTPException
+from pydantic import BaseModel
+from typing import List, Optional
+
+router = APIRouter()
+
+class QueryRequest(BaseModel):
+    text: str
+    user_id: str = "default_user"
+
+class QueryResponse(BaseModel):
+    response: str
+    sources: List[str] = []
+
+@router.post("/query", response_model=QueryResponse)
+async def process_query(request: QueryRequest):
+    # This will eventually call the cognitive orchestrator
+    # For now, it's a placeholder for Phase 1 verification
+    return QueryResponse(
+        response=f"Brain received: {request.text}. Phase 1: Foundation is active.",
+        sources=["Phase 1: Foundation"]
+    )

app/core/config.py

@@ -0,0 +1,36 @@
+from pydantic_settings import BaseSettings, SettingsConfigDict
+from functools import lru_cache
+import os
+from pathlib import Path
+from dotenv import load_dotenv
+
+# Load .env file if it exists
+env_path = Path(__file__).parent.parent.parent / ".env"
+load_dotenv(dotenv_path=env_path)
+
+class Settings(BaseSettings):
+    PROJECT_NAME: str = "Soma"
+    VERSION: str = "0.1.0"
+    API_V1_STR: str = "/api/v1"
+    
+    OPENAI_API_KEY: str = os.getenv("OPENAI_API_KEY", "")
+    
+    # Working Memory (Redis)
+    REDIS_HOST: str = os.getenv("REDIS_HOST", "localhost")
+    REDIS_PORT: int = int(os.getenv("REDIS_PORT", 6379))
+    
+    # Episodic Memory (ChromaDB)
+    CHROMA_DB_PATH: str = os.getenv("CHROMA_DB_PATH", "./chroma_db")
+    
+    # Semantic Memory (Neo4j)
+    NEO4J_URI: str = os.getenv("NEO4J_URI", "bolt://localhost:7687")
+    NEO4J_USER: str = os.getenv("NEO4J_USER", "neo4j")
+    NEO4J_PASSWORD: str = os.getenv("NEO4J_PASSWORD", "password")
+
+    model_config = SettingsConfigDict(case_sensitive=True)
+
+@lru_cache()
+def get_settings():
+    return Settings()
+
+settings = get_settings()

app/main.py

@@ -0,0 +1,30 @@
+from fastapi import FastAPI
+from fastapi.middleware.cors import CORSMiddleware
+from app.core.config import settings
+from app.api.endpoints import router as api_router
+
+app = FastAPI(
+    title=settings.PROJECT_NAME,
+    version=settings.VERSION,
+    openapi_url=f"{settings.API_V1_STR}/openapi.json"
+)
+
+# Set up CORS
+app.add_middleware(
+    CORSMiddleware,
+    allow_origins=["*"],
+    allow_credentials=True,
+    allow_methods=["*"],
+    allow_headers=["*"],
+)
+
+# Include the API router
+app.include_router(api_router, prefix=settings.API_V1_STR)
+
+@app.get("/")
+async def root():
+    return {"message": f"Welcome to {settings.PROJECT_NAME} API"}
+
+if __name__ == "__main__":
+    import uvicorn
+    uvicorn.run("app.main:app", host="0.0.0.0", port=8000, reload=True)

app/services/orchestrator.py

@@ -0,0 +1,30 @@
+from langgraph.graph import StateGraph, END
+from typing import TypedDict, Annotated, List
+import operator
+
+class AgentState(TypedDict):
+    input: str
+    chat_history: List[dict]
+    context: List[str]
+    response: str
+
+def call_model(state: AgentState):
+    # Simplified logic for Phase 1
+    # Will be expanded with memory layers in later phases
+    return {"response": f"Orchestrator processed: {state['input']}"}
+
+def create_graph():
+    workflow = StateGraph(AgentState)
+    
+    # Add nodes
+    workflow.add_node("call_model", call_model)
+    
+    # Set entry point
+    workflow.set_entry_point("call_model")
+    
+    # Add edges
+    workflow.add_edge("call_model", END)
+    
+    return workflow.compile()
+
+orchestrator = create_graph()

requirements.txt

@@ -0,0 +1,13 @@
+fastapi
+uvicorn
+langgraph
+langchain
+langchain-openai
+python-dotenv
+pydantic
+redis
+chromadb
+neo4j
+python-multipart
+aiosqlite
+pydantic-settings

tests/test_phase1.py

@@ -0,0 +1,18 @@
+import requests
+import json
+
+url = "http://localhost:8000/api/v1/query"
+payload = {
+    "text": "Hello Soma!",
+    "user_id": "test_user"
+}
+headers = {
+    "Content-Type": "application/json"
+}
+
+try:
+    response = requests.post(url, data=json.dumps(payload), headers=headers)
+    print(f"Status Code: {response.status_code}")
+    print(f"Response Body: {response.json()}")
+except Exception as e:
+    print(f"Error: {e}")