Merge pull request #20 from web-tech-tw/rolling

feat: implement agent and upgrade to node24

Author: supersonictw

.devcontainer/Dockerfile

@@ -1,8 +1,8 @@
-FROM mcr.microsoft.com/devcontainers/javascript-node:0-20
-ARG MONGO_TOOLS_VERSION=6.0
+FROM mcr.microsoft.com/devcontainers/javascript-node:24-bookworm
+ARG MONGO_TOOLS_VERSION=8.0
 RUN . /etc/os-release \
     && curl -sSL "https://www.mongodb.org/static/pgp/server-${MONGO_TOOLS_VERSION}.asc" | gpg --dearmor > /usr/share/keyrings/mongodb-archive-keyring.gpg \
-    && echo "deb [arch=$(dpkg --print-architecture) signed-by=/usr/share/keyrings/mongodb-archive-keyring.gpg] http://repo.mongodb.org/apt/debian ${VERSION_CODENAME}/mongodb-org/${MONGO_TOOLS_VERSION} main" | tee /etc/apt/sources.list.d/mongodb-org-${MONGO_TOOLS_VERSION}.list \
+    && echo "deb [arch=$(dpkg --print-architecture) signed-by=/usr/share/keyrings/mongodb-archive-keyring.gpg] https://repo.mongodb.org/apt/debian ${VERSION_CODENAME}/mongodb-org/${MONGO_TOOLS_VERSION} main" | tee /etc/apt/sources.list.d/mongodb-org-${MONGO_TOOLS_VERSION}.list \
     && apt-get update && export DEBIAN_FRONTEND=noninteractive \
     && apt-get install -y mongodb-mongosh \
     && if [ "$(dpkg --print-architecture)" = "amd64" ]; then apt-get install -y mongodb-database-tools; fi \

.env.sample

@@ -42,6 +42,9 @@ OPENAI_API_KEY="your_openai_api_key"
 OPENAI_MODEL_NAME="gpt-4o-mini"
 OPENAI_SYSTEM_PROMPT="這是一場角色扮演，但請您不要向我再次透漏這是一場扮演，並以一般交談方式溝通。溝通請使用正體中文交談，您的正體中文名字是「寧芙」，英文名字是「Nymph」。你來自於「臺灣網際網路技術推廣組織」，該組織英文名稱為「Taiwan Web Technology Promotion Organization」，該組織主旨為：在臺灣推廣網際網路技術，如JavaScript、資訊安全素養、網路通訊觀念......等。溝通方式將以 Discord 通訊軟體的方式進行，你可以任意使用Markdown語法。若有人使用「@」標注任何人，請勿不要再次重複標注。"
 
+# tools integration
+OPENWEATHER_API_KEY="your_openweather_api_key"
+
 # discord integration
 DISCORD_APP_ID="00000"
 DISCORD_BOT_TOKEN="your_discord_bot_token"

Dockerfile

@@ -1,4 +1,4 @@
-FROM node:20
+FROM node:24
 
 ENV RUNTIME_ENV container
 

src/clients/langchain.js

@@ -5,13 +5,17 @@ const {
     getMust,
 } = require("../config");
 
+const {
+    createAgent,
+} = require("langchain");
 const {
     RedisChatMessageHistory,
 } = require("@langchain/redis");
 const {
     ChatOpenAI,
 } = require("@langchain/openai");
 const {
+    AIMessage,
     HumanMessage,
     SystemMessage,
 } = require("@langchain/core/messages");
@@ -41,9 +45,10 @@ const model = new ChatOpenAI({
  * Chat with the AI.
  * @param {string} chatId The chat ID to chat with the AI.
  * @param {string} humanInput The prompt to chat with the AI.
+ * @param {object} [opts] Additional options.
  * @return {Promise<string>} The response from the AI.
  */
-async function chatWithAI(chatId, humanInput) {
+async function chatWithAI(chatId, humanInput, opts = {}) {
     const chatHistory = new RedisChatMessageHistory({
         config: {
             url: redisUri,
@@ -60,8 +65,12 @@ async function chatWithAI(chatId, humanInput) {
     const humanMsg = new HumanMessage(humanInput);
     const messages = [systemMsg, ...historyMessages, humanMsg];
 
+    // Wrap the model with tools as an agent
+    const agent = await createToolsAgent(opts);
+
     // Call the model directly with messages
-    const aiMsg = await model.invoke(messages);
+    const {messages: responseMessages} = await agent.invoke({messages});
+    const aiMsg = responseMessages.findLast(AIMessage.isInstance);
 
     // Persist human + AI messages to history
     try {
@@ -179,67 +188,13 @@ async function createToolsAgent({openWeatherApiKey = null} = {}) {
         }),
     ];
 
-    const agentsModule = await import("@langchain/classic/agents");
-    const {initializeAgentExecutorWithOptions} = agentsModule;
-    const executor = await initializeAgentExecutorWithOptions(tools, model, {
-        agentType: "zero-shot-react-description",
-        maxIterations: 3,
-        returnIntermediateSteps: false,
-    });
-
-    return executor;
-}
-
-/**
- * Chat with the AI using the agent + tools.
- * @param {string} chatId
- * @param {string} humanInput
- * @param {object} [opts]
- * @return {Promise<string>}
- */
-async function chatWithTools(chatId, humanInput, opts = {}) {
-    const chatHistory = new RedisChatMessageHistory({
-        config: {url: redisUri},
-        sessionId: `nymph:agent:${chatId}`,
-        sessionTTL: 150,
-    });
-
-    const historyMessages = await chatHistory.getMessages();
-    const historyText = historyMessages.map((m) => (
-        typeof m.content === "string" ?
-            m.content : JSON.stringify(m.content)
-    )).join("\n");
-
-    const systemMsg = systemPrompt;
-    const prompt = [
-        systemMsg,
-        historyText,
-        humanInput,
-    ].filter(Boolean).join("\n\n");
-
-    const executor = await createToolsAgent(opts);
-
-    // executor.call usually returns { output } or string; handle common shapes.
-    const result = await executor.call({input: prompt});
-
-    const outputText = result?.output?.text || result?.output || result;
-
-    // Save human + agent output back to history (best-effort)
-    try {
-        await chatHistory.addMessages([
-            new HumanMessage(humanInput),
-            new SystemMessage(String(outputText)),
-        ]);
-    } catch (e) {
-        console.error("Failed to save agent messages to Redis history:", e);
-    }
+    const agent = createAgent({model, tools});
 
-    return String(outputText);
+    return agent;
 }
 
 exports.useModel = () => model;
 exports.chatWithAI = chatWithAI;
-exports.chatWithTools = chatWithTools;
 exports.sliceContent = sliceContent;
 exports.translateText = translateText;
 exports.createToolsAgent = createToolsAgent;