mirror of
https://github.com/RoboSats/robosats.git
synced 2024-12-13 10:56:24 +00:00
195 lines
6.1 KiB
Python
195 lines
6.1 KiB
Python
import requests, ring, os
|
|
from decouple import config
|
|
import numpy as np
|
|
import coinaddrvalidator as addr
|
|
from api.models import Order
|
|
|
|
def get_tor_session():
|
|
session = requests.session()
|
|
# Tor uses the 9050 port as the default socks port
|
|
session.proxies = {'http': 'socks5://127.0.0.1:9050',
|
|
'https': 'socks5://127.0.0.1:9050'}
|
|
return session
|
|
|
|
def validate_onchain_address(address):
|
|
'''
|
|
Validates an onchain address
|
|
'''
|
|
|
|
validation = addr.validate('btc', address.encode('utf-8'))
|
|
|
|
if not validation.valid:
|
|
return False, {
|
|
"bad_address":
|
|
"Does not look like a valid address"
|
|
}
|
|
|
|
NETWORK = str(config('NETWORK'))
|
|
if NETWORK == 'mainnet':
|
|
if validation.network == 'main':
|
|
return True, None
|
|
else:
|
|
return False, {
|
|
"bad_address":
|
|
"This is not a bitcoin mainnet address"
|
|
}
|
|
elif NETWORK == 'testnet':
|
|
if validation.network == 'test':
|
|
return True, None
|
|
else:
|
|
return False, {
|
|
"bad_address":
|
|
"This is not a bitcoin testnet address"
|
|
}
|
|
|
|
market_cache = {}
|
|
@ring.dict(market_cache, expire=3) # keeps in cache for 3 seconds
|
|
def get_exchange_rates(currencies):
|
|
"""
|
|
Params: list of currency codes.
|
|
Checks for exchange rates in several public APIs.
|
|
Returns the median price list.
|
|
"""
|
|
|
|
session = get_tor_session()
|
|
|
|
APIS = config("MARKET_PRICE_APIS",
|
|
cast=lambda v: [s.strip() for s in v.split(",")])
|
|
|
|
api_rates = []
|
|
for api_url in APIS:
|
|
try: # If one API is unavailable pass
|
|
if "blockchain.info" in api_url:
|
|
blockchain_prices = session.get(api_url).json()
|
|
blockchain_rates = []
|
|
for currency in currencies:
|
|
try: # If a currency is missing place a None
|
|
blockchain_rates.append(
|
|
float(blockchain_prices[currency]["last"]))
|
|
except:
|
|
blockchain_rates.append(np.nan)
|
|
api_rates.append(blockchain_rates)
|
|
|
|
elif "yadio.io" in api_url:
|
|
yadio_prices = session.get(api_url).json()
|
|
yadio_rates = []
|
|
for currency in currencies:
|
|
try:
|
|
yadio_rates.append(float(
|
|
yadio_prices["BTC"][currency]))
|
|
except:
|
|
yadio_rates.append(np.nan)
|
|
api_rates.append(yadio_rates)
|
|
except:
|
|
pass
|
|
|
|
if len(api_rates) == 0:
|
|
return None # Wops there is not API available!
|
|
|
|
exchange_rates = np.array(api_rates)
|
|
median_rates = np.nanmedian(exchange_rates, axis=0)
|
|
|
|
return median_rates.tolist()
|
|
|
|
|
|
def get_lnd_version():
|
|
|
|
# If dockerized, return LND_VERSION envvar used for docker image.
|
|
# Otherwise it would require LND's version.grpc libraries...
|
|
try:
|
|
lnd_version = config("LND_VERSION")
|
|
return lnd_version
|
|
except:
|
|
pass
|
|
|
|
# If not dockerized and LND is local, read from CLI
|
|
try:
|
|
stream = os.popen("lnd --version")
|
|
lnd_version = stream.read()[:-1]
|
|
return lnd_version
|
|
except:
|
|
return ""
|
|
|
|
|
|
robosats_commit_cache = {}
|
|
@ring.dict(robosats_commit_cache, expire=3600)
|
|
def get_commit_robosats():
|
|
|
|
commit = os.popen('git log -n 1 --pretty=format:"%H"')
|
|
commit_hash = commit.read()
|
|
|
|
return commit_hash
|
|
|
|
premium_percentile = {}
|
|
@ring.dict(premium_percentile, expire=300)
|
|
def compute_premium_percentile(order):
|
|
|
|
queryset = Order.objects.filter(
|
|
currency=order.currency, status=Order.Status.PUB).exclude(id=order.id)
|
|
|
|
print(len(queryset))
|
|
if len(queryset) <= 1:
|
|
return 0.5
|
|
|
|
amount = order.amount if not order.has_range else order.max_amount
|
|
order_rate = float(order.last_satoshis) / float(amount)
|
|
rates = []
|
|
for similar_order in queryset:
|
|
similar_order_amount = similar_order.amount if not similar_order.has_range else similar_order.max_amount
|
|
rates.append(
|
|
float(similar_order.last_satoshis) / float(similar_order_amount))
|
|
|
|
rates = np.array(rates)
|
|
return round(np.sum(rates < order_rate) / len(rates), 2)
|
|
|
|
|
|
def weighted_median(values, sample_weight=None, quantiles= 0.5, values_sorted=False):
|
|
"""Very close to numpy.percentile, but it supports weights.
|
|
NOTE: quantiles should be in [0, 1]!
|
|
:param values: numpy.array with data
|
|
:param quantiles: array-like with many quantiles needed. For weighted median 0.5
|
|
:param sample_weight: array-like of the same length as `array`
|
|
:param values_sorted: bool, if True, then will avoid sorting of
|
|
initial array assuming array is already sorted
|
|
:return: numpy.array with computed quantiles.
|
|
"""
|
|
values = np.array(values)
|
|
quantiles = np.array(quantiles)
|
|
if sample_weight is None:
|
|
sample_weight = np.ones(len(values))
|
|
sample_weight = np.array(sample_weight)
|
|
assert np.all(quantiles >= 0) and np.all(quantiles <= 1), \
|
|
'quantiles should be in [0, 1]'
|
|
|
|
if not values_sorted:
|
|
sorter = np.argsort(values)
|
|
values = values[sorter]
|
|
sample_weight = sample_weight[sorter]
|
|
|
|
weighted_quantiles = np.cumsum(sample_weight) - 0.5 * sample_weight
|
|
weighted_quantiles -= weighted_quantiles[0]
|
|
weighted_quantiles /= weighted_quantiles[-1]
|
|
|
|
return np.interp(quantiles, weighted_quantiles, values)
|
|
|
|
def compute_avg_premium(queryset):
|
|
premiums = []
|
|
volumes = []
|
|
|
|
# We exclude BTC, as LN <-> BTC swap premiums should not be mixed with FIAT.
|
|
|
|
for tick in queryset.exclude(currency=1000):
|
|
premiums.append(float(tick.premium))
|
|
volumes.append(float(tick.volume))
|
|
|
|
total_volume = sum(volumes)
|
|
|
|
# weighted_median_premium is the weighted median of the premiums by volume
|
|
|
|
weighted_median_premium = weighted_median(values=premiums,
|
|
sample_weight=volumes,
|
|
quantiles=0.5,
|
|
values_sorted=False)
|
|
|
|
return weighted_median_premium, total_volume
|