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

Pass a promise on loadMessage

Browse Source 
I've changed because i need to write to files a big chat history and appendFileSync is deprecated
This commit is contained in:
Fr4nZ82
2020-11-14 04:28:29 +01:00
committed by GitHub
parent 6d02d405a7
commit 9a4b755bd6
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/WAConnection/7.MessagesExtra.ts
View File

@@ -144,7 +144,7 @@ export class WAConnection extends Base {
* @param chunkSize the number of messages to load in a single request * @param chunkSize the number of messages to load in a single request
* @param mostRecentFirst retreive the most recent message first or retreive from the converation start * @param mostRecentFirst retreive the most recent message first or retreive from the converation start
*/ */
loadAllMessages(jid: string, onMessage: (m: WAMessage) => void, chunkSize = 25, mostRecentFirst = true) { loadAllMessages(jid: string, onMessage: (m: WAMessage) => Promise<void>, chunkSize = 25, mostRecentFirst = true) {
let offsetID = null let offsetID = null
const loadMessage = async () => { const loadMessage = async () => {
const {messages} = await this.loadMessages(jid, chunkSize, offsetID, mostRecentFirst) const {messages} = await this.loadMessages(jid, chunkSize, offsetID, mostRecentFirst)
@@ -152,12 +152,12 @@ export class WAConnection extends Base {
let lastMessage let lastMessage
if (mostRecentFirst) { if (mostRecentFirst) {
for (let i = messages.length - 1; i >= 0; i--) { for (let i = messages.length - 1; i >= 0; i--) {
onMessage(messages[i]) await onMessage(messages[i])
lastMessage = messages[i] lastMessage = messages[i]
} }
} else { } else {
for (let i = 0; i < messages.length; i++) { for (let i = 0; i < messages.length; i++) {
onMessage(messages[i]) await onMessage(messages[i])
lastMessage = messages[i] lastMessage = messages[i]
} }
} }