diff --git a/extensions/signal/src/monitor/event-handler.system-messages.test.ts b/extensions/signal/src/monitor/event-handler.system-messages.test.ts new file mode 100644 index 00000000000..9b055f1c75f --- /dev/null +++ b/extensions/signal/src/monitor/event-handler.system-messages.test.ts @@ -0,0 +1,128 @@ +import { beforeEach, describe, expect, it, vi } from "vitest"; +import { createSignalEventHandler } from "./event-handler.js"; +import { + createBaseSignalEventHandlerDeps, + createSignalReceiveEvent, +} from "./event-handler.test-harness.js"; + +const { sendTypingMock, sendReadReceiptMock, dispatchInboundMessageMock } = vi.hoisted(() => ({ + sendTypingMock: vi.fn(), + sendReadReceiptMock: vi.fn(), + dispatchInboundMessageMock: vi.fn(async () => ({ + queuedFinal: false, + counts: { tool: 0, block: 0, final: 0 }, + })), +})); + +vi.mock("../send.js", () => ({ + sendMessageSignal: vi.fn(), + sendTypingSignal: sendTypingMock, + sendReadReceiptSignal: sendReadReceiptMock, +})); + +vi.mock("../../../../src/auto-reply/dispatch.js", async (importOriginal) => { + const actual = await importOriginal(); + return { + ...actual, + dispatchInboundMessage: dispatchInboundMessageMock, + dispatchInboundMessageWithDispatcher: dispatchInboundMessageMock, + dispatchInboundMessageWithBufferedDispatcher: dispatchInboundMessageMock, + }; +}); + +vi.mock("../../../../src/pairing/pairing-store.js", () => ({ + readChannelAllowFromStore: vi.fn().mockResolvedValue([]), + upsertChannelPairingRequest: vi.fn(), +})); + +function makeDeps() { + return createBaseSignalEventHandlerDeps({ + // oxlint-disable-next-line typescript/no-explicit-any + cfg: { messages: { inbound: { debounceMs: 0 } } } as any, + historyLimit: 0, + }); +} + +describe("signal system message filtering", () => { + beforeEach(() => { + sendTypingMock.mockReset().mockResolvedValue(true); + sendReadReceiptMock.mockReset().mockResolvedValue(true); + dispatchInboundMessageMock.mockClear(); + }); + + it("filters expiration timer update (expiresInSeconds, no text)", async () => { + const handler = createSignalEventHandler(makeDeps()); + await handler( + createSignalReceiveEvent({ + dataMessage: { + message: null, + attachments: [], + expiresInSeconds: 604800, + groupInfo: { groupId: "g1", groupName: "Test Group" }, + }, + }), + ); + expect(dispatchInboundMessageMock).not.toHaveBeenCalled(); + }); + + it("filters expiration timer update with isExpirationUpdate flag", async () => { + const handler = createSignalEventHandler(makeDeps()); + await handler( + createSignalReceiveEvent({ + dataMessage: { + message: null, + attachments: [], + isExpirationUpdate: true, + expiresInSeconds: 604800, + groupInfo: { groupId: "g1", groupName: "Test Group" }, + }, + }), + ); + expect(dispatchInboundMessageMock).not.toHaveBeenCalled(); + }); + + it("filters groupV2Change messages", async () => { + const handler = createSignalEventHandler(makeDeps()); + await handler( + createSignalReceiveEvent({ + dataMessage: { + message: null, + attachments: [], + groupV2Change: { editor: "+15550001111", changes: [] }, + groupInfo: { groupId: "g1", groupName: "Test Group" }, + }, + }), + ); + expect(dispatchInboundMessageMock).not.toHaveBeenCalled(); + }); + + it("does NOT filter normal message with expiresInSeconds=0", async () => { + const handler = createSignalEventHandler(makeDeps()); + await handler( + createSignalReceiveEvent({ + dataMessage: { + message: "hello", + attachments: [], + expiresInSeconds: 0, + groupInfo: { groupId: "g1", groupName: "Test Group" }, + }, + }), + ); + expect(dispatchInboundMessageMock).toHaveBeenCalled(); + }); + + it("does NOT filter message with text even if expiresInSeconds > 0", async () => { + const handler = createSignalEventHandler(makeDeps()); + await handler( + createSignalReceiveEvent({ + dataMessage: { + message: "hello with timer", + attachments: [], + expiresInSeconds: 604800, + groupInfo: { groupId: "g1", groupName: "Test Group" }, + }, + }), + ); + expect(dispatchInboundMessageMock).toHaveBeenCalled(); + }); +}); diff --git a/extensions/signal/src/monitor/event-handler.ts b/extensions/signal/src/monitor/event-handler.ts index 58ff8d4f8d7..0516f3f2194 100644 --- a/extensions/signal/src/monitor/event-handler.ts +++ b/extensions/signal/src/monitor/event-handler.ts @@ -562,6 +562,21 @@ export function createSignalEventHandler(deps: SignalEventHandlerDeps) { const groupName = dataMessage.groupInfo?.groupName ?? undefined; const isGroup = Boolean(groupId); + // Skip signal-cli system messages that have no user-visible content + const isTimerUpdate = + !messageText && + !quoteText && + !dataMessage.attachments?.length && + (dataMessage.isExpirationUpdate === true || + (typeof dataMessage.expiresInSeconds === "number" && dataMessage.expiresInSeconds > 0)); + const isGroupV2Change = Boolean(dataMessage.groupV2Change); + if (isTimerUpdate || isGroupV2Change) { + logVerbose( + `signal: skipping system message (isTimerUpdate=${isTimerUpdate}, isGroupV2Change=${isGroupV2Change})`, + ); + return; + } + if (!isGroup) { const allowedDirectMessage = await handleSignalDirectMessageAccess({ dmPolicy: deps.dmPolicy, diff --git a/extensions/signal/src/monitor/event-handler.types.ts b/extensions/signal/src/monitor/event-handler.types.ts index 4ccb85cde5d..3ceddc0fe2f 100644 --- a/extensions/signal/src/monitor/event-handler.types.ts +++ b/extensions/signal/src/monitor/event-handler.types.ts @@ -39,6 +39,9 @@ export type SignalDataMessage = { } | null; quote?: { text?: string | null } | null; reaction?: SignalReactionMessage | null; + expiresInSeconds?: number | null; + groupV2Change?: Record | null; + isExpirationUpdate?: boolean | null; }; export type SignalReactionMessage = {