github/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-04-19 07:57:28 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor: share chat abort auth invocation

Browse Source
This commit is contained in:
Peter Steinberger
2026-03-13 19:10:51 +00:00
parent f201bad372
commit 1fe261f92f
1 changed files with 32 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

46
src/gateway/server-methods/chat.abort-authorization.test.ts
View File

@@ -6,6 +6,30 @@ import {
} from "./chat.abort.test-helpers.js"; } from "./chat.abort.test-helpers.js";
import { chatHandlers } from "./chat.js"; import { chatHandlers } from "./chat.js";
async function invokeSingleRunAbort({
context,
runId = "run-1",
connId,
deviceId,
scopes,
}: {
context: ReturnType<typeof createChatAbortContext>;
runId?: string;
connId: string;
deviceId: string;
scopes: string[];
}) {
return await invokeChatAbortHandler({
handler: chatHandlers["chat.abort"],
context,
request: { sessionKey: "main", runId },
client: {
connId,
connect: { device: { id: deviceId }, scopes },
},
});
}
describe("chat.abort authorization", () => { describe("chat.abort authorization", () => {
it("rejects explicit run aborts from other clients", async () => { it("rejects explicit run aborts from other clients", async () => {
const context = createChatAbortContext({ const context = createChatAbortContext({
@@ -17,14 +41,11 @@ describe("chat.abort authorization", () => {
]), ]),
}); });
const respond = await invokeChatAbortHandler({ const respond = await invokeSingleRunAbort({
handler: chatHandlers["chat.abort"],
context, context,
request: { sessionKey: "main", runId: "run-1" }, connId: "conn-other",
client: { deviceId: "dev-other",
connId: "conn-other", scopes: ["operator.write"],
connect: { device: { id: "dev-other" }, scopes: ["operator.write"] },
},
}); });
const [ok, payload, error] = respond.mock.calls.at(-1) ?? []; const [ok, payload, error] = respond.mock.calls.at(-1) ?? [];
@@ -92,14 +113,11 @@ describe("chat.abort authorization", () => {
]), ]),
}); });
const respond = await invokeChatAbortHandler({ const respond = await invokeSingleRunAbort({
handler: chatHandlers["chat.abort"],
context, context,
request: { sessionKey: "main", runId: "run-1" }, connId: "conn-admin",
client: { deviceId: "dev-admin",
connId: "conn-admin", scopes: ["operator.admin"],
connect: { device: { id: "dev-admin" }, scopes: ["operator.admin"] },
},
}); });
const [ok, payload] = respond.mock.calls.at(-1) ?? []; const [ok, payload] = respond.mock.calls.at(-1) ?? [];