app.py

from fastapi import FastAPI

from graph.rag_pipeline_graph import get_rag_pipeline_graph
from type.state_schema import RAGState


api = FastAPI()



@api.get("/")
def greet_json():
    return {"Hello": "World!"}

# if __name__ == "__main__":
@api.post("/")
def rag_pipeline_graph():
    graph = get_rag_pipeline_graph()

    input_data = RAGState(
        query="유용한 재무정보의 질적특성에 관한 설명",
        top_k=5
    )

    final_state = graph.invoke(input_data)
    # print("\n🧠 최종 응답:", final_state.final_response)
    # print("\n🧠 최종 응답:", final_state["final_response"])
    # print("\n🧠 최종 응답:", final_state.get("final_response", "[응답 없음]"))
    return  final_state.get("final_response", "[응답 없음]")