colin/Signal-Desktop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Grab most recent attributes when saving messages in batchers

Browse Source
This commit is contained in:
trevor-signal
2023-12-15 13:04:08 -05:00
committed by GitHub
parent 36c4c6bfb0
commit a03aab14cb
1 changed files with 14 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
ts/util/messageBatcher.ts
View File

@@ -12,7 +12,13 @@ const updateMessageBatcher = createBatcher<MessageAttributesType>({
maxSize: 50, maxSize: 50,
processBatch: async (messageAttrs: Array<MessageAttributesType>) => { processBatch: async (messageAttrs: Array<MessageAttributesType>) => {
log.info('updateMessageBatcher', messageAttrs.length); log.info('updateMessageBatcher', messageAttrs.length);
await window.Signal.Data.saveMessages(messageAttrs, {
// Grab the latest from the cache in case they've changed
const messagesToSave = messageAttrs.map(
message => window.MessageCache.accessAttributes(message.id) ?? message
);
await window.Signal.Data.saveMessages(messagesToSave, {
ourAci: window.textsecure.storage.user.getCheckedAci(), ourAci: window.textsecure.storage.user.getCheckedAci(),
}); });
}, },
@@ -40,7 +46,13 @@ export const saveNewMessageBatcher = createWaitBatcher<MessageAttributesType>({
maxSize: 30, maxSize: 30,
processBatch: async (messageAttrs: Array<MessageAttributesType>) => { processBatch: async (messageAttrs: Array<MessageAttributesType>) => {
log.info('saveNewMessageBatcher', messageAttrs.length); log.info('saveNewMessageBatcher', messageAttrs.length);
await window.Signal.Data.saveMessages(messageAttrs, {
// Grab the latest from the cache in case they've changed
const messagesToSave = messageAttrs.map(
message => window.MessageCache.accessAttributes(message.id) ?? message
);
await window.Signal.Data.saveMessages(messagesToSave, {
forceSave: true, forceSave: true,
ourAci: window.textsecure.storage.user.getCheckedAci(), ourAci: window.textsecure.storage.user.getCheckedAci(),
}); });