franpcode/Baileys
1
0
Fork 0
mirror of https://github.com/FranP-code/Baileys.git synced 2025-10-13 00:32:22 +00:00
Code Issues Packages Projects Releases Wiki Activity

message ordering bug fix

Browse Source
This commit is contained in:
Adhiraj
2020-10-05 23:13:03 +05:30
parent c0ca27dc2f
commit 9c34f35a7b
4 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/Tests/Tests.Messages.ts
View File

@@ -1,4 +1,4 @@
import { MessageType, Mimetype, delay, promiseTimeout, WA_MESSAGE_STATUS_TYPE, WAMessageStatusUpdate, MessageOptions, toNumber } from '../WAConnection/WAConnection' import { MessageType, Mimetype, delay, promiseTimeout, WA_MESSAGE_STATUS_TYPE, WAMessageStatusUpdate } from '../WAConnection/WAConnection'
import {promises as fs} from 'fs' import {promises as fs} from 'fs'
import * as assert from 'assert' import * as assert from 'assert'
import { WAConnectionTest, testJid, sendAndRetreiveMessage, assertChatDBIntegrity } from './Common' import { WAConnectionTest, testJid, sendAndRetreiveMessage, assertChatDBIntegrity } from './Common'

4
src/WAConnection/3.Connect.ts
View File

@@ -195,13 +195,15 @@ export class WAConnection extends Base {
const messages = json[2] as WANode[] const messages = json[2] as WANode[]
if (messages) { if (messages) {
messages.reverse().forEach (([,, message]: ['message', null, WAMessage]) => { messages.reverse().forEach (([,, message]: ['message', null, WAMessage]) => {
const jid = message.key.remoteJid const jid = message.key.remoteJid
const chat = chats.get(jid) const chat = chats.get(jid)
if (chat) { if (chat) {
const fm = chat.messages.all()[0] const fm = chat.messages.all()[0]
const prevEpoch = (fm && fm['epoch']) || 0
const prevEpoch = (fm && fm['epoch']) || 0
message['epoch'] = prevEpoch-1 message['epoch'] = prevEpoch-1
chat.messages.insert (message) chat.messages.insert (message)
} }

2
src/WAConnection/Utils.ts
View File

@@ -30,7 +30,7 @@ export const waChatKey = (pin: boolean) => ({
compare: (k1: string, k2: string) => k2.localeCompare (k1) compare: (k1: string, k2: string) => k2.localeCompare (k1)
}) })
export const waMessageKey = { export const waMessageKey = {
key: (m: WAMessage) => toNumber (m.messageTimestamp).toString(16).padStart(8, '0') + (5000 + (m['epoch'] || 0)).toString(16), key: (m: WAMessage) => (5000 + (m['epoch'] || 0)).toString(16) + toNumber (m.messageTimestamp).toString(16).padStart(8, '0'),
compare: (k1: string, k2: string) => k1.localeCompare (k2) compare: (k1: string, k2: string) => k1.localeCompare (k2)
} }
export const WA_MESSAGE_ID = (m: WAMessage) => GET_MESSAGE_ID (m.key) export const WA_MESSAGE_ID = (m: WAMessage) => GET_MESSAGE_ID (m.key)

1
tsconfig.json
View File

@@ -9,6 +9,7 @@
"strict": false, "strict": false,
"noImplicitThis": true, "noImplicitThis": true,
"esModuleInterop": true, "esModuleInterop": true,
"resolveJsonModule": true,
"forceConsistentCasingInFileNames": true, "forceConsistentCasingInFileNames": true,
"declaration": true, "declaration": true,
"lib": ["es2019", "esnext.array"] "lib": ["es2019", "esnext.array"]