HLTech / vaunt

import com.google.common.collect.Lists;

import com.hltech.vaunt.validator.domain.representation.model.Contract;

import com.hltech.vaunt.validator.domain.representation.model.Service;

import java.util.List;

import java.util.Optional;

import java.util.stream.Collectors;

public class VauntValidator {

    public List<ValidationResult> validate(Service consumer, Service provider) {

        return consumer.getExpectations().getProviderNameToContracts().get(provider.getName()).stream()

                .map(consumerContract -> validateWithMatchingProviderContract(

                        consumerContract, provider.getCapabilities().getContracts()))

                .collect(Collectors.toList());

    }

    private ValidationResult validateWithMatchingProviderContract(

            Contract consumerContract, List<Contract> providerContracts) {

        Optional<Contract> matchingProviderContract = providerContracts.stream()

                .filter(providerContract -> isEndpointMatching(consumerContract, providerContract))

                .findFirst();

        if (!matchingProviderContract.isPresent()) {

            return ValidationResult.failure(Lists.newArrayList(ValidationError.MISSING_ENDPOINT));

        }

        if (!consumerContract.getBody().equals(matchingProviderContract.get().getBody())) {

            return ValidationResult.failure(Lists.newArrayList(ValidationError.WRONG_SCHEMA));

        }

        return ValidationResult.success();

    }

    private boolean isEndpointMatching(Contract firstContract, Contract secondContract) {

        return firstContract.getDestinationType().equals(secondContract.getDestinationType())

                && firstContract.getDestinationName().equals(secondContract.getDestinationName());

    }

}