fix set/load key

Author: clairton

src/services/client_baileys.ts

@@ -165,7 +165,6 @@ export class ClientBaileys implements Client {
           // eslint-disable-next-line @typescript-eslint/no-explicit-any
         } catch (error: any) {
           logger.error(error, 'Erro on send status')
-          await this.store?.dataStore?.setKey(id, waMessageKey)
           await this.onWebhookError(error)
         }
       } else {
@@ -211,7 +210,6 @@ export class ClientBaileys implements Client {
         await this.onWebhookError(error)
       }
     } else {
-      await this.store?.dataStore?.setKey(id, waMessageKey)
       await this.listener.process(this.phone, [waMessage], 'qrcode')
     }
   }
@@ -326,7 +324,6 @@ export class ClientBaileys implements Client {
           }
           const messageCallsWebhook = this.config.rejectCallsWebhook || this.config.messageCallsWebhook
           if (messageCallsWebhook) {
-            const id = uuid()
             const waMessageKey = {
               fromMe: false,
               id: uuid(),
@@ -338,7 +335,6 @@ export class ClientBaileys implements Client {
                 conversation: messageCallsWebhook,
               },
             }
-            await this.store?.dataStore?.setKey(id, waMessageKey)
             await this.listener.process(this.phone, [message], 'notify')
           }
           setTimeout(() => {

src/services/data_store_file.ts

@@ -107,14 +107,6 @@ const dataStoreFile = async (phone: string, config: Config): Promise<DataStore>
         }
       }
     })
-    ev.on('messages.update', (updates: WAMessageUpdate[]) => {
-      for (const update of updates) {
-        const { key } = update
-        if (key.id) {
-          dataStore.setKey(key.id, key)
-        }
-      }
-    })
     ev.on('contacts.upsert', async (contacts: Contact[]) => {
       logger.debug('contacts.upsert %s', phone, JSON.stringify(contacts))
       const { saveProfilePicture } = mediaStore

src/services/listener_baileys.ts

@@ -89,14 +89,13 @@ export class ListenerBaileys implements Listener {
     const store = await config.getStore(phone, config)
     if (messageType && !['update', 'receipt'].includes(messageType)) {
       i = await config.getMessageMetadata(i)
-      if (i.key && i.key.id) {
+      if (i.key && i.key) {
         const idUno = uuid()
-        const idBaileys = i.key.id
+        const idBaileys = i.key.id!
         await store?.dataStore.setUnoId(idBaileys, idUno)
         await store?.dataStore.setKey(idUno, i.key)
-        if (i.key.remoteJid) {
-          await store.dataStore.setMessage(i.key.remoteJid, i)
-        }
+        await store?.dataStore.setKey(idBaileys, i.key)
+        await store.dataStore.setMessage(i.key.remoteJid!, i)
         if (isSaveMedia(i)) {
           logger.debug(`Saving media...`)
           i = await store?.mediaStore.saveMedia(i)