mirror of
https://github.com/autistic-symposium/blockchain-data-engineering-toolkit.git
synced 2025-04-25 18:29:19 -04:00
💾
This commit is contained in:
parent
78549114f6
commit
f23e1b9fd6
@ -74,7 +74,7 @@ def log_info(string) -> None:
|
|||||||
def log_debug(string) -> None:
|
def log_debug(string) -> None:
|
||||||
"""Print STDOUT debug using the logging library."""
|
"""Print STDOUT debug using the logging library."""
|
||||||
|
|
||||||
logging.debug('⚠️ %s', string)
|
logging.debug('🟡 %s', string)
|
||||||
|
|
||||||
|
|
||||||
def open_json(filepath) -> dict:
|
def open_json(filepath) -> dict:
|
||||||
|
@ -4,21 +4,35 @@
|
|||||||
|
|
||||||
import src.utils.os_utils as os_utils
|
import src.utils.os_utils as os_utils
|
||||||
|
|
||||||
|
def _craft_url(env_vars, endpoint):
|
||||||
|
"""Craft the URL for the API."""
|
||||||
|
|
||||||
def fetch_token_balance(ewallet):
|
host = env_vars['API_HOST_URL']
|
||||||
|
if host == '0.0.0.0':
|
||||||
|
host = 'http://localhost'
|
||||||
|
port = env_vars['API_HOST_PORT']
|
||||||
|
|
||||||
|
return f"{host}:{port}/{endpoint}"
|
||||||
|
|
||||||
|
|
||||||
|
def fetch_token_balance(env_vars, wallet):
|
||||||
"""Test the fetch_token_balance function."""
|
"""Test the fetch_token_balance function."""
|
||||||
|
|
||||||
endpoint = f"balance/{wallet}"
|
endpoint = f'balance/{wallet}'
|
||||||
url = f'http://localhost:80/{endpoint}'
|
|
||||||
|
url = _craft_url(env_vars, endpoint)
|
||||||
|
|
||||||
response = os_utils.send_get_request(url)
|
response = os_utils.send_get_request(url)
|
||||||
os_utils.log_info(response)
|
os_utils.log_info(response)
|
||||||
|
|
||||||
|
|
||||||
def fetch_top_token_holders(env_vars, top_number):
|
def fetch_top_token_holders(env_vars):
|
||||||
"""Test the fetch_top_token_holders function."""
|
"""Test the fetch_top_token_holders function."""
|
||||||
|
|
||||||
url = os_utils.format_url(f"{env_vars['API_HOST_URL']}:{env_vars['API_HOST_PORT']}", \
|
endpoint = f'top'
|
||||||
"top")
|
|
||||||
|
url = _craft_url(env_vars, endpoint)
|
||||||
|
|
||||||
response = os_utils.send_get_request(url)
|
response = os_utils.send_get_request(url)
|
||||||
os_utils.log_info(response)
|
os_utils.log_info(response)
|
||||||
|
|
||||||
@ -26,7 +40,9 @@ def fetch_top_token_holders(env_vars, top_number):
|
|||||||
def fetch_change(env_vars, wallet):
|
def fetch_change(env_vars, wallet):
|
||||||
"""Test the fetch_change function."""
|
"""Test the fetch_change function."""
|
||||||
|
|
||||||
url = os_utils.format_url(f"{env_vars['API_HOST_URL']}:{env_vars['API_HOST_PORT']}", \
|
endpoint = f'weekly/{wallet}'
|
||||||
f"/weekly/{wallet}")
|
|
||||||
|
url = _craft_url(env_vars, endpoint)
|
||||||
|
|
||||||
response = os_utils.send_get_request(url)
|
response = os_utils.send_get_request(url)
|
||||||
os_utils.log_info(response)
|
os_utils.log_info(response)
|
||||||
|
Loading…
x
Reference in New Issue
Block a user