File size: 1,025 Bytes
2af6ef5
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
"""PhantomAPI — POST /v1/responses."""

from fastapi import APIRouter, Depends

from app.dependencies import verify_api_key
from app.schemas.responses import ResponsesRequest
from app.services.chat import process_responses_api

router = APIRouter()


@router.post("/responses", dependencies=[Depends(verify_api_key)])
async def responses(payload: ResponsesRequest):
    """Modern Responses API endpoint for newer n8n versions."""
    data = payload.model_dump()
    input_data = data.get("input", "")

    # Normalise input to messages list
    if isinstance(input_data, str):
        messages = [{"role": "user", "content": input_data}]
    elif isinstance(input_data, list):
        messages = input_data
    else:
        messages = []

    # Inject system instructions
    instructions = data.get("instructions", "")
    if instructions:
        messages.insert(0, {"role": "system", "content": instructions})

    return process_responses_api(messages, data["model"], data.get("tools"))