from sqlalchemy.orm import Session

from app.domain.models.lessons import Lesson


class LessonsRepository:
    def __init__(self, db: Session):
        self.db = db

    def get_all(self):
        return self.db.query(Lesson).all()

    def get_by_id(self, lesson_id: int):
        return self.db.query(Lesson).filter(Lesson.id == lesson_id).first()

    def create(self, lesson: Lesson):
        self.db.add(lesson)
        self.db.commit()
        self.db.refresh(lesson)
        return lesson

    def update(self, lesson: Lesson):
        self.db.merge(lesson)
        self.db.commit()
        self.db.refresh(lesson)
        return lesson

    def delete(self, lesson_id: int):
        lesson = self.db.query(Lesson).filter(Lesson.id == lesson_id).first()
        if lesson:
            self.db.delete(lesson)
            self.db.commit()
            return lesson

        return None