From 3072e4a82695a71cdffa38e94afbf213c2b14233 Mon Sep 17 00:00:00 2001 From: Gui Heise Date: Fri, 14 Jan 2022 13:17:37 -0500 Subject: [PATCH] Specify coingecko id's and remove async keyword from cli --- cli.py | 2 +- mev_inspect/prices.py | 4 ++-- mev_inspect/schemas/prices.py | 2 +- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/cli.py b/cli.py index 4cbaeb0..140268e 100644 --- a/cli.py +++ b/cli.py @@ -108,7 +108,7 @@ def enqueue_many_blocks_command(after_block: int, before_block: int, batch_size: @cli.command() @coro -async def fetch_all_prices(): +def fetch_all_prices(): inspect_db_session = get_inspect_session() logger.info("Fetching prices") diff --git a/mev_inspect/prices.py b/mev_inspect/prices.py index 94816c6..af0eff3 100644 --- a/mev_inspect/prices.py +++ b/mev_inspect/prices.py @@ -3,7 +3,7 @@ from typing import List from pycoingecko import CoinGeckoAPI -from mev_inspect.schemas.prices import TOKEN_ADDRESSES, TOKEN_NAME_BY_ADDRESS, Price +from mev_inspect.schemas.prices import COINGECKO_ID_BY_ADDRESS, TOKEN_ADDRESSES, Price def fetch_prices() -> List[Price]: @@ -12,7 +12,7 @@ def fetch_prices() -> List[Price]: for token_address in TOKEN_ADDRESSES: price_data = cg.get_coin_market_chart_by_id( - id=TOKEN_NAME_BY_ADDRESS[token_address], vs_currency="usd", days="max" + id=COINGECKO_ID_BY_ADDRESS[token_address], vs_currency="usd", days="max" ) price_time_series = price_data["prices"] diff --git a/mev_inspect/schemas/prices.py b/mev_inspect/schemas/prices.py index 3b99ad1..e57987c 100644 --- a/mev_inspect/schemas/prices.py +++ b/mev_inspect/schemas/prices.py @@ -29,7 +29,7 @@ TOKEN_ADDRESSES = [ CDAI_TOKEN_ADDRESS, ] -TOKEN_NAME_BY_ADDRESS = { +COINGECKO_ID_BY_ADDRESS = { WETH_ADDRESS: "weth", ETH_TOKEN_ADDRESS: "ethereum", WBTC_TOKEN_ADDRESS: "wrapped-bitcoin",