Function NewInput

internal/evaluation_target/input/input.go:40–70

NewInput returns a Input struct with FPath and evaluator ready to use

(ctx context.Context, paths []string, p policy.Policy)

// NewInput returns a Input struct with FPath and evaluator ready to use
func NewInput(ctx context.Context, paths []string, p policy.Policy) (*Input, error) {
	i := &Input{
		Paths: paths,
	}

	for _, sourceGroup := range p.Spec().Sources {
		// Todo: Make each fetch run concurrently
		policySources := source.PolicySourcesFrom(sourceGroup)

		for _, policySource := range policySources {
			log.Debugf("policySource: %#v", policySource)
		}

		var c evaluator.Evaluator
		var err error
		if utils.IsOpaEnabled() {
			c, err = newOPAEvaluator(ctx, policySources, p, sourceGroup, nil)
		} else {
			c, err = newConftestEvaluator(ctx, policySources, p, sourceGroup)
		}
		if err != nil {
			log.Debug("Failed to initialize the evaluator!")
			return nil, err
		}

		log.Debug("Evaluator initialized")
		i.Evaluators = append(i.Evaluators, c)

	}
	return i, nil
}