Function create

apps/web/pages/api/user-thread-status/index.ts:31–113

(params: {
  threadIds: string[];
  userId: string;
  muted: boolean;
  read: boolean;
  reminder: boolean;
  reminderType?: ReminderTypes;
  communityId: string;
})

}

export async function create(params: {
  threadIds: string[];
  userId: string;
  muted: boolean;
  read: boolean;
  reminder: boolean;
  reminderType?: ReminderTypes;
  communityId: string;
}) {
  const body = createSchema.safeParse(params);
  if (!body.success) {
    return { status: 400, data: { error: body.error } };
  }

  const {
    threadIds,
    userId,
    muted,
    read,
    reminder,
    reminderType,
    communityId,
  } = params;

  const creation = muted || read || reminder;

  if (creation && threadIds.length > 0) {
    await prisma.$transaction([
      prisma.userThreadStatus.deleteMany({
        where: {
          userId,
          threadId: { in: threadIds },
        },
      }),
      prisma.userThreadStatus.createMany({
        data: threadIds.map((threadId) => {
          if (reminderType) {
            const remindAt = getRemindAt(reminderType);
            createRemindMeJob(`${threadId}_${userId}`, remindAt, {
              threadId,
              userId,
            });
            return {
              userId,
              threadId,
              muted,
              read,
              reminder,
              remindAt,
            };
          }
          return {
            userId,
            threadId,
            muted,
            read,
            reminder,
          };