Function task

packages/queue/src/tasks/remind-me-later.ts:16–55

(payload: Payload, logger: Logger)

}

async function task(payload: Payload, logger: Logger) {
  const { threadId, userId } = payload;
  logger.info({ 'Setting remind me later for thread': threadId, user: userId });
  const status = await prisma.userThreadStatus.findFirst({
    where: {
      threadId,
      userId,
      reminder: true,
    },
  });

  if (status) {
    await prisma.userThreadStatus.deleteMany({
      where: {
        threadId,
        userId,
        reminder: true,
      },
    });

    const thread = await prisma.threads.findUnique({
      where: { id: threadId },
      include: { messages: true },
    });
    if (thread && thread.messages.length > 0) {
      const message = thread.messages[0];
      try {
        await push({
          channelId: thread.channelId,
          threadId,
          messageId: message.id,
          isThread: true,
          isReply: false,
        });
      } catch (exception) {}

      logger.info({ 'Push websocket for thread': threadId });
    }
  }
}