HLTech / judge-d

import dev.hltech.dredd.domain.contracts.ServiceContracts;

import dev.hltech.dredd.domain.contracts.ServiceContractsRepository;

import dev.hltech.dredd.domain.environment.EnvironmentRepository;

import dev.hltech.dredd.domain.validation.EnvironmentValidatorResult;

import dev.hltech.dredd.domain.validation.InterfaceContractValidator;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Component;

import java.util.List;

import java.util.Optional;

import static java.util.stream.Collectors.toList;

@Component

public class JudgeD {

    private EnvironmentRepository environmentRepository;

    private ServiceContractsRepository serviceContractsRepository;

    @Autowired

    public JudgeD(EnvironmentRepository environmentRepository, ServiceContractsRepository serviceContractsRepository) {

        this.environmentRepository = environmentRepository;

        this.serviceContractsRepository = serviceContractsRepository;

    }

    public <C, E> EnvironmentValidatorResult validateServiceAgainstEnv(ServiceContracts validatedService, String environment, InterfaceContractValidator<C, E> validator) {

        List<ServiceContracts> environmentContracts = this.environmentRepository.get(environment)

            .getAllServices()

            .stream()

            .map(sv -> this.serviceContractsRepository.find(sv.getName(), sv.getVersion()))

            .filter(it -> it.isPresent())

            .map(it -> it.get())

            .collect(toList());

        return new EnvironmentValidatorResult(

            validator.getCommunicationInterface(),

            validator.validateCapabilities(validatedService, environmentContracts),

            validator.validateExpectations(validatedService, environmentContracts)

        );

    }

    }

}