openclaw/src/auto-reply/reply/reply-payloads.test.ts
Yaroslav Boiko 838259331f fix(discord): add media dedup production code for messaging tool pipeline
Wire media URL tracking through the embedded agent pipeline so that
media already sent via messaging tools is not delivered again by the
reply dispatcher.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
2026-02-16 23:51:51 +01:00

62 lines
2.2 KiB
TypeScript

import { describe, expect, it } from "vitest";
import { filterMessagingToolMediaDuplicates } from "./reply-payloads.js";
describe("filterMessagingToolMediaDuplicates", () => {
it("strips mediaUrl when it matches sentMediaUrls", () => {
const result = filterMessagingToolMediaDuplicates({
payloads: [{ text: "hello", mediaUrl: "file:///tmp/photo.jpg" }],
sentMediaUrls: ["file:///tmp/photo.jpg"],
});
expect(result).toEqual([{ text: "hello", mediaUrl: undefined, mediaUrls: undefined }]);
});
it("preserves mediaUrl when it is not in sentMediaUrls", () => {
const result = filterMessagingToolMediaDuplicates({
payloads: [{ text: "hello", mediaUrl: "file:///tmp/photo.jpg" }],
sentMediaUrls: ["file:///tmp/other.jpg"],
});
expect(result).toEqual([{ text: "hello", mediaUrl: "file:///tmp/photo.jpg" }]);
});
it("filters matching entries from mediaUrls array", () => {
const result = filterMessagingToolMediaDuplicates({
payloads: [
{
text: "gallery",
mediaUrls: ["file:///tmp/a.jpg", "file:///tmp/b.jpg", "file:///tmp/c.jpg"],
},
],
sentMediaUrls: ["file:///tmp/b.jpg"],
});
expect(result).toEqual([
{ text: "gallery", mediaUrls: ["file:///tmp/a.jpg", "file:///tmp/c.jpg"] },
]);
});
it("clears mediaUrls when all entries match", () => {
const result = filterMessagingToolMediaDuplicates({
payloads: [{ text: "gallery", mediaUrls: ["file:///tmp/a.jpg"] }],
sentMediaUrls: ["file:///tmp/a.jpg"],
});
expect(result).toEqual([{ text: "gallery", mediaUrl: undefined, mediaUrls: undefined }]);
});
it("returns payloads unchanged when no media present", () => {
const payloads = [{ text: "plain text" }];
const result = filterMessagingToolMediaDuplicates({
payloads,
sentMediaUrls: ["file:///tmp/photo.jpg"],
});
expect(result).toStrictEqual(payloads);
});
it("returns payloads unchanged when sentMediaUrls is empty", () => {
const payloads = [{ text: "hello", mediaUrl: "file:///tmp/photo.jpg" }];
const result = filterMessagingToolMediaDuplicates({
payloads,
sentMediaUrls: [],
});
expect(result).toBe(payloads);
});
});