Skip to content

Commit e335821

Browse files
committed
fix: duplicate message in the database
1 parent 8bf7ebe commit e335821

7 files changed

Lines changed: 51 additions & 2 deletions

File tree

.idea/.gitignore

Lines changed: 8 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

.idea/inspectionProfiles/Project_Default.xml

Lines changed: 6 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

.idea/modules.xml

Lines changed: 8 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

.idea/prettier.xml

Lines changed: 6 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

.idea/vcs.xml

Lines changed: 6 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

.idea/whatsapp-api.iml

Lines changed: 12 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

src/whatsapp/services/whatsapp.service.ts

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1324,8 +1324,6 @@ export class WAStartupService {
13241324
}
13251325
}
13261326

1327-
this.client.ev.emit('messages.upsert', { messages: [m], type: 'notify' });
1328-
13291327
return {
13301328
keyId: m.key.id,
13311329
keyFromMe: m.key.fromMe,
@@ -1355,9 +1353,14 @@ export class WAStartupService {
13551353
messageSent['externalAttributes'] = options?.externalAttributes;
13561354

13571355
this.ws.send(this.instance.name, 'send.message', messageSent);
1356+
this.ws.send(this.instance.name, 'messages.upsert', messageSent);
1357+
13581358
this.sendDataWebhook('sendMessage', messageSent).catch((error) =>
13591359
this.logger.error(error),
13601360
);
1361+
this.sendDataWebhook('messagesUpsert', messageSent).catch((error) =>
1362+
this.logger.error(error),
1363+
);
13611364

13621365
return messageSent;
13631366
} catch (error) {

0 commit comments

Comments
 (0)