LonamiWebs/Telethon
1
1
Fork 0
mirror of https://github.com/LonamiWebs/Telethon.git synced 2024-11-22 09:26:37 +03:00
Code Issues Packages Projects Releases Wiki Activity

New assistant command and check if hastebin is down

Browse Source
This commit is contained in:
Lonami Exo 2018-11-15 17:53:14 +01:00
parent 0f7c2b891a
commit f90dd76f4c
1 changed files with 20 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
telethon_examples/assistant.py
View File

@ -66,6 +66,10 @@ SEARCH = (
DOCS = 'TL Reference for [{}](https://lonamiwebs.github.io/Telethon/?q={})' DOCS = 'TL Reference for [{}](https://lonamiwebs.github.io/Telethon/?q={})'
RTD = '[Read The Docs!](https://telethon.readthedocs.io)' RTD = '[Read The Docs!](https://telethon.readthedocs.io)'
RTFD = '[Read The F* Docs!](https://telethon.readthedocs.io)' RTFD = '[Read The F* Docs!](https://telethon.readthedocs.io)'
UPDATES = (
'Check out [Working with Updates](https://telethon.readthedocs.io'
'/en/latest/extra/basic/working-with-updates.html) in the documentation.'
)
DOCS_CLIENT = 'https://telethon.readthedocs.io/en/latest/telethon.client.html#' DOCS_CLIENT = 'https://telethon.readthedocs.io/en/latest/telethon.client.html#'
DOCS_MESSAGE = ( DOCS_MESSAGE = (
'https://telethon.readthedocs.io/en/latest/' 'https://telethon.readthedocs.io/en/latest/'
@ -106,8 +110,8 @@ If you need more information, use `logging.DEBUG` instead.
ALREADY_FIXED = ( ALREADY_FIXED = (
"This issue has already been fixed, but it's not yet available in PyPi. " "This issue has already been fixed, but it's not yet available in PyPi. "
"You can upgrade now with `pip install --upgrade git+https://github.com" "You can upgrade now with `pip3 install -U https://github.com/LonamiWebs"
"/LonamiWebs/Telethon@master`." "/Telethon/archive/master.zip`."
) )
GOOD_RESOURCES = ( GOOD_RESOURCES = (
@ -201,6 +205,15 @@ async def handler(event):
]) ])
@bot.on(events.NewMessage(pattern='#(updates|events?)', forwards=False))
async def handler(event):
"""#updates: Advices the user to read "Working with Updates"."""
await asyncio.wait([
event.delete(),
event.respond(UPDATES, reply_to=event.reply_to_msg_id)
])
def get_docs_message(kind, query): def get_docs_message(kind, query):
kind = kind.lower() kind = kind.lower()
cls = {'client': TelegramClient, 'msg': custom.Message}[kind] cls = {'client': TelegramClient, 'msg': custom.Message}[kind]
@ -319,7 +332,7 @@ if aiohttp:
return return
sent = await event.respond( sent = await event.respond(
'Uploading paste...', reply_to=msg.reply_to_msg_id) 'Uploading paste…', reply_to=msg.reply_to_msg_id)
name = html.escape( name = html.escape(
utils.get_display_name(await msg.get_sender()) or 'A user') utils.get_display_name(await msg.get_sender()) or 'A user')
@ -341,6 +354,10 @@ if aiohttp:
async with aiohttp.ClientSession() as session: async with aiohttp.ClientSession() as session:
async with session.post('https://hastebin.com/documents', async with session.post('https://hastebin.com/documents',
data=code.encode('utf-8')) as resp: data=code.encode('utf-8')) as resp:
if resp.status >= 300:
await sent.edit("Hastebin seems to be down… ( ^^')")
return
haste = (await resp.json())['key'] haste = (await resp.json())['key']
await asyncio.wait([ await asyncio.wait([