comparisons

type ChannelResult struct {
	ChannelID   string                        `json:"channel_id"`
	ChannelName string                        `json:"channel_name"`
	RunID       string                        `json:"run_id"`
	RunStatus   domain.RunStatus              `json:"run_status"`
	ReportReady bool                          `json:"report_ready"`
	Passed      bool                          `json:"passed"`
	Verdict     string                        `json:"verdict"`
	Metrics     map[string]domain.MetricValue `json:"metrics"`
}

type Clock interface{ Now() time.Time }

type Dependencies struct {
	Repository  Repository
	Runner      Runner
	Clock       Clock
	MetaFactory MetaFactory
}

type ExecutionRepository interface {
	GetComparison(context.Context, string) (domain.Comparison, error)
	IsLocalComparison(context.Context, string) (bool, error)
	UpdateComparison(context.Context, uint64, domain.Comparison) error
}

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

type HistoryPage struct {
	SchemaVersion int       `json:"schema_version"`
	Comparisons   []Summary `json:"comparisons"`
	NextCursor    string    `json:"next_cursor"`
}

type HistoryRepository interface {
	ComparisonHistory(context.Context, string, []string) (HistoryPage, error)
}

type MetaFactory func(time.Time) (domain.EntityMeta, error)

type PreparationDependencies struct {
	Repository  PreparationRepository
	Targets     TargetPreparer
	Clock       Clock
	MetaFactory MetaFactory
}

type PreparationRepository interface {
	GetPlan(context.Context, string) (domain.Plan, error)
	ResolvePlanTargetSelection(
		context.Context,
		domain.Plan,
		string,
		string,
	) (domain.Model, domain.Channel, domain.ChannelModel, error)
}

type PreparedComparison struct {
	Meta  domain.EntityMeta        `json:"meta"`
	Plan  domain.EntityRevisionRef `json:"plan"`
	Model domain.EntityRevisionRef `json:"model"`
	Runs  []runs.PreparedRun       `json:"runs"`
}

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

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

type RefresherDependencies struct {
	Repository ExecutionRepository
	Runs       RunReader
	Clock      Clock
}

type Repository interface {
	PreparationRepository
	ExecutionRepository
	CreateComparison(context.Context, domain.Comparison) error
}

type RunReader interface {
	GetRun(context.Context, string) (domain.Run, error)
}

type Runner interface {
	TargetPreparer
	AcceptPrepared(context.Context, runs.PreparedRun, *credentials.Lease) (string, error)
	ActivateRun(context.Context, string) error
	GetRun(context.Context, string) (domain.Run, error)
	CancelRun(context.Context, string) error
}

type Service struct {
	*Preparer
	*Refresher
	// contains filtered or unexported fields
}

type Snapshot struct {
	SchemaVersion int       `json:"schema_version"`
	Comparisons   []Summary `json:"comparisons"`
}

type StartCommand struct {
	PlanID     string   `json:"plan_id"`
	ModelID    string   `json:"model_id"`
	ChannelIDs []string `json:"channel_ids"`
}

type Summary struct {
	ID        string          `json:"id"`
	CreatedAt time.Time       `json:"created_at"`
	Status    string          `json:"status"`
	PlanID    string          `json:"plan_id"`
	PlanName  string          `json:"plan_name"`
	ModelID   string          `json:"model_id"`
	ModelName string          `json:"model_name"`
	Channels  []ChannelResult `json:"channels"`
}

type TargetPreparer interface {
	BuildTarget(context.Context, runs.StartCommand) (runs.PreparedRun, *credentials.Lease, error)
}