run

type CountRunsResultHandler interface {
	Handle(context.Context, *CountRunsResultQuery) (*Status, error)
}

type CountRunsResultQuery struct {
	SubmissionID string
}

type ListRunsFilter struct {
	SearchWord string
	Exact      bool
	Status     []string
	IDs        []string
}

type ListRunsHandler interface {
	Handle(context.Context, *ListRunsQuery) ([]*RunItem, int, error)
}

type ListRunsQuery struct {
	WorkspaceID  string
	SubmissionID string
	Pg           *utils.Pagination
	Filter       *ListRunsFilter
}

type ListTasksHandler interface {
	Handle(context.Context, *ListTasksQuery) ([]*TaskItem, int, error)
}

type ListTasksQuery struct {
	WorkspaceID  string
	SubmissionID string
	RunID        string
	Pg           *utils.Pagination
}

type Queries struct {
	ListRuns        ListRunsHandler
	ListTasks       ListTasksHandler
	CountRunsResult CountRunsResultHandler
}

type ReadModel interface {
	ListAllRunIDs(ctx context.Context, submissionID string) ([]string, error)
	ListRuns(ctx context.Context, submissionID string, pg *utils.Pagination, filter *ListRunsFilter) ([]*RunItem, error)
	CountRuns(ctx context.Context, submissionID string, filter *ListRunsFilter) (int, error)

	ListTasks(ctx context.Context, runID string, pg *utils.Pagination) ([]*TaskItem, error)
	CountTasks(ctx context.Context, runID string) (int, error)
	CountRunsResult(ctx context.Context, submissionID string) ([]*StatusCount, error)
	CountTasksResult(ctx context.Context, runID string) ([]*StatusCount, error)
}

type RunItem struct {
	ID          string
	Name        string
	Status      string
	StartTime   int64
	FinishTime  *int64
	Duration    int64
	EngineRunID string
	Inputs      string
	Outputs     string
	TaskStatus  Status
	Log         *string
	Message     *string
}

type Status struct {
	Count        int64
	Succeeded    int64
	Failed       int64
	Running      int64
	Cancelling   int64
	Cancelled    int64
	Queued       int64
	Initializing int64
	Pending      int64
}

type StatusCount struct {
	Count  int64
	Status string
}

type TaskItem struct {
	Name       string
	RunID      string
	Status     string
	StartTime  int64
	FinishTime *int64
	Duration   int64
	Stdout     string
	Stderr     string
}