| 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') |
|
|
