store fixes

This commit is contained in:
Adhiraj Singh
2021-07-20 20:03:53 +05:30
parent cd127dbca9
commit 5f8106d4e0

View File

@@ -208,17 +208,18 @@ export default(
} else { } else {
messages = list.array messages = list.array
} }
const diff = count - messages.length const diff = count - messages.length
if (diff < 0) { if (diff < 0) {
messages = messages.slice(-count) // get the last X messages messages = messages.slice(-count) // get the last X messages
} else if (diff > 0) { } else if (diff > 0) {
const [fMessage] = messages const [fMessage] = messages
const extra = await retrieve (diff, { before: fMessage?.key || cursorKey }) const cursor = { before: fMessage?.key || cursorKey }
const extra = await retrieve (diff, cursor)
// add to DB // add to DB
for(let i = extra.length-1; i >= 0;i--) { for(let i = extra.length-1; i >= 0;i--) {
list.upsert(extra[i], 'prepend') list.upsert(extra[i], 'prepend')
} }
messages.splice(0, 0, ...extra)
} }
} else messages = await retrieve(count, cursor) } else messages = await retrieve(count, cursor)