Additional fixes

currency/pairs.go

@@ -210,12 +210,14 @@ func (p Pairs) Remove(pair Pair) (Pairs, error) {
 	return nil, fmt.Errorf("%s %w", pair, ErrPairNotFound)
 }
 
-// Add adds a specified pair to the list of pairs if it doesn't exist
-func (p Pairs) Add(pair Pair) Pairs {
-	if p.Contains(pair, true) {
-		return p
+// Add adds specified pairs to the list of pairs if they don't exist
+func (p Pairs) Add(pairs ...Pair) Pairs {
+	for x := range pairs {
+		if p.Contains(pairs[x], true) {
+			continue
+		}
+		p = append(p, pairs[x])
 	}
-	p = append(p, pair)
 	return p
 }
 

exchanges/coinbasepro/coinbasepro.go

@@ -151,7 +151,6 @@ var (
 	errNoWalletForCurrency    = errors.New("no wallet found for currency, address creation impossible")
 	errChannelNameUnknown     = errors.New("unknown channel name")
 	errNoWalletsReturned      = errors.New("no wallets returned")
-	errUnknownEndpointLimit   = errors.New("unknown endpoint limit")
 	errPayMethodNotFound      = errors.New("payment method not found")
 	errUnknownL2DataType      = errors.New("unknown l2update data type")
 	errUnknownSide            = errors.New("unknown side")

exchanges/coinbasepro/coinbasepro_test.go

@@ -1675,7 +1675,7 @@ func TestProcessSnapshotUpdate(t *testing.T) {
 }
 
 func TestGenerateDefaultSubscriptions(t *testing.T) {
-	comparison := []subscription.Subscription{{Channel: "heartbeats"}, {Channel: "status"}, {Channel: "ticker"},
+	comparison := subscription.List{{Channel: "heartbeats"}, {Channel: "status"}, {Channel: "ticker"},
 		{Channel: "ticker_batch"}, {Channel: "candles"}, {Channel: "market_trades"}, {Channel: "level2"},
 		{Channel: "user"}}
 	for i := range comparison {