student_usecase_audio.go

//go:generate mockery --output mock --name StudentUsecaseAudio
package student

import (
	"context"
	"errors"

	"github.com/kujilabo/cocotola/cocotola-api/src/app/domain"
	"github.com/kujilabo/cocotola/cocotola-api/src/app/service"
	userD "github.com/kujilabo/cocotola/cocotola-api/src/user/domain"
	libD "github.com/kujilabo/cocotola/lib/domain"
	liberrors "github.com/kujilabo/cocotola/lib/errors"
	"github.com/kujilabo/cocotola/lib/log"
)

type StudentUsecaseAudio interface {
	FindAudioByID(ctx context.Context, organizationID userD.OrganizationID, operatorID userD.AppUserID, workbookID domain.WorkbookID, problemID domain.ProblemID, audioID domain.AudioID) (service.Audio, error)
}

type studentUsecaseAudio struct {
	transaction       service.Transaction
	pf                service.ProcessorFactory
	synthesizerClient service.SynthesizerClient
	findStudentFunc   FindStudentFunc
}

func NewStudentUsecaseAudio(transaction service.Transaction, pf service.ProcessorFactory, synthesizerClient service.SynthesizerClient, findStudentFunc FindStudentFunc) StudentUsecaseAudio {
	return &studentUsecaseAudio{
		transaction:       transaction,
		pf:                pf,
		synthesizerClient: synthesizerClient,
		findStudentFunc:   findStudentFunc,
	}
}

func (s *studentUsecaseAudio) FindAudioByID(ctx context.Context, organizationID userD.OrganizationID, operatorID userD.AppUserID, workbookID domain.WorkbookID, problemID domain.ProblemID, audioID domain.AudioID) (service.Audio, error) {
	var result service.Audio
	if err := s.transaction.Do(ctx, func(rf service.RepositoryFactory) error {
		student, workbook, err := s.findStudentAndWorkbook(ctx, rf, organizationID, operatorID, workbookID)
		if err != nil {
			return liberrors.Errorf("s.findStudentAndWorkbook. err: %w", err)
		}

		problem, err := workbook.FindProblemByID(ctx, student, problemID)
		if err != nil {
			return liberrors.Errorf("workbook.FindProblemByID. err: %w", err)
		}

		savedAudioID, ok := (problem.GetProperties(ctx)["audioId"]).(domain.AudioID)
		if !ok {
			return errors.New("mismatch")
		}

		logger := log.FromContext(ctx)
		if audioID != savedAudioID {
			logger.Debugf("properties: %+v", problem.GetProperties(ctx))
			logger.Warnf("audioID: %d, %s", audioID, problem.GetProperties(ctx)["audioId"])
			message := "invalid audio id"
			return domain.NewPluginError(domain.ErrorType(domain.ErrorTypeClient), message, []string{message}, libD.ErrInvalidArgument)
		}

		tmpResult, err := s.synthesizerClient.FindAudioByAudioID(ctx, audioID)
		if err != nil {
			return liberrors.Errorf("s.synthesizerClient.FindAudioByAudioID. err: %w", err)
		}

		result = tmpResult
		return nil
	}); err != nil {
		return nil, liberrors.Errorf("FindAudioByID. err: %w", err)
	}

	return result, nil
}

func (s *studentUsecaseAudio) findStudentAndWorkbook(ctx context.Context, rf service.RepositoryFactory, organizationID userD.OrganizationID, operatorID userD.AppUserID, workbookID domain.WorkbookID) (service.Student, service.Workbook, error) {
	student, err := s.findStudentFunc(ctx, rf, organizationID, operatorID)
	if err != nil {
		return nil, nil, liberrors.Errorf("failed to findStudent. err: %w", err)
	}
	workbookService, err := student.FindWorkbookByID(ctx, workbookID)
	if err != nil {
		return nil, nil, liberrors.Errorf("studentService.FindWorkbookByID. err: %w", err)
	}
	return student, workbookService, nil
}