Mirror/robosats
1
0
Fork 0
mirror of https://github.com/RoboSats/robosats.git synced 2025-01-18 12:11:35 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Add second market price API. Median price is used.

Browse Source
This commit is contained in:
Reckless_Satoshi 2022-01-14 06:57:56 -08:00
parent 032d3a1369
commit ad58f66968
No known key found for this signature in database
GPG Key ID: 9C4585B561315571
3 changed files with 22 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
.env-sample
View File

@ -6,8 +6,8 @@ LND_GRPC_HOST='127.0.0.1:10009'
REDIS_URL=''
# Market price public API
MARKET_PRICE_API = 'https://blockchain.info/ticker'
# List of market price public APIs. If the currency is available in more than 1 API, will use median price.
MARKET_PRICE_APIS = https://blockchain.info/ticker, https://api.yadio.io/exrates/BTC
# Host e.g. robotestagw3dcxmd66r4rgksb4nmmr43fh77bzn2ia2eucduyeafnyd.onion
HOST_NAME = ''

1
api/logics.py
View File

@ -10,7 +10,6 @@ import math
FEE = float(config('FEE'))
BOND_SIZE = float(config('BOND_SIZE'))
MARKET_PRICE_API = config('MARKET_PRICE_API')
ESCROW_USERNAME = config('ESCROW_USERNAME')
PENALTY_TIMEOUT = int(config('PENALTY_TIMEOUT'))

26
api/utils.py
View File

@ -1,18 +1,32 @@
import requests, ring, os
from decouple import config
from statistics import median
market_cache = {}
@ring.dict(market_cache, expire=30) #keeps in cache for 30 seconds
def get_exchange_rate(currency):
# TODO Add fallback Public APIs and error handling
# Think about polling price data in a different way (e.g. store locally every t seconds)
'''
Checks for exchange rates in several public APIs.
Returns the median price.
'''
market_prices = requests.get(config('MARKET_PRICE_API')).json()
exchange_rate = float(market_prices[currency]['last'])
APIS = config('MARKET_PRICE_APIS', cast=lambda v: [s.strip() for s in v.split(',')])
exchange_rates = []
return exchange_rate
for api_url in APIS:
print(api_url)
try:
if 'blockchain.info' in api_url:
blockchain_prices = requests.get(api_url).json()
exchange_rates.append(float(blockchain_prices[currency]['last']))
elif 'yadio.io' in api_url:
yadio_prices = requests.get(api_url).json()
exchange_rates.append(float(yadio_prices['BTC'][currency]))
except:
pass
return median(exchange_rates)
lnd_v_cache = {}