From 69acf88a7b1f26891c8f1a8d9673ca2ae11ff114 Mon Sep 17 00:00:00 2001
From: Adrian Gallagher <thrasher@addictionsoftware.com>
Date: Fri, 13 Jul 2018 11:19:11 +1000
Subject: [PATCH] Fix race condition in request

---
 exchanges/request/request.go | 20 ++++++++++++--------
 1 file changed, 12 insertions(+), 8 deletions(-)

diff --git a/exchanges/request/request.go b/exchanges/request/request.go
index 7beb4eaf..52e41e50 100644
--- a/exchanges/request/request.go
+++ b/exchanges/request/request.go
@@ -18,8 +18,8 @@ var supportedMethods = []string{"GET", "POST", "HEAD", "PUT", "DELETE", "OPTIONS
 // Requester struct for the request client
 type Requester struct {
 	HTTPClient  *http.Client
-	UnauthLimit RateLimit
-	AuthLimit   RateLimit
+	UnauthLimit *RateLimit
+	AuthLimit   *RateLimit
 	Name        string
 	Cycle       time.Time
 	m           sync.Mutex
@@ -34,8 +34,8 @@ type RateLimit struct {
 }
 
 // NewRateLimit creates a new RateLimit
-func NewRateLimit(d time.Duration, rate int) RateLimit {
-	return RateLimit{Duration: d, Rate: rate}
+func NewRateLimit(d time.Duration, rate int) *RateLimit {
+	return &RateLimit{Duration: d, Rate: rate}
 }
 
 // ToString returns the rate limiter in string notation
@@ -156,7 +156,7 @@ func (r *Requester) SetRateLimit(auth bool, duration time.Duration, rate int) {
 }
 
 // GetRateLimit gets the request Requester ratelimiter
-func (r *Requester) GetRateLimit(auth bool) RateLimit {
+func (r *Requester) GetRateLimit(auth bool) *RateLimit {
 	if auth {
 		return r.AuthLimit
 	}
@@ -164,9 +164,13 @@ func (r *Requester) GetRateLimit(auth bool) RateLimit {
 }
 
 // New returns a new Requester
-func New(name string, authLimit, unauthLimit RateLimit, httpRequester *http.Client) *Requester {
-	r := &Requester{HTTPClient: httpRequester, UnauthLimit: unauthLimit, AuthLimit: authLimit, Name: name}
-	return r
+func New(name string, authLimit, unauthLimit *RateLimit, httpRequester *http.Client) *Requester {
+	return &Requester{
+		HTTPClient:  httpRequester,
+		UnauthLimit: unauthLimit,
+		AuthLimit:   authLimit,
+		Name:        name,
+	}
 }
 
 // IsValidMethod returns whether the supplied method is supported