|
| 1 | +import typing as T |
| 2 | + |
| 3 | +import openai |
| 4 | +from mcp.server.fastmcp import FastMCP |
| 5 | +from pydantic import BaseModel |
| 6 | + |
| 7 | +from inkeep_mcp_server.settings import inkeep_settings |
| 8 | + |
| 9 | +# Initialize FastMCP server |
| 10 | +mcp = FastMCP("inkeep-mcp-server") |
| 11 | + |
| 12 | + |
| 13 | +# https://docs.anthropic.com/en/docs/build-with-claude/citations#plain-text-documents |
| 14 | +class InkeepRAGDocument(BaseModel): |
| 15 | + # anthropic fields citation types |
| 16 | + type: str |
| 17 | + source: T.Dict |
| 18 | + title: T.Optional[str] = None |
| 19 | + context: T.Optional[str] = None |
| 20 | + # inkeep specific fields |
| 21 | + source_type: T.Optional[str] = None |
| 22 | + url: T.Optional[str] = None |
| 23 | + |
| 24 | + |
| 25 | +class InkeepRAGResponse(BaseModel): |
| 26 | + content: T.List[InkeepRAGDocument] = [] |
| 27 | + |
| 28 | + |
| 29 | +async def make_inkeep_rag_request(query: str) -> InkeepRAGResponse: |
| 30 | + async with openai.AsyncOpenAI( |
| 31 | + base_url=inkeep_settings.INKEEP_API_BASE_URL, |
| 32 | + api_key=inkeep_settings.INKEEP_API_KEY, |
| 33 | + ) as openai_client: |
| 34 | + # https://platform.openai.com/docs/guides/structured-outputs?api-mode=chat |
| 35 | + inkeep_rag_response = await openai_client.beta.chat.completions.parse( |
| 36 | + model=inkeep_settings.INKEEP_API_MODEL, |
| 37 | + messages=[ |
| 38 | + {"role": "user", "content": query}, |
| 39 | + ], |
| 40 | + response_format=InkeepRAGResponse, |
| 41 | + ) |
| 42 | + |
| 43 | + inkeep_rag_response_parsed = inkeep_rag_response.choices[0].message.parsed |
| 44 | + if inkeep_rag_response_parsed: |
| 45 | + return inkeep_rag_response_parsed |
| 46 | + else: |
| 47 | + return InkeepRAGResponse() |
| 48 | + |
| 49 | + |
| 50 | +@mcp.tool( |
| 51 | + name="rag-search", |
| 52 | + description="Search for relevant docs for a query using Inkeep's RAG API.", |
| 53 | +) |
| 54 | +async def rag_search(query: str) -> InkeepRAGResponse: |
| 55 | + return await make_inkeep_rag_request(query) |
0 commit comments