services/protocol/openai_search.py

from __future__ import annotations

from services.account_service import account_service
from services.openai_backend_api import OpenAIBackendAPI, SEARCH_MODEL

MODEL = SEARCH_MODEL


def handle(body: dict[str, object]) -> dict[str, object]:
    token = account_service.get_text_access_token()
    account = account_service.get_account(token) or {}
    result = OpenAIBackendAPI(token).search(str(body["prompt"]))
    account_service.mark_text_used(token)
    result["_account_email"] = str(account.get("email") or "")
    return result