Restrict msg_ttl to create and purge key-value operation

Signed-off-by: Casper Beyer <casper@synadia.com>

Author: caspervonb

nats/src/nats/js/kv.py

@@ -226,7 +226,7 @@ async def create(self, key: str, value: bytes, validate_keys: bool = True, msg_t
 
         pa = None
         try:
-            pa = await self.update(key, value, last=0, validate_keys=validate_keys, msg_ttl=msg_ttl)
+            pa = await self._update(key, value, last=0, validate_keys=validate_keys, msg_ttl=msg_ttl)
         except nats.js.errors.KeyWrongLastSequenceError as err:
             # In case of attempting to recreate an already deleted key,
             # the client would get a KeyWrongLastSequenceError.  When this happens,
@@ -246,7 +246,7 @@ async def create(self, key: str, value: bytes, validate_keys: bool = True, msg_t
                 # to recreate using the last revision.
                 raise err
             except nats.js.errors.KeyDeletedError as err:
-                pa = await self.update(
+                pa = await self._update(
                     key, value, last=err.entry.revision, validate_keys=validate_keys, msg_ttl=msg_ttl
                 )
 
@@ -258,14 +258,20 @@ async def update(
         value: bytes,
         last: Optional[int] = None,
         validate_keys: bool = True,
-        msg_ttl: Optional[float] = None,
     ) -> int:
         """
         update will update the value if the latest revision matches.
-
-        Note: TTL parameter is accepted for internal use by create(), but should not be
-        used directly on update operations per NATS KV semantics.
         """
+        return await self._update(key, value, last=last, validate_keys=validate_keys)
+
+    async def _update(
+        self,
+        key: str,
+        value: bytes,
+        last: Optional[int] = None,
+        validate_keys: bool = True,
+        msg_ttl: Optional[float] = None,
+    ) -> int:
         if validate_keys and not _is_key_valid(key):
             raise nats.js.errors.InvalidKeyError(key)
 
@@ -286,15 +292,17 @@ async def update(
         return pa.seq
 
     async def delete(
-        self, key: str, last: Optional[int] = None, validate_keys: bool = True, msg_ttl: Optional[float] = None
+        self,
+        key: str,
+        last: Optional[int] = None,
+        validate_keys: bool = True,
     ) -> bool:
         """
         delete will place a delete marker and remove all previous revisions.
 
         :param key: The key to delete
         :param last: Expected last revision number (for optimistic concurrency)
         :param validate_keys: Whether to validate the key format
-        :param msg_ttl: Optional TTL (time-to-live) in seconds for the delete marker
         """
         if validate_keys and not _is_key_valid(key):
             raise nats.js.errors.InvalidKeyError(key)
@@ -305,7 +313,7 @@ async def delete(
         if last and last > 0:
             hdrs[api.Header.EXPECTED_LAST_SUBJECT_SEQUENCE] = str(last)
 
-        await self._js.publish(f"{self._pre}{key}", headers=hdrs, msg_ttl=msg_ttl)
+        await self._js.publish(f"{self._pre}{key}", headers=hdrs)
         return True
 
     async def purge(self, key: str, msg_ttl: Optional[float] = None) -> bool: