chore: upgrade to v3.0.0 and add compatibility with new WhatsMeow provider

This commit updates the codebase to align with version v3.0.0 and introduces
support for a new WhatsMeow provider.
A compatible adapter is required and is available at:
https://github.com/mbap-dev/provider-whatsmeow

Author: mbap-dev

.gitignore

@@ -7,5 +7,7 @@ data/medias/*
 data/stores/*
 data/sessions/*
 .env
+.idea/*
+
 .yarn/*
 .yarnrc.yml

.tool-versions

@@ -0,0 +1,2 @@
+nodejs 24.7.0
+yarn 1.22.22

__tests__/jobs/timer.ts

@@ -7,7 +7,7 @@ const delLastTimerMock = delLastTimer as jest.MockedFunction<typeof delLastTimer
 
 describe('timer', () => {
   let incoming, job, payload, phone, to, message, time, sendSpy, mockGetLastTimer, incomingPayload
-  
+
   beforeEach(() => {
     incoming = mock<Incoming>()
     mockGetLastTimer = jest.fn()
@@ -17,21 +17,24 @@ describe('timer', () => {
     message = `${new Date().getTime()}s sdfhosfo`
     time = '2011-10-05T14:48:00.000Z'
     payload = {
-      phone, to, message, time
+      phone,
+      to,
+      message,
+      time,
     }
     sendSpy = jest.spyOn(incoming, 'send')
 
-    incomingPayload =[
+    incomingPayload = [
       phone,
       {
         messaging_product: 'whatsapp',
         to,
         type: 'text',
         text: {
-          body: message
-        } 
+          body: message,
+        },
       },
-      {}
+      {},
     ]
     delLastTimerMock.mockResolvedValue(Promise.resolve())
   })

__tests__/routes/blacklist.ts

@@ -24,8 +24,8 @@ describe('blacklist routes', () => {
     const reload = mock<Reload>()
     const logout = mock<Logout>()
     const app: App = new App(incoming, outgoing, '', getConfigTest, sessionStore, onNewLogin, addToBlacklist, reload, logout)
-    const res = await request(app.server).post('/2/blacklist/1').send({ttl: 1, to: '3'})
-    expect(addToBlacklist).toHaveBeenCalledWith('2', '1', '3', 1);
+    const res = await request(app.server).post('/2/blacklist/1').send({ ttl: 1, to: '3' })
+    expect(addToBlacklist).toHaveBeenCalledWith('2', '1', '3', 1)
     expect(res.status).toEqual(200)
   })
 })

__tests__/services/blacklist.ts

@@ -1,4 +1,3 @@
-
 jest.mock('../../src/services/redis')
 import { isInBlacklistInMemory, addToBlacklistInMemory, cleanBlackList, isInBlacklistInRedis } from '../../src/services/blacklist'
 import { redisGet, redisKeys, blacklist } from '../../src/services/redis'

__tests__/services/media_store_file.ts

@@ -8,12 +8,12 @@ const phone = `${new Date().getTime()}`
 const messageId = `wa.${new Date().getTime()}`
 const url = `http://somehost`
 const mimetype = 'text/plain'
-const extension = 'txt' 
+const extension = 'txt'
 
 const message = {
   messaging_product: 'whatsapp',
   id: `${phone}/${messageId}`,
-  mime_type: mimetype
+  mime_type: mimetype,
 }
 const dataStore = mock<DataStore>()
 // eslint-disable-next-line @typescript-eslint/no-unused-vars
@@ -25,15 +25,36 @@ describe('media routes', () => {
   let mediaStore: MediaStore
 
   beforeEach(() => {
-    dataStore.loadMediaPayload.mockReturnValue(new Promise((resolve) => resolve(message)))
+    dataStore.loadMediaPayload.mockReset()
     mediaStore = getMediaStoreFile(phone, defaultConfig, getTestDataStore)
   })
 
   test('getMedia', async () => {
+    dataStore.loadMediaPayload.mockResolvedValueOnce(message)
     const response = {
       url: `${url}/v15.0/download/${phone}/${messageId}.${extension}`,
-      ...message
+      ...message,
     }
     expect(await mediaStore.getMedia(url, messageId)).toStrictEqual(response)
   })
+
+  test('getMedia without mime type', async () => {
+    const payload = {
+      messaging_product: 'whatsapp',
+      id: `${phone}/${messageId}`,
+      filename: `${messageId}.${extension}`,
+    }
+    dataStore.loadMediaPayload.mockResolvedValueOnce(payload)
+    const response = {
+      url: `${url}/v15.0/download/${phone}/${messageId}.${extension}`,
+      ...payload,
+      mime_type: mimetype,
+    }
+    expect(await mediaStore.getMedia(url, messageId)).toStrictEqual(response)
+  })
+
+  test('getMedia not found', async () => {
+    dataStore.loadMediaPayload.mockResolvedValueOnce(undefined)
+    expect(await mediaStore.getMedia(url, messageId)).toBeUndefined()
+  })
 })

__tests__/services/outgoing_cloud_api.ts

@@ -49,7 +49,7 @@ describe('service outgoing whatsapp cloud api', () => {
     service = new OutgoingCloudApi(getConfig, isInBlacklistMock, addToBlacklistMock)
     textPayload = {
       text: {
-        body: 'test'
+        body: 'test',
       },
       type: 'text',
       to: 'abc',
@@ -63,8 +63,8 @@ describe('service outgoing whatsapp cloud api', () => {
               value: {
                 contacts: [{ wa_id }],
                 metadata: { display_phone_number: 'abc' },
-                messages: [ { from: 'abc' }, ]
-              }
+                messages: [{ from: 'abc' }],
+              },
             },
           ],
         },
@@ -77,7 +77,7 @@ describe('service outgoing whatsapp cloud api', () => {
           changes: [
             {
               value: {
-                statuses: [ { status: 'deleted' } ]
+                statuses: [{ status: 'deleted' }],
               },
             },
           ],

__tests__/services/session_store_file.ts

@@ -38,7 +38,7 @@ describe('service session store file', () => {
         return MAX_CONNECT_RETRY + 1
       }
       return getConnectCount(session)
-    } 
+    }
     expect(await store.verifyStatusStandBy(session)).toBe(true)
   })
   test('return a no standby on count and verify', async () => {
@@ -50,7 +50,7 @@ describe('service session store file', () => {
         return MAX_CONNECT_RETRY - 2
       }
       return getConnectCount(session)
-    } 
-    expect(!!await store.verifyStatusStandBy(session)).toBe(false)
+    }
+    expect(!!(await store.verifyStatusStandBy(session))).toBe(false)
   })
 })

__tests__/services/socket.ts

@@ -49,7 +49,7 @@ describe('service socket', () => {
       onNewLogin,
       attempts: 1,
       time: 1,
-      config: { ...defaultConfig, whatsappVersion }
+      config: { ...defaultConfig, whatsappVersion },
     })
     expect(response && response.status.attempt).toBe(1)
   })
@@ -65,7 +65,7 @@ describe('service socket', () => {
       onNewLogin,
       attempts: 1,
       time: 1,
-      config: { ...defaultConfig, whatsappVersion } 
+      config: { ...defaultConfig, whatsappVersion },
     })
     expect(mockOn).toHaveBeenCalled()
   })