from fastapi import FastAPI
import redis
import os
import json

app = FastAPI()

redis_host = os.getenv("REDIS_HOST", "localhost")
redis_port = int(os.getenv("REDIS_PORT", 6379))
r = redis.Redis(host=redis_host, port=redis_port, decode_responses=True)

@app.get("/health")
async def health():
    return {"status": "ok", "service": "orchestrator"}

@app.post("/process")
async def process_text(request: dict):
    # Здесь будет логика обработки текста и вызова инструментов
    text = request.get("text", "")
    user = request.get("user", "guest")
    print(f"Processing from {user}: {text}")
    
    # Простой ответ для теста
    response = "Я получил ваше сообщение, но пока не умею отвечать."
    
    return {"response": response}