Merge pull request #5023 from mengyiren/feature/kraken_cancel_all_orders

Feature/kraken cancel all orders

Author: timmolter

.idea/codeStyles/Project.xml

@@ -152,6 +152,14 @@ KrakenCancelOrderResult cancelOrder(
       @FormParam("txid") String transactionId)
       throws IOException;
 
+  @POST
+  @Path("private/CancelAll")
+  @Consumes(MediaType.APPLICATION_FORM_URLENCODED)
+  KrakenCancelOrderResult cancelAllOrders(
+      @HeaderParam("API-Key") String apiKey,
+      @HeaderParam("API-Sign") ParamsDigest signer,
+      @FormParam("nonce") SynchronizedValueFactory<Long> nonce);
+
   @POST
   @Path("private/OpenOrders")
   @Consumes(MediaType.APPLICATION_FORM_URLENCODED)
@@ -193,14 +201,15 @@ KrakenQueryOrderResult queryOrders(
   /**
    * Get trades history
    *
-   * @param type ype = type of trade (optional) all = all types (default) any position = any
-   *     position (open or closed) closed position = positions that have been closed closing
-   *     position = any trade closing all or part of a position no position = non-positional trades
+   * @param type          ype = type of trade (optional) all = all types (default) any position =
+   *                      any position (open or closed) closed position = positions that have been
+   *                      closed closing position = any trade closing all or part of a position no
+   *                      position = non-positional trades
    * @param includeTrades whether or not to include trades related to position in output (optional.
-   *     default = false)
-   * @param start starting unix timestamp or trade tx id of results (optional. exclusive)
-   * @param end ending unix timestamp or trade tx id of results (optional. inclusive)
-   * @param offset result offset
+   *                      default = false)
+   * @param start         starting unix timestamp or trade tx id of results (optional. exclusive)
+   * @param end           ending unix timestamp or trade tx id of results (optional. inclusive)
+   * @param offset        result offset
    */
   @POST
   @Path("private/TradesHistory")

xchange-kraken/src/main/java/org/knowm/xchange/kraken/KrakenAuthenticated.java

@@ -2,6 +2,7 @@
 
 import java.io.IOException;
 import java.util.Collection;
+import java.util.Collections;
 import java.util.Map;
 import org.knowm.xchange.Exchange;
 import org.knowm.xchange.currency.CurrencyPair;
@@ -17,6 +18,7 @@
 import org.knowm.xchange.kraken.dto.trade.KrakenOrder;
 import org.knowm.xchange.kraken.dto.trade.KrakenTrade;
 import org.knowm.xchange.service.trade.TradeService;
+import org.knowm.xchange.service.trade.params.CancelAllOrders;
 import org.knowm.xchange.service.trade.params.CancelOrderByIdParams;
 import org.knowm.xchange.service.trade.params.CancelOrderByUserReferenceParams;
 import org.knowm.xchange.service.trade.params.CancelOrderParams;
@@ -97,6 +99,11 @@ public boolean cancelOrder(CancelOrderParams orderParams) throws IOException {
     return false;
   }
 
+  @Override
+  public Collection<String> cancelAllOrders(CancelAllOrders orderParams) throws IOException {
+    return Collections.singletonList(String.valueOf(super.cancelAllKrakenOrders().getCount()));
+  }
+
   @Override
   public Class[] getRequiredCancelOrderParamClasses() {
     return new Class[] {CancelOrderByIdParams.class, CancelOrderByUserReferenceParams.class};

xchange-kraken/src/main/java/org/knowm/xchange/kraken/service/KrakenTradeService.java

@@ -318,6 +318,15 @@ public KrakenCancelOrderResponse cancelKrakenOrder(String orderId) throws IOExce
     return checkResult(result);
   }
 
+  public KrakenCancelOrderResponse cancelAllKrakenOrders() {
+    KrakenCancelOrderResult result =
+        kraken.cancelAllOrders(
+            exchange.getExchangeSpecification().getApiKey(),
+            signatureCreator,
+            exchange.getNonceFactory());
+    return checkResult(result);
+  }
+
   protected KrakenTradeVolume getTradeVolume(CurrencyPair... currencyPairs) throws IOException {
 
     KrakenTradeVolumeResult result =

xchange-kraken/src/main/java/org/knowm/xchange/kraken/service/KrakenTradeServiceRaw.java

@@ -162,6 +162,22 @@ public void placeOrderWithTimeInForceTest() throws Exception {
     assertThat(requestParams.get("timeinforce")).isEqualTo("IOC");
   }
 
+  @Test
+  public void cancelAllOrdersTest() throws Exception {
+    stubFor(
+        post(urlPathEqualTo("/0/private/CancelAll"))
+            .willReturn(
+                aResponse()
+                    .withStatus(200)
+                    .withHeader("Content-Type", "application/json")
+                    .withBody(OPEN_ORDERS_BODY)));
+    classUnderTest.cancelAllOrders(null);
+    List<LoggedRequest> requests =
+        wireMockRule.findAll(postRequestedFor(urlEqualTo("/0/private/CancelAll")));
+    Map<String, String> requestParams = parseAddOrderRequestBody(requests.get(0));
+    assertThat(requestParams.get("nonce")).isLessThan(String.valueOf(System.currentTimeMillis()));
+  }
+  
   private void stubAddOrderApi() {
     stubFor(
         post(urlPathEqualTo("/0/private/AddOrder"))