import sqlalchemy as db
import json
# from  manga_py1.parser import Parser
# from manga_py1.info import Info
# from Downloader import my_awesome_handler
import os

def download():
    db_URI = 'mysql+pymysql://mdownload:mdownload@192.168.86.198:3306/Downloads'

    engine = db.create_engine(db_URI)
    con = engine.connect()

    metadata = db.MetaData()

    url_metadata = db.Table('url_metadata', metadata, autoload = True, autoload_with= engine)
    manga = db.Table('manga', metadata, autoload=True, autoload_with=engine)
    # query = db.select([manga.columns.url, url_metadata.columns.base_url, manga.columns.url_flag])
    query = db.text(""" select manga.url, url_metadata.base_url , manga.name from manga join url_metadata on manga.url_flag = url_metadata.flag """)
    result = con.execute(query).fetchall()
    y=0
    url = []
    base = []
    name = []
    #PATH = 'Manga/'
    # PATH = 'smb://MediaServer._smb._tcp.local/Downloads/Manga/'
    PATH = '/download'
    for x in result:
        # print(result[y][0])
        url.append(result[y][0])
        base.append(result[y][1])
        name.append(result[y][2])

        # print(base[y]+url[y])
        query = """ select active from manga where manga_id = """ + str(y+1)
        try:
            active = con.execute(query).fetchone()
        except engine.Error as e:
            if 'MySQL server has gone away' in str(e):
                con = engine.connect()

        if active[0] != 0:
            print("""manga-py """ + base[y]+url[y] + """ -n \"""" + name[y] + """\" -d \"""" + PATH + """\" -z -N """)

            execute = """manga-py """ + base[y]+url[y] + """ -n \"""" + name[y] + """\" -d \"""" + PATH + """\" -z -N"""
            os.system(execute)
        y = y+1

def upload_jason():
    url = []
    base = []
    name = []
    y = 0
    z = 0

    db_URI = 'mysql+pymysql://mdownload:mdownload@192.168.86.198:3306/Downloads'

    engine = db.create_engine(db_URI)
    con = engine.connect()
    metadata = db.MetaData()
    manga = db.Table('manga', metadata, autoload=True, autoload_with=engine)

    with open("tach.json", "r") as tf:
        data = json.load(tf)
        for x in data["mangas"]:
            # Manga Name
            name.append(data["mangas"][y]["manga"][1])
            # Mange URL
            url.append(data["mangas"][y]["manga"][0])
            # Mange Base URL
            base.append(data["mangas"][y]["manga"][2])
            y=y+1
        # query = """ Delete from manga"""
        # con.execute(query)
        # query = """ Alter table manga auto_increment = 1 """
        # con.execute(query)
        for x in name:
            query = """select name from manga where name = \"""" + name[z] + """\""""
            exists = con.execute(query).fetchone()
            if exists == None  or exists[0] != name[z]:
                query = """ insert into manga(name, url, url_flag, view_format, unknown_value) values (\"""" + name[z] + """\",\"""" + url[z] + """\",\"""" + str(base[z]) + """\",\"0\",\"0\")"""
                print(query)
                con.execute(query)
            else:
                continue
            z=z+1

while True:
    print("1. Download \n 2. Upload\n 3. Exit")
    download()
    # val = input(">>>")
    # if val == "1":
    #     download()
    # elif val == "2":
    #     upload_jason()
    # elif val == "3":
    #     exit()