public void handleInternal()

in src/main/java/org/apache/cassandra/sidecar/routes/StreamSSTableComponentHandler.java [61:89]

29 lines of code
2 McCabe index (conditional complexity)


    public void handleInternal(RoutingContext context,
                               HttpServerRequest httpRequest,
                               String host,
                               SocketAddress remoteAddress,
                               StreamSSTableComponentRequest request)
    {
        validate(request)
        .compose(validParams ->
                 snapshotPathBuilder.build(host, validParams)
                                    .onSuccess(path -> {
                                        logger.debug("StreamSSTableComponentHandler handled {} for client {}. "
                                                     + "Instance: {}", path, remoteAddress, host);
                                        context.put(FileStreamHandler.FILE_PATH_CONTEXT_KEY, path)
                                               .next();
                                    }))
        .onFailure(cause -> {
            String errMsg =
            "StreamSSTableComponentHandler failed for request: {} from: {}. Instance: {}";
            logger.error(errMsg, request, remoteAddress, host, cause);
            if (cause instanceof NoSuchFileException)
            {
                context.fail(wrapHttpException(HttpResponseStatus.NOT_FOUND, cause.getMessage()));
            }
            else
            {
                context.fail(wrapHttpException(HttpResponseStatus.BAD_REQUEST, "Invalid request for " + request));
            }
        });
    }