fix for annoying volatility filter (#15)

* fixes

* fixes

* fixes

* fixes

Author: mikekonan

.github/workflows/docker_image.yml

@@ -2,7 +2,7 @@ name: Docker Image CI
 
 on:
   push:
-    branches: [ main ]
+    branches: [ main, debug ]
     tags:
       - v*
   pull_request:

Makefile

@@ -1,7 +1,10 @@
-.PHONY: help build clean
+.PHONY: help build build-local clean
 
 .DEFAULT_GOAL := help
 
+build-local:
+	go build -trimpath -o ./bin/freqtrade-proxy
+
 build: ## build binaries
 	go build -trimpath -o ./bin/freqtrade-proxy-darwin-amd64
 	for arch in "linux/amd64" "linux/arm/v6" "linux/arm/v7" "linux/arm64" ; do \

proxy/kucoin/kucoin.go

@@ -21,12 +21,19 @@ type subscriptionManager struct {
 	clients []*ws
 	rl      ratelimit.Limiter
 	l       *sync.Mutex
+	subs    map[string]struct{}
 }
 
 func (m *subscriptionManager) Subscribe(svc *sdk.ApiService, msg *sdk.WebSocketSubscribeMessage, store *store.Store) {
 	m.l.Lock()
 	defer m.l.Unlock()
 
+	if _, ok := m.subs[msg.Topic]; ok {
+		return
+	}
+
+	m.subs[msg.Topic] = struct{}{}
+
 	for i, c := range m.clients {
 		if c.count == 250 {
 			continue
@@ -87,7 +94,7 @@ func New(s *store.Store) *kucoin {
 	instance := &kucoin{
 		client:              fasthttp.Client{},
 		store:               s,
-		subscriptionManager: &subscriptionManager{clients: nil, rl: ratelimit.New(9), l: new(sync.Mutex)},
+		subscriptionManager: &subscriptionManager{clients: nil, rl: ratelimit.New(9), l: new(sync.Mutex), subs: map[string]struct{}{}},
 	}
 
 	svc := sdk.NewApiService(sdk.ApiKeyVersionOption(sdk.ApiKeyVersionV2))
@@ -178,8 +185,7 @@ func (kucoin *kucoin) getKlines(pair string, timeframe string, startAt int64, en
 			break
 		}
 
-		logrus.Warn(i)
-		if i == retryCount {
+		if i == retryCount || !strings.HasPrefix(resp.Code, "429") {
 			return sdk.KLinesModel{}, resp, err
 		}
 
@@ -232,7 +238,7 @@ func (kucoin *kucoin) truncateTs(timeframe string, ts time.Time) time.Time {
 type apiResp struct {
 	Code    string          `json:"code"`
 	RawData json.RawMessage `json:"data,omitempty"`
-	Message string          `json:"msg"`
+	Message string          `json:"msg,omitempty"`
 }
 
 func (resp *apiResp) json() []byte {

store/store.go

@@ -243,12 +243,6 @@ func (store *Store) Get(exchange string, pair string, timeframe string, from tim
 			logrus.Panic()
 		}
 
-		if fromCandle.Ts == 0 {
-			if err := tx.Get(&fromCandle, store.selectFirstCandleAfterTs(exchange, pair, timeframe, from.Unix())); err != nil && !errors.Is(err, sql.ErrNoRows) {
-				logrus.Panic()
-			}
-		}
-
 		if fromCandle.Ts == 0 {
 			return nil
 		}