-
Notifications
You must be signed in to change notification settings - Fork 126
/
symbols.go
40 lines (36 loc) · 894 Bytes
/
symbols.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
package models
import (
"strings"
"github.com/diadata-org/diadata/pkg/dia"
)
func (datastore *DB) GetSymbols(exchange string) ([]string, error) {
var result []string
var cursor uint64
key := "dia_" + dia.FilterKing + "_"
for {
var keys []string
var err error
keys, cursor, err = datastore.redisClient.Scan(cursor, key+"*", 10).Result()
if err != nil {
log.Error("GetPairs err", err)
return result, err
}
for _, value := range keys {
filteredKey := strings.Replace(strings.Replace(value, key, "", 1), "_ZSET", "", 1)
s := strings.Split(strings.Replace(filteredKey, key, "", 1), "_")
if exchange == "" {
if len(s) == 1 {
result = append(result, s[0])
}
} else {
if s[1] == exchange {
result = append(result, s[0])
}
}
}
if cursor == 0 {
log.Debugf("GetSymbols %v returns %v", key, result)
return result, nil
}
}
}