workflowtest

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

type FakeContextOptions struct {
	// Inputs is the initial workflow inputs.
	Inputs map[string]any
	// Variables is the initial branch-local state.
	Variables map[string]any
	// Logger overrides the default discard logger.
	Logger *slog.Logger
	// Compiler overrides the default compiler. When nil, callers of
	// Compiler() receive nil — tests that exercise template
	// evaluation should always set this.
	Compiler script.Compiler
	// BranchID is the value returned by Context.BranchID. Defaults
	// to "fake-branch".
	BranchID string
	// StepName is the value returned by Context.StepName. Defaults
	// to "fake-step".
	StepName string
	// WaitFunc, when non-nil, is invoked by Context.Wait. Tests that
	// exercise wait semantics supply their own function; otherwise
	// Wait returns (nil, nil).
	WaitFunc func(topic string, timeout time.Duration) (any, error)
	// OnProgress, when non-nil, receives every ProgressDetail passed
	// to Context.ReportProgress. Tests can inspect the slice to
	// verify their activity reported progress correctly.
	OnProgress func(detail workflow.ProgressDetail)
}

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

type TestOptions struct {
	// ExecutionID sets a fixed execution ID. Auto-generated if empty.
	ExecutionID string

	// Checkpointer overrides the default in-memory checkpointer.
	Checkpointer workflow.Checkpointer

	// Callbacks receives execution lifecycle events.
	Callbacks workflow.ExecutionCallbacks

	// StepProgressStore receives step progress updates.
	StepProgressStore workflow.StepProgressStore
}