fmt: apply spotless

Author: SoulPancake

src/main/java/dev/openfga/sdk/api/StreamedListObjectsApi.java

@@ -61,15 +61,15 @@ public CompletableFuture<ApiResponse<StreamingResponseBody>> streamedListObjects
             telemetryAttributes.put(Attributes.FGA_CLIENT_REQUEST_METHOD, "StreamedListObjects");
 
             return new HttpRequestAttempt<>(
-                    httpRequest,
-                    "streamedListObjects",
-                    StreamingResponseBody.class,
-                    apiClient,
-                    requestConfiguration)
+                            httpRequest,
+                            "streamedListObjects",
+                            StreamingResponseBody.class,
+                            apiClient,
+                            requestConfiguration)
                     .addTelemetryAttributes(telemetryAttributes)
                     .attemptHttpRequest();
         } catch (Exception e) {
             return CompletableFuture.failedFuture(new ApiException(e));
         }
     }
-}
+}

src/main/java/dev/openfga/sdk/api/client/HttpRequestAttempt.java

@@ -371,4 +371,4 @@ public void onComplete() {
             out.flush();
         }
     }
-}
+}

src/main/java/dev/openfga/sdk/api/client/OpenFgaClient.java

@@ -82,7 +82,7 @@ public CompletableFuture<ClientListStoresResponse> listStores(ClientListStoresOp
         configuration.assertValid();
         var overrides = new ConfigurationOverride().addHeaders(options);
         return call(() -> api.listStores(
-                options.getPageSize(), options.getContinuationToken(), options.getName(), overrides))
+                        options.getPageSize(), options.getContinuationToken(), options.getName(), overrides))
                 .thenApply(ClientListStoresResponse::new);
     }
 
@@ -299,12 +299,12 @@ public CompletableFuture<ClientReadChangesResponse> readChanges(
         var options = readChangesOptions != null ? readChangesOptions : new ClientReadChangesOptions();
         var overrides = new ConfigurationOverride().addHeaders(options);
         return call(() -> api.readChanges(
-                storeId,
-                request.getType(),
-                options.getPageSize(),
-                options.getContinuationToken(),
-                request.getStartTime(),
-                overrides))
+                        storeId,
+                        request.getType(),
+                        options.getPageSize(),
+                        options.getContinuationToken(),
+                        request.getStartTime(),
+                        overrides))
                 .thenApply(ClientReadChangesResponse::new);
     }
 
@@ -495,19 +495,19 @@ private CompletableFuture<ClientWriteResponse> writeTransactions(
             // For transaction-based writes, all tuples are successful if the call succeeds
             List<ClientWriteSingleResponse> writeResponses = writeTuples != null
                     ? writeTuples.stream()
-                    .map(tuple -> new ClientWriteSingleResponse(tuple.asTupleKey(), ClientWriteStatus.SUCCESS))
-                    .collect(Collectors.toList())
+                            .map(tuple -> new ClientWriteSingleResponse(tuple.asTupleKey(), ClientWriteStatus.SUCCESS))
+                            .collect(Collectors.toList())
                     : new ArrayList<>();
 
             List<ClientWriteSingleResponse> deleteResponses = deleteTuples != null
                     ? deleteTuples.stream()
-                    .map(tuple -> new ClientWriteSingleResponse(
-                            new TupleKey()
-                                    .user(tuple.getUser())
-                                    .relation(tuple.getRelation())
-                                    ._object(tuple.getObject()),
-                            ClientWriteStatus.SUCCESS))
-                    .collect(Collectors.toList())
+                            .map(tuple -> new ClientWriteSingleResponse(
+                                    new TupleKey()
+                                            .user(tuple.getUser())
+                                            .relation(tuple.getRelation())
+                                            ._object(tuple.getObject()),
+                                    ClientWriteStatus.SUCCESS))
+                            .collect(Collectors.toList())
                     : new ArrayList<>();
 
             return new ClientWriteResponse(writeResponses, deleteResponses);
@@ -642,18 +642,18 @@ private CompletableFuture<ClientWriteResponse> writeNonTransaction(
         CompletableFuture<List<ClientWriteSingleResponse>> allWritesFuture = writeFutures.isEmpty()
                 ? CompletableFuture.completedFuture(new ArrayList<>())
                 : CompletableFuture.allOf(writeFutures.toArray(new CompletableFuture[0]))
-                .thenApply(v -> writeFutures.stream()
-                        .map(CompletableFuture::join)
-                        .flatMap(List::stream)
-                        .collect(Collectors.toList()));
+                        .thenApply(v -> writeFutures.stream()
+                                .map(CompletableFuture::join)
+                                .flatMap(List::stream)
+                                .collect(Collectors.toList()));
 
         CompletableFuture<List<ClientWriteSingleResponse>> allDeletesFuture = deleteFutures.isEmpty()
                 ? CompletableFuture.completedFuture(new ArrayList<>())
                 : CompletableFuture.allOf(deleteFutures.toArray(new CompletableFuture[0]))
-                .thenApply(v -> deleteFutures.stream()
-                        .map(CompletableFuture::join)
-                        .flatMap(List::stream)
-                        .collect(Collectors.toList()));
+                        .thenApply(v -> deleteFutures.stream()
+                                .map(CompletableFuture::join)
+                                .flatMap(List::stream)
+                                .collect(Collectors.toList()));
 
         return CompletableFuture.allOf(allWritesFuture, allDeletesFuture)
                 .thenApply(v -> new ClientWriteResponse(allWritesFuture.join(), allDeletesFuture.join()));
@@ -831,7 +831,7 @@ public CompletableFuture<List<ClientBatchCheckClientResponse>> clientBatchCheck(
         var options = batchCheckOptions != null
                 ? batchCheckOptions
                 : new ClientBatchCheckClientOptions()
-                .maxParallelRequests(FgaConstants.CLIENT_MAX_METHOD_PARALLEL_REQUESTS);
+                        .maxParallelRequests(FgaConstants.CLIENT_MAX_METHOD_PARALLEL_REQUESTS);
 
         HashMap<String, String> headers = options.getAdditionalHeaders() != null
                 ? new HashMap<>(options.getAdditionalHeaders())
@@ -892,8 +892,8 @@ public CompletableFuture<ClientBatchCheckResponse> batchCheck(
         var options = batchCheckOptions != null
                 ? batchCheckOptions
                 : new ClientBatchCheckOptions()
-                .maxParallelRequests(FgaConstants.CLIENT_MAX_METHOD_PARALLEL_REQUESTS)
-                .maxBatchSize(FgaConstants.CLIENT_MAX_BATCH_SIZE);
+                        .maxParallelRequests(FgaConstants.CLIENT_MAX_METHOD_PARALLEL_REQUESTS)
+                        .maxBatchSize(FgaConstants.CLIENT_MAX_BATCH_SIZE);
 
         HashMap<String, String> headers = options.getAdditionalHeaders() != null
                 ? new HashMap<>(options.getAdditionalHeaders())
@@ -954,22 +954,22 @@ public CompletableFuture<ClientBatchCheckResponse> batchCheck(
         var override = new ConfigurationOverride().addHeaders(options);
 
         Consumer<List<BatchCheckItem>> singleBatchCheckRequest = request -> call(() -> {
-            BatchCheckRequest body = new BatchCheckRequest().checks(request);
-            if (options.getConsistency() != null) {
-                body.consistency(options.getConsistency());
-            }
+                    BatchCheckRequest body = new BatchCheckRequest().checks(request);
+                    if (options.getConsistency() != null) {
+                        body.consistency(options.getConsistency());
+                    }
 
-            // Set authorizationModelId from options if available; otherwise, use the default from configuration
-            String authorizationModelId = !isNullOrWhitespace(options.getAuthorizationModelId())
-                    ? options.getAuthorizationModelId()
-                    : configuration.getAuthorizationModelId();
+                    // Set authorizationModelId from options if available; otherwise, use the default from configuration
+                    String authorizationModelId = !isNullOrWhitespace(options.getAuthorizationModelId())
+                            ? options.getAuthorizationModelId()
+                            : configuration.getAuthorizationModelId();
 
-            if (!isNullOrWhitespace(authorizationModelId)) {
-                body.authorizationModelId(authorizationModelId);
-            }
+                    if (!isNullOrWhitespace(authorizationModelId)) {
+                        body.authorizationModelId(authorizationModelId);
+                    }
 
-            return api.batchCheck(configuration.getStoreId(), body, override);
-        })
+                    return api.batchCheck(configuration.getStoreId(), body, override);
+                })
                 .whenComplete((batchCheckResponseApiResponse, throwable) -> {
                     try {
                         if (throwable != null) {
@@ -1205,7 +1205,7 @@ public CompletableFuture<ClientListRelationsResponse> listRelations(
         var options = listRelationsOptions != null
                 ? listRelationsOptions
                 : new ClientListRelationsOptions()
-                .maxParallelRequests(FgaConstants.CLIENT_MAX_METHOD_PARALLEL_REQUESTS);
+                        .maxParallelRequests(FgaConstants.CLIENT_MAX_METHOD_PARALLEL_REQUESTS);
 
         HashMap<String, String> headers = options.getAdditionalHeaders() != null
                 ? new HashMap<>(options.getAdditionalHeaders())
@@ -1390,4 +1390,4 @@ private <T> CompletableFuture<T> call(CheckedInvocation<T> action) {
             return CompletableFuture.failedFuture(throwable);
         }
     }
-}
+}

src/main/java/dev/openfga/sdk/api/client/StreamedResponseIterator.java

@@ -92,4 +92,4 @@ public StreamedListObjectsResponse next() {
 
         return current;
     }
-}
+}

src/main/java/dev/openfga/sdk/api/client/StreamingException.java

@@ -28,4 +28,4 @@ private static String formatErrorMessage(Status error) {
         String messageStr = error.getMessage() != null ? error.getMessage() : "Unknown error";
         return String.format("Error in streaming response: code=%s, message=%s", codeStr, messageStr);
     }
-}
+}

src/main/java/dev/openfga/sdk/api/client/StreamingResponseBody.java

@@ -21,4 +21,4 @@ public void close() throws IOException {
             body.close();
         }
     }
-}
+}