A Simple API for AtomicDEX network statistics

Currrent production URL: https://defi-stats.komodo.earth/docs#/

The goal of this project is to provide all required data from the Komodo DeFi DEX network to match the required formats for a variety of target consumers:

• CoinGecko
• CMC
• https://markets.atomicdex.io/

Data is sourced from the Komodo DeFi API's SQLite database. It is calculated and then stored in json files in the cache/folder every 5 minutes (or less). API endpoints then serve the data from these files (to reduce API endpoint response times).

Data is also imported into more robust databases (mySQL, postgresSQL/Timescale & dGraph) for future reference and to alow more complex queries over a longer timeframe.

Setup and requirements

Database setup

sudo apt update
sudo apt install postgresql postgresql-contrib build-essential python-dev python3-dev python3-psycopg2

sudo systemctl start postgresql.service
# https://www.digitalocean.com/community/tutorials/how-to-install-and-use-postgresql-on-ubuntu-18-04
# sudo -u postgres createuser --interactive
# sudo -u postgres createdb stats_swaps
# sudo -u postgres psql
# ALTER USER postgres PASSWORD 'myPassword';
# Update .env with creds (see readme after TODO: update)


cd ~/defi_stats/api
git stash
git pull
poetry install
docker compose build

# If not previously running wiuth systemd, skip this bit
sudo systemctl stop defi_stats.service 
sudo systemctl disable defi_stats.service 

docker compose up

• Run ./setup.sh to install poetry dependencies
• Create mm2/.env, and mm2_8762/.env with the following inside (change the userpass)

MM_CONF_PATH=/home/komodian/mm2/MM2.json
MM_COINS_PATH=/home/komodian/mm2/coins
MM_LOG=/home/komodian/mm2/mm2.log
USERPASS=RPC_CONTRoL_USERP@SSW0RD
USER_ID=1000
GROUP_ID=1000

• Next, create mm2/MM2.json and mm2_8762/MM2.json. Use the templates in each folder - cp mm2/MM2.template.json mm2/MM2.json. Change the passphrases.

• Get the latest coins file for each mm2 folder with wget https://raw.githubusercontent.com/KomodoPlatform/coins/master/coins

• Then execute ./run_mm2.sh to initialise the mm2 databases. You will need to find the path to the MM2.db file in each folder to input below. This script will tail the logs, but you can ctl-c to exit without stopping the service.

• Create api/.env file containing the following variables:

# DEPENDENCY VERSIONS
POETRY_VERSION='1.7.1'

# Use `serve` for front end. Any other value will do database merge and processing.
NODE_TYPE='serve'

# FastAPI
API_PORT=7068
API_HOST='0.0.0.0'
API_USER="komodian"
API_PASS="api_password"


# API KEYS
FIXER_API_KEY=your_key

# DATABASES

## External MySQL source DB
mysql_hostname="db_IP"
mysql_username="db_username"
mysql_password="db_password"
MYSQL_DATABASE="db_name"

## Postgres/TimescaleDB
POSTGRES_HOST=pgsqldb
POSTGRES_PORT=5432
POSTGRES_DATABASE=db_name
PGDATA=/var/lib/postgresql/data
MYSQL_USERNAME=db_user
POSTGRES_PASSWORD=db_pass

## Sqlite
LOCAL_MM2_DB_PATH_7777="/home/komodian/api/db/local/MM2_7777.db"
LOCAL_MM2_DB_PATH_8762="/home/komodian/api/db/local/MM2_8762.db"
HOST_LOCAL_MM2_DB_PATH_7777="/home/hound/defi_stats/api/db/local/MM2_7777.db"
HOST_LOCAL_MM2_DB_PATH_8762="/home/hound/defi_stats/api/db/local/MM2_8762.db"

# Komodo DeFi (hosts below are docker services, set to 127.0.0.1 if not using docker)
DEXAPI_7777_HOST="http://komodefi"
DEXAPI_8762_HOST="http://komodefi_8762"
DEXAPI_7777_PORT="7877"
DEXAPI_8762_PORT="7862"


# AtomicDEX API
COINS_CONFIG_URL='https://raw.githubusercontent.com/KomodoPlatform/coins/master/utils/coins_config.json'
COINS_URL='https://raw.githubusercontent.com/KomodoPlatform/coins/master/coins'

Edit the values for your paths and passwords etc. Some of these are not curently in us in main branch, but will be used later.

Sourcing data

• To ensure data integrity, past swaps are sourced from several long running Seed Nodes. This is periodically sourced via rsync with ./import_dbs.sh (assuming ssh key access). This script should be added to cron to check for updates every minute. E.g. * * * * * /home/USERNAME/defi_stats/api/db/source/import_dbs.sh

Running the API

From the project root folder, execute ./run_api.sh. Optionally, use the defi-stats.service file as a template to let systemd to manage the defi stats service.

Testing

You may need to install pytest: sudo apt install python-pytest

From the api folder:

• To test everything: poetry run pytest -vv
• To test a specific file: poetry run pytest -vv tests/test_file.py

Note

Alternative APIs are hosted at:

• https://stats-api.atomicdex.io/docs
• https://nomics.komodo.earth:8080/api/v1/info
• https://stats.testchain.xyz:8080/api/v1/summary

These should be consolidated in this repo at some point. They are based on branches of https://github.com/KomodoPlatform/dexstats_sqlite_py

Warning

Some data is cached with memcache. if the size of this data grows too large, it might fail to enter the cache. It should be split into smaller parts. See https://github.com/memcached/memcached/wiki/ConfiguringServer for configuration.

Known Issues

To speed up the orderbook request loop, the requests are sent in separate threads which update the memcache. As a result, the first request for an orderbook may return a template rather than actual result.

To mitigate this there are a few options:

• send a second request after a 3 second delay (kind of makes the threading speed up pointless, though waiting for one item could also give others later in the loop time to populate)
• Increase the orderbook loop frequency (this will reduce returned template chance, but can still happen for first request after cache expiry)
• Use a no_cache param for run_every functions so that background processing never uses existing cache. Alongside a loop frequency less than expiry time, this should ensure a persistantly populated cache at the expense of additional processing.
• Use a no_thread param for endpoint functions to avoid consumers receving a template where data should exist. This will be slightly less responsive when cache is empty, but will return valid data. This will update the cache along the way, but cant be relied on to keep the cache updated as consumer initiated requests is unpredictable.

Endpoints

All endpoints for this update will have a api/v3/ prefix. Swagger docs are available at https://192.168.0.1:7766/docs#/ (replace with domain/IP address when deployed).

For CoinGecko endpoints, we are using the prefix api/v3/gecko/ Endpoints previously at http://stats.testchain.xyz/ have been migrated to the prefix api/v3/markets/ Endpoints previously at https://stats-api.atomicdex.io/ have been migrated to the prefix api/v3/stats-api/

Data completeness

Add * * * * * /home/USERNAME/defi_stats/update_MM2_db.sh > /home/atomic/logs/db_update.log to the crontab of the server you are running this api on to collect a variety of MM2.db files on varying netids, and to cover any missing data from swaps completed during server downtime. SSH key access is required.

This will place the external MM2.db copies into the defi_stats/DB folder, which is then periodically scanned, with all data merged into defi_stats/DB/{netid}_MM2.db for each netid, and defi_stats/DB/all_MM2.db for the complete picture.

TODOs:

• Create table for liquidity to track it over time. Should be updated every hour, with any rows older than 1 day reduced into a single row of average values for the day. | id | pair | base_amount | quote_amount | base_price_usd | quote_price_usd | base_liquidity_usd | quote_liquidity_usd | combined_liquidity | timestamp | updated_at |

• Equivalent view for volumes can be derived from the defi_swaps table

• Migrate gui/version/pubkey related views/queries from kmd.stats.io

• Additional endpoints for use in apps:

  • Dex Resilience alerts for newsfeed.
  • "Trending pairs" and similar network context stats
  • Automated "Latest release" link / hash for all apps.

On Update:

• Run poetry install in the api/ folder to update any deps.
• If changes to DB, edit .env to uncomment # RESET_TABLE=True then launch. After launch, disable this again and restart. It will clear the db data and reload the table with new schema.