84 lines
3.3 KiB
Python
84 lines
3.3 KiB
Python
import os
|
|
import time
|
|
import json
|
|
import aiohttp
|
|
import discord
|
|
from discord.ext import commands
|
|
|
|
# load aliases from json
|
|
with open(os.path.join(os.path.dirname(__file__), 'currency_aliases.json'), 'r', encoding='utf-8') as f:
|
|
_ALIAS_MAP = json.load(f)
|
|
|
|
# in-memory cache for rates: {base: (timestamp, rates_dict)}
|
|
_RATE_CACHE = {}
|
|
_CACHE_TTL = 3600 # seconds
|
|
|
|
class CurrencyConverter(commands.Cog):
|
|
def __init__(self, bot):
|
|
self.bot = bot
|
|
|
|
def _norm(self, cur: str) -> str:
|
|
"""Normalize a currency string to its ISO code.
|
|
Returns upper-case ISO code or raises ValueError if unknown.
|
|
"""
|
|
cur = cur.strip().lower()
|
|
if cur in _ALIAS_MAP:
|
|
return _ALIAS_MAP[cur]
|
|
cur = cur.upper()
|
|
if len(cur) == 3 and cur.isalpha():
|
|
return cur
|
|
raise ValueError(f"unknown currency '{cur}'")
|
|
|
|
async def _get_rates(self, base: str) -> dict:
|
|
"""Fetch rates for *base* from cache or the Frankfurter API.
|
|
Returns a dict mapping target ISO codes to float rates.
|
|
"""
|
|
now = time.time()
|
|
cached = _RATE_CACHE.get(base)
|
|
if cached and now - cached[0] < _CACHE_TTL:
|
|
return cached[1]
|
|
url = f"https://api.frankfurter.app/latest?base={base}"
|
|
async with aiohttp.ClientSession() as session:
|
|
async with session.get(url) as resp:
|
|
if resp.status != 200:
|
|
raise RuntimeError('currency API error')
|
|
data = await resp.json()
|
|
rates = data.get('rates', {})
|
|
_RATE_CACHE[base] = (now, rates)
|
|
return rates
|
|
|
|
@commands.command(name='currency')
|
|
async def currency(self, ctx, amount: float = 1, from_cur: str = None, to_cur: str = None):
|
|
"""Convert *amount* from *from_cur* to *to_cur*.
|
|
If *amount* is omitted the command is parsed as ``!currency <from> <to>``.
|
|
"""
|
|
# discord.py passes arguments left-to-right; we need to support two signatures.
|
|
# When the user supplies only two strings, *amount* will be parsed as the first string.
|
|
if from_cur is None and to_cur is None:
|
|
# only two arguments were given, treat them as from/to and default amount=1
|
|
to_cur = amount # type: ignore
|
|
from_cur = str(amount) # type: ignore
|
|
amount = 1.0
|
|
try:
|
|
from_code = self._norm(str(from_cur))
|
|
to_code = self._norm(str(to_cur))
|
|
except ValueError as e:
|
|
return await ctx.reply(f"❌ {e}")
|
|
try:
|
|
rates = await self._get_rates(from_code)
|
|
except Exception:
|
|
return await ctx.reply('❌ could not fetch conversion rates, try again later')
|
|
rate = rates.get(to_code)
|
|
if rate is None:
|
|
return await ctx.reply(f"❌ unsupported conversion: {from_code} → {to_code}")
|
|
result = amount * rate
|
|
embed = discord.Embed(title='Currency conversion', color=0x00ff00)
|
|
embed.add_field(name='From', value=f"{amount:g} {from_code}", inline=True)
|
|
embed.add_field(name='To', value=f"{result:g} {to_code}", inline=True)
|
|
embed.add_field(name='Rate', value=f"1 {from_code} = {rate:g} {to_code}", inline=False)
|
|
embed.set_footer(text='Data from frankfurter.app')
|
|
await ctx.reply(embed=embed)
|
|
|
|
async def setup(bot):
|
|
await bot.add_cog(CurrencyConverter(bot))
|