nyrn
/
openclaw
mirror of https://github.com/openclaw/openclaw.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

test: dedupe msteams revoked thread context

This commit is contained in:
Peter Steinberger 2026-03-13 22:01:37 +00:00
parent 40b0cbd713
commit 2ebc7e3ded
1 changed files with 18 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
extensions/msteams/src/messenger.test.ts
View File

@ -139,6 +139,22 @@ describe("msteams messenger", () => {
}); });
describe("sendMSTeamsMessages", () => { describe("sendMSTeamsMessages", () => {
function createRevokedThreadContext(params?: { failAfterAttempt?: number; sent?: string[] }) {
let attempt = 0;
return {
sendActivity: async (activity: unknown) => {
const { text } = activity as { text?: string };
const content = text ?? "";
attempt += 1;
if (params?.failAfterAttempt && attempt < params.failAfterAttempt) {
params.sent?.push(content);
return { id: `id:${content}` };
}
throw new TypeError(REVOCATION_ERROR);
},
};
}
const baseRef: StoredConversationReference = { const baseRef: StoredConversationReference = {
activityId: "activity123", activityId: "activity123",
user: { id: "user123", name: "User" }, user: { id: "user123", name: "User" },
@ -305,13 +321,7 @@ describe("msteams messenger", () => {
it("falls back to proactive messaging when thread context is revoked", async () => { it("falls back to proactive messaging when thread context is revoked", async () => {
const proactiveSent: string[] = []; const proactiveSent: string[] = [];
const ctx = createRevokedThreadContext();
const ctx = {
sendActivity: async () => {
throw new TypeError(REVOCATION_ERROR);
},
};
const adapter = createFallbackAdapter(proactiveSent); const adapter = createFallbackAdapter(proactiveSent);
const ids = await sendMSTeamsMessages({ const ids = await sendMSTeamsMessages({
@ -331,21 +341,7 @@ describe("msteams messenger", () => {
it("falls back only for remaining thread messages after context revocation", async () => { it("falls back only for remaining thread messages after context revocation", async () => {
const threadSent: string[] = []; const threadSent: string[] = [];
const proactiveSent: string[] = []; const proactiveSent: string[] = [];
let attempt = 0; const ctx = createRevokedThreadContext({ failAfterAttempt: 2, sent: threadSent });
const ctx = {
sendActivity: async (activity: unknown) => {
const { text } = activity as { text?: string };
const content = text ?? "";
attempt += 1;
if (attempt === 1) {
threadSent.push(content);
return { id: `id:${content}` };
}
throw new TypeError(REVOCATION_ERROR);
},
};
const adapter = createFallbackAdapter(proactiveSent); const adapter = createFallbackAdapter(proactiveSent);
const ids = await sendMSTeamsMessages({ const ids = await sendMSTeamsMessages({