services/problem_set_service.go

package services

import (
	"context"
	"errors"

	entity "abdanhafidz.com/go-boilerplate/models/entity"
	"abdanhafidz.com/go-boilerplate/repositories"
	"github.com/google/uuid"
)

var (
	ErrProblemSetNotFound = errors.New("problem set not found")
	ErrQuestionNotFound   = errors.New("question not found")
)

type ProblemSetService interface {
	CreateProblemSet(ctx context.Context, ps entity.ProblemSet) error
	GetProblemSet(ctx context.Context, id uuid.UUID) (entity.ProblemSet, error)
	ListProblemSets(ctx context.Context) ([]entity.ProblemSet, error)
	UpdateProblemSet(ctx context.Context, ps entity.ProblemSet) error
	DeleteProblemSet(ctx context.Context, id uuid.UUID) error

	AddQuestion(ctx context.Context, q entity.Questions) error
	UpdateQuestion(ctx context.Context, q entity.Questions) error
	DeleteQuestion(ctx context.Context, qID uuid.UUID) error
	ListQuestions(ctx context.Context, psID uuid.UUID) ([]entity.Questions, error)

	AssignProblemSetToExam(ctx context.Context, examId uuid.UUID, problemSetId uuid.UUID) error
	RemoveAssignedProblemSet(ctx context.Context, assignId uuid.UUID) error
	GetQuestionById(ctx context.Context, qID uuid.UUID) (entity.Questions, error)
	ListQuestionsByExam(ctx context.Context, examId uuid.UUID) ([]entity.Questions, error)
}

type problemSetService struct {
	problemSetRepository           repositories.ProblemSetRepository
	questionsRepository            repositories.QuestionsRepository
	problemSetExamAssignRepository repositories.ProblemSetExamAssignRepository
}

func NewProblemSetService(
	problemSetRepository repositories.ProblemSetRepository,
	questionsRepository repositories.QuestionsRepository,
	problemSetExamAssignRepository repositories.ProblemSetExamAssignRepository,
) ProblemSetService {
	return &problemSetService{
		problemSetRepository:           problemSetRepository,
		questionsRepository:            questionsRepository,
		problemSetExamAssignRepository: problemSetExamAssignRepository,
	}
}

// ---------------- Problem Set CRUD ----------------

func (s *problemSetService) CreateProblemSet(ctx context.Context, ps entity.ProblemSet) error {
	return s.problemSetRepository.Create(ctx, ps)
}

func (s *problemSetService) GetProblemSet(ctx context.Context, id uuid.UUID) (entity.ProblemSet, error) {
	ps, err := s.problemSetRepository.Get(ctx, id)
	if err != nil {
		return entity.ProblemSet{}, ErrProblemSetNotFound
	}
	return ps, nil
}

func (s *problemSetService) ListProblemSets(ctx context.Context) ([]entity.ProblemSet, error) {
	return s.problemSetRepository.List(ctx)
}

func (s *problemSetService) UpdateProblemSet(ctx context.Context, ps entity.ProblemSet) error {
	_, err := s.problemSetRepository.Get(ctx, ps.Id)
	if err != nil {
		return ErrProblemSetNotFound
	}
	return s.problemSetRepository.Update(ctx, ps)
}

func (s *problemSetService) DeleteProblemSet(ctx context.Context, id uuid.UUID) error {
	_, err := s.problemSetRepository.Get(ctx, id)
	if err != nil {
		return ErrProblemSetNotFound
	}
	return s.problemSetRepository.Delete(ctx, id)
}

// ---------------- Questions ----------------

func (s *problemSetService) AddQuestion(ctx context.Context, q entity.Questions) error {
	_, err := s.problemSetRepository.Get(ctx, q.ProblemSetId)
	if err != nil {
		return ErrProblemSetNotFound
	}
	return s.questionsRepository.Create(ctx, q)
}

func (s *problemSetService) UpdateQuestion(ctx context.Context, q entity.Questions) error {
	_, err := s.questionsRepository.Get(ctx, q.Id)
	if err != nil {
		return ErrQuestionNotFound
	}
	return s.questionsRepository.Update(ctx, q)
}

func (s *problemSetService) DeleteQuestion(ctx context.Context, qID uuid.UUID) error {
	_, err := s.questionsRepository.Get(ctx, qID)
	if err != nil {
		return ErrQuestionNotFound
	}
	return s.questionsRepository.Delete(ctx, qID)
}

func (s *problemSetService) ListQuestions(ctx context.Context, psID uuid.UUID) ([]entity.Questions, error) {
	_, err := s.problemSetRepository.Get(ctx, psID)
	if err != nil {
		return nil, ErrProblemSetNotFound
	}
	return s.questionsRepository.ListByProblemSet(ctx, psID)
}

// ---------------- Exam ↔ Problem Set (Mapping Table) ----------------

func (s *problemSetService) AssignProblemSetToExam(ctx context.Context, examId uuid.UUID, problemSetId uuid.UUID) error {
	_, err := s.problemSetRepository.Get(ctx, problemSetId)
	if err != nil {
		return ErrProblemSetNotFound
	}

	assign := entity.ProblemSetExamAssign{
		Id:           uuid.New(),
		ExamId:       examId,
		ProblemSetId: problemSetId,
	}

	return s.problemSetExamAssignRepository.Create(ctx, assign)
}

func (s *problemSetService) RemoveAssignedProblemSet(ctx context.Context, assignId uuid.UUID) error {
	return s.problemSetExamAssignRepository.Delete(ctx, assignId)
}

func (s *problemSetService) GetQuestionById(ctx context.Context, qID uuid.UUID) (entity.Questions, error) {
	question, err := s.questionsRepository.Get(ctx, qID)
	if err != nil {
		return entity.Questions{}, err
	}
	return question, err
}

func (s *problemSetService) ListQuestionsByExam(ctx context.Context, examId uuid.UUID) ([]entity.Questions, error) {
	assign, err := s.problemSetExamAssignRepository.GetByExam(ctx, examId)
	if err != nil {
		return []entity.Questions{}, err
	}
	return s.questionsRepository.ListByProblemSet(ctx, assign.ProblemSetId)
}