|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
from asyncio import sleep |
|
|
|
|
|
from telethon.errors import MessageDeleteForbiddenError, MessageNotModifiedError |
|
|
from telethon.tl.custom import Message |
|
|
from telethon.tl.types import MessageService |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
async def eor(event, text=None, time=None, link_preview=False, edit_time=None, **args): |
|
|
reply_to = event.reply_to_msg_id or event |
|
|
if event.out and not isinstance(event, MessageService): |
|
|
if edit_time: |
|
|
await sleep(edit_time) |
|
|
if args.get("file") and not event.media: |
|
|
await event.delete() |
|
|
ok = await event.client.send_message( |
|
|
event.chat_id, |
|
|
text, |
|
|
link_preview=link_preview, |
|
|
reply_to=reply_to, |
|
|
**args |
|
|
) |
|
|
else: |
|
|
try: |
|
|
ok = await event.edit(text, link_preview=link_preview, **args) |
|
|
except MessageNotModifiedError: |
|
|
ok = event |
|
|
else: |
|
|
ok = await event.client.send_message( |
|
|
event.chat_id, text, link_preview=link_preview, reply_to=reply_to, **args |
|
|
) |
|
|
|
|
|
if time: |
|
|
await sleep(time) |
|
|
return await ok.delete() |
|
|
return ok |
|
|
|
|
|
|
|
|
async def eod(event, text=None, **kwargs): |
|
|
kwargs["time"] = kwargs.get("time", 8) |
|
|
return await eor(event, text, **kwargs) |
|
|
|
|
|
|
|
|
async def _try_delete(event): |
|
|
try: |
|
|
return await event.delete() |
|
|
except (MessageDeleteForbiddenError): |
|
|
pass |
|
|
except BaseException as er: |
|
|
from . import LOGS |
|
|
|
|
|
LOGS.error("Error while Deleting Message..") |
|
|
LOGS.exception(er) |
|
|
|
|
|
|
|
|
setattr(Message, "eor", eor) |
|
|
setattr(Message, "try_delete", _try_delete) |
|
|
|
