validation

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

type ExternalValidator interface {
	GetMinMax(ctx context.Context, model models.External) (uint64, uint64, error)
}

type FlexUint64 uint64

type MockValidator struct {

	// Control behavior
	ValidateDependenciesFunc func(ctx context.Context, modelID string, position, interval uint64) (Result, error)
	GetInitialPositionFunc   func(ctx context.Context, modelID string) (uint64, error)
	GetEarliestPositionFunc  func(ctx context.Context, modelID string) (uint64, error)
	GetValidRangeFunc        func(ctx context.Context, modelID string) (uint64, uint64, error)

	// Track calls for assertions
	ValidateCalls   []ValidateCall
	InitialCalls    []string
	EarliestCalls   []string
	ValidRangeCalls []string
	// contains filtered or unexported fields
}

type Result struct {
	CanProcess bool
	Errors     []error
}

type ValidateCall struct {
	ModelID  string
	Position uint64
	Interval uint64
}

type Validator interface {
	// ValidateDependencies checks if all dependencies are satisfied for a given position
	ValidateDependencies(ctx context.Context, modelID string, position, interval uint64) (Result, error)

	// GetInitialPosition calculates the initial position for a model based on its dependencies
	GetInitialPosition(ctx context.Context, modelID string) (uint64, error)

	// GetEarliestPosition gets the earliest available position for a model
	GetEarliestPosition(ctx context.Context, modelID string) (uint64, error)

	// GetValidRange returns the valid position range [min, max] for a model based on its dependencies
	// min = MAX(MIN(external_mins), MAX(transformation_mins))
	// max = MIN(MAX(external_maxs), MIN(transformation_maxs))
	GetValidRange(ctx context.Context, modelID string) (minPos, maxPos uint64, err error)
}