Function updateLesson

src/features/lessons/db/lessons.ts:37–78

(
  id: string,
  data: Partial<typeof LessonTable.$inferInsert>
)

}

export async function updateLesson(
  id: string,
  data: Partial<typeof LessonTable.$inferInsert>
) {
  const [updatedLesson, courseId] = await db.transaction(async trx => {
    const currentLesson = await trx.query.LessonTable.findFirst({
      where: eq(LessonTable.id, id),
      columns: { sectionId: true },
    })

    if (
      data.sectionId != null &&
      currentLesson?.sectionId !== data.sectionId &&
      data.order == null
    ) {
      data.order = await getNextCourseLessonOrder(data.sectionId)
    }

    const [updatedLesson] = await trx
      .update(LessonTable)
      .set(data)
      .where(eq(LessonTable.id, id))
      .returning()
    if (updatedLesson == null) {
      trx.rollback()
      throw new Error("Failed to update lesson")
    }

    const section = await trx.query.CourseSectionTable.findFirst({
      columns: { courseId: true },
      where: eq(CourseSectionTable.id, updatedLesson.sectionId),
    })

    if (section == null) return trx.rollback()

    return [updatedLesson, section.courseId]
  })

  revalidateLessonCache({ courseId, id: updatedLesson.id })

  return updatedLesson
}

export async function deleteLesson(id: string) {
  const [deletedLesson, courseId] = await db.transaction(async trx => {