admin/basicmachines-co-basic-memory
1
0
Fork 0
mirror of https://github.com/basicmachines-co/basic-memory synced 2026-06-21 13:47:35 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix all endpoints for tools

Browse Source
This commit is contained in:
phernandez
2024-12-25 10:18:12 -06:00
parent 59fa354c77
commit 353342a5e2
6 changed files with 64 additions and 52 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/basic_memory/api/routers/documents.py
+2 -2
View File
@@ -17,7 +17,7 @@ from basic_memory.services.document_service import (
router = APIRouter(prefix="/documents", tags=["documents"])
@router.post("/", response_model=DocumentCreateResponse, status_code=201)
@router.post("/create", response_model=DocumentCreateResponse, status_code=201)
async def create_document(
doc: DocumentRequest,
service: DocumentServiceDep,
@@ -41,7 +41,7 @@ async def create_document(
raise HTTPException(status_code=400, detail=str(e))
@router.get("/", response_model=List[DocumentCreateResponse])
@router.get("/list", response_model=List[DocumentCreateResponse])
async def list_documents(
service: DocumentServiceDep,
) -> List[DocumentCreateResponse]:
src/basic_memory/mcp/__init__.py
+1 -2
View File
@@ -1,2 +1 @@
"""MCP server for basic-memory."""
from .server import server
"""MCP server for basic-memory."""
src/basic_memory/mcp/async_client.py
+8
View File
@@ -0,0 +1,8 @@
from httpx import ASGITransport, AsyncClient
from basic_memory.api.app import app as fastapi_app
BASE_URL = "http://test"
# Create shared async client
client = AsyncClient(transport=ASGITransport(app=fastapi_app), base_url=BASE_URL)
src/basic_memory/mcp/server.py
+41 -37
View File
@@ -4,17 +4,13 @@ import sys
from typing import Any, List
from fastmcp import FastMCP
from httpx import AsyncClient, ASGITransport
from loguru import logger
from basic_memory.api.app import app as fastapi_app
from basic_memory.mcp.async_client import client
# Create FastMCP server
mcp = FastMCP("Basic Memory")
# Create shared async client
client = AsyncClient(transport=ASGITransport(app=fastapi_app), base_url="http://test")
def setup_logging(log_file: str = "basic-memory-mcp.log"):
"""Configure logging for the application."""
@@ -48,7 +44,8 @@ async def log_api_call(method: str, url: str, data: Any, response: Any):
logger.debug(f"API Request: {method} {url}")
logger.debug(f"Request Data: {data}")
logger.debug(f"Response Status: {response.status_code}")
logger.debug(f"Response Data: {response.json()}")
if response.status_code != 204: # Only try to log response data if it's not No Content
logger.debug(f"Response Data: {response.json()}")
# Knowledge Graph Tools
@@ -59,25 +56,28 @@ async def log_api_call(method: str, url: str, data: Any, response: Any):
@mcp.tool()
async def create_entities(entities: list[dict]) -> dict:
"""Create new entities in the knowledge graph."""
response = await client.post("/knowledge/entities", json={"entities": entities})
await log_api_call("POST", "/knowledge/entities", entities, response)
url = "/knowledge/entities"
data = {"entities": entities}
response = await client.post(url, json=data)
return response.json()
@mcp.tool()
async def create_relations(relations: list[dict]) -> dict:
"""Create relations between entities."""
response = await client.post("/knowledge/relations", json={"relations": relations})
await log_api_call("POST", "/knowledge/relations", relations, response)
url = "/knowledge/relations"
data = {"relations": relations}
response = await client.post(url, json=data)
return response.json()
@mcp.tool()
async def add_observations(path_id: str, observations: list[str]) -> dict:
"""Add observations to an entity."""
url = "/knowledge/observations"
data = {"path_id": path_id, "observations": observations}
response = await client.post("/knowledge/observations", json=data)
await log_api_call("POST", "/knowledge/observations", data, response)
response = await client.post(url, json=data)
await log_api_call("POST", url, data, response)
return response.json()
@@ -87,24 +87,26 @@ async def add_observations(path_id: str, observations: list[str]) -> dict:
@mcp.tool()
async def get_entity(path_id: str) -> dict:
"""Get a specific entity by path_id."""
response = await client.get(f"/knowledge/entities/{path_id}")
await log_api_call("GET", f"/knowledge/entities/{path_id}", None, response)
url = f"/knowledge/entities/{path_id}"
response = await client.get(url)
return response.json()
@mcp.tool()
async def search_nodes(query: str) -> dict:
"""Search for entities in the knowledge graph."""
response = await client.post("/knowledge/search", json={"query": query})
await log_api_call("POST", "/knowledge/search", {"query": query}, response)
url = "/knowledge/search"
data = {"query": query}
response = await client.post(url, json=data)
return response.json()
@mcp.tool()
async def open_nodes(path_ids: List[str]) -> dict:
"""Search for entities in the knowledge graph."""
response = await client.post("/knowledge/nodes", json={"path_ids": path_ids})
await log_api_call("POST", "/knowledge/nodes", {"path_ids": path_ids}, response)
url = "/knowledge/nodes"
data = {"path_ids": path_ids}
response = await client.post(url, json=data)
return response.json()
@@ -114,32 +116,34 @@ async def open_nodes(path_ids: List[str]) -> dict:
@mcp.tool()
async def delete_entities(path_ids: List[str]) -> dict:
"""Search for entities in the knowledge graph."""
response = await client.post("/knowledge/entities/delete", json={"path_ids": path_ids})
await log_api_call("POST", "/knowledge/entities/delete", {"path_ids": path_ids}, response)
url = "/knowledge/entities/delete"
data = {"path_ids": path_ids}
response = await client.post(url, json=data)
return response.json()
@mcp.tool()
async def delete_observations(path_id: str, observations: list[str]) -> dict:
"""Delete observations from an entity."""
url = "/knowledge/observations/delete"
data = {
"path_id": path_id,
"observations": observations,
} # Match the parameter name with what we're using
}
response = await client.post(
"/knowledge/observations/delete", json=data
) # Change to observations endpoint
await log_api_call("POST", "/knowledge/observations/delete", data, response)
url, json=data
)
return response.json()
@mcp.tool()
async def delete_relations(relations: list[dict]) -> dict:
"""Delete relations between entities."""
url = "/knowledge/relations/delete"
data = {"relations": relations}
response = await client.post(
"/knowledge/relations/delete", json={"relations": relations}
) # Change to relations endpoint
await log_api_call("POST", "/knowledge/relations/delete", {"relations": relations}, response)
url, json=data
)
return response.json()
@@ -149,42 +153,42 @@ async def delete_relations(relations: list[dict]) -> dict:
@mcp.tool()
async def create_document(path: str, content: str, metadata: dict = None) -> dict:
"""Create a new document."""
url = "/documents/create"
data = {"path": path, "content": content, "metadata": metadata}
response = await client.post("/documents/", json=data)
await log_api_call("POST", "/documents/", data, response)
response = await client.post(url, json=data)
return response.json()
@mcp.tool()
async def get_document(path: str) -> dict:
"""Get a document by path_id."""
response = await client.get(f"/documents/{path}/")
await log_api_call("GET", f"/documents/{path}/", None, response)
url = f"/documents/{path}"
response = await client.get(url)
return response.json()
@mcp.tool()
async def update_document(path: str, content: str, metadata: dict = None) -> dict:
"""Update an existing document."""
url = f"/documents/{path}"
data = {"path": path, "content": content, "metadata": metadata}
response = await client.put(f"/documents/{path}/", json=data)
await log_api_call("PUT", f"/documents/{path}/", data, response)
response = await client.put(url, json=data)
return response.json()
@mcp.tool()
async def list_documents() -> list:
"""List all documents."""
response = await client.get("/documents/")
await log_api_call("GET", "/documents/", None, response)
url = "/documents/list"
response = await client.get(url)
return response.json()
@mcp.tool()
async def delete_document(path: str) -> dict:
"""Delete an existing document."""
response = await client.delete(f"/documents/{path}/")
await log_api_call("DELETE", f"/documents/{path}/", None, response)
url = f"/documents/{path}"
response = await client.delete(url)
if response.status_code == 204:
return {"deleted": True}