feat: fmt and whitespace

Author: SoulPancake

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

@@ -79,7 +79,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);
     }
 
@@ -296,12 +296,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);
     }
 
@@ -492,19 +492,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(apiResponse, writeResponses, deleteResponses);
@@ -639,18 +639,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()));
@@ -828,7 +828,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())
@@ -889,8 +889,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())
@@ -951,22 +951,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) {
@@ -1126,7 +1126,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())
@@ -1311,4 +1311,4 @@ private <T> CompletableFuture<T> call(CheckedInvocation<T> action) {
             return CompletableFuture.failedFuture(throwable);
         }
     }
-}
+}

src/test/java/dev/openfga/sdk/api/client/OpenFgaClientWriteResponseHeadersTest.java

@@ -321,4 +321,4 @@ void writeTransactionMode_shouldMaintainBackwardCompatibility() throws Exception
         assertNotNull(response.getHeaders());
         assertFalse(response.getHeaders().isEmpty());
     }
-}
+}