cache crypto prices for 5 mins

micro · Mar 21, 2022 · adc0061 · adc0061
1 parent 3a63283
commit adc0061
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/crypto/handler/crypto.go b/crypto/handler/crypto.go
@@ -217,6 +217,15 @@ func (c *Crypto) Price(ctx context.Context, req *pb.PriceRequest, rsp *pb.PriceR
 		return errors.BadRequest("crypto.price", "invalid symbol")
 	}
 
+	// check the cache
+	cached, ok := c.Cache.Get("prices:"+req.Symbol)
+	if ok {
+		rsp.Symbol = req.Symbol
+		rsp.Price, _ = cached.(float64)
+		return nil
+	}
+
+
 	uri := fmt.Sprintf("%slast/crypto/%s?apikey=%s", c.Api, req.Symbol, c.Key)
 
 	resp, err := http.Get(uri)
@@ -243,6 +252,9 @@ func (c *Crypto) Price(ctx context.Context, req *pb.PriceRequest, rsp *pb.PriceR
 	rsp.Symbol = req.Symbol
 	rsp.Price = respBody["price"].(float64)
 
+	// set the cache
+	c.Cache.Set("prices:"+req.Symbol, rsp.Price, time.Minute * 5)
+
 	return nil
 }