Function refreshDbInternal

src/actions/refresh-db/index.ts:23–102

(userId?: string, email?: string)

};

export async function refreshDbInternal(userId?: string, email?: string) {
  if (!email) {
    return {
      error: true,
      message: 'You are not logged in',
    };
  }

  if (process.env.LOCAL_CMS_PROVIDER) {
    return { error: false, message: 'Refetched Courses' };
  }

  if (!userId) {
    return {
      error: true,
      message: 'You are not logged in',
    };
  }

  // Only allow user to refetch every minute
  if (await cache.get('rate-limit', [email])) {
    return {
      error: true,
      message: 'Wait sometime before refetching',
    };
  }

  const allCourses = (await getAllCourses()) as Course[];

  // Check which course the user has purchased
  const userCourses = await db.userPurchases.findMany({
    where: {
      userId,
    },
  });

  const coursesWithoutUser = allCourses
    .filter((course) => {
      return !userCourses.some(
        (userCourse) => userCourse.courseId === course.id,
      );
    })
    .filter((x) => APPX_COURSE_IDS.includes(x.id));

  const responses: Course[] = [];

  const promises = coursesWithoutUser
    .filter((x) => !x.openToEveryone)
    .map(async (course) => {
      const courseId = course.appxCourseId.toString();

      const data = await checkUserEmailForPurchase(email, courseId);

      if (data.data === '1') {
        responses.push(course);
      }
    });