fix(client): correct name of write method

Author: rhamzeh

openfga_sdk/client/openfga_client.py

@@ -420,7 +420,7 @@ async def _write_with_transaction(self, body: ClientWriteRequest, options: dict[
                 i, True, None) for i in body.deletes]
         return ClientWriteResponse(writes=writes_response, deletes=deletes_response)
 
-    async def writes(self, body: ClientWriteRequest, options: dict[str, str]):
+    async def write(self, body: ClientWriteRequest, options: dict[str, str]):
         """
         Write or deletes tuples
         :param body - the write request
@@ -458,7 +458,7 @@ async def write_tuples(self, body: List[ClientTuple], options: dict[str, str]):
         :param retryParams.minWaitInMs(options) - Override the minimum wait before a retry is initiated
         """
         options = set_heading_if_not_set(options, CLIENT_METHOD_HEADER, "WriteTuples")
-        result = await self.writes(ClientWriteRequest(body, None), options)
+        result = await self.write(ClientWriteRequest(body, None), options)
         return result
 
     async def delete_tuples(self, body: List[ClientTuple], options: dict[str, str]):
@@ -471,7 +471,7 @@ async def delete_tuples(self, body: List[ClientTuple], options: dict[str, str]):
         :param retryParams.minWaitInMs(options) - Override the minimum wait before a retry is initiated
         """
         options = set_heading_if_not_set(options, CLIENT_METHOD_HEADER, "DeleteTuples")
-        result = await self.writes(ClientWriteRequest(None, body), options)
+        result = await self.write(ClientWriteRequest(None, body), options)
         return result
 
     #######################

test/test_openfga_client.py

@@ -757,7 +757,7 @@ async def test_write(self, mock_request):
                     )
                 ],
             )
-            await api_client.writes(
+            await api_client.write(
                 body,
                 options={"authorization_model_id": "01G5JAVJ41T49E9TT3SKVS7X1J"}
             )
@@ -794,7 +794,7 @@ async def test_delete(self, mock_request):
                     )
                 ],
             )
-            await api_client.writes(
+            await api_client.write(
                 body,
                 options={"authorization_model_id": "01G5JAVJ41T49E9TT3SKVS7X1J"}
             )
@@ -847,7 +847,7 @@ async def test_write_batch(self, mock_request):
             )
             transaction = WriteTransaction(
                 disabled=True, max_per_chunk=1, max_parallel_requests=10)
-            response = await api_client.writes(
+            response = await api_client.write(
                 body,
                 options={"authorization_model_id": "01G5JAVJ41T49E9TT3SKVS7X1J",
                          "transaction": transaction}
@@ -961,7 +961,7 @@ async def test_write_batch_min_parallel(self, mock_request):
                 ],
             )
             transaction = WriteTransaction(disabled=True, max_per_chunk=1, max_parallel_requests=1)
-            response = await api_client.writes(
+            response = await api_client.write(
                 body,
                 options={"authorization_model_id": "01G5JAVJ41T49E9TT3SKVS7X1J",
                          "transaction": transaction}
@@ -1074,7 +1074,7 @@ async def test_write_batch_larger_chunk(self, mock_request):
                 ],
             )
             transaction = WriteTransaction(disabled=True, max_per_chunk=2, max_parallel_requests=2)
-            response = await api_client.writes(
+            response = await api_client.write(
                 body,
                 options={"authorization_model_id": "01G5JAVJ41T49E9TT3SKVS7X1J",
                          "transaction": transaction}
@@ -1185,7 +1185,7 @@ async def test_write_batch_failed(self, mock_request):
             )
             transaction = WriteTransaction(
                 disabled=True, max_per_chunk=1, max_parallel_requests=10)
-            response = await api_client.writes(
+            response = await api_client.write(
                 body,
                 options={"authorization_model_id": "01G5JAVJ41T49E9TT3SKVS7X1J",
                          "transaction": transaction}
@@ -1289,7 +1289,7 @@ async def test_delete_batch(self, mock_request):
             )
             transaction = WriteTransaction(
                 disabled=True, max_per_chunk=1, max_parallel_requests=10)
-            await api_client.writes(
+            await api_client.write(
                 body,
                 options={"authorization_model_id": "01G5JAVJ41T49E9TT3SKVS7X1J",
                          "transaction": transaction}
@@ -1425,7 +1425,7 @@ async def test_write_batch_unauthorized(self, mock_request):
                 )
                 transaction = WriteTransaction(
                     disabled=True, max_per_chunk=1, max_parallel_requests=10)
-                await api_client.writes(
+                await api_client.write(
                     body,
                     options={"authorization_model_id": "01G5JAVJ41T49E9TT3SKVS7X1J",
                              "transaction": transaction}