from langgraph.graph import StateGraph, END
def memory_node(state: AgentState):
# Search for relevant memories
search_result = search_memory(
query=state["messages"][-1].content,
user_id=state["user_id"],
)
# Add new memory
add_memory(
content=state["messages"][-1].content,
user_id=state["user_id"],
)
return {
"context": search_result.get("summary", ""),
"memory_tool_results": [search_result],
}
# Build graph
workflow = StateGraph(AgentState)
workflow.add_node("memory", memory_node)
workflow.set_entry_point("memory")
workflow.add_edge("memory", END)