royalnet/database.py

import datetime
import sqlalchemy.exc
import discord
from sqlalchemy import create_engine, Column, Integer, String, Boolean, DateTime, ForeignKey
from sqlalchemy.orm import sessionmaker, relationship
from sqlalchemy.ext.declarative import declarative_base
import lol


class NoUsersMatchingError(Exception):
    pass


class InvalidPasswordError(Exception):
    pass


# Initialize the database
engine = create_engine("sqlite:///db.sqlite")
Base = declarative_base()
Session = sessionmaker(bind=engine)


class Diario(Base):
    __tablename__ = "diario"

    id = Column(Integer, primary_key=True)

    text = Column(String, nullable=False)
    date = Column(DateTime, nullable=False)

    def __repr__(self):
        return f"<Diario {self.date} {self.text}>"


class Account(Base):
    __tablename__ = "account"

    id = Column(Integer, primary_key=True)

    lol = relationship("LoL")


class LoL(Base):
    __tablename__ = "lol"

    id = Column(Integer, primary_key=True)
    parent_id = Column(Integer, ForeignKey("account.id"))

    last_updated = Column(DateTime)
    summoner_name = Column(String, nullable=False)
    level = Column(Integer)
    soloq_division = Column(Integer)
    soloq_tier = Column(Integer)
    flexq_division = Column(Integer)
    flexq_tier = Column(Integer)
    ttq_division = Column(Integer)
    ttq_tier = Column(Integer)

    def __repr__(self):
        return f"<LoL {self.id} {self.summoner_name}>"


    def generate_discord_embed(self):
        embed = discord.Embed(type="rich")
        # TODO: change the icon
        embed.set_author(name="League of Legends", url="http://euw.leagueoflegends.com/", icon_url="https://cdn.discordapp.com/attachments/152150752523976704/307558194824216578/icon.png")
        embed.add_field(name="Summoner", value=str(self.summoner_name))
        embed.add_field(name="Level", value=str(self.level))
        if self.soloq_tier is not None:
            embed.add_field(name="Solo/duo SR", value=f"{lol.tiers[self.soloq_tier].capitalize()} {lol.divisions[self.soloq_division]}", inline=False)
            embed.set_thumbnail(url=f"https://royal.steffo.me/loltiers/{lol.tiers[self.soloq_tier].lower()}_{lol.divisions[self.soloq_division].lower()}.png")
        if self.flexq_tier is not None:
            embed.add_field(name="Flex SR", value=f"{lol.tiers[self.flexq_tier].capitalize()} {lol.divisions[self.flexq_division]}", inline=False)
        if self.ttq_tier is not None:
            embed.add_field(name="Twisted Treeline", value=f"{lol.tiers[self.ttq_tier].capitalize()} {lol.divisions[self.ttq_division]}", inline=False)
        embed.colour = discord.Colour(0x09AEBB)
        return embed

Base.metadata.create_all(engine)


def migrate_diario():
    import datetime
    session = Session()
    file = open("diario.txt", encoding="utf8")
    for row in file:
        entry = row.split("|", 1)
        new = Diario()
        new.date = datetime.datetime.fromtimestamp(int(entry[0]))
        new.text = entry[1]
        session.add(new)
    session.commit()


def new_diario_entry(dt, text):
    # Create a new session
    session = Session()
    # Create a new diario entry
    entry = Diario()
    entry.date = dt
    entry.text = text
    # Add the entry to the database
    session.add(entry)
    # Commit the change
    session.commit()


# TODO: this can be moved to a method of the LoL class
async def update_lol(discord_id):
    # Create a new database session
    session = Session()
    # Find the user
    user = session.query(Account).filter_by(id=discord_id).join(LoL).first()
    # TODO: ewww
    for account in user.lol:
        # Find the League of Legends ID
        lid = account.id
        # Poll the League API for more information
        data = await lol.get_summoner_data("euw", summoner_id=lid)
        # Change tracker: if anything meaningful changes, set this to True
        changes = False
        # Update the user data
        account.summoner_name = data["name"]
        account.level = data["summonerLevel"]
        # Poll the League API for ranked data
        try:
            soloq, flexq, ttq = await lol.get_rank_data("euw", lid)
        except lol.LoLAPIError as e:
            if e.status_code == 404:
                account.soloq_tier = None
                account.soloq_division = None
                account.flexq_tier = None
                account.flexq_division = None
                account.ttq_tier = None
                account.ttq_division = None
        else:
            # Update the user data
            if soloq is not None:
                account.soloq_tier = lol.tiers.index(soloq["tier"])
                account.soloq_division = lol.divisions.index(soloq["entries"][0]["division"])
            else:
                account.soloq_tier = None
                account.soloq_division = None
            if flexq is not None:
                account.flexq_tier = lol.tiers.index(flexq["tier"])
                account.flexq_division = lol.divisions.index(flexq["entries"][0]["division"])
            else:
                account.flexq_tier = None
                account.flexq_division = None
            if ttq is not None:
                account.ttq_tier = lol.tiers.index(ttq["tier"])
                account.ttq_division = lol.divisions.index(ttq["entries"][0]["division"])
            else:
                account.ttq_tier = None
                account.ttq_division = None
        # Mark the user as updated
        account.last_updated = datetime.datetime.now()
    # Commit the changes
    session.commit()