services

type ChallengeService interface {
	CreateChallenge(challenge *entities.Challenge) (*entities.Challenge, error)
	// UpdateChallenge(challenge *entities.Challenge) (err error)
	DeleteChallenge(challenge *entities.Challenge) (err error)
	FindChallengeByID(challengeID uint) (challenge *entities.Challenge, err error)
	AllChallenges() (challenges []*entities.Challenge, err error)
	AddTestcase(challenge *entities.Challenge, testcase *entities.ChallengeTestcase) (*entities.ChallengeTestcase, error)
	UpdateTestcase(testcase *entities.ChallengeTestcase) (err error)
	DeleteTestcase(testcase *entities.ChallengeTestcase) (err error)
	AllTestcases(challenge *entities.Challenge) (testcases []*entities.ChallengeTestcase, err error)
	FindTestcaseByID(testcaseID uint) (testcase *entities.ChallengeTestcase, err error)
	PaginationChallengesWithStatus(options *entities.ChallengePaginationOptions) (result *entities.PaginationResult[*entities.ChallengeExtended], err error)
	UpdateChallengeWithTestcase(challenge *entities.Challenge) (err error)
	CountAllChallengesByUser(user *entities.User) (total int64, err error)
	ValidateTestcases(testcases []*entities.ChallengeTestcase) (err error)
}

type DockerService interface {
	PullImage(imageName string) error
	ImageExist(imageName string) (bool, error)
	GetLog(containerID string, showStdout, showStderr bool) (string, error)
	GetContainerExitCode(containerID string) (int, error)
	CreateVolume(name string) (volume.Volume, error)
	DeleteVolume(v volume.Volume) error
	CopyToContainer(containerID, targetPath string, content []byte) error
	CreateContainer(imageName string, command []string, volumes []mount.Mount, memoryLimit int64, containerName string) (response container.CreateResponse, err error)
	StartContainer(containerID string) error
	StopContainer(containerID string) error
	RemoveContainer(containerID string) error
	WaitContainer(containerID string, timeout uint) string
}

type JWTService interface {
	GenerateToken(user entities.User) (string, error)
	ValidateToken(token string) (*entities.User, error)
}

type KafkaService interface {
	Produce(topic string, message string) error
	Consume(topic string, groupID string) (chan string, chan error)
	IsTopicExist(topic string) bool
	OverriddenHost(host string)
	CreateTopic(topic string, partitions int) error
}

type SandboxService interface {
	CreateSandbox(lang, code string) (*entities.SandboxInstance, error)
	CompileSandbox(instance *entities.SandboxInstance) (result *entities.SandboxRunResult)
	Run(instance *entities.SandboxInstance, stdin string, memoryLimit, timeLimit uint) (result *entities.SandboxRunResult)
	CleanUp(instance *entities.SandboxInstance) error
	ValidateMemoryLimit(memoryLimit uint) (err error)
	ValidateTimeLimit(timeLimit uint) (err error)
}

type ServiceKit struct {
	JWTService        JWTService
	UserService       UserService
	ChallengeService  ChallengeService
	SubmissionService SubmissionService
	SandboxService    SandboxService
	KafkaService      KafkaService
}

type SubmissionService interface {
	CreateSubmission(submission *entities.Submission) (*entities.Submission, error)
	DeleteSubmission(submission *entities.Submission) error
	GetSubmissionByID(submissionID uint) (*entities.Submission, error)
	GetSubmissionByUser(user *entities.User) ([]*entities.Submission, error)
	GetSubmissionByChallenge(challenge *entities.Challenge) ([]*entities.Submission, error)
	CreateSubmissionTestcase(submissionTestcase *entities.SubmissionTestcase) (*entities.SubmissionTestcase, error)
	GetSubmissionTestcaseBySubmission(submission *entities.Submission) ([]*entities.SubmissionTestcase, error)
	SubmitSubmission(submission *entities.Submission) (*entities.Submission, error)
	ProcessSubmission(submission *entities.Submission) (*entities.Submission, error)
	Pagination(options *entities.SubmissionPaginationOptions) (result *entities.PaginationResult[*entities.Submission], err error)
}

type UserService interface {
	Register(email, password, displayname string) (user *entities.User, err error)
	Login(email, password string) (user *entities.User, err error)
	UpdateRole(user *entities.User, role string) (err error)
	FindUserByID(id uint) (user *entities.User, err error)
	Pagination(options *entities.PaginationOptions) (result *entities.PaginationResult[*entities.User], err error)
}