public APIGatewayV2HTTPResponse handleRequest()

in lambda/java/src/main/java/com/amazonaws/workshop/ListPodcasts.java [41:79]
32 lines of code
5 McCabe index (conditional complexity)

    public APIGatewayV2HTTPResponse handleRequest(APIGatewayV2HTTPEvent event, Context context) {
        DynamoDbTable<PodcastEpisode> podcastTable = enhancedClient.table(PODCAST_TABLE, WorkshopUtils.LIST_PODCAST_TABLE_SCHEMA);

        ScanRequest.Builder scanRequest =
                ScanRequest
                        .builder()
                        .tableName(PODCAST_TABLE)
                        .projectionExpression("id, #t, #p")
                        .expressionAttributeNames(ImmutableMap.of("#t", "title", "#p", "podcast"));

        if (event.getQueryStringParameters() != null) {
            scanRequest.filterExpression(getFilterExpressionFromQueryParams(event.getQueryStringParameters()).expression());
        }

        ScanResponse response = dynamoDbClient.scan(scanRequest.build());

        System.out.println(String.format("Number of podcasts returned in response: %d", response.count()));

        if (response.hasLastEvaluatedKey()) {
            System.out.println("Response contains LastEvaluatedKey. There is still more data to be scanned.");
        } else {
            System.out.println("Response does not contain LastEvaluatedKey. There is no more data to be scanned.");
        }

        List<Map<String, String>> items = new ArrayList<>();
        for(Map<String, AttributeValue> av : response.items()) {
            Map<String, String> subMap = new HashMap<>();
            av.entrySet().forEach(e -> {
                subMap.put(e.getKey(), e.getValue().s());
            });
            items.add(subMap);
        }

        try {
            return APIGatewayV2HTTPResponse.builder().withStatusCode(200).withBody(WorkshopUtils.writeValue(items)).build();
        } catch (Exception e) {
            throw new RuntimeException("Unable to list podcasts!", e);
        }
    }