Add extra check to markConversationRead
This commit is contained in:
parent
9229fca569
commit
94f318ea08
1 changed files with 7 additions and 4 deletions
|
@ -13,6 +13,7 @@ import { tapToViewMessagesDeletionService } from '../services/tapToViewMessagesD
|
||||||
import { isGroup, isDirectConversation } from './whatTypeOfConversation';
|
import { isGroup, isDirectConversation } from './whatTypeOfConversation';
|
||||||
import * as log from '../logging/log';
|
import * as log from '../logging/log';
|
||||||
import { getConversationIdForLogging } from './idForLogging';
|
import { getConversationIdForLogging } from './idForLogging';
|
||||||
|
import { isConversationAccepted } from './isConversationAccepted';
|
||||||
import { ReadStatus } from '../messages/MessageReadStatus';
|
import { ReadStatus } from '../messages/MessageReadStatus';
|
||||||
|
|
||||||
export async function markConversationRead(
|
export async function markConversationRead(
|
||||||
|
@ -134,10 +135,12 @@ export async function markConversationRead(
|
||||||
readSyncJobQueue.add({ readSyncs });
|
readSyncJobQueue.add({ readSyncs });
|
||||||
}
|
}
|
||||||
|
|
||||||
await readReceiptsJobQueue.addIfAllowedByUser(
|
if (isConversationAccepted(conversationAttrs)) {
|
||||||
window.storage,
|
await readReceiptsJobQueue.addIfAllowedByUser(
|
||||||
allReadMessagesSync
|
window.storage,
|
||||||
);
|
allReadMessagesSync
|
||||||
|
);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
expiringMessagesDeletionService.update();
|
expiringMessagesDeletionService.update();
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue