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());

    }

    public List<ValidationResult> validate(List<Contract> expectations, List<Contract> capabilities) {

        return expectations.stream()

                .map(consumerContract -> validateWithMatchingProviderContract(consumerContract, capabilities))

                .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 new ValidationResult(false, Lists.newArrayList("No endpoint required by consumer"));

        }

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

            return new ValidationResult(false, Lists.newArrayList("Unmatching schema of the message"));

        }

        return new ValidationResult(true, Lists.newArrayList());

    }

}