public void execute()

in functions/CDDDockerJava/src/main/java/com/amazonaws/greengrass/cdddocker/handlers/RequestHandler.java [44:122]
58 lines of code
13 McCabe index (conditional complexity)

    public void execute(ImmutableGreengrassLambdaEvent immutableGreengrassLambdaEvent) {
        LambdaLogger logger = immutableGreengrassLambdaEvent.getLogger();

        Optional<Map> optionalInput = immutableGreengrassLambdaEvent.getJsonInput();

        if (!optionalInput.isPresent()) {
            loggingHelper.logAndPublish(Optional.ofNullable(logger), topics.getResponseTopic(), "Empty message received on request topic");
            return;
        }

        Map input = optionalInput.get();

        if (!input.containsKey(TYPE_KEY)) {
            loggingHelper.logAndPublish(Optional.ofNullable(logger), topics.getResponseTopic(), "Message received on request topic without a type");
            return;
        }

        String typeString;

        try {
            typeString = (String) input.get(TYPE_KEY);
        } catch (ClassCastException e) {
            loggingHelper.logAndPublish(Optional.ofNullable(logger), topics.getResponseTopic(), "Message received on request topic with a type value that is not a string [" + e.getMessage() + "]");
            return;
        }

        DockerRequestType dockerRequestType;

        try {
            dockerRequestType = DockerRequestType.valueOf(typeString);
        } catch (IllegalArgumentException e) {
            loggingHelper.logAndPublish(Optional.ofNullable(logger), topics.getResponseTopic(), "Message received on request topic with a type value that was not understood [" + typeString + "]");
            return;
        }

        if (DockerRequestType.LIST.equals(dockerRequestType)) {
            // Just send the list request to the bus and let someone else handle it
            dispatcher.dispatch(ImmutableDockerListRequest.builder().build());
            return;
        }

        Optional<String> optionalName = Optional.ofNullable((String) input.get(NAME_KEY));

        if ((DockerRequestType.PULL.equals(dockerRequestType)) || (DockerRequestType.RUN.equals(dockerRequestType)) ||
                (DockerRequestType.STOP.equals(dockerRequestType))) {
            if (!nameFieldPresent(logger, dockerRequestType, optionalName)) return;

            // Send the request to the bus with the name and let someone else handle it

            if (DockerRequestType.PULL.equals(dockerRequestType)) {
                DockerPullRequest dockerPullRequest = ImmutableDockerPullRequest.builder()
                        .name(optionalName.get())
                        .build();

                dispatcher.dispatch(dockerPullRequest);
                return;
            }

            if (DockerRequestType.RUN.equals(dockerRequestType)) {
                DockerRunRequest dockerRunRequest = ImmutableDockerRunRequest.builder()
                        .name(optionalName.get())
                        .build();

                dispatcher.dispatch(dockerRunRequest);
                return;
            }

            if (DockerRequestType.STOP.equals(dockerRequestType)) {
                DockerStopRequest dockerStopRequest = ImmutableDockerStopRequest.builder()
                        .name(optionalName.get())
                        .build();

                dispatcher.dispatch(dockerStopRequest);
                return;
            }
        }

        loggingHelper.logAndPublish(Optional.of(logger), topics.getResponseTopic(), "Not implemented yet [" + dockerRequestType + "]");
    }