definition

type BranchMode string

type BranchPolicy struct {
	Mode BranchMode `json:"mode,omitempty"`
}

type Edge struct {
	ID        string         `json:"id,omitempty"`
	From      string         `json:"from"`
	To        string         `json:"to"`
	Kind      EdgeKind       `json:"kind,omitempty"`
	Condition string         `json:"condition,omitempty"`
	Priority  int            `json:"priority,omitempty"`
	Label     string         `json:"label,omitempty"`
	Metadata  map[string]any `json:"metadata,omitempty"`
}

type EdgeKind string

type ExecutorSpec struct {
	Type    string         `json:"type"`
	Ref     string         `json:"ref,omitempty"`
	Version string         `json:"version,omitempty"`
	Config  map[string]any `json:"config,omitempty"`
}

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

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

type InputBinding struct {
	Source    InputSource `json:"source,omitempty"`
	From      string      `json:"from,omitempty"`
	Path      string      `json:"path,omitempty"`
	Label     string      `json:"label,omitempty"`
	As        string      `json:"as,omitempty"`
	Required  bool        `json:"required,omitempty"`
	Default   any         `json:"default,omitempty"`
	Transform string      `json:"transform,omitempty"`
}

type InputMode string

type InputSource string

type InputSpec struct {
	Mode     InputMode      `json:"mode,omitempty"`
	Bindings []InputBinding `json:"bindings,omitempty"`
}

type LoopGroup struct {
	ID            string        `json:"id"`
	Start         string        `json:"start"`
	End           string        `json:"end"`
	Mode          string        `json:"mode,omitempty"`
	MaxIterations int           `json:"max_iterations"`
	CountBinding  *InputBinding `json:"count_binding,omitempty"`
}

type LoopPolicy struct {
	MaxIterations int           `json:"max_iterations,omitempty"`
	Condition     string        `json:"condition,omitempty"`
	Mode          string        `json:"mode,omitempty"`
	CountBinding  *InputBinding `json:"count_binding,omitempty"`
}

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

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

type Node struct {
	ID             string                   `json:"id"`
	Name           string                   `json:"name"`
	Description    string                   `json:"description,omitempty"`
	Type           string                   `json:"type,omitempty"`
	Executor       ExecutorSpec             `json:"executor,omitzero"`
	Input          any                      `json:"input,omitempty"`
	InputSpec      *InputSpec               `json:"input_spec,omitempty"`
	Params         map[string]any           `json:"params,omitempty"`
	ParamBindings  map[string]InputBinding  `json:"param_bindings,omitempty"`
	ParamTemplates map[string]ParamTemplate `json:"param_templates,omitempty"`
	DependsOn      []string                 `json:"depends_on,omitempty"`
	Retry          *RetryPolicy             `json:"retry,omitempty"`
	Loop           *LoopPolicy              `json:"loop,omitempty"`
	Timeout        time.Duration            `json:"timeout,omitempty"`
	Branch         *BranchPolicy            `json:"branch,omitempty"`
	Disabled       bool                     `json:"disabled,omitempty"`
	UI             map[string]any           `json:"ui,omitempty"` // editor-only data, removed by compiler
}

type ParamTemplate struct {
	Segments []ParamTemplateSegment `json:"segments"`
}

type ParamTemplateSegment struct {
	Type    string        `json:"type"`
	Value   string        `json:"value,omitempty"`
	Binding *InputBinding `json:"binding,omitempty"`
}

type PublishConfig struct {
	Enabled      bool              `json:"enabled"`
	Route        string            `json:"route,omitempty"`
	Method       string            `json:"method,omitempty"`
	InputMode    string            `json:"input_mode,omitempty"`
	ResponseMode string            `json:"response_mode,omitempty"`
	AuthRequired bool              `json:"auth_required,omitempty"`
	Headers      map[string]string `json:"headers,omitempty"`
	TimeoutMS    int64             `json:"timeout,omitempty"`
}

type Repository interface {
	SaveWorkflow(ctx context.Context, workflow *Workflow) error
	GetWorkflow(ctx context.Context, workflowID string) (*Workflow, error)
	ListWorkflows(ctx context.Context) ([]*Workflow, error)
	CreateVersion(ctx context.Context, workflowID string, definition *WorkflowDefinition) (*WorkflowVersion, error)
	SaveVersion(ctx context.Context, version *WorkflowVersion) error
	GetVersion(ctx context.Context, versionID string) (*WorkflowVersion, error)
	ListVersions(ctx context.Context, workflowID string) ([]*WorkflowVersion, error)
	GetActiveVersion(ctx context.Context, workflowID string) (*WorkflowVersion, error)
	PublishVersion(ctx context.Context, versionID string) (*WorkflowVersion, error)
}

type RetryPolicy struct {
	MaxAttempts int           `json:"max_attempts,omitempty"`
	Backoff     time.Duration `json:"backoff,omitempty"`
	MaxBackoff  time.Duration `json:"max_backoff,omitempty"`
}

type Trigger struct {
	ID      string         `json:"id"`
	Type    TriggerType    `json:"type"`
	Enabled bool           `json:"enabled"`
	Config  map[string]any `json:"config,omitempty"`
}

type TriggerType string

type VersionStatus string

type Workflow struct {
	ID            string         `json:"id"`
	Name          string         `json:"name"`
	Description   string         `json:"description,omitempty"`
	ActiveVersion string         `json:"active_version,omitempty"`
	Tags          []string       `json:"tags,omitempty"`
	Metadata      map[string]any `json:"metadata,omitempty"`
	CreatedAt     time.Time      `json:"created_at"`
	UpdatedAt     time.Time      `json:"updated_at"`
}

type WorkflowDefinition struct {
	ID             string         `json:"id"`
	Name           string         `json:"name"`
	Description    string         `json:"description,omitempty"`
	MaxConcurrency int            `json:"max_concurrency,omitempty"`
	FailFast       bool           `json:"fail_fast,omitempty"`
	EntryNodes     []string       `json:"entry_nodes,omitempty"`
	Nodes          []Node         `json:"nodes"`
	Edges          []Edge         `json:"edges,omitempty"`
	LoopGroups     []LoopGroup    `json:"loop_groups,omitempty"`
	Triggers       []Trigger      `json:"triggers,omitempty"`
	PublishConfig  *PublishConfig `json:"publish_config,omitempty"`
	Metadata       map[string]any `json:"metadata,omitempty"`
}

type WorkflowVersion struct {
	ID         string              `json:"id"`
	WorkflowID string              `json:"workflow_id"`
	Version    int                 `json:"version"`
	Status     VersionStatus       `json:"status"`
	Definition *WorkflowDefinition `json:"definition"`
	CreatedAt  time.Time           `json:"created_at"`
}

type Workspace struct {
	SchemaVersion  int               `json:"schema_version"`
	Revision       uint64            `json:"revision"`
	ActiveID       string            `json:"activeId"`
	Folders        []WorkspaceFolder `json:"folders"`
	Entries        []WorkspaceEntry  `json:"entries"`
	ServiceActions []map[string]any  `json:"serviceActions"`
	UpdatedAt      time.Time         `json:"updated_at"`
}

type WorkspaceDocument struct {
	Definition *WorkflowDefinition `json:"definition"`
	Layout     map[string]any      `json:"layout,omitempty"`
}

type WorkspaceEntry struct {
	ID       string            `json:"id"`
	SavedAt  time.Time         `json:"savedAt"`
	FolderID string            `json:"folderId,omitempty"`
	Document WorkspaceDocument `json:"document"`
}

type WorkspaceFolder struct {
	ID        string    `json:"id"`
	Name      string    `json:"name"`
	CreatedAt time.Time `json:"createdAt"`
}

type WorkspaceRepository interface {
	GetWorkspace(ctx context.Context) (*Workspace, error)
	SaveWorkspace(ctx context.Context, workspace *Workspace, expectedRevision uint64) (*Workspace, error)
}