mirror of
https://github.com/python-telegram-bot/python-telegram-bot.git
synced 2024-11-25 00:27:46 +01:00
119 lines
3.2 KiB
Python
119 lines
3.2 KiB
Python
#!/usr/bin/env python
|
|
|
|
"""
|
|
This Bot uses the BotEventHandler class to handle the bot.
|
|
|
|
First, a few handler functions are defined. Then, those functions are passed to
|
|
the Broadcaster and registered at their respective places.
|
|
Then, the bot is started and the CLI-Loop is entered, where all text inputs are
|
|
inserted into the update queue for the bot to handle.
|
|
|
|
"""
|
|
|
|
import sys
|
|
from telegram import BotEventHandler
|
|
from telegram.broadcaster import run_async
|
|
from time import sleep
|
|
import re
|
|
|
|
last_chat_id = 0
|
|
|
|
|
|
def removeCommand(text):
|
|
return ' '.join(text.split(' ')[1:])
|
|
|
|
|
|
# Command Handlers
|
|
def startCommandHandler(bot, update):
|
|
bot.sendMessage(update.message.chat_id, text='Hi!')
|
|
|
|
|
|
def helpCommandHandler(bot, update):
|
|
bot.sendMessage(update.message.chat_id, text='Help!')
|
|
|
|
|
|
def anyMessageHandler(bot, update):
|
|
print("chat_id: %d\nFrom: %s\nText: %s" %
|
|
(update.message.chat_id, str(update.message.from_user),
|
|
update.message.text))
|
|
|
|
|
|
def unknownCommandHandler(bot, update):
|
|
bot.sendMessage(update.message.chat_id, text='Command not recognized!')
|
|
|
|
|
|
@run_async
|
|
def messageHandler(bot, update):
|
|
"""
|
|
Example for an asynchronous handler. It's not guaranteed that replies will
|
|
be in order when using @run_async
|
|
"""
|
|
|
|
# Save last chat_id to use in reply handler
|
|
global last_chat_id
|
|
last_chat_id = update.message.chat_id
|
|
|
|
sleep(2) # IO-heavy operation here
|
|
bot.sendMessage(update.message.chat_id, text=update.message.text)
|
|
|
|
|
|
def errorHandler(bot, error):
|
|
print(str(error))
|
|
|
|
|
|
def CLIReplyCommandHandler(bot, update):
|
|
if last_chat_id is not 0:
|
|
bot.sendMessage(chat_id=last_chat_id, text=removeCommand(update))
|
|
|
|
|
|
def unknownCLICommandHandler(bot, update):
|
|
print("Command not found: %s" % update)
|
|
|
|
|
|
def main():
|
|
# Create the EventHandler and pass it your bot's token
|
|
eh = BotEventHandler("TOKEN")
|
|
|
|
# Get the broadcaster to register handlers
|
|
bc = eh.broadcaster
|
|
|
|
# on different commands - answer in Telegram
|
|
bc.addTelegramCommandHandler("start", startCommandHandler)
|
|
bc.addTelegramCommandHandler("help", helpCommandHandler)
|
|
|
|
# on regex match - print all messages to stdout
|
|
bc.addTelegramRegexHandler(re.compile('.*'), anyMessageHandler)
|
|
|
|
# on CLI commands - type "/reply text" in terminal to reply to the last
|
|
# active chat
|
|
bc.addStringCommandHandler('reply', CLIReplyCommandHandler)
|
|
|
|
# on unknown commands - answer on Telegram
|
|
bc.addUnknownTelegramCommandHandler(unknownCommandHandler)
|
|
|
|
# on unknown CLI commands - notify the user
|
|
bc.addUnknownStringCommandHandler(unknownCLICommandHandler)
|
|
|
|
# on noncommand i.e message - echo the message on Telegram
|
|
bc.addTelegramMessageHandler(messageHandler)
|
|
|
|
# on error - print error to stdout
|
|
bc.addErrorHandler(errorHandler)
|
|
|
|
# Start the Bot and store the update Queue,
|
|
# so we can insert updates ourselves
|
|
update_queue = eh.start()
|
|
|
|
# Start CLI-Loop
|
|
while True:
|
|
if sys.version_info.major is 2:
|
|
text = raw_input()
|
|
elif sys.version_info.major is 3:
|
|
text = input()
|
|
|
|
if len(text) > 0:
|
|
update_queue.put(text) # Put command into queue
|
|
|
|
if __name__ == '__main__':
|
|
main()
|
|
|