| 19 | |
| 20 | @Drone.on(events.NewMessage(incoming=True, func=lambda e: e.is_private)) |
| 21 | async def clone(event): |
| 22 | if event.is_reply: |
| 23 | reply = await event.get_reply_message() |
| 24 | if reply.text == message: |
| 25 | return |
| 26 | try: |
| 27 | link = get_link(event.text) |
| 28 | if not link: |
| 29 | return |
| 30 | except TypeError: |
| 31 | return |
| 32 | s, r = await force_sub(event.client, fs, event.sender_id, ft) |
| 33 | if s == True: |
| 34 | await event.reply(r) |
| 35 | return |
| 36 | edit = await event.reply("Processing!") |
| 37 | try: |
| 38 | if 't.me/+' in link: |
| 39 | q = await join(userbot, link) |
| 40 | await edit.edit(q) |
| 41 | return |
| 42 | if 't.me/' in link: |
| 43 | await get_msg(userbot, Bot, Drone, event.sender_id, edit.id, link, 0) |
| 44 | except FloodWait as fw: |
| 45 | return await Drone.send_message(event.sender_id, f'Try again after {fw.x} seconds due to floodwait from telegram.') |
| 46 | except Exception as e: |
| 47 | print(e) |
| 48 | await Drone.send_message(event.sender_id, f"An error occurred during cloning of `{link}`\n\n**Error:** {str(e)}") |
| 49 | |