59 lines
1.7 KiB
JavaScript
59 lines
1.7 KiB
JavaScript
import test from "node:test"
|
|
import assert from "node:assert/strict"
|
|
import fs from "node:fs"
|
|
import os from "node:os"
|
|
import path from "node:path"
|
|
|
|
import { handleOpenClawTelegramReplyEndInteraction } from "../src/adapters/openclaw-interactive-handler.ts"
|
|
|
|
test("openclaw interactive handler persists state and emits response actions", async () => {
|
|
const tempDir = fs.mkdtempSync(path.join(os.tmpdir(), "reply-end-interactive-"))
|
|
const calls = []
|
|
|
|
const handled = await handleOpenClawTelegramReplyEndInteraction(tempDir, {
|
|
callback: {
|
|
data: "rec:continue",
|
|
messageId: "77",
|
|
chatId: "864811879",
|
|
},
|
|
conversationId: "864811879",
|
|
sessionKey: "agent:main:main",
|
|
callbackId: "cb-77",
|
|
respond: {
|
|
editButtons: async (input) => {
|
|
calls.push(["editButtons", input])
|
|
},
|
|
reply: async (input) => {
|
|
calls.push(["reply", input])
|
|
},
|
|
},
|
|
})
|
|
|
|
assert.equal(handled, true)
|
|
const statePath = path.join(tempDir, "reply-end-controls.json")
|
|
const stored = JSON.parse(fs.readFileSync(statePath, "utf-8"))
|
|
assert.equal(stored["864811879"].lastChoice, "continue")
|
|
assert.equal(calls[0][0], "editButtons")
|
|
assert.equal(calls[1][0], "reply")
|
|
})
|
|
|
|
test("openclaw interactive handler ignores unrelated callback data", async () => {
|
|
const tempDir = fs.mkdtempSync(path.join(os.tmpdir(), "reply-end-interactive-"))
|
|
const handled = await handleOpenClawTelegramReplyEndInteraction(tempDir, {
|
|
callback: {
|
|
data: "other:value",
|
|
messageId: "78",
|
|
chatId: "864811879",
|
|
},
|
|
conversationId: "864811879",
|
|
sessionKey: "agent:main:main",
|
|
callbackId: "cb-78",
|
|
respond: {
|
|
editButtons: async () => {},
|
|
reply: async () => {},
|
|
},
|
|
})
|
|
|
|
assert.equal(handled, false)
|
|
})
|