workflow

type AgentOutputEnvelope struct {
	Outputs map[string]interface{} `json:"outputs"`
}

type AgentRequest struct {
	StepID  string                                  `json:"step_id"`
	Prompt  string                                  `json:"prompt"`
	Outputs map[string]*config.WorkflowPromptOutput `json:"outputs"`
	Example map[string]interface{}                  `json:"example,omitempty"`
}

type ListItem struct {
	Name        string                           `json:"name"`
	Description string                           `json:"description"`
	Inputs      map[string]*config.WorkflowInput `json:"inputs,omitempty"`
}

type RunExecutionSummary struct {
	ToolsExecuted          int `json:"tools_executed"`
	AgentBoundariesCrossed int `json:"agent_boundaries_crossed"`
}

type RunFailure struct {
	Code    string    `json:"code"`
	Message string    `json:"message"`
	StepID  string    `json:"step_id,omitempty"`
	At      time.Time `json:"at"`
}

type RunHistoryEvent struct {
	StepID   string    `json:"step_id"`
	StepType string    `json:"step_type"`
	Status   string    `json:"status"`
	At       time.Time `json:"at"`
}

type RunListFilter struct {
	Workflow string
	Statuses map[RunStatus]bool
}

type RunPruneOptions struct {
	Statuses  map[RunStatus]bool
	OlderThan *time.Duration
	Now       time.Time
	Apply     bool
}

type RunPruneResult struct {
	Scanned  int               `json:"scanned"`
	Matched  int               `json:"matched"`
	Deleted  int               `json:"deleted"`
	RunIDs   []string          `json:"run_ids,omitempty"`
	Warnings []RunStoreWarning `json:"warnings,omitempty"`
}

type RunResult struct {
	RunID          string                 `json:"run_id"`
	WorkflowName   string                 `json:"workflow_name"`
	Status         RunStatus              `json:"status"`
	Revision       int                    `json:"revision"`
	Cursor         int                    `json:"cursor"`
	AwaitingStepID string                 `json:"awaiting_step_id,omitempty"`
	Inputs         map[string]interface{} `json:"inputs"`
	StepSummaries  []RunStepSummary       `json:"step_summaries"`
	Next           *AgentRequest          `json:"next,omitempty"`
	CreatedAt      string                 `json:"created_at"`
	UpdatedAt      string                 `json:"updated_at"`
	ExpiresAt      string                 `json:"expires_at,omitempty"`
	CompletedAt    string                 `json:"completed_at,omitempty"`
	Result         *RunSummary            `json:"result,omitempty"`
	Failure        *RunFailure            `json:"failure,omitempty"`
}

type RunStatus string

type RunStepSummary struct {
	StepID    string `json:"step_id"`
	StepType  string `json:"step_type"`
	Status    string `json:"status"`
	HasOutput bool   `json:"has_output"`
}

type RunStoreWarning struct {
	Code    string `json:"code"`
	RunID   string `json:"run_id,omitempty"`
	File    string `json:"file,omitempty"`
	Message string `json:"message"`
}

type RunSummary struct {
	TerminalStepID string               `json:"terminal_step_id,omitempty"`
	Summary        *RunExecutionSummary `json:"summary,omitempty"`
}

type Runner struct {
	ToolFunc func(tool string, args map[string]interface{}) (interface{}, error)
	// contains filtered or unexported fields
}

type StepOutputEntry struct {
	Key   string      `json:"key"`
	Value interface{} `json:"value"`
}

type StepOutputPage struct {
	Path       string            `json:"path,omitempty"`
	Kind       string            `json:"kind"`
	Offset     int               `json:"offset"`
	Limit      int               `json:"limit"`
	Total      int               `json:"total"`
	Returned   int               `json:"returned"`
	HasMore    bool              `json:"has_more"`
	NextOffset int               `json:"next_offset,omitempty"`
	Items      []interface{}     `json:"items,omitempty"`
	Entries    []StepOutputEntry `json:"entries,omitempty"`
	Text       string            `json:"text,omitempty"`
}

type Workflow struct {
	// Name is the workflow identifier (from the key in raven.yaml).
	Name string

	// Description is a brief summary of what the workflow does.
	Description string

	// Inputs defines the parameters the workflow accepts.
	Inputs map[string]*config.WorkflowInput

	// Steps are executed in order.
	Steps []*config.WorkflowStep
}

type WorkflowRunState struct {
	Version      int                    `json:"version"`
	RunID        string                 `json:"run_id"`
	WorkflowName string                 `json:"workflow_name"`
	WorkflowHash string                 `json:"workflow_hash"`
	Status       RunStatus              `json:"status"`
	Cursor       int                    `json:"cursor"`
	AwaitingStep string                 `json:"awaiting_step_id,omitempty"`
	Inputs       map[string]interface{} `json:"inputs"`
	Steps        map[string]interface{} `json:"steps"`
	History      []RunHistoryEvent      `json:"history,omitempty"`
	Failure      *RunFailure            `json:"failure,omitempty"`
	CreatedAt    time.Time              `json:"created_at"`
	UpdatedAt    time.Time              `json:"updated_at"`
	CompletedAt  *time.Time             `json:"completed_at,omitempty"`
	ExpiresAt    *time.Time             `json:"expires_at,omitempty"`
	Revision     int                    `json:"revision"`
	LockedBy     *string                `json:"locked_by,omitempty"`
	LockedAt     *time.Time             `json:"locked_at,omitempty"`
}