mirror of
https://github.com/Redume/Shirino.git
synced 2024-11-25 01:36:23 +03:00
Compare commits
3 commits
69bd887878
...
6d9dfac41a
Author | SHA1 | Date | |
---|---|---|---|
6d9dfac41a | |||
90c3646db7 | |||
cf0da8f220 |
4 changed files with 48 additions and 37 deletions
|
@ -1,6 +1,11 @@
|
|||
.git/
|
||||
.vscode/
|
||||
.idea/
|
||||
.github/
|
||||
|
||||
.DS_Store
|
||||
__pycache__
|
||||
__pycache__
|
||||
|
||||
.mypy_cache
|
||||
mypy.ini
|
||||
pylintrc
|
|
@ -4,3 +4,4 @@ coinapi_keys:
|
|||
- key
|
||||
- key2 # coinapi keys list
|
||||
telegram_token: # telegram bot token
|
||||
kekkai_instance: 'https://kekkai-api.redume.su/'
|
|
@ -1,8 +0,0 @@
|
|||
{
|
||||
"RUB": ["руб", "рубли", "рубля", "рублей", "рубль", "российский рубль", "rub", "rouble", "roubles", "russian rouble"],
|
||||
"USD": ["доллары", "доллар", "доллара", "долларах", "долларов", "зеленых", "бакса", "баксов", "usd", "dollar", "dollars"],
|
||||
"UAH": ["гривны", "гривен", "гривен", "hryvnia"],
|
||||
"EUR": ["евро", "eur", "euro", "euros"],
|
||||
"KZT": ["тенге", "казахстанский тенге", "kazakhstani tenge", "tenge"],
|
||||
"TRY": ["турецкая лира", "турецких лир", "try", "tl", "Turkish lira", "lira"]
|
||||
}
|
69
main.py
69
main.py
|
@ -2,10 +2,13 @@ from aiogram import Bot, Dispatcher, types
|
|||
|
||||
import asyncio
|
||||
import yaml
|
||||
import requests
|
||||
|
||||
import hashlib
|
||||
|
||||
import json
|
||||
|
||||
from http import HTTPStatus
|
||||
|
||||
from function.convert import Converter
|
||||
from function.format_number import format_number
|
||||
|
||||
|
@ -16,10 +19,9 @@ dp = Dispatcher()
|
|||
@dp.message()
|
||||
@dp.inline_query()
|
||||
async def currency(query: types.Message | types.InlineQuery) -> None:
|
||||
global result, from_currency_alias, conv_currency_alias
|
||||
global result, from_currency, conv_currency
|
||||
|
||||
try:
|
||||
currency_json = json.load(open('currency.json', 'r', encoding='utf-8'))
|
||||
text = query.query if isinstance(query, types.InlineQuery) else query.text
|
||||
args = text.split()
|
||||
result_id = hashlib.md5(text.encode()).hexdigest()
|
||||
|
@ -36,18 +38,19 @@ async def currency(query: types.Message | types.InlineQuery) -> None:
|
|||
"2 or 3 arguments are required.",
|
||||
"@shirino_bot USD RUB "
|
||||
"\n@shirino_bot 12 USD RUB",
|
||||
None,
|
||||
query)
|
||||
if len(args) == 4:
|
||||
conv.amount = float(args[0])
|
||||
from_currency_alias = args[1].lower()
|
||||
conv_currency_alias = args[3].lower()
|
||||
from_currency = args[1].lower()
|
||||
conv_currency = args[3].lower()
|
||||
elif len(args) == 3:
|
||||
conv.amount = float(args[0])
|
||||
from_currency_alias = args[1].lower()
|
||||
conv_currency_alias = args[2].lower()
|
||||
from_currency = args[1].lower()
|
||||
conv_currency = args[2].lower()
|
||||
elif len(args) == 2:
|
||||
from_currency_alias = args[0].lower()
|
||||
conv_currency_alias = args[1].lower()
|
||||
from_currency = args[0].lower()
|
||||
conv_currency = args[1].lower()
|
||||
else:
|
||||
try:
|
||||
if query.chat.type in ['supergroup', 'group']:
|
||||
|
@ -55,56 +58,66 @@ async def currency(query: types.Message | types.InlineQuery) -> None:
|
|||
except:
|
||||
pass
|
||||
|
||||
return await reply(result_id, 'The source and target currency could not be determined.', None, query)
|
||||
|
||||
from_currency, conv_currency = None, None
|
||||
|
||||
for currency_code, aliases in currency_json.items():
|
||||
if from_currency_alias in aliases:
|
||||
from_currency = currency_code
|
||||
if conv_currency_alias in aliases:
|
||||
conv_currency = currency_code
|
||||
|
||||
if from_currency and conv_currency:
|
||||
break
|
||||
return await reply(result_id, 'The source and target currency could not be determined.', None, None, query)
|
||||
|
||||
if not from_currency or not conv_currency:
|
||||
return await reply(result_id,
|
||||
'The currency exchange rate could not be found.',
|
||||
None,
|
||||
None,
|
||||
query)
|
||||
|
||||
conv.from_currency = from_currency.upper()
|
||||
conv.conv_currency = conv_currency.upper()
|
||||
conv.convert()
|
||||
|
||||
result = f'{format_number(conv.amount)} {conv.from_currency} = {conv.conv_amount} {conv.conv_currency}'
|
||||
return await reply(result_id, result, None, query)
|
||||
res_chart = requests.get(f'{config['kekkai_instance']}/api/getChart/week/', {
|
||||
'from_currency': from_currency,
|
||||
'conv_currency': conv_currency
|
||||
}, timeout=3)
|
||||
|
||||
if not HTTPStatus(res_chart.status_code).is_success:
|
||||
res_chart = None
|
||||
else:
|
||||
res_chart = res_chart.json()['message']
|
||||
|
||||
result = f'{format_number(conv.amount)} {conv.from_currency} = {conv.conv_amount} {conv.conv_currency}' \
|
||||
f'\n{f'[График]({res_chart})' if res_chart else ''}'
|
||||
return await reply(result_id, result, None, res_chart, query)
|
||||
|
||||
except Exception as e:
|
||||
print(e)
|
||||
|
||||
|
||||
async def reply(result_id: str | None, title: str | None, desc, query: types.InlineQuery | types.Message) -> None:
|
||||
async def reply(
|
||||
result_id: str | None,
|
||||
title: str,
|
||||
desc: str | None,
|
||||
img: str | None,
|
||||
query: types.InlineQuery | types.Message,
|
||||
) -> None:
|
||||
|
||||
if isinstance(query, types.InlineQuery):
|
||||
article = [None]
|
||||
article[0] = types.InlineQueryResultArticle(
|
||||
id=result_id,
|
||||
title=title,
|
||||
thumbnail_url=img,
|
||||
description=desc,
|
||||
input_message_content=types.InputTextMessageContent(
|
||||
message_text=title
|
||||
message_text=title,
|
||||
parse_mode='markdown'
|
||||
)
|
||||
)
|
||||
|
||||
await query.answer(
|
||||
article,
|
||||
cache_time=1,
|
||||
parse_mode='markdown',
|
||||
cache_time=0,
|
||||
is_personal=True,
|
||||
)
|
||||
else:
|
||||
await query.answer(f'{title} \n{desc}')
|
||||
|
||||
await query.answer(f'{title} \n{'' if desc else ''}')
|
||||
|
||||
async def main() -> None:
|
||||
bot = Bot(config['telegram_token'])
|
||||
|
|
Loading…
Add table
Reference in a new issue