exec

type CodeExecutionService interface {
	Enqueue(ctx context.Context, uuid uuid.UUID, srcCode string, prLangId string, tests []TestFile, params TestingParams) srvcerror.E
	Listen(ctx context.Context, uuid uuid.UUID) (<-chan Event, srvcerror.E)
	Get(ctx context.Context, execUuid uuid.UUID) (Execution, srvcerror.E)
}

type CodeWithLang struct {
	SrcCode string // user submitted solution source code
	LangId  string // short compiler, interpreter id
}

type CompilationError struct {
	ErrorMsg *string `json:"error_msg"`
}

type Event interface {
	Type() string
	MarshalJSON() ([]byte, error)
}

type ExecRepo interface {
	Save(ctx context.Context, exec *Execution) error
	Get(ctx context.Context, id uuid.UUID) (*Execution, error)
}

type ExecRequest struct {
	UUID  uuid.UUID
	Code  string
	Lang  PrLang
	Tests []TestFile

	CpuMs  int `json:"cpu_ms"`  // max user-mode CPU time in milliseconds
	MemKiB int `json:"mem_kib"` // max resident set size in kibibytes

	// optional testlib.h checker program. If not provided,
	// only output of the user's solution is returned from tester
	// and is not viable for grading. "run program" use case.
	Checker *string `json:"checker"`

	// optional testlib.h interactor program.
	Interactor *string `json:"interactor"`
}

type ExecResStreamOrganizer struct {
	// contains filtered or unexported fields
}

type ExecStage string

type Execution struct {
	UUID      uuid.UUID     `json:"uuid"`
	Stage     ExecStage     `json:"stage"`
	TestRes   []TestRes     `json:"test_res"`
	PrLang    PrLang        `json:"pr_lang"`
	Params    TestingParams `json:"params"`
	ErrorMsg  *string       `json:"error_msg"`
	SysInfo   *string       `json:"sys_info"` // testing hardware info
	CreatedAt time.Time     `json:"created_at"`
	SubmComp  *RunData      `json:"subm_comp"` // submitted code compilation runtime data

}

type FileEvalRepo struct {
	// contains filtered or unexported fields
}

type FinishedCompiling struct {
	RuntimeData *RunData `json:"runtime_data"`
}

type FinishedTest struct {
	TestID  int      `json:"test_id"`
	Subm    *RunData `json:"submission"`
	Checker *RunData `json:"checker"`
}

type FinishedTesting struct{}

type IgnoredTest struct {
	TestId int `json:"test_id"`
}

type InMemExecRepo struct {
	// contains filtered or unexported fields
}

type InternalServerError struct {
	ErrorMsg *string `json:"error_msg"`
}

type PrLang struct {
	ShortId   string  `json:"short_id"`   // short lang/compiler/interpreter id
	Display   string  `json:"display"`    // user-friendly programming lang name
	CodeFname string  `json:"code_fname"` // source code filename for mv in to box
	CompCmd   *string `json:"comp_cmd"`   // compile command
	CompFname *string `json:"comp_fname"` // exe fname after comp for mv out of box
	ExecCmd   string  `json:"exec_cmd"`   // execution command
}

type ReachedTest struct {
	TestId int     `json:"test_id"`
	In     *string `json:"in"`
	Ans    *string `json:"ans"`
}

type ReceivedSubmission struct {
	SysInfo   string    `json:"sys_info"`
	StartedAt time.Time `json:"started_at"`
}

type RunData struct {
	StdIn       string  `json:"in"`            // standard input
	StdOut      string  `json:"out"`           // standard output
	StdErr      string  `json:"err"`           // standard error
	CpuMs       int64   `json:"cpu_ms"`        // cpu user-mode time in milliseconds
	WallMs      int64   `json:"wall_ms"`       // wall clock time in milliseconds
	MemKiB      int64   `json:"mem_kib"`       // memory usage (resident set size) in kibibytes
	ExitCode    int64   `json:"exit"`          // exit code
	CtxSwV      int64   `json:"ctx_sw_v"`      // voluntary context switches, e.g. waiting for I/O
	CtxSwF      int64   `json:"ctx_sw_f"`      // involuntary context switches, e.g. waiting for CPU
	Signal      *int64  `json:"signal"`        // exit signal if any
	IsOomKilled bool    `json:"is_oom_killed"` // whether the process was killed due to memory exhaustion
	IsolStatus  *string `json:"isol_status"`   // isolate sandbox execution environment status
	IsolMsg     *string `json:"isol_msg"`      // isolate sandbox execution environment message
}

type StartedCompiling struct{}

type TestFile struct {
	InSha256   *string // SHA256 hash of input for caching
	InDownlUrl *string // URL to download input
	InContent  *string // input content as alternative to URL

	AnsSha256   *string // SHA256 hash of answer for caching
	AnsDownlUrl *string // URL to download answer
	AnsContent  *string // answer content as alternative to URL
}

type TestFileStore interface {
	Open(key string) (io.ReadCloser, error)
}

type TestRes struct {
	ID       int     `json:"id"`
	Input    *string `json:"inp"` // trimmed test input file preview
	Answer   *string `json:"ans"` // trimmed test answer file preview
	Reached  bool    `json:"rch"`
	Ignored  bool    `json:"ign"` // when score group has another failed test
	Finished bool    `json:"fin"`

	Subm    *RunData `json:"subm_rd"` // user submitted solution
	Checker *RunData `json:"tlib_rd"` // testlib checker
}

type TestingParams struct {
	CpuMs  int `json:"cpu_ms"`  // maximum user-mode CPU time in milliseconds
	MemKiB int `json:"mem_kib"` // maximum resident set size in kibibytes

	// optional testlib.h checker program. If not provided,
	// only output of the user's solution is returned from tester
	// and is not viable for grading. "run program" use case.
	Checker *string `json:"checker"`

	// optional testlib.h interactor program.
	Interactor *string `json:"interactor"`
}