diff --git a/ts/jobs/normalMessageSendJobQueue.ts b/ts/jobs/normalMessageSendJobQueue.ts index 9545a5fe1..36a464c05 100644 --- a/ts/jobs/normalMessageSendJobQueue.ts +++ b/ts/jobs/normalMessageSendJobQueue.ts @@ -225,7 +225,7 @@ export class NormalMessageSendJobQueue extends JobQueue; @@ -453,9 +453,11 @@ function getMessageRecipients({ async function getMessageSendData({ conversation, + log, message, }: Readonly<{ conversation: ConversationModel; + log: LoggerType; message: MessageModel; }>): Promise<{ attachments: Array; @@ -469,8 +471,20 @@ async function getMessageSendData({ quote: WhatIsThis; sticker: WhatIsThis; }> { - const messageTimestamp = - message.get('sent_at') || message.get('timestamp') || Date.now(); + let messageTimestamp: number; + const sentAt = message.get('sent_at'); + const timestamp = message.get('timestamp'); + if (sentAt) { + messageTimestamp = sentAt; + } else if (timestamp) { + log.error('message lacked sent_at. Falling back to timestamp'); + messageTimestamp = timestamp; + } else { + log.error( + 'message lacked sent_at and timestamp. Falling back to current time' + ); + messageTimestamp = Date.now(); + } const [ attachmentsWithData,