WhatsApp: mark offline/history messages as read

src/web/inbound.ts

@@ -130,7 +130,7 @@ export async function monitorWebInbox(options: {
     type?: string;
     messages?: Array<import("@whiskeysockets/baileys").WAMessage>;
   }) => {
-    if (upsert.type !== "notify") return;
+    if (upsert.type !== "notify" && upsert.type !== "append") return;
     for (const msg of upsert.messages ?? []) {
       const id = msg.key?.id ?? undefined;
       // De-dupe on message id; Baileys can emit retries.
@@ -205,6 +205,10 @@ export async function monitorWebInbox(options: {
         logVerbose(`Self-chat mode: skipping read receipt for ${id}`);
       }
 
+      // If this is history/offline catch-up, we marked it as read above,
+      // but we skip triggering the auto-reply logic to avoid spamming old context.
+      if (upsert.type === "append") continue;
+
       let body = extractText(msg.message ?? undefined);
       if (!body) {
         body = extractMediaPlaceholder(msg.message ?? undefined);

src/web/monitor-inbox.test.ts

@@ -842,3 +842,39 @@ it("defaults to self-only when no config is present", async () => {
 
   await listener.close();
 });
+
+it("handles append messages by marking them read but skipping auto-reply", async () => {
+  const onMessage = vi.fn();
+  const listener = await monitorWebInbox({ verbose: false, onMessage });
+  const sock = await createWaSocket();
+
+  const upsert = {
+    type: "append",
+    messages: [
+      {
+        key: { id: "history1", fromMe: false, remoteJid: "999@s.whatsapp.net" },
+        message: { conversation: "old message" },
+        messageTimestamp: 1_700_000_000,
+        pushName: "History Sender",
+      },
+    ],
+  };
+
+  sock.ev.emit("messages.upsert", upsert);
+  await new Promise((resolve) => setImmediate(resolve));
+
+  // Verify it WAS marked as read
+  expect(sock.readMessages).toHaveBeenCalledWith([
+    {
+      remoteJid: "999@s.whatsapp.net",
+      id: "history1",
+      participant: undefined,
+      fromMe: false,
+    },
+  ]);
+
+  // Verify it WAS NOT passed to onMessage
+  expect(onMessage).not.toHaveBeenCalled();
+
+  await listener.close();
+});