}}
+}}
+
+Then return:
+{{ "result": "✅ Creation of resource is Done." }}
+
+⚠️ JSON must be strictly valid (RFC8259).
+No markdown, no comments, no truncation, no null placeholders.
+"""
+
+prompt = ChatPromptTemplate.from_messages([
+ ("system", system_text),
+ ("placeholder", "{messages}")
+])
+
+# ----------------------------
+# MCP TOOLS
+# ----------------------------
+client = MultiServerMCPClient(
+ {
+ "oci-ops": {
+ "command": sys.executable,
+ "args": ["server_mcp.py"],
+ "transport": "stdio",
+ "env": {
+ "PATH": os.environ.get("PATH", "") + os.pathsep + os.path.expanduser("~/.local/bin"),
+ "OCI_CLI_BIN": config_data["OCI_CLI_BIN"],
+ "OCI_CLI_PROFILE": config_data["oci_profile"],
+ },
+ },
+ }
+)
+
+async def load_tools():
+ tools = await client.get_tools()
+ if not tools:
+ print("❌ No MCP tools loaded")
+ else:
+ print("🛠️ Loaded tools:", [t.name for t in tools])
+ return tools
+
+tools = asyncio.get_event_loop().run_until_complete(load_tools())
+
+# ----------------------------
+# AGENT EXECUTOR
+# ----------------------------
+agent_executor = create_react_agent(
+ model=llm,
+ tools=tools,
+ prompt=prompt,
+)
+
+# ----------------------------
+# FLASK ROUTES
+# ----------------------------
+@app.route("/")
+def index():
+ return render_template("chat.html")
+
+@app.route("/send", methods=["POST"])
+def send():
+ user_message = request.form["message"]
+ memory_state.messages.append(HumanMessage(content=user_message))
+ user_html = f"You: {user_message}
"
+
+ try:
+ # injeta estado atual na conversa
+ params_json = json.dumps({"parameters": memory_state.parameters}, indent=2)
+ context_message = AIMessage(content=f"Current known parameters:\n{params_json}")
+
+ result = asyncio.run(agent_executor.ainvoke({
+ "messages": memory_state.messages + [context_message]
+ }))
+
+ debug_info = ""
+
+ if check_truncation(result):
+ debug_info += "\n\n⚠️ Warning: Response truncated by max_tokens limit."
+
+ new_messages = result.get("messages", [])
+
+ if new_messages:
+ memory_state.messages.extend(new_messages)
+ assistant_reply = new_messages[-1].content
+
+ parsed = safe_json_extract(assistant_reply)
+ if not parsed: # fallback se falhar
+ parsed = sanitize_json(assistant_reply)
+
+ if parsed and "parameters" in parsed:
+ # atualiza parâmetros
+ for k, v in parsed["parameters"].items():
+ if v is not None:
+ memory_state.parameters[k] = v
+ print("📌 Current status:", memory_state.parameters)
+
+ missing = validate_payload(memory_state.parameters)
+ if not missing:
+ print("✅ All parameters filled in. The agent should now create the VM..")
+ else:
+ print("⚠️ Faltando parâmetros:", missing)
+ if not missing:
+ debug_info += "\n✅ All parameters filled in. The agent should now create the VM.."
+ else:
+ debug_info += f"\n⚠️ Missing parameters: {missing}"
+
+ if missing:
+ auto_followup = f"Please resolve the following missing parameters: {missing}"
+ memory_state.messages.append(HumanMessage(content=auto_followup))
+
+ # adiciona debug_info na resposta enviada ao navegador
+ assistant_reply += "\n\n" + debug_info
+
+ # se vieram candidatos
+ if parsed and "candidates" in parsed and parsed["candidates"]:
+ memory_state.candidates = parsed["candidates"]
+ print("🔍 Candidates found:", memory_state.candidates)
+
+ # monta bloco HTML de candidatos
+ candidates_html = ""
+ for param, items in memory_state.candidates.items():
+ candidates_html += f"Options for {param}:
"
+ for c in items:
+ line = f"{c.get('index')}. {c.get('name')} — {c.get('ocid')} — v{c.get('version')} — score {c.get('score')}"
+ candidates_html += line + "
"
+
+ ask_text = parsed.get("ask", "Choose an index or provide the OCID.")
+ assistant_reply = f"{json.dumps({'parameters': memory_state.parameters}, ensure_ascii=False)}
{candidates_html}{ask_text}"
+
+ else:
+ memory_state.candidates = {}
+
+ else:
+ assistant_reply = "⚠️ No response from agent."
+ except Exception as e:
+ assistant_reply = f"⚠️ Erro: {e}"
+
+ bot_html = f"Assistant: {assistant_reply}
"
+ return Markup(user_html + bot_html)
+
+# ----------------------------
+# MAIN
+# ----------------------------
+if __name__ == "__main__":
+ app.run(host="0.0.0.0", port=8080, debug=True)
\ No newline at end of file