workflow

type AgentRunner interface {
	Run(ctx context.Context, sessionKey string, prompt string) (string, error)
}

type ChannelSender interface {
	SendMessage(ctx context.Context, channel string, message string) error
}

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

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

type RunResult struct {
	RunID        string
	WorkflowName string
	Status       string
	StepResults  map[string]string // stepID -> result
	Error        string
	StartedAt    time.Time
	CompletedAt  time.Time
}

type RunStatus struct {
	RunID          string
	WorkflowName   string
	Status         string
	TotalSteps     int
	CompletedSteps int
	StartedAt      time.Time
	StepStatuses   []StepStatus
}

type RunStore interface {
	CreateRun(ctx context.Context, w *Workflow) (string, error)
	UpdateRunStatus(ctx context.Context, runID string, status string) error
	CompleteRun(ctx context.Context, runID string, status string, errMsg string) error
	CreateStepRun(ctx context.Context, runID string, step Step, renderedPrompt string) error
	UpdateStepStatus(ctx context.Context, runID string, stepID string, status string, result string, errMsg string) error
	GetRunStatus(ctx context.Context, runID string) (*RunStatus, error)
	GetStepResults(ctx context.Context, runID string) (map[string]string, error)
	ListRuns(ctx context.Context, limit int) ([]RunStatus, error)
}

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

type Step struct {
	ID        string        `yaml:"id"`
	Agent     string        `yaml:"agent"`  // executor | researcher | planner | memory-manager
	Prompt    string        `yaml:"prompt"` // Go template with {{step-id.result}}
	DependsOn []string      `yaml:"depends_on"`
	DeliverTo []string      `yaml:"deliver_to"` // per-step delivery
	Timeout   time.Duration `yaml:"timeout"`
}

type StepStatus struct {
	StepID string
	Agent  string
	Status string
	Error  string
}

type Workflow struct {
	Name        string   `yaml:"name"`
	Description string   `yaml:"description"`
	Schedule    string   `yaml:"schedule"`   // optional cron expression
	DeliverTo   []string `yaml:"deliver_to"` // optional result delivery targets
	Steps       []Step   `yaml:"steps"`
}