fix(events): detect premium/lottie stickers wrapped in lottieStickerMessage

Author: zeative

src/events/decoders/messages.ts

@@ -80,6 +80,7 @@ const WRAPPER_FIELDS = [
   'viewOnceMessageV2Extension',
   'documentWithCaptionMessage',
   'editedMessage',
+  'lottieStickerMessage',
 ] as const
 
 const unwrap = (content: Record<string, unknown>): Record<string, unknown> => {
@@ -99,6 +100,13 @@ const unwrap = (content: Record<string, unknown>): Record<string, unknown> => {
   return node
 }
 
+const unwrappedMessage = (msg: WAMessage): WAMessage => {
+  const content = asRecord(msg.message)
+  if (content == null) return msg
+  const inner = unwrap(content)
+  return inner === content ? msg : ({ ...msg, message: inner } as WAMessage)
+}
+
 const richResponseText = (content: Record<string, unknown>): string | null => {
   const forwarded = asRecord(asRecord(asRecord(content['botForwardedMessage'])?.['message'])?.['richResponseMessage'])
   const rich = forwarded ?? asRecord(content['richResponseMessage'])
@@ -480,12 +488,12 @@ const anyText = (msg: WAMessage): string | null => {
 }
 
 const contextInfoOf = (msg: WAMessage): WAContextInfo | null => {
-  const content = msg.message
+  const content = asRecord(unwrappedMessage(msg).message)
   if (content == null) return null
-  const ext = content.extendedTextMessage?.contextInfo
+  const ext = asRecord(content['extendedTextMessage'])?.['contextInfo'] as WAContextInfo | undefined
   if (ext != null) return ext
   for (const field of Object.values(MEDIA_FIELD)) {
-    const node = (content as Record<string, unknown>)[field]
+    const node = content[field]
     if (node != null && typeof node === 'object') {
       const ci = (node as { contextInfo?: WAContextInfo | null }).contextInfo
       if (ci != null) return ci
@@ -729,10 +737,11 @@ const buildMediaAttachment = (
   kind: MediaKind,
   ctx: DecodeContext,
 ): MediaAttachment | null => {
-  const node = mediaNodeOf(msg, kind)
+  const norm = unwrappedMessage(msg)
+  const node = mediaNodeOf(norm, kind)
   if (node === null) return null
-  const bufferFn = createDownloadFn(msg, kind, ctx.logger)
-  const streamFn = createStreamFn(msg, kind, ctx.logger)
+  const bufferFn = createDownloadFn(norm, kind, ctx.logger)
+  const streamFn = createStreamFn(norm, kind, ctx.logger)
   return {
     type: kind,
     mimetype: typeof node.mimetype === 'string' ? node.mimetype : null,

tests/events/decoders/messages.test.ts

@@ -22,6 +22,7 @@ const {
   decodeAudio,
   decodeDocument,
   decodeSticker,
+  decodeMessage,
   decodeMention,
   decodeMentionAll,
 } = await import('../../../src/events/decoders/messages.js')
@@ -328,6 +329,30 @@ describe('decodeSticker', () => {
     expect(out?.chatType).toBe('sticker')
     expect(out?.media).toBeDefined()
   })
+  it('decodes a premium/lottie sticker wrapped in lottieStickerMessage', () => {
+    const lottie = base({
+      message: {
+        messageContextInfo: { messageSecret: 'secret' },
+        lottieStickerMessage: {
+          message: {
+            stickerMessage: {
+              mimetype: 'application/was',
+              fileLength: '31525',
+              isAnimated: true,
+              isLottie: true,
+              mediaKey: 'k',
+              url: 'https://mmg.whatsapp.net/x.enc',
+              directPath: '/v/x.enc',
+            },
+          },
+        },
+      },
+    } as unknown as Partial<WAMessage>)
+    const sticker = decodeSticker(lottie, ctx)
+    expect(sticker?.chatType).toBe('sticker')
+    expect(sticker?.media?.type).toBe('sticker')
+    expect(decodeMessage(lottie, ctx)?.chatType).toBe('sticker')
+  })
   it('returns null without stickerMessage', () => {
     expect(decodeSticker(base({ message: {} }), ctx)).toBeNull()
   })