runs

type Clock interface {
	Now() time.Time
}

type ConnectionCommand struct {
	Protocol        domain.Protocol `json:"protocol"`
	Model           string          `json:"model"`
	ChannelID       string          `json:"channel_id,omitempty"`
	BaseURL         string          `json:"base_url,omitempty"`
	APIKey          string          `json:"api_key,omitempty"`
	CredentialRunID string          `json:"credential_run_id,omitempty"`
}

type CredentialStore interface {
	Get(context.Context, credentials.StoreRef) (*credentials.Lease, error)
}

type Dependencies struct {
	Repository           Repository
	QuickTasks           QuickTaskCatalog
	CaseTypes            *casetypes.Registry
	Credentials          CredentialStore
	QuickTaskCredentials credentials.Store
	// MissingRun declares the repository adapter's private not-found sentinel;
	// see PreparationDependencies.MissingRun.
	MissingRun       error
	Executor         Executor
	Clock            Clock
	MetaFactory      MetaFactory
	Environment      EnvironmentProvider
	Reporter         ReportGenerator
	ReportError      func(error)
	ReportDiagnostic func(Diagnostic)
}

type Diagnostic struct {
	RunID        string
	RequestID    string
	Operation    string
	ErrorCode    string
	Duration     time.Duration
	DroppedCount uint64
	Err          error
}

type EnvironmentProvider func() domain.EnvironmentSnapshot

type ExecutionRepository interface {
	GetRun(context.Context, string) (domain.Run, error)
	UpdateRun(context.Context, uint64, domain.Run) error
	// AppendResults atomically writes outputs whose suite and case identities
	// have been resolved against the prepared run snapshot by the caller.
	AppendResults(context.Context, ...domain.Result) error
}

type ExecutionRequest struct {
	Run         domain.Run
	Entry       domain.RunEntrySnapshot
	Cases       []domain.TestCase
	Credential  *credentials.Lease
	StopSending <-chan struct{}
	OnProgress  func(load.Progress)
}

type Executor interface {
	Execute(context.Context, ExecutionRequest, func(ResultDraft) error) error
}

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

type HostDependencies struct {
	Repository       ExecutionRepository
	Executor         Executor
	Clock            Clock
	MetaFactory      MetaFactory
	Reporter         ReportGenerator
	ReportError      func(error)
	ReportDiagnostic func(Diagnostic)
	RequestProgress  func(string, load.Progress)
	// PersistenceFailure is a synchronous owner signal, separate from lossy
	// diagnostics. It must return promptly and must not call back into this Host.
	PersistenceFailure func(string)
}

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

type PreparationDependencies struct {
	Repository           PreparationRepository
	QuickTasks           QuickTaskCatalog
	CaseTypes            *casetypes.Registry
	Credentials          CredentialStore
	QuickTaskCredentials credentials.Store
	// MissingRun declares the repository adapter's private not-found sentinel
	// so a quick task whose draft references a deleted source run can start
	// from the submitted form values instead of failing.
	MissingRun  error
	Clock       Clock
	MetaFactory MetaFactory
	Environment EnvironmentProvider
}

type PreparationRepository interface {
	GetPlan(context.Context, string) (domain.Plan, error)
	ResolvePlanTargetSelection(
		context.Context, domain.Plan, string, string,
	) (domain.Model, domain.Channel, domain.ChannelModel, error)
	ListTestCases(context.Context) ([]domain.TestCase, error)
	ListSuites(context.Context) ([]domain.Suite, error)
	GetRun(context.Context, string) (domain.Run, error)
}

type PreparedRun struct {
	Meta     domain.EntityMeta  `json:"meta"`
	PlanID   string             `json:"plan_id"`
	Snapshot domain.RunSnapshot `json:"snapshot"`
}

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

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

type QuickTaskCatalog interface {
	GetSuite(context.Context, string) (domain.Suite, error)
	GetChannel(context.Context, string) (domain.Channel, error)
	ListChannelModels(context.Context) ([]domain.ChannelModel, error)
}

type QuickTaskCommand struct {
	SuiteID               string                     `json:"suite_id"`
	Seed                  uint64                     `json:"seed"`
	RequestTimeoutSeconds float64                    `json:"request_timeout_seconds"`
	CaseConcurrency       uint32                     `json:"case_concurrency,omitempty"`
	Model                 string                     `json:"model"`
	ChannelID             string                     `json:"channel_id,omitempty"`
	BaseURL               string                     `json:"base_url,omitempty"`
	APIKey                string                     `json:"api_key,omitempty"`
	Inputs                map[string]json.RawMessage `json:"inputs"`
	SourceRunID           string                     `json:"source_run_id,omitempty"`
	CredentialRunID       string                     `json:"credential_run_id,omitempty"`
}

type QuickTaskDetail struct {
	Seed                  uint64                     `json:"seed"`
	RequestTimeoutSeconds float64                    `json:"request_timeout_seconds"`
	CaseConcurrency       uint32                     `json:"case_concurrency"`
	SchemaVersion         int                        `json:"schema_version"`
	RunID                 string                     `json:"run_id"`
	Suite                 QuickTaskSuite             `json:"suite"`
	Model                 string                     `json:"model"`
	BaseURL               string                     `json:"base_url"`
	ChannelID             string                     `json:"channel_id,omitempty"`
	CredentialRunID       string                     `json:"credential_run_id,omitempty"`
	Inputs                map[string]json.RawMessage `json:"inputs"`
}

type QuickTaskSuite struct {
	domain.Suite
	CaseCount int `json:"case_count"`
}

type RecoveryRepository interface {
	ListRecoveryRuns(context.Context) ([]domain.Run, error)
	UpdateRun(context.Context, uint64, domain.Run) error
}

type RememberQuickTaskCredentialCommand struct {
	RunID    string          `json:"run_id"`
	BaseURL  string          `json:"base_url"`
	Protocol domain.Protocol `json:"protocol"`
	APIKey   string          `json:"api_key"`
}

type ReportGenerator interface {
	Generate(context.Context, string) error
}

type Repository interface {
	ExecutionRepository
	PreparationRepository
	CreateRun(context.Context, domain.Run) error
}

type ResultDraft struct {
	Performance     json.RawMessage
	CaseID          string
	RequestID       string
	ExecutionStatus domain.ExecutionStatus
	Verification    testspec.Verdict
	Observation     *testspec.Observation
	Failure         domain.FailureKind
	ErrorCode       domain.ErrorCode
	Detail          *domain.ProviderDetail
	Dimensions      map[string]string
	Metrics         map[string]float64
	EvidenceIDs     []string
}

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

type StartCommand struct {
	PlanID          string             `json:"plan_id"`
	ModelID         string             `json:"model_id"`
	ChannelID       string             `json:"channel_id"`
	CaseConcurrency uint32             `json:"case_concurrency,omitempty"`
	Connection      *ConnectionCommand `json:"connection,omitempty"`
}