status-im
/
status-go
mirror of https://github.com/status-im/status-go.git
2
0
Fork 0
Code Issues Projects Releases Wiki Activity

feat: stt market data handler

This commit is contained in:
Anthony Laibe 2022-10-24 10:41:36 +02:00 committed by Anthony Laibe
parent 6918dd5ab8
commit 32ffb30bf0
1 changed files with 28 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

37
services/wallet/cryptocompare.go
View File

@ -11,6 +11,10 @@ import (
const cryptocompareURL = "https://min-api.cryptocompare.com" const cryptocompareURL = "https://min-api.cryptocompare.com"
var renameMapping = map[string]string{
"STT": "SNT",
}
type Coin struct { type Coin struct {
ID string `json:"Id"` ID string `json:"Id"`
Name string `json:"Name"` Name string `json:"Name"`
@ -60,10 +64,25 @@ type MarketValuesContainer struct {
Display map[string]map[string]MarketCoinValues `json:"Display"` Display map[string]map[string]MarketCoinValues `json:"Display"`
} }
func renameSymbols(symbols []string) (renames []string) {
for _, symbol := range symbols {
renames = append(renames, getRealSymbol(symbol))
}
return
}
func getRealSymbol(symbol string) string {
if val, ok := renameMapping[strings.ToUpper(symbol)]; ok {
return val
}
return strings.ToUpper(symbol)
}
func fetchCryptoComparePrices(symbols []string, currency string) (map[string]float64, error) { func fetchCryptoComparePrices(symbols []string, currency string) (map[string]float64, error) {
realSymbols := renameSymbols(symbols)
httpClient := http.Client{Timeout: time.Minute} httpClient := http.Client{Timeout: time.Minute}
url := fmt.Sprintf("%s/data/pricemulti?fsyms=%s&tsyms=%s&extraParams=Status.im", cryptocompareURL, strings.Join(symbols, ","), currency) url := fmt.Sprintf("%s/data/pricemulti?fsyms=%s&tsyms=%s&extraParams=Status.im", cryptocompareURL, strings.Join(realSymbols, ","), currency)
resp, err := httpClient.Get(url) resp, err := httpClient.Get(url)
if err != nil { if err != nil {
return nil, err return nil, err
@ -83,7 +102,7 @@ func fetchCryptoComparePrices(symbols []string, currency string) (map[string]flo
result := make(map[string]float64) result := make(map[string]float64)
for _, symbol := range symbols { for _, symbol := range symbols {
result[symbol] = prices[strings.ToUpper(symbol)][strings.ToUpper(currency)] result[symbol] = prices[getRealSymbol(symbol)][strings.ToUpper(currency)]
} }
return result, nil return result, nil
} }
@ -112,17 +131,18 @@ func fetchCryptoCompareTokenDetails(symbols []string) (map[string]Coin, error) {
coins := make(map[string]Coin) coins := make(map[string]Coin)
for _, symbol := range symbols { for _, symbol := range symbols {
coins[symbol] = container.Data[symbol] coins[symbol] = container.Data[getRealSymbol(symbol)]
} }
return coins, nil return coins, nil
} }
func fetchTokenMarketValues(symbols []string, currency string) (map[string]MarketCoinValues, error) { func fetchTokenMarketValues(symbols []string, currency string) (map[string]MarketCoinValues, error) {
realSymbols := renameSymbols(symbols)
item := map[string]MarketCoinValues{} item := map[string]MarketCoinValues{}
httpClient := http.Client{Timeout: time.Minute} httpClient := http.Client{Timeout: time.Minute}
url := fmt.Sprintf("%s/data/pricemultifull?fsyms=%s&tsyms=%s&extraParams=Status.im", cryptocompareURL, strings.Join(symbols, ","), currency) url := fmt.Sprintf("%s/data/pricemultifull?fsyms=%s&tsyms=%s&extraParams=Status.im", cryptocompareURL, strings.Join(realSymbols, ","), currency)
resp, err := httpClient.Get(url) resp, err := httpClient.Get(url)
if err != nil { if err != nil {
return item, err return item, err
@ -140,19 +160,18 @@ func fetchTokenMarketValues(symbols []string, currency string) (map[string]Marke
return item, err return item, err
} }
for key, element := range container.Display { for _, symbol := range symbols {
item[key] = element[strings.ToUpper(currency)] item[symbol] = container.Display[getRealSymbol(symbol)][strings.ToUpper(currency)]
} }
return item, nil return item, nil
} }
func fetchHourlyMarketValues(symbol string, currency string, limit int, aggregate int) ([]TokenHistoricalPairs, error) { func fetchHourlyMarketValues(symbol string, currency string, limit int, aggregate int) ([]TokenHistoricalPairs, error) {
item := []TokenHistoricalPairs{} item := []TokenHistoricalPairs{}
httpClient := http.Client{Timeout: time.Minute} httpClient := http.Client{Timeout: time.Minute}
url := fmt.Sprintf("%s/data/v2/histohour?fsym=%s&tsym=%s&aggregate=%d&limit=%d&extraParams=Status.im", cryptocompareURL, symbol, currency, aggregate, limit) url := fmt.Sprintf("%s/data/v2/histohour?fsym=%s&tsym=%s&aggregate=%d&limit=%d&extraParams=Status.im", cryptocompareURL, getRealSymbol(symbol), currency, aggregate, limit)
resp, err := httpClient.Get(url) resp, err := httpClient.Get(url)
if err != nil { if err != nil {
return item, err return item, err
@ -179,7 +198,7 @@ func fetchDailyMarketValues(symbol string, currency string, limit int, allData b
item := []TokenHistoricalPairs{} item := []TokenHistoricalPairs{}
httpClient := http.Client{Timeout: time.Minute} httpClient := http.Client{Timeout: time.Minute}
url := fmt.Sprintf("%s/data/v2/histoday?fsym=%s&tsym=%s&aggregate=%d&limit=%d&allData=%v&extraParams=Status.im", cryptocompareURL, symbol, currency, aggregate, limit, allData) url := fmt.Sprintf("%s/data/v2/histoday?fsym=%s&tsym=%s&aggregate=%d&limit=%d&allData=%v&extraParams=Status.im", cryptocompareURL, getRealSymbol(symbol), currency, aggregate, limit, allData)
resp, err := httpClient.Get(url) resp, err := httpClient.Get(url)
if err != nil { if err != nil {
return item, err return item, err