Added debug log entry before enqueuing DOE job
This commit is contained in:
parent
79757f22aa
commit
9a2cbf9a51
1 changed files with 9 additions and 3 deletions
|
@ -56,6 +56,15 @@ export async function sendDeleteForEveryoneMessage(
|
||||||
),
|
),
|
||||||
});
|
});
|
||||||
|
|
||||||
|
const conversationIdForLogging = getConversationIdForLogging(
|
||||||
|
conversationAttributes
|
||||||
|
);
|
||||||
|
|
||||||
|
log.info(
|
||||||
|
`sendDeleteForEveryoneMessage: enqueing DeleteForEveryone: ${idForLogging} ` +
|
||||||
|
`in conversation ${conversationIdForLogging}`
|
||||||
|
);
|
||||||
|
|
||||||
try {
|
try {
|
||||||
const jobData: ConversationQueueJobData = {
|
const jobData: ConversationQueueJobData = {
|
||||||
type: conversationQueueJobEnum.enum.DeleteForEveryone,
|
type: conversationQueueJobEnum.enum.DeleteForEveryone,
|
||||||
|
@ -66,9 +75,6 @@ export async function sendDeleteForEveryoneMessage(
|
||||||
targetTimestamp,
|
targetTimestamp,
|
||||||
};
|
};
|
||||||
await conversationJobQueue.add(jobData, async jobToInsert => {
|
await conversationJobQueue.add(jobData, async jobToInsert => {
|
||||||
const conversationIdForLogging = getConversationIdForLogging(
|
|
||||||
conversationAttributes
|
|
||||||
);
|
|
||||||
log.info(
|
log.info(
|
||||||
`sendDeleteForEveryoneMessage: Deleting message ${idForLogging} ` +
|
`sendDeleteForEveryoneMessage: Deleting message ${idForLogging} ` +
|
||||||
`in conversation ${conversationIdForLogging} with job ${jobToInsert.id}`
|
`in conversation ${conversationIdForLogging} with job ${jobToInsert.id}`
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue