Merge pull request #355 from hearchco/as/feat/exchange-currencies

feat(exchange): supported currencies route

src/router/routes/responses.go

@@ -36,3 +36,10 @@ type ExchangeResponse struct {
  Amount float64 `json:"amount"`
  Result float64 `json:"result"`
 }
+
+type CurrenciesResponse struct {
+ responseBase
+
+ Base currency.Currency `json:"base"`
+ Currencies currency.Currencies `json:"currencies"`
+}

src/router/routes/route_currencies.go

@@ -0,0 +1,57 @@
+package routes
+
+import (
+ "fmt"
+ "net/http"
+ "time"
+
+ "github.com/hearchco/agent/src/cache"
+ "github.com/hearchco/agent/src/config"
+ "github.com/hearchco/agent/src/exchange"
+ "github.com/rs/zerolog/log"
+)
+
+func routeCurrencies(w http.ResponseWriter, ver string, conf config.Exchange, db cache.DB, ttl time.Duration) error {
+ // Capture start time.
+ startTime := time.Now()
+
+ // Get the cached currencies.
+ currencies, err := db.GetCurrencies(conf.BaseCurrency, conf.Engines)
+ if err != nil {
+ log.Error().
+ Err(err).
+ Str("base", conf.BaseCurrency.String()).
+ Str("engines", fmt.Sprintf("%v", conf.Engines)).
+ Msg("Error while getting currencies from cache")
+ }
+
+ // Create the exchange.
+ var exch exchange.Exchange
+ if currencies == nil {
+ // Fetch the currencies from the enabled engines.
+ exch = exchange.NewExchange(conf)
+ // Cache the currencies if any have been fetched.
+ if len(exch.Currencies()) > 0 {
+ err := db.SetCurrencies(conf.BaseCurrency, conf.Engines, exch.Currencies(), ttl)
+ if err != nil {
+ log.Error().
+ Err(err).
+ Str("base", conf.BaseCurrency.String()).
+ Str("engines", fmt.Sprintf("%v", conf.Engines)).
+ Msg("Error while setting currencies in cache")
+ }
+ }
+ } else {
+ // Use the cached currencies.
+ exch = exchange.NewExchange(conf, currencies)
+ }
+
+ return writeResponseJSON(w, http.StatusOK, CurrenciesResponse{
+ responseBase{
+ ver,
+ time.Since(startTime).Milliseconds(),
+ },
+ conf.BaseCurrency,
+ exch.Currencies(),
+ })
+}

src/router/routes/setup.go

@@ -102,6 +102,28 @@ func Setup(mux *chi.Mux, ver string, db cache.DB, conf config.Config) {
  }
  })
 
+ // /currencies
+ mux.Get("/currencies", func(w http.ResponseWriter, r *http.Request) {
+ err := routeCurrencies(w, ver, conf.Exchange, db, conf.Server.Cache.TTL.Currencies)
+ if err != nil {
+ log.Error().
+ Err(err).
+ Str("path", r.URL.Path).
+ Str("method", r.Method).
+ Msg("Failed to send response")
+ }
+ })
+ mux.Post("/currencies", func(w http.ResponseWriter, r *http.Request) {
+ err := routeCurrencies(w, ver, conf.Exchange, db, conf.Server.Cache.TTL.Currencies)
+ if err != nil {
+ log.Error().
+ Err(err).
+ Str("path", r.URL.Path).
+ Str("method", r.Method).
+ Msg("Failed to send response")
+ }
+ })
+
  // /proxy
  mux.Get("/proxy", func(w http.ResponseWriter, r *http.Request) {
  err := routeProxy(w, r, conf.Server.ImageProxy.Salt, conf.Server.ImageProxy.Timeout)