from FastTelethonhelper import fast_download
from FastTelethonhelper import fast_upload
from telethon import TelegramClient, events,sync
import asyncio
import os

app_id = os.getenv("APP_ID")
api_hash = os.getenv("API_HASH")
btoken = os.getenv("BOT")
chnl = os.getenv("CHN")
p = os.getenv("DBS")

api_id = int(app_id)
api_hash = str(api_hash)
bot_token = str(btoken)
channel= int(chnl)

p = str(p)

async def downdb():
    client = TelegramClient(None, api_id, api_hash)
    await client.start(bot_token=bot_token)
    
    os.remove('instance/database.db')
    @client.on(events.NewMessage)
    async def handler(event):
        last_message = event.message
        await fast_download(client,last_message)
        await asyncio.sleep(10)
        await client.disconnect()
        

    return '2'
print(p)
if p=='1':
    print('database sync event')
    loop = asyncio.new_event_loop()
    asyncio.set_event_loop(loop)
    rp = loop.run_until_complete(downdb())
    print('done')