Setup new top gainers endpoiont (#634)

.dockerignore

@@ -16,4 +16,5 @@ db.dump
 __pycache__
 kafka_data
 pg_data
-!terminal/.env
+!terminal/.env
+!.python-version

api/apis.py

@@ -148,7 +148,7 @@ def ticker_24(self, type: str = "FULL", symbol: str | None = None):
             params["symbol"] = symbol
 
         # mongo_cache = self.setup_mongocache()
-        # expire_after = 15m because candlesticks are 15m
+        # # because candlesticks are 15m
         # session = CachedSession('ticker_24_cache', backend=mongo_cache, expire_after=15)
         data = self.request(url=self.ticker24_url, params=params)
         return data

api/autotrade/controller.py

@@ -74,3 +74,7 @@ def edit_settings(self, data):
         AsyncBaseProducer().update_required("UPDATE_AUTOTRADE_SETTINGS")
         self.session.close()
         return settings
+
+    def get_fiat(self):
+        data = self.get_settings()
+        return data.fiat

api/charts/controllers.py

@@ -116,7 +116,8 @@ class MarketDominationController(Database, BinbotApi):
     def __init__(self) -> None:
         super().__init__()
         self.collection = self.kafka_db.market_domination
-        self.autotrade_settings = AutotradeSettingsController().get_settings()
+        self.autotrade_db = AutotradeSettingsController()
+        self.autotrade_settings = self.autotrade_db.get_settings()
 
     def mkdm_migration(self):
         """
@@ -236,3 +237,16 @@ def get_market_domination(self, size=7):
             ]
         )
         return list(result)
+
+    def top_gainers(self):
+        """
+        Get market top gainers of the day
+
+        ATTENTION - This is a very heavy weight operation
+        ticker_24() retrieves all tokens
+        """
+        fiat = self.autotrade_db.get_fiat()
+        ticket_data = self.ticker_24()
+
+        fiat_market_data = sorted((item for item in ticket_data if item["symbol"].endswith(fiat) and float(item["priceChangePercent"]) > 0), key=lambda x: x["priceChangePercent"], reverse=True)
+        return fiat_market_data[:10]

api/charts/routes.py

@@ -1,4 +1,4 @@
-from fastapi import APIRouter
+from fastapi import APIRouter, HTTPException
 from tools.round_numbers import format_ts
 from charts.models import (
     GetMarketDominationResponse,
@@ -99,3 +99,22 @@ def md_migration():
         return json_response_error(
             f"Failed to migrate market domination data: {error.args[0]}"
         )
+
+
+@charts_blueprint.get("/top-gainers", tags=["assets"])
+def top_gainers():
+    try:
+        response = MarketDominationController().top_gainers()
+        if response:
+            return json_response(
+                {
+                    "data": response,
+                    "message": "Successfully retrieved top gainers data.",
+                    "error": 0,
+                }
+            )
+        else:
+            raise HTTPException(404, detail="No data found")
+
+    except Exception as error:
+        return json_response_error(f"Failed to retrieve top gainers data: {error}")

api/database/models/autotrade_table.py

@@ -40,6 +40,7 @@ class AutotradeTable(SQLModel, table=True):
     stop_loss: float = Field(default=0)
     take_profit: float = Field(default=2.3)
     balance_to_use: str = Field(default="USDC")
+    fiat: str = Field(default="USDC")
     max_request: int = Field(default=950)
     telegram_signals: bool = Field(default=True)
     max_active_autotrade_bots: int = Field(default=1)

api/tests/test_autotrade_settings.py

@@ -50,6 +50,8 @@ def test_get_autotrade_settings(client) -> None:
             "test_autotrade": False,
             "trailling_deviation": 0.63,
             "stop_loss": 0.0,
+            "fiat": "USDC",
+            # Below to be deprecated
             "balance_to_use": "USDC",
             "telegram_signals": True,
             "close_condition": "dynamic_trailling",