private boolean isGenExists()

in src/main/java/com/amazonaws/mskdatagen/validators/ValidateUnusedAttrs.java [39:60]

• 18 lines of code
• 2 McCabe index (conditional complexity)

    private boolean isGenExists(Context context, Config config) {
        Optional<GeneratorsConfigs> generatorsConfigs = Optional.ofNullable(context.getContextMap().get(ConfigType.GENERATORS_CONFIG))
                .orElse(Collections.emptyList()).stream()
                .map(GeneratorsConfigs.class::cast)
                .filter(t -> config.getTopic().equals(t.getTopic()))
                .findFirst();

        if (generatorsConfigs.isPresent()) {
            Set<List<String>> attrKey = generatorsConfigs
                    .map(t -> t.getByNamespace(config.getNs()))
                    .map(Map::keySet)
                    .orElse(Collections.emptySet());

            List<String> attrs = attrKey.stream().map(t -> t.toArray(new String[0]))
                    .map(t -> String.join("->", t))
                    .collect(Collectors.toList());

            return attrs.stream().anyMatch(t -> config.getAttr().equals(t));
        }

        return false;
    }