Resolve "Add processBefore parameter to kraken.futures.Trade.{cancel_order,edit_order,create_order,create_batch_order}"

kraken/futures/trade.py

@@ -119,6 +119,7 @@
     def create_batch_order(
         self: Trade,
         batchorder_list: list[dict],
+        processBefore: Optional[str] = None,
         *,
         extra_params: Optional[dict] = None,
     ) -> dict:
@@ -133,6 +134,8 @@
         :param batchorder_list: List of order instructions (see example below -
             or the linked official Kraken documentation)
         :type batchorder_list: list[dict]
+        :param processBefore: Process before timestamp otherwise reject
+        :type processBefore: str, optional
         :return: Information about the submitted request
         :rtype: dict
 
@@ -223,10 +226,14 @@
             }
         """
         batchorder: dict = {"batchOrder": batchorder_list}
+        params = {"json": f"{batchorder}"}
+        if processBefore:
+            params["processBefore"] = processBefore
+
         return self._request(  # type: ignore[return-value]
             method="POST",
             uri="/derivatives/api/v3/batchorder",
-            post_params={"json": f"{batchorder}"},
+            post_params=params,
             auth=True,
             extra_params=extra_params,
         )
@@ -335,6 +342,7 @@
         self: Trade,
         order_id: Optional[str] = None,
         cliOrdId: Optional[str] = None,
+        processBefore: Optional[str] = None,
         *,
         extra_params: Optional[dict] = None,
     ) -> dict:
@@ -351,6 +359,8 @@
         :type order_id: str, optional
         :param cliOrdId: The client defined order id
         :type cliOrdId: str, optional
+        :param processBefore: Process before timestamp otherwise reject
+        :type processBefore: str, optional
         :raises ValueError: If both ``order_id`` and ``cliOrdId`` are not set
         :return: Success or failure
         :rtype: dict
@@ -377,6 +387,8 @@
             params["order_id"] = order_id
         elif defined(cliOrdId):
             params["cliOrdId"] = cliOrdId
+        elif defined(processBefore):
+            params["processBefore"] = processBefore
         else:
             raise ValueError("Either order_id or cliOrdId must be set!")
 
@@ -395,6 +407,7 @@
         limitPrice: Optional[str | float] = None,
         size: Optional[str | float] = None,
         stopPrice: Optional[str | float] = None,
+        processBefore: Optional[str] = None,
         *,
         extra_params: Optional[dict] = None,
     ) -> dict:
@@ -416,6 +429,8 @@
         :type size: str | float, optional
         :param stopPrice: The stop price
         :type stopPrice: str | float, optional
+        :param processBefore: Process before timestamp otherwise reject
+        :type processBefore: str, optional
         :raises ValueError: If both ``orderId`` and ``cliOrdId`` are not set
         :return: Success or failure
         :rtype: dict
@@ -453,6 +468,8 @@
             params["size"] = size
         if defined(stopPrice):
             params["stopPrice"] = stopPrice
+        if defined(processBefore):
+            params["processBefore"] = processBefore
 
         return self._request(  # type: ignore[return-value]
             method="POST",
@@ -524,6 +541,7 @@
         triggerSignal: Optional[str] = None,
         trailingStopDeviationUnit: Optional[str] = None,
         trailingStopMaxDeviation: Optional[str] = None,
+        processBefore: Optional[str] = None,
         *,
         extra_params: Optional[dict] = None,
     ) -> dict:
@@ -561,6 +579,8 @@
         :type trailingStopDeviationUnit: str, optional
         :param trailingStopMaxDeviation: See referenced Kraken documentation
         :type trailingStopMaxDeviation: str, optional
+        :param processBefore: Process before timestamp otherwise reject
+        :type processBefore: str, optional
         :return: Success or failure
         :rtype: dict
 
@@ -721,6 +741,8 @@
             params["trailingStopDeviationUnit"] = trailingStopDeviationUnit
         if defined(trailingStopMaxDeviation):
             params["trailingStopMaxDeviation"] = trailingStopMaxDeviation
+        if defined(processBefore):
+            params["processBefore"] = processBefore
 
         return self._request(  # type: ignore[return-value]
             method="POST",

pyproject.toml

@@ -339,6 +339,7 @@ ignore-names = [
   "TIMEOUT",
   "URL",
   "HEADERS",
+  "processBefore",
 ]
 
 [tool.ruff.lint.pylint]
@@ -547,6 +548,7 @@ good-names = [
   "TIMEOUT",
   "URL",
   "HEADERS",
+  "processBefore",
 ]
 
 # Good variable names regexes, separated by a comma. If names match any regex,

tests/futures/test_futures_trade.py

@@ -99,6 +99,7 @@ def test_create_order(futures_demo_trade) -> None:
             limitPrice=1,
             stopPrice=10,
             reduceOnly=True,
+            processBefore="3033-11-08T19:56:35.441899Z",
         )
 
     # FIXME: why are these commented out?
@@ -204,6 +205,7 @@ def test_create_batch_order(futures_demo_trade) -> None:
                         "cliOrdId": "my_client_id",
                     },
                 ],
+                processBefore="3033-11-08T19:56:35.441899Z",
             ),
         )
 
@@ -227,6 +229,7 @@ def test_edit_order(futures_demo_trade) -> None:
             cliOrdId="685d5a1a-23eb-450c-bf17-1e4ab5c6fe8a",
             size=111.0,
             stopPrice=1000,
+            processBefore="3033-11-08T19:56:35.441899Z",
         ),
     )
 
@@ -251,7 +254,8 @@ def test_cancel_order(futures_demo_trade) -> None:
     """
     assert is_success(
         futures_demo_trade.cancel_order(
-            cliOrdId="685d5a1a-23eb-450c-bf17-1e4ab5c6fe8a",
+            cliOrdId="my_another_client_id",
+            processBefore="3033-11-08T19:56:35.441899Z",
         ),
     )
     assert is_success(