runtime

type AssetMetadata struct {
	SHA256    string
	Size      int64
	MediaType string
}

type AssetResolver interface {
	Open(context.Context, string) (AssetStream, error)
}

type AssetStream interface {
	io.ReadCloser
	Metadata() AssetMetadata
}

type Descriptor struct {
	ID          string                    `json:"id"`
	Label       string                    `json:"label"`
	DefaultSpec testspec.Spec             `json:"default_spec"`
	Metrics     []testspec.Metric         `json:"metrics"`
	Settings    map[string]testspec.Input `json:"settings"`
}

type Execution struct {
	Spec      testspec.Spec
	Inputs    testspec.ResolvedInputs
	Random    testspec.RandomContext
	Settings  testspec.RunSettings
	Transport Transport
	Assets    AssetResolver
}

type Module interface {
	Descriptor() Descriptor
	// ValidateProtocol checks native operation and workflow rules after Spec.Validate.
	ValidateProtocol(testspec.Spec) error
	Execute(context.Context, Execution) testspec.Observation
}

type PreparedFile struct {
	InputName string
	Pointer   string
	AssetRef  string
	SHA256    string
	Size      int64
	MediaType string
	Encoding  string
}

type PreparedWire struct {
	SHA256 string
	Bytes  int64
	Files  []PreparedFile
}

type Request struct {
	Method  string
	Path    string
	Body    testspec.RenderedRequest
	Headers map[string]string
	Assets  AssetResolver
}

type Response struct {
	HTTP         *http.Response
	Started      time.Time
	TTFBMS       float64
	RequestBody  json.RawMessage
	PreparedWire *PreparedWire `json:"-"`
}

type TaskProtocol struct {
	ID               string
	Label            string
	SubmitPath       string
	PollPath         string
	IDPointer        string
	StatusPointer    string
	UsagePointer     string
	ArtifactPointers map[string]string
	TerminalStatuses []string
	DefaultBody      json.RawMessage
	Headers          map[string]string
}

type Transport interface {
	Send(context.Context, Request) (Response, error)
}