HLTech / pact-gen

public class FeignMethodRepresentationExtractor implements ClientMethodRepresentationExtractor {

    private final Collection<AnnotatedMethodHandler> annotatedMethodHandlers;

    public FeignMethodRepresentationExtractor(Collection<AnnotatedMethodHandler> annotatedMethodHandlers) {

        this.annotatedMethodHandlers = annotatedMethodHandlers;

    }

    @Override

    public ClientMethodRepresentation extractClientMethodRepresentation(Method clientMethod) {

        return ClientMethodRepresentation.builder()

            .requestRepresentation(extractRequestProperties(clientMethod))

            .responseRepresentationList(extractResponseProperties(clientMethod))

            .build();

    }

    private RequestRepresentation extractRequestProperties(Method feignClientMethod) {

        return this.annotatedMethodHandlers.stream()

            .filter(annotationHandler -> annotationHandler.isSupported(feignClientMethod))

            .findFirst().orElseThrow(() -> new IllegalArgumentException("Unknown HTTP method"))

            .handle(feignClientMethod);

    }

    private static List<ResponseRepresentation> extractResponseProperties(Method feignClientMethod) {

        feignClientMethod.getGenericReturnType();

        List<ResponseRepresentation> results = Arrays

            .stream(feignClientMethod.getDeclaredAnnotationsByType(InteractionInfo.class))

            .map(annotation -> populateResponse(

                annotation.responseStatus(),

                RawHeadersParser.parseAll(annotation.responseHeaders()),

                feignClientMethod,

                annotation.description()))

            .collect(Collectors.toList());

        return !results.isEmpty() ? results :

            Lists.newArrayList(populateResponse(HttpStatus.OK, Lists.newArrayList(), feignClientMethod, ""));

    }

    private static ResponseRepresentation populateResponse(

        HttpStatus status, List<Param> headers, Method feignClientMethod, String description) {

        return ResponseRepresentation.builder()

            .status(status)

            .headers(headers)

            .body(Body.builder()

                .type(feignClientMethod.getReturnType())

                .genericArgumentTypes(

                    TypeExtractor.extractParameterTypesFromType(feignClientMethod.getGenericReturnType()))

                .build())

            .description(description)

            .build();