From d7126e657edb0a593c9f3fd8de78d868e05c52cd Mon Sep 17 00:00:00 2001 From: Redume Date: Sat, 21 Dec 2024 23:32:25 +0300 Subject: [PATCH] Removed CoinAPI. Made kekkai api a higher priority than ddg --- config_sample.yaml | 3 --- utils/convert.py | 56 +++++++++++++++++++--------------------------- 2 files changed, 23 insertions(+), 36 deletions(-) diff --git a/config_sample.yaml b/config_sample.yaml index a86a0ce..9e09ebb 100644 --- a/config_sample.yaml +++ b/config_sample.yaml @@ -1,7 +1,4 @@ debug: false # debug logging timeout: 2 # http requests timeout -coinapi_keys: - - key - - key2 # coinapi keys list telegram_token: # telegram bot token kekkai_instance: 'https://kekkai-api.redume.su/' \ No newline at end of file diff --git a/utils/convert.py b/utils/convert.py index acbd79d..a03c0b5 100644 --- a/utils/convert.py +++ b/utils/convert.py @@ -4,6 +4,9 @@ import requests import json import re +from datetime import datetime +from http import HTTPStatus + from decimal import Decimal, ROUND_DOWN from utils.format_number import format_number @@ -21,14 +24,14 @@ class Converter: self.conv_currency: str = '' def convert(self) -> None: - if not self.ddg(): - self.coinapi() + if not self.kekkai(): + self.kekkai() number = Decimal(str(self.conv_amount)) self.conv_amount = format_number(number.quantize(Decimal('1.00'), rounding=ROUND_DOWN)) - def ddg(self) -> bool: + def ddg(self) -> None: res = requests.get('https://duckduckgo.com/js/spice/currency' f'/{self.amount}' f'/{self.from_currency}' @@ -41,7 +44,7 @@ class Converter: del data['timestamp'] if len(data.get('to')) == 0: - return False + raise RuntimeError('Failed to get the exchange rate from DDG') conv = data.get('to')[0] conv_amount = conv.get('mid') @@ -51,35 +54,22 @@ class Converter: self.conv_amount = float(conv_amount) + def kekkai(self) -> bool: + date = datetime.today().strftime('%Y-%m-%d') + + res = requests.get(f'{config['kekkai_instance']}/api/getRate/', { + 'from_currency': self.from_currency, + 'conv_currency': self.conv_currency, + 'date': date + }, timeout=3) + + data = res.json() + + if not HTTPStatus(res.status_code).is_success: + return None + + self.conv_amount = float(data.get('rate') * self.amount) + return True - def coinapi(self, depth: int = config['coinapi_keys']) -> None: - if depth <= 0: - raise RecursionError('Rate limit on all tokens') - resp = requests.get( - ( - 'https://rest.coinapi.io/v1/exchangerate' - f'/{self.from_currency}' - f'/{self.conv_currency}' - ), - headers={ - 'X-CoinAPI-Key': config['coinapi_keys'][coinapi_active[0]], - }, - timeout=config['timeout'], - ) - - if resp.status_code == 429: - rotate_token(config['coinapi_keys'], coinapi_active) - self.coinapi(depth - 1) - - data = resp.json() - rate = data.get('rate') - if rate is None: - raise RuntimeError('Failed to get the exchange rate from CoinAPI') - - self.conv_amount = float(rate * self.amount) - - -def rotate_token(lst, active) -> None: - active[0] = (active[0] + 1) % len(lst)