Merge branch 'main' into feat/streamed-list-objects-consumer

Author: SoulPancake

.github/workflows/fossa.yaml

@@ -1,6 +1,7 @@
 # Changelog
 
 ## [Unreleased](https://github.com/openfga/java-sdk/compare/v0.9.2...HEAD)
+- fix: preserve response headers in transaction write operations (#254)
 - feat: Add `streamedListObjects` API endpoint with consumer callback support (#252)
 
 ## v0.9.2

CHANGELOG.md

@@ -507,7 +507,7 @@ private CompletableFuture<ClientWriteResponse> writeTransactions(
                             .collect(Collectors.toList())
                     : new ArrayList<>();
 
-            return new ClientWriteResponse(writeResponses, deleteResponses);
+            return new ClientWriteResponse(apiResponse, writeResponses, deleteResponses);
         });
     }
 
@@ -710,7 +710,7 @@ public CompletableFuture<ClientWriteResponse> writeTuples(
             List<ClientWriteSingleResponse> writeResponses = tupleKeys.stream()
                     .map(tuple -> new ClientWriteSingleResponse(tuple.asTupleKey(), ClientWriteStatus.SUCCESS))
                     .collect(Collectors.toList());
-            return new ClientWriteResponse(writeResponses, new ArrayList<>());
+            return new ClientWriteResponse(apiResponse, writeResponses, new ArrayList<>());
         });
     }
 
@@ -756,7 +756,7 @@ public CompletableFuture<ClientWriteResponse> deleteTuples(
                                     ._object(tuple.getObject()),
                             ClientWriteStatus.SUCCESS))
                     .collect(Collectors.toList());
-            return new ClientWriteResponse(new ArrayList<>(), deleteResponses);
+            return new ClientWriteResponse(apiResponse, new ArrayList<>(), deleteResponses);
         });
     }
 

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

@@ -28,6 +28,17 @@ public ClientWriteResponse(List<ClientWriteSingleResponse> writes, List<ClientWr
         this.deletes = deletes != null ? deletes : Collections.emptyList();
     }
 
+    public ClientWriteResponse(
+            ApiResponse<Object> apiResponse,
+            List<ClientWriteSingleResponse> writes,
+            List<ClientWriteSingleResponse> deletes) {
+        this.statusCode = apiResponse.getStatusCode();
+        this.headers = apiResponse.getHeaders();
+        this.rawResponse = apiResponse.getRawResponse();
+        this.writes = writes != null ? writes : Collections.emptyList();
+        this.deletes = deletes != null ? deletes : Collections.emptyList();
+    }
+
     public int getStatusCode() {
         return statusCode;
     }