flows

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

type Flow interface {
	// ID returns the unique identifier for this flow
	ID() string

	// Name returns the human-readable name for this flow
	Name() string

	// Execute runs the flow with the given context and data
	Execute(ctx context.Context, data map[string]any) (*FlowResult, error)

	// Steps returns all steps in this flow
	Steps() []*Step

	// AddStep adds a step to the flow
	AddStep(step *Step) Flow

	// AddBeforeHook adds a hook to run before a specific step
	AddBeforeHook(stepID string, hook HookFunc) Flow

	// AddAfterHook adds a hook to run after a specific step
	AddAfterHook(stepID string, hook HookFunc) Flow
}

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

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

type FlowResult struct {
	Success   bool           `json:"success"`
	Data      map[string]any `json:"data"`
	Errors    []string       `json:"errors,omitempty"`
	NextStep  string         `json:"next_step,omitempty"`
	Completed bool           `json:"completed"`
}

type HookFunc func(ctx context.Context, step *Step, data map[string]any) error

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

type SignupFlow struct {
	*BaseFlow
	// contains filtered or unexported fields
}

type Step struct {
	ID          string         `json:"id"`
	Name        string         `json:"name"`
	Type        string         `json:"type"`
	Required    bool           `json:"required"`
	Config      map[string]any `json:"config"`
	BeforeHooks []HookFunc     `json:"-"`
	AfterHooks  []HookFunc     `json:"-"`
	Handler     StepHandler    `json:"-"`
}

type StepHandler func(ctx context.Context, step *Step, data map[string]any) (*StepResult, error)

type StepResult struct {
	Success bool           `json:"success"`
	Data    map[string]any `json:"data"`
	Error   string         `json:"error,omitempty"`
	Skip    bool           `json:"skip"`
	Stop    bool           `json:"stop"`
}