Update app.py

app.py

@@ -1,105 +1,69 @@
 import os
-import httpx
+import requests
 from fastapi import FastAPI, HTTPException
-from fastapi.middleware.cors import CORSMiddleware
-from pydantic import BaseModel
+from fastapi.responses import JSONResponse
 
 # -------------------------------------------------
-# FastAPI App Configuration
+# CONFIGURATION
 # -------------------------------------------------
+HUGGINGFACE_BACKEND = os.getenv("SAP_BACKEND_URL", "https://pd03-agentkit.hf.space/purchase-orders")
+
 app = FastAPI(
-    title="SAP Purchase Order API Demo",
+    title="SAP MCP Server",
     description=(
-        "Backend to fetch purchase order data from SAP Sandbox API.\n\n"
-        "Designed for integration with OpenAI Agentkit UI — "
-        "Agentkit automatically discovers endpoints from `/openapi.json`."
+        "Minimal MCP-compatible FastAPI server that exposes a tool to fetch SAP "
+        "purchase orders from the Hugging Face backend."
     ),
     version="1.0.0",
 )
 
-# Enable CORS for Agentkit and browser testing
-app.add_middleware(
-    CORSMiddleware,
-    allow_origins=["*"],
-    allow_credentials=True,
-    allow_methods=["*"],
-    allow_headers=["*"],
-)
-
 # -------------------------------------------------
-# Environment Variables
-# -------------------------------------------------
-SAP_API_KEY = os.getenv("SAP_API_KEY")
-SAP_BASE_URL = (
-    "https://sandbox.api.sap.com/s4hanacloud/sap/opu/odata4/"
-    "sap/api_purchaseorder_2/srvd_a2x/sap/purchaseorder/0001/PurchaseOrder?$top=50"
-)
-
+# MCP Manifest (for AgentKit autodiscovery)
 # -------------------------------------------------
-# Pydantic Models (for OpenAPI schema)
-# -------------------------------------------------
-class PurchaseOrderItem(BaseModel):
-    PurchaseOrder: str | None = None
-    Supplier: str | None = None
-    CreatedByUser: str | None = None
-    CreatedDateTime: str | None = None
-
-
-class PurchaseOrderResponse(BaseModel):
-    source: str
-    count: int
-    data: list[PurchaseOrderItem] | dict
+@app.get("/.well-known/mcp/manifest.json", include_in_schema=False)
+async def get_manifest():
+    """Returns MCP manifest so AgentKit can auto-discover the tool."""
+    manifest = {
+        "name": "sap_mcp_server",
+        "description": "MCP server exposing a tool for retrieving SAP purchase orders.",
+        "version": "1.0.0",
+        "tools": [
+            {
+                "name": "get_purchase_orders",
+                "description": "Fetches the top 50 purchase orders from the SAP Sandbox API "
+                               "via the Hugging Face backend.",
+                "input_schema": {"type": "object", "properties": {}},
+                "output_schema": {"type": "object"},
+                "http": {
+                    "method": "GET",
+                    "url": "/tools/get_purchase_orders"
+                }
+            }
+        ]
+    }
+    return JSONResponse(content=manifest)
 
 
 # -------------------------------------------------
-# Routes
+# Tool Endpoint
 # -------------------------------------------------
-
-@app.get("/", tags=["Root"])
-async def root():
-    """Friendly welcome message for the root URL."""
-    return {
-        "message": "👋 Welcome to the SAP Purchase Order API demo!",
-        "available_endpoints": {
-            "health": "/health",
-            "purchase_orders": "/purchase-orders",
-            "docs": "/docs"
-        },
-        "instructions": (
-            "Use /purchase-orders to fetch SAP Sandbox data, "
-            "or open /docs for the interactive Swagger UI."
-        ),
-    }
-
-
-@app.get("/health", summary="Health check", tags=["System"])
-async def health_check():
-    """Check if the API is running."""
-    return {"status": "ok", "message": "SAP Purchase Order API backend is running"}
-
-
-@app.get(
-    "/purchase-orders",
-    response_model=PurchaseOrderResponse,
-    summary="Get Purchase Orders",
-    tags=["Purchase Orders"],
-    description="Fetches the top 50 purchase orders from the SAP Sandbox API.",
-)
+@app.get("/tools/get_purchase_orders", tags=["MCP Tools"])
 async def get_purchase_orders():
-    """Fetch purchase order data from SAP Sandbox API."""
-    if not SAP_API_KEY:
-        raise HTTPException(status_code=500, detail="SAP_API_KEY not found in environment")
+    """
+    Fetch the top 50 SAP purchase orders from your Hugging Face backend.
+    This endpoint is exposed as an MCP tool for AgentKit.
+    """
+    try:
+        resp = requests.get(HUGGINGFACE_BACKEND, timeout=30)
+        resp.raise_for_status()
+        return resp.json()
+    except requests.exceptions.RequestException as e:
+        raise HTTPException(status_code=500, detail=f"Failed to call backend: {e}")
 
-    headers = {"APIKey": SAP_API_KEY}
 
-    try:
-        async with httpx.AsyncClient(timeout=30.0) as client:
-            resp = await client.get(SAP_BASE_URL, headers=headers)
-            resp.raise_for_status()
-            data = resp.json()
-            po_items = data.get("value", [])
-            return {"source": "SAP Sandbox", "count": len(po_items), "data": po_items}
-    except httpx.HTTPStatusError as e:
-        raise HTTPException(status_code=e.response.status_code, detail=f"SAP API error: {e.response.text}")
-    except Exception as e:
-        raise HTTPException(status_code=500, detail=str(e))
+# -------------------------------------------------
+# Health Route
+# -------------------------------------------------
+@app.get("/health", tags=["System"])
+async def health():
+    return {"status": "ok", "message": "SAP MCP Server is running"}