ops

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

type GitExecutionContext struct {
	Workspace        *contextual.WorkspaceContext `json:"workspace,omitempty"`
	CellResolution   *cellref.Context             `json:"cell_resolution,omitempty"`
	RestoreArtifact  *jobdb.ArtifactKey           `json:"restore_artifact,omitempty"`
	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 {
	Objects() *objects.Store
	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 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 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)
}