mirror of
https://git.wownero.com/wowlet/wowlet-backend.git
synced 2024-08-15 01:03:13 +00:00
Change the fiat API to ECB, the last one turned premium...
This commit is contained in:
parent
abfe22e89c
commit
223f41832b
1 changed files with 25 additions and 3 deletions
|
@ -2,6 +2,9 @@
|
||||||
# Copyright (c) 2020, The Monero Project.
|
# Copyright (c) 2020, The Monero Project.
|
||||||
# Copyright (c) 2020, dsc@xmr.pm
|
# Copyright (c) 2020, dsc@xmr.pm
|
||||||
|
|
||||||
|
from datetime import datetime, timedelta
|
||||||
|
import re
|
||||||
|
|
||||||
from wowlet_backend.utils import httpget
|
from wowlet_backend.utils import httpget
|
||||||
from wowlet_backend.tasks import FeatherTask
|
from wowlet_backend.tasks import FeatherTask
|
||||||
|
|
||||||
|
@ -15,9 +18,28 @@ class FiatRatesTask(FeatherTask):
|
||||||
|
|
||||||
self._websocket_cmd = "fiat_rates"
|
self._websocket_cmd = "fiat_rates"
|
||||||
|
|
||||||
self._http_endpoint = "https://api.exchangeratesapi.io/latest?base=USD"
|
self._http_endpoint = "https://sdw-wsrest.ecb.europa.eu/service/data/EXR/D.USD+GBP+JPY+CZK+CAD+ZAR+KRW+MXN+RUB+SEK+THB+NZD+AUD+CHF+TRY+CNY.EUR.SP00.A"
|
||||||
|
|
||||||
async def task(self):
|
async def task(self):
|
||||||
"""Fetch fiat rates"""
|
"""Fetch fiat rates"""
|
||||||
result = await httpget(self._http_endpoint, json=True)
|
start_from = "?startPeriod=" + (datetime.now() - timedelta(days=7)).strftime("%Y-%m-%d")
|
||||||
return result
|
result = await httpget(self._http_endpoint + start_from, json=False)
|
||||||
|
|
||||||
|
results = {}
|
||||||
|
currency = ""
|
||||||
|
value = ""
|
||||||
|
|
||||||
|
# XML "parsing"
|
||||||
|
for line in result.split("\n"):
|
||||||
|
if "\"UNIT\"" in line:
|
||||||
|
if currency:
|
||||||
|
results[currency] = value
|
||||||
|
currency = re.search(r"value=\"(\w+)\"", line).group(1)
|
||||||
|
if "ObsValue value" in line:
|
||||||
|
value = float(re.search("ObsValue value=\"([0-9.]+)\"", line).group(1))
|
||||||
|
|
||||||
|
# Base currency is EUR, needs to be USD
|
||||||
|
results['EUR'] = 1
|
||||||
|
usd_rate = results['USD']
|
||||||
|
results = {k: round(v / usd_rate, 4) for k, v in results.items()}
|
||||||
|
return results
|
||||||
|
|
Loading…
Reference in a new issue