ops

type ActivityHandlerV2[In OpInputType, Out OpOutputType] func(deps OpDependencies, ctx context.Context, in In) (Out, error)

type GitExecutionContext struct {
	BaseRepo         string `json:"base_repo,omitempty"`
	BaseRef          string `json:"base_ref,omitempty"`
	ResolvedBaseHash string `json:"resolved_base_hash,omitempty"`
	RecipeSourceRepo string `json:"recipe_source_repo,omitempty"`
	RecipeSourceRef  string `json:"recipe_source_ref,omitempty"`
	PersistHash      string `json:"persist_hash,omitempty"`
	ParentHash       string `json:"parent_hash,omitempty"`
	CellName         string `json:"cell_name,omitempty"`
	GitAuthor        string `json:"git_author,omitempty"`
	NodePath         string `json:"node_path,omitempty"`
	InvokeSeq        int64  `json:"invoke_seq,omitempty"`
	InvokeHash       string `json:"invoke_hash,omitempty"`
	WorktreePath     string `json:"worktree_path,omitempty"`
}

type HasManagmentService interface {
	GetManagementService() ManagementService
}

type JobTool interface {
	GetJobKey() jobdb.JobKey
	AwaitJobs(jobIds ...string) error
}

type ManagementService interface {
	// GetRoutes returns HTTP routes this service provides
	GetRoutes() []Route

	// Initialize with injected dependencies
	Initialize(deps ServiceDependencies2) error
	Close()
}

type MapDecoder interface {
	DecodeFromMap(input any) error
}

type OpBuilder interface {
	WithType(t string) OpBuilder
	WithDescription(desc string) OpBuilder
	WithVersion(ver string) OpBuilder
	WithDefaultTimeout(d time.Duration) OpBuilder
	WithAcceptsArtifacts(accept bool) OpBuilder
	AddStep(name string, step Step) OpBuilder
	WithManagementService(svc ManagementService) OpBuilder
	Build() (RegisterableOp, error)
	BuildOrPanic() RegisterableOp
}

type OpDependencies interface {
	Database() *gorm.DB
	WorkflowControl() workflowctl.WorkflowControl
	GetInputArtifacts() []jobdb.Artifact
	AddOutputArtifact(jobdb.Artifact) error
	AddExternalArtifact(name string, url string, expand bool) error
	GetOutputArtifacts() []jobdb.Artifact
	GetExternalArtifacts() map[string]recipeartifacts.Ref
	WorktreePath() string
	GitContext() GitExecutionContext
	CurrentJobContext() jobcontext.Current
	ProtectedEnv() map[string]string
	JobTool() JobTool
	FindArtifact(key jobdb.ArtifactKey) (jobdb.Artifact, error)
	SetNextTaskType(taskType string)
}

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

type OpExecutor interface {
}

type OpInputType = any

type OpMetadata struct {
	Type             string        // Unique identifier for the activity type
	Description      string        // Detailed description
	Version          string        // Semantic version
	DefaultTimeout   time.Duration // Default execution timeout
	AcceptsArtifacts bool          // Whether the op accepts inbox artifact bindings
}

type OpOutputType = any

type OperationPathProvider interface {
	OperationPaths() OperationPaths
}

type OperationPathRuntime struct {
	Views       OperationPathViews
	Mounts      []RequiredMount
	Ports       []RequiredPort
	SandboxType string
}

type OperationPathRuntimeProvider interface {
	OperationPathRuntime() OperationPathRuntime
}

type OperationPathTransformRequest struct {
	Input map[string]interface{}
	Host  OperationPaths
}

type OperationPathTransformResult struct {
	Runtime      OperationPathRuntime
	Replacements map[string]string
}

type OperationPathTransformer interface {
	TransformOperationPaths(context.Context, OperationPathTransformRequest) (OperationPathTransformResult, error)
}

type OperationPathViews struct {
	Host OperationPaths
	Op   OperationPaths
}

type OperationPaths struct {
	Workdir      string
	WorktreePath string
	Inbox        string
	Outbox       string
}

type RawMessageOrStruct = any

type RegisterableOp interface {
	GetMetadata() OpMetadata
	GetName() string
	TaskChain() []TaskStep
	GetManagementService() ManagementService
	// contains filtered or unexported methods
}

type RequiredMount struct {
	Source string
	Target string
	Mode   string
}

type RequiredPort struct {
	Host string
	Port int
}

type Route struct {
	Method  string
	Path    string
	Handler http.HandlerFunc
}

type SSEEvent struct {
	Type string                 `json:"type"`
	Data map[string]interface{} `json:"data"`
}

type SSEManager interface {
	Broadcast(event SSEEvent)
	Subscribe(clientID string) <-chan SSEEvent
	Unsubscribe(clientID string)
}

type ServiceDependencies2 interface {
	// WorkflowControl returns a typed workflow controller if available.
	WorkflowControl() workflowctl.WorkflowControl

	// SSEManager returns the server-sent-event manager when supported.
	SSEManager() SSEManager

	// Database returns the shared GORM handle for the current runtime when available.
	Database() *gorm.DB
	// contains filtered or unexported methods
}

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

type Step interface {
	// contains filtered or unexported methods
}

type TaskBasedJobTool struct {
	TaskContext jobworkflow.TaskContext
}

type TaskStep struct {
	Name           string
	InputType      reflect.Type
	OutputType     reflect.Type
	DisallowAsTask bool
	NextStepTask   string
	Invoke         func(deps OpDependencies, ctx context.Context, resolvedInput map[string]interface{}) (map[string]interface{}, error)
}