From 136dac8152273b7e95395930036b6e2c724ed650 Mon Sep 17 00:00:00 2001
From: E Sequeira <5458743+geseq@users.noreply.github.com>
Date: Thu, 3 Nov 2022 03:03:30 +0000
Subject: [PATCH] Kraken: use configured endpoint for futures (#1071)

* fix: use configured endpoint for kraken futures

* cleanup

* Update kraken_futures.go

* remove redundant constant
---
 exchanges/kraken/kraken.go         | 3 +--
 exchanges/kraken/kraken_futures.go | 6 ++++++
 exchanges/kraken/kraken_wrapper.go | 2 +-
 3 files changed, 8 insertions(+), 3 deletions(-)

diff --git a/exchanges/kraken/kraken.go b/exchanges/kraken/kraken.go
index 179439e0..591b8622 100644
--- a/exchanges/kraken/kraken.go
+++ b/exchanges/kraken/kraken.go
@@ -25,8 +25,7 @@ import (
 
 const (
 	krakenAPIURL         = "https://api.kraken.com"
-	krakenFuturesURL     = "https://futures.kraken.com"
-	futuresURL           = "https://futures.kraken.com/derivatives"
+	krakenFuturesURL     = "https://futures.kraken.com/derivatives"
 	krakenSpotVersion    = "0"
 	krakenFuturesVersion = "3"
 )
diff --git a/exchanges/kraken/kraken_futures.go b/exchanges/kraken/kraken_futures.go
index 09f2d26d..1f0573a8 100644
--- a/exchanges/kraken/kraken_futures.go
+++ b/exchanges/kraken/kraken_futures.go
@@ -316,6 +316,12 @@ func (k *Kraken) SendFuturesAuthRequest(ctx context.Context, method, path string
 			"Nonce":   nonce,
 		}
 
+		var futuresURL string
+		futuresURL, err = k.API.Endpoints.GetURL(exchange.RestFutures)
+		if err != nil {
+			return nil, err
+		}
+
 		return &request.Item{
 			Method:        method,
 			Path:          futuresURL + common.EncodeURLValues(path, data),
diff --git a/exchanges/kraken/kraken_wrapper.go b/exchanges/kraken/kraken_wrapper.go
index c98fc189..eedd1751 100644
--- a/exchanges/kraken/kraken_wrapper.go
+++ b/exchanges/kraken/kraken_wrapper.go
@@ -182,7 +182,7 @@ func (k *Kraken) SetDefaults() {
 	k.API.Endpoints = k.NewEndpoints()
 	err = k.API.Endpoints.SetDefaultEndpoints(map[exchange.URL]string{
 		exchange.RestSpot:      krakenAPIURL,
-		exchange.RestFutures:   futuresURL,
+		exchange.RestFutures:   krakenFuturesURL,
 		exchange.WebsocketSpot: krakenWSURL,
 	})
 	if err != nil {