From 47c026e8edbb7f5890c860aed060ead3ab941971 Mon Sep 17 00:00:00 2001 From: yuriy0803 <68668177+yuriy0803@users.noreply.github.com> Date: Fri, 14 Apr 2023 20:03:28 +0200 Subject: [PATCH] Update redis.go --- storage/redis.go | 11 ++--------- 1 file changed, 2 insertions(+), 9 deletions(-) diff --git a/storage/redis.go b/storage/redis.go index 2adb6ea..1f727af 100644 --- a/storage/redis.go +++ b/storage/redis.go @@ -1772,7 +1772,6 @@ func (r *RedisClient) NumberStratumWorker(count int) { } func (r *RedisClient) StoreExchangeData(ExchangeData []map[string]interface{}) { - tx := r.client.Multi() defer tx.Close() @@ -1780,13 +1779,11 @@ func (r *RedisClient) StoreExchangeData(ExchangeData []map[string]interface{}) { for _, coindata := range ExchangeData { for key, value := range coindata { - - cmd := tx.HSet(r.formatKey("exchange", coindata["symbol"]), fmt.Sprintf("%v", key), fmt.Sprintf("%v", value)) + cmd := tx.HSet(r.formatKey("exchange", coindata["symbol"].(string)), fmt.Sprintf("%v", key), fmt.Sprintf("%v", value)) err := cmd.Err() if err != nil { - log.Printf("Error while Storing %s : Key-%s , value-%s , Error : %v", coindata["symbol"], key, value, err) + log.Printf("Error while Storing %s : Key-%s , value-%s , Error : %v", coindata["symbol"].(string), key, value, err) } - } } log.Printf("Writing Exchange Data ") @@ -1794,14 +1791,10 @@ func (r *RedisClient) StoreExchangeData(ExchangeData []map[string]interface{}) { } func (r *RedisClient) GetExchangeData(coinsymbol string) (map[string]string, error) { - cmd := r.client.HGetAllMap(r.formatKey("exchange", coinsymbol)) - result, err := cmd.Result() - if err != nil { return nil, err } - return result, err }