1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
|
import random
import sys
import telepot
import traceback
import time
import logging
class BotManager(object):
started = False
def __init__(self, token):
self.token = token
# Attempt to create a bot with telepot
try:
logging.info("Creating bot listener with token {}...".format(token))
self.bot = telepot.Bot(token)
logging.info("Bot succesfully created.")
except:
traceback.print_exc()
logging.error("Error creating bot listener. radiodiodibot will now exit...")
sys.exit(1)
def start(self):
# Try fetching bot information from Telegram to check connection
try:
logging.info("Bot info: {}".format(self.bot.getMe()))
except:
logging.error("Could not fetch bot info. Check your token and connectivity to Telegram!")
sys.exit(1)
self.bot.message_loop(self.handle)
logging.info("Listening for messages...")
while True:
time.sleep(10)
def default_action(self, msg):
content_type, chat_type, chat_id = telepot.glance(msg)
self.bot.sendMessage(chat_id, "Radio palaa keväällä 2017!")
# Placeholder action for testing commands
def now_playing(self, msg):
content_type, chat_type, chat_id = telepot.glance(msg)
songs = ["Ace of Spades", "Mökkitie", "Alpha Russian XXL Night Mixtape", "teekkarihymni"]
self.bot.sendMessage(chat_id, "Radiossa soi {}!".format(random.choice(songs)))
# Determine which action to take
def parse_message(self, msg):
t = msg["text"]
if "/nowplaying" in t:
self.now_playing(msg)
else:
self.default_action(msg)
# Start parsing the incoming message if it is a text message
def handle(self, msg):
content_type, chat_type, chat_id = telepot.glance(msg)
logging.info(content_type, chat_type, chat_id)
if content_type == 'text':
self.parse_message(msg)
|
