feat(cloud): parse inbound reply context so msg.replied() resolves on cloud

Author: zeative

src/cloud/translate/inbound.ts

@@ -151,13 +151,38 @@ const contactsNode = (msg: CloudWebhookMessage): Record<string, unknown> | null
   return { contactsArrayMessage: { displayName: `${cards.length} contacts`, contacts: cards } }
 }
 
+/**
+ * Attach a baileys-shaped contextInfo (from Meta's `context: { id, from }`) so the decoder can
+ * resolve the quoted message via the store — enables `msg.replied()` on cloud replies. A stub
+ * `quotedMessage` is required to enter the decoder's resolve branch (it looks up by stanzaId).
+ */
+const applyQuotedContext = (
+  message: Record<string, unknown>,
+  msg: CloudWebhookMessage,
+): Record<string, unknown> => {
+  const context = msg['context'] as { id?: string; from?: string } | undefined
+  if (!context?.id) return message
+  const contextInfo = {
+    stanzaId: context.id,
+    ...(context.from ? { participant: toJid(context.from) } : {}),
+    quotedMessage: {},
+  }
+  if (typeof message['conversation'] === 'string') {
+    return { extendedTextMessage: { text: message['conversation'], contextInfo } }
+  }
+  const key = Object.keys(message)[0]
+  if (key) (message[key] as Record<string, unknown>)['contextInfo'] = contextInfo
+  return message
+}
+
 const translateMessage = (msg: CloudWebhookMessage, value: CloudWebhookValue): WAMessage | null => {
   if (!msg.id || !msg.from) return null
-  const message: Record<string, unknown> | null =
+  const node: Record<string, unknown> | null =
     msg.type === 'text' && typeof msg.text?.body === 'string'
       ? { conversation: msg.text.body }
       : (mediaNode(msg) ?? interactiveNode(msg) ?? locationNode(msg) ?? contactsNode(msg))
-  if (message === null) return null
+  if (node === null) return null
+  const message = applyQuotedContext(node, msg)
   const pushName = contactName(value, msg.from)
   return {
     key: { id: msg.id, remoteJid: toJid(msg.from), fromMe: false },

tests/integration/cloud-receive-text.test.ts

@@ -107,3 +107,35 @@ describe('integration: cloud webhook without connect()', () => {
     expect(texts[0]?.text).toBe('halo bot')
   })
 })
+
+describe('integration: cloud inbound quoted/context parsing', () => {
+  function reply(quotedId: string) {
+    return post(JSON.stringify({
+      object: 'whatsapp_business_account',
+      entry: [{ id: 'W', changes: [{ field: 'messages', value: {
+        messaging_product: 'whatsapp', metadata: { phone_number_id: '555' },
+        contacts: [{ profile: { name: 'Budi' }, wa_id: '628111000222' }],
+        messages: [{ from: '628111000222', id: 'wamid.REPLY', timestamp: '1752350000',
+          type: 'text', text: { body: 'setuju' }, context: { from: '555', id: quotedId } }],
+      } }] }],
+    }))
+  }
+
+  it('a reply carries context.id → msg.replied() resolves the stored original', async () => {
+    const c = await connectedClient()
+    // bot sends a message first → stored under its wamid
+    fetchMock.mockResolvedValueOnce(new Response(JSON.stringify({ messages: [{ id: 'wamid.ORIG' }] }), { status: 200 }))
+    await c.send('628111000222').text('pertanyaan?')
+    await new Promise((r) => setTimeout(r, 5))
+
+    let quoted: MessageContext | null = null
+    const done = new Promise<void>((resolve) => {
+      c.on('text', async (m) => { if (m.text === 'setuju') { quoted = await m.replied(); resolve() } })
+    })
+    await c.webhook()(reply('wamid.ORIG'))
+    await done
+    expect(quoted).not.toBeNull()
+    expect(quoted?.chatId).toBe('wamid.ORIG')
+    expect(quoted?.text).toBe('pertanyaan?')
+  })
+})