use coingecko pro api

base/settings.py

@@ -37,6 +37,7 @@
 AWS_SECRET_ACCESS_KEY = os.environ.get("PL_AWS_SECRET_ACCESS_KEY")
 # CACHALOT_ENABLED = strtobool(os.environ.get("PL_CACHALOT_ENABLED", "False"))
 # CACHALOT_TIMEOUT = os.environ.get("PL_CACHALOT_TIMEOUT")
+COINGECKO_API_KEY = os.environ.get("PL_COINGECKO_API_KEY")
 DEBUG = strtobool(os.environ.get("PL_DEBUG", "False"))
 ENVIRONMENT = os.environ.get("PL_ENVIRONMENT", "local")
 LOG_LEVEL = os.getenv("PL_LOG_LEVEL", "INFO").upper()
@@ -53,7 +54,11 @@
 
 BLOCK_SAVE_HEIGHT = os.environ.get("BLOCK_SAVE_HEIGHT")
 
-COINGECKO_URL = "https://api.coingecko.com/api/v3"
+COINGECKO_URL = (
+    "https://pro-api.coingecko.com/api/v3"
+    if COINGECKO_API_KEY
+    else "https://api.coingecko.com/api/v3"
+)
 # Number of hours around a given timestamp for querying historical prices
 HISTORICAL_PRICE_QUERY_HOURS = 24
 

donations/models.py

@@ -241,6 +241,8 @@ def fetch_usd_prices(self):
                     "No existing price within acceptable time period; fetching historical price..."
                 )
                 endpoint = f"{settings.COINGECKO_URL}/coins/{self.ft.id}/history?date={format_date(self.donated_at)}&localization=false"
+                if settings.COINGECKO_API_KEY:
+                    endpoint += f"&x_cg_pro_api_key={settings.COINGECKO_API_KEY}"
                 logger.info(f"coingecko endpoint: {endpoint}")
                 response = requests.get(endpoint)
                 logger.info(f"coingecko response: {response}")

indexer_app/tasks.py

@@ -59,7 +59,7 @@ def listen_to_near_events():
     try:
         # Update below with desired network & block height
         # start_block = get_block_height("current_block_height")
-        start_block = 112952680
+        start_block = 112959664
         logger.info(f"what's the start block, pray tell? {start_block-1}")
         loop.run_until_complete(indexer("mainnet", start_block - 1, None))
     except WorkerLostError: