public void validate()

in src/main/java/com/amazonaws/mskdatagen/validators/ValidateDependencies.java [19:34]

• 14 lines of code
• 5 McCabe index (conditional complexity)

    public void validate(Context context) {
        List<GeneratorsConfigs> generatorsConfigs = context.getGenerators().collect(Collectors.toList());

        List<String> topics = generatorsConfigs.stream().map(GeneratorsConfigs::getTopic).collect(Collectors.toList());
        for (GeneratorsConfigs generatorsConfig : generatorsConfigs) {
            if (!generatorsConfig.getDependencies().isEmpty()) {
                for (Generator generator : getGeneratorsByNs(generatorsConfig.getKeys())) {
                    validateDependencyGenerator(topics, generatorsConfig.getTopic(), generator, generatorsConfigs);
                }

                for (Generator generator : getGeneratorsByNs(generatorsConfig.getValue())) {
                    validateDependencyGenerator(topics, generatorsConfig.getTopic(), generator, generatorsConfigs);
                }
            }
        }
    }