ops

type ActivityInvocationOutput struct {
	GitResult    contextual.GitCommitContext    `json:"git,omitempty"`
	NextTask     string                         `json:"nextTaskType,omitempty"`
	OpOutput     map[string]interface{}         `json:"output"`
	ArtifactRefs map[string]recipeartifacts.Ref `json:"artifact_refs,omitempty"`
}

type ActivityInvocationOutputRaw struct {
	GitResult    contextual.GitCommitContext    `json:"git,omitempty"`
	NextTask     string                         `json:"nextTaskType,omitempty"`
	Output       any                            `json:"output"`
	ArtifactRefs map[string]recipeartifacts.Ref `json:"artifact_refs,omitempty"`
}

type ActivityInvocationRequest struct {
	Input          map[string]interface{}         `json:"input"`
	Const          bool                           `json:"const,omitempty"`
	GitTaskContext gitstate.GlobalGitTaskContext  `json:"context"`
	ArtifactKeys   []swf.ArtifactKey              `json:"artifact_keys,omitempty"`
	Artifacts      map[string]recipeartifacts.Ref `json:"artifacts,omitempty"`
	Deps           ops.OpDependencies             `json:"-"`
}

type ActivityRegisterable interface {
	RegisterActivityWithOptions(a interface{}, options activity.RegisterOptions)
}

type ActivityRegistration struct {
	Activity     ops.RegisterableOp // parent op
	Step         ops.TaskStep
	StepIndex    int
	TaskType     string // opType:stepName
	NextTaskType string
	InputSchema  *jsonschema.Schema
	OutputSchema *jsonschema.Schema
	Metadata     ops.OpMetadata
}

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

type ConsumeArtifactInput struct {
	Artifact swf.ArtifactKey `json:"artifact" validate:"required"`
}

type ConsumeArtifactOutput struct {
	Name string `json:"name"`
}

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

type EmitArtifactOutput struct {
	Name string `json:"name"`
}

type GenericActivityFunc func(context.Context, any) (any, error)

type GenericInput struct {
	Message  string                 `json:"message,omitempty"`
	Command  string                 `json:"command,omitempty"`
	Text     string                 `json:"text,omitempty"`
	Name     string                 `json:"name,omitempty"`
	Run      string                 `json:"run,omitempty"`
	Duration string                 `json:"duration,omitempty"`
	Data     interface{}            `json:"data,omitempty"`
	Items    []interface{}          `json:"items,omitempty"`
	Error    bool                   `json:"error,omitempty"`
	Extra    map[string]interface{} `json:"-" mapstructure:",remain"`
}

type GenericOutput struct {
	// String outputs
	Result    interface{} `json:"result,omitempty"`
	Output    string      `json:"output,omitempty"`
	Status    string      `json:"status,omitempty"`
	Stdout    string      `json:"stdout,omitempty"`
	Report    string      `json:"report,omitempty"`
	Response  string      `json:"response,omitempty"`
	Body      string      `json:"body,omitempty"`
	Slept     string      `json:"slept,omitempty"`
	Action    string      `json:"action,omitempty"`
	Handler   string      `json:"handler,omitempty"`
	Processor string      `json:"processor,omitempty"`
	Recipe    string      `json:"recipe,omitempty"`

	// Boolean outputs
	Logged bool `json:"logged,omitempty"`
	Valid  bool `json:"valid,omitempty"`

	// Numeric outputs
	Count      int     `json:"count,omitempty"`
	Confidence float64 `json:"confidence,omitempty"`

	// Complex outputs
	Model interface{}   `json:"model,omitempty"`
	Data  interface{}   `json:"data,omitempty"`
	Items []interface{} `json:"items,omitempty"`
}

type NextTaskOverrideInput struct {
	Message string `json:"message"`
}

type NextTaskOverrideOutput struct {
	Message string `json:"message"`
	Step    string `json:"step"`
}

type SchemaGenerator interface {
	GenerateSchema(typ reflect.Type) (*jsonschema.Schema, error)
	ValidateStructTags(typ reflect.Type) error
}