Skip to content

Commit

Permalink
ran formatter
Browse files Browse the repository at this point in the history
  • Loading branch information
cole committed Sep 28, 2024
1 parent b8087f8 commit 7cf2501
Show file tree
Hide file tree
Showing 3 changed files with 88 additions and 88 deletions.
30 changes: 15 additions & 15 deletions data/src/main/java/com/microsoft/azure/kusto/data/BaseClient.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -38,21 +38,21 @@ protected String post(HttpRequest request) throws DataServiceException {
}
}

// protected Mono<String> postAsync(HttpRequest request) {
// // Execute and get the response
// return httpClient.send(request)
// .onErrorContinue((err, src) -> LOGGER.error("Error coming from src {}", src, err))
// .flatMap(this::processResponseAsync)
// .onErrorContinue((err, src) -> LOGGER.error("Error coming from src {}", src, err));
// }
//
// public Mono<String> processResponseAsync(HttpResponse response) {
// try {
// return Mono.just(Objects.requireNonNull(processResponseBody(response)));
// } catch (Exception e) {
// return Mono.error(new RuntimeException("Error processing response", e));
// }
// }
// protected Mono<String> postAsync(HttpRequest request) {
// // Execute and get the response
// return httpClient.send(request)
// .onErrorContinue((err, src) -> LOGGER.error("Error coming from src {}", src, err))
// .flatMap(this::processResponseAsync)
// .onErrorContinue((err, src) -> LOGGER.error("Error coming from src {}", src, err));
// }
//
// public Mono<String> processResponseAsync(HttpResponse response) {
// try {
// return Mono.just(Objects.requireNonNull(processResponseBody(response)));
// } catch (Exception e) {
// return Mono.error(new RuntimeException("Error processing response", e));
// }
// }

private String processResponseBody(HttpResponse response) throws DataServiceException {
String responseBody = Utils.isGzipResponse(response) ? Utils.gzipedInputToString(response.getBodyAsBinaryData().toStream())
Expand Down
10 changes: 5 additions & 5 deletions data/src/main/java/com/microsoft/azure/kusto/data/Client.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -9,11 +9,11 @@

public interface Client {

// Mono<KustoOperationResult> executeQueryAsync(String database, String command, ClientRequestProperties properties);
//
// Mono<KustoOperationResult> executeMgmtAsync(String database, String command, ClientRequestProperties properties);
//
// Mono<String> executeToJsonAsync(String database, String command, ClientRequestProperties properties);
// Mono<KustoOperationResult> executeQueryAsync(String database, String command, ClientRequestProperties properties);
//
// Mono<KustoOperationResult> executeMgmtAsync(String database, String command, ClientRequestProperties properties);
//
// Mono<String> executeToJsonAsync(String database, String command, ClientRequestProperties properties);

@Deprecated
KustoOperationResult executeQuery(String command) throws DataServiceException, DataClientException;
Expand Down
136 changes: 68 additions & 68 deletions data/src/main/java/com/microsoft/azure/kusto/data/ClientImpl.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -59,68 +59,68 @@ public ClientImpl(ConnectionStringBuilder csb, HttpClient httpClient) throws URI
clientDetails = new ClientDetails(csb.getApplicationNameForTracing(), csb.getUserNameForTracing(), csb.getClientVersionForTracing());
}

// @Override
// public Mono<KustoOperationResult> executeQueryAsync(String database, String command, ClientRequestProperties properties) {
// KustoRequest kr = new KustoRequest(command, database, properties);
// return executeQueryAsync(kr);
// }
//
// Mono<KustoOperationResult> executeQueryAsync(@NotNull KustoRequest kr) {
// if (kr.getCommandType() != CommandType.QUERY) {
// kr.setCommandType(CommandType.QUERY);
// }
// return executeAsync(kr);
// }
//
// @Override
// public Mono<KustoOperationResult> executeMgmtAsync(String database, String command, ClientRequestProperties properties) {
// KustoRequest kr = new KustoRequest(command, database, properties);
// return executeMgmtAsync(kr);
// }
//
// public Mono<KustoOperationResult> executeMgmtAsync(@NotNull KustoRequest kr) {
// if (kr.getCommandType() != CommandType.ADMIN_COMMAND) {
// kr.setCommandType(CommandType.ADMIN_COMMAND);
// }
// return executeAsync(kr);
// }
//
// private Mono<KustoOperationResult> executeAsync(KustoRequest kr) {
//
// Mono<String> resultMono = executeToJsonAsync(kr)
// .onErrorContinue((err, src) -> LOGGER.error("Error coming from src {}", src, err));
// Mono<String> endpointMono = Mono.just(String.format(kr.getCommandType().getEndpoint(), clusterUrl))
// .onErrorContinue((err, src) -> LOGGER.error("Error coming from src {}", src, err));
//
// return Mono.zip(resultMono, endpointMono)
// .onErrorContinue((err, src) -> LOGGER.error("Error coming from src {}", src, err))
// .map(tuple2 -> new JsonResult(tuple2.getT1(), tuple2.getT2()))
// .onErrorContinue((err, src) -> LOGGER.error("Error coming from src {}", src, err))
// .flatMap(this::processJsonResultAsync)
// .onErrorContinue((err, src) -> LOGGER.error("Error coming from src {}", src, err));
// }
//
// public Mono<KustoOperationResult> processJsonResultAsync(JsonResult res) {
// try {
// return Mono.just(processJsonResult(res));
// } catch (Exception e) {
// return Mono.error(new RuntimeException("Error processing json result", e));
// }
// }
//
// public Mono<String> executeToJsonAsync(String database, String command, ClientRequestProperties properties) {
// KustoRequest kr = new KustoRequest(command, database, properties);
// return executeToJsonAsync(kr)
// .onErrorContinue((err, src) -> LOGGER.error("Error coming from src {}", src, err));
// }
//
// Mono<String> executeToJsonAsync(KustoRequest kr) {
// return just(kr)
// .flatMap(this::prepareRequestAsync)
// .onErrorContinue((err, src) -> LOGGER.error("Error coming from src {}", src, err))
// .flatMap(this::processRequestAsync)
// .onErrorContinue((err, src) -> LOGGER.error("Error coming from src {}", src, err));
// }
// @Override
// public Mono<KustoOperationResult> executeQueryAsync(String database, String command, ClientRequestProperties properties) {
// KustoRequest kr = new KustoRequest(command, database, properties);
// return executeQueryAsync(kr);
// }
//
// Mono<KustoOperationResult> executeQueryAsync(@NotNull KustoRequest kr) {
// if (kr.getCommandType() != CommandType.QUERY) {
// kr.setCommandType(CommandType.QUERY);
// }
// return executeAsync(kr);
// }
//
// @Override
// public Mono<KustoOperationResult> executeMgmtAsync(String database, String command, ClientRequestProperties properties) {
// KustoRequest kr = new KustoRequest(command, database, properties);
// return executeMgmtAsync(kr);
// }
//
// public Mono<KustoOperationResult> executeMgmtAsync(@NotNull KustoRequest kr) {
// if (kr.getCommandType() != CommandType.ADMIN_COMMAND) {
// kr.setCommandType(CommandType.ADMIN_COMMAND);
// }
// return executeAsync(kr);
// }
//
// private Mono<KustoOperationResult> executeAsync(KustoRequest kr) {
//
// Mono<String> resultMono = executeToJsonAsync(kr)
// .onErrorContinue((err, src) -> LOGGER.error("Error coming from src {}", src, err));
// Mono<String> endpointMono = Mono.just(String.format(kr.getCommandType().getEndpoint(), clusterUrl))
// .onErrorContinue((err, src) -> LOGGER.error("Error coming from src {}", src, err));
//
// return Mono.zip(resultMono, endpointMono)
// .onErrorContinue((err, src) -> LOGGER.error("Error coming from src {}", src, err))
// .map(tuple2 -> new JsonResult(tuple2.getT1(), tuple2.getT2()))
// .onErrorContinue((err, src) -> LOGGER.error("Error coming from src {}", src, err))
// .flatMap(this::processJsonResultAsync)
// .onErrorContinue((err, src) -> LOGGER.error("Error coming from src {}", src, err));
// }
//
// public Mono<KustoOperationResult> processJsonResultAsync(JsonResult res) {
// try {
// return Mono.just(processJsonResult(res));
// } catch (Exception e) {
// return Mono.error(new RuntimeException("Error processing json result", e));
// }
// }
//
// public Mono<String> executeToJsonAsync(String database, String command, ClientRequestProperties properties) {
// KustoRequest kr = new KustoRequest(command, database, properties);
// return executeToJsonAsync(kr)
// .onErrorContinue((err, src) -> LOGGER.error("Error coming from src {}", src, err));
// }
//
// Mono<String> executeToJsonAsync(KustoRequest kr) {
// return just(kr)
// .flatMap(this::prepareRequestAsync)
// .onErrorContinue((err, src) -> LOGGER.error("Error coming from src {}", src, err))
// .flatMap(this::processRequestAsync)
// .onErrorContinue((err, src) -> LOGGER.error("Error coming from src {}", src, err));
// }

@Override
public KustoOperationResult executeQuery(String command) throws DataServiceException, DataClientException {
Expand Down Expand Up @@ -257,12 +257,12 @@ private String executeToJsonResult(KustoRequest kr) throws DataServiceException,
request.getSdkRequest().getCommandType().getActivityTypeSuffix().concat(".executeToJsonResult"));
}

// public Mono<String> processRequestAsync(KustoRequestContext request) {
// return MonitoredActivity.invoke(
// (SupplierNoException<Mono<String>>) () -> postAsync(request.getHttpRequest())
// .onErrorContinue((err, src) -> LOGGER.error("Error coming from src {}", src, err)),
// request.getSdkRequest().getCommandType().getActivityTypeSuffix().concat(".executeToJsonResult"));
// }
// public Mono<String> processRequestAsync(KustoRequestContext request) {
// return MonitoredActivity.invoke(
// (SupplierNoException<Mono<String>>) () -> postAsync(request.getHttpRequest())
// .onErrorContinue((err, src) -> LOGGER.error("Error coming from src {}", src, err)),
// request.getSdkRequest().getCommandType().getActivityTypeSuffix().concat(".executeToJsonResult"));
// }

private void validateEndpoint() throws DataServiceException, DataClientException {
if (!endpointValidated) {
Expand Down

0 comments on commit 7cf2501

Please sign in to comment.