🚧 Desenvolvendo a estrutura inicial do envio de mensagem. Endpoint POST com a mensagem e o ID do usuário.
parent
e82727fd92
commit
9e574b1e25
Binary file not shown.
Binary file not shown.
Binary file not shown.
@ -0,0 +1,14 @@
|
||||
from fastapi import APIRouter
|
||||
from app.api.schemas import ChatRequest, ChatResponse
|
||||
from app.services.orchestrator_service import OrchestratorService
|
||||
|
||||
router = APIRouter()
|
||||
service = OrchestratorService()
|
||||
|
||||
@router.post("/chat", response_model=ChatResponse)
|
||||
async def chat(request: ChatRequest):
|
||||
result = await service.handle_message(
|
||||
message=request.message,
|
||||
user_id=request.user_id
|
||||
)
|
||||
return ChatResponse(response=result)
|
||||
@ -0,0 +1,8 @@
|
||||
from pydantic import BaseModel
|
||||
|
||||
class ChatRequest(BaseModel):
|
||||
message: str
|
||||
user_id: str
|
||||
|
||||
class ChatResponse(BaseModel):
|
||||
response: str
|
||||
@ -0,0 +1,6 @@
|
||||
from fastapi import FastAPI
|
||||
from app.api.routes import router
|
||||
|
||||
app = FastAPI(title="AI Orquestrador")
|
||||
|
||||
app.include_router(router)
|
||||
Binary file not shown.
@ -0,0 +1,10 @@
|
||||
class OrchestratorService:
|
||||
|
||||
async def handle_message(self, message: str, user_id: str) -> str:
|
||||
# Aqui futuramente:
|
||||
# - chamada ao Gemini
|
||||
# - verificação de intenção
|
||||
# - chamada de tools
|
||||
# - integração com banco
|
||||
|
||||
return f"Mensagem recebida do usuário {user_id}: {message}"
|
||||
Binary file not shown.
Loading…
Reference in New Issue