JuliusFreudenberger
4f403561ba
Messages now get deleted and deleted for a smoother experience. Other small changes: - States as constants - String formatting with f-string-literals
281 lines
11 KiB
Python
281 lines
11 KiB
Python
import _pickle as pickle
|
|
import time
|
|
|
|
import schedule
|
|
from telegram import Update, InlineKeyboardButton, InlineKeyboardMarkup
|
|
from telegram.ext import ConversationHandler, CommandHandler, MessageHandler, CallbackQueryHandler, CallbackContext
|
|
from telegram.ext.filters import Filters
|
|
|
|
from bot import send_message, edit_message_and_delete_answer
|
|
from weather_openweathermap import City, get_city_by_name
|
|
|
|
users = {}
|
|
|
|
LIST, ADD_CITY, ADD_TIME, EDIT, EDIT_CITY, EDIT_TIME = range(6)
|
|
|
|
|
|
class Subscription(object):
|
|
time: time
|
|
city: City
|
|
chat_id: int
|
|
|
|
def __init__(self, chat_id: int, city: City):
|
|
self.chat_id = chat_id
|
|
self.city = city
|
|
|
|
def __str__(self):
|
|
return f"{self.city.name} at {time.strftime('%H:%M', self.time)}"
|
|
|
|
def edit_time(self, edited_time: time):
|
|
self.time = edited_time
|
|
schedule_subscriptions()
|
|
save_users_to_file()
|
|
|
|
def edit_city(self, edited_city: City):
|
|
self.city = edited_city
|
|
schedule_subscriptions()
|
|
save_users_to_file()
|
|
|
|
|
|
class User(object):
|
|
chat_id: int
|
|
subs = []
|
|
|
|
def __init__(self, chat_id: int):
|
|
self.chat_id = chat_id
|
|
global users
|
|
users[self.chat_id] = self.subs
|
|
|
|
def __getstate__(self):
|
|
attributes = self.__dict__.copy()
|
|
attributes['subs'] = self.subs
|
|
for i in range(len(attributes['subs'])):
|
|
try:
|
|
del attributes['subs'][i].city.weather
|
|
except AttributeError:
|
|
pass
|
|
return attributes
|
|
|
|
def __setstate__(self, state):
|
|
self.chat_id = state['chat_id']
|
|
self.subs = state['subs']
|
|
|
|
def add_subscription(self, subscription: Subscription):
|
|
self.subs.append(subscription)
|
|
global users
|
|
users[self.chat_id] = self
|
|
save_users_to_file()
|
|
schedule_subscriptions()
|
|
|
|
def del_subscription(self, idx: int):
|
|
del self.subs[idx]
|
|
save_users_to_file()
|
|
schedule_subscriptions()
|
|
|
|
|
|
def save_users_to_file():
|
|
global users
|
|
with open("users.pkl", 'wb') as users_file:
|
|
pickle.dump(users, users_file)
|
|
|
|
|
|
def load_users_from_file():
|
|
global users
|
|
try:
|
|
with open("users.pkl", 'rb') as users_file:
|
|
users = pickle.load(users_file)
|
|
schedule_subscriptions()
|
|
except FileNotFoundError:
|
|
pass
|
|
except EOFError:
|
|
pass
|
|
|
|
|
|
def schedule_subscriptions():
|
|
schedule.default_scheduler.clear()
|
|
for user in users.values():
|
|
for sub in user.subs:
|
|
sub.city.query_weather()
|
|
schedule.default_scheduler.every().day.at(time.strftime("%H:%M", sub.time)).do(
|
|
send_message, chat_id=user.chat_id, message=str(sub.city.weather))
|
|
sub.city.weather.clear()
|
|
|
|
|
|
def push_callback(update: Update, context: CallbackContext):
|
|
global users
|
|
if update.effective_chat.id in users:
|
|
user = users[update.effective_chat.id]
|
|
else:
|
|
user = User(update.effective_chat.id)
|
|
users[update.effective_chat.id] = user
|
|
string = f"Hello, {update.effective_user.first_name}!\nYou have {len(user.subs)} subscriptions:\n"
|
|
|
|
button_list = []
|
|
for i, subscription in enumerate(user.subs):
|
|
button_list.append(
|
|
InlineKeyboardButton(text=f"{subscription.city.name} at {time.strftime('%H:%M', subscription.time)}",
|
|
callback_data=f"/push_edit {i}"))
|
|
button_list.append(InlineKeyboardButton(text="Add", callback_data="/push_add"))
|
|
button_list.append(InlineKeyboardButton(text="End", callback_data="/cancel"))
|
|
reply_markup = InlineKeyboardMarkup.from_column(button_list)
|
|
update.message.reply_text(string, reply_markup=reply_markup)
|
|
context.bot.delete_message(chat_id=update.effective_chat.id, message_id=update.effective_message.message_id)
|
|
return LIST
|
|
|
|
|
|
def edit_sub_callback(update: Update, context: CallbackContext):
|
|
global users
|
|
user = users[update.effective_chat.id]
|
|
sub_idx = int(update.callback_query.data[11:])
|
|
sub = user.subs[sub_idx]
|
|
context.user_data['sub'] = sub
|
|
button_list = [[InlineKeyboardButton(text="City", callback_data="/push_edit_city"),
|
|
InlineKeyboardButton(text="Time", callback_data="/push_edit_time")],
|
|
[InlineKeyboardButton(text="Delete", callback_data=f"/push_edit_delete {sub_idx}"),
|
|
InlineKeyboardButton(text="Cancel", callback_data="/cancel")]]
|
|
reply_markup = InlineKeyboardMarkup(button_list)
|
|
update.callback_query.answer()
|
|
update.callback_query.edit_message_text(f"Change subscription {sub}.\nWhat do you want to change?",
|
|
reply_markup=reply_markup)
|
|
return EDIT
|
|
|
|
|
|
def edit_city_callback(update: Update, context: CallbackContext):
|
|
update.callback_query.answer()
|
|
update.callback_query.edit_message_text("Tell me the city you want information for:")
|
|
return EDIT_CITY
|
|
|
|
|
|
def edited_city_callback(update: Update, context: CallbackContext):
|
|
global users
|
|
user = users[update.effective_chat.id]
|
|
city_name = update.message.text
|
|
city = get_city_by_name(city_name)
|
|
if city.name == "none":
|
|
edit_message_and_delete_answer(chat_id=update.effective_chat.id, message_id=update.effective_message.message_id,
|
|
message=f"The city {city_name} was not found! Try again")
|
|
return None
|
|
else:
|
|
context.user_data['sub'].edit_city(city)
|
|
edit_message_and_delete_answer(chat_id=update.effective_chat.id, message_id=update.effective_message.message_id,
|
|
message=f"Subscription now is {context.user_data['sub']}")
|
|
|
|
del context.user_data['sub']
|
|
return ConversationHandler.END
|
|
|
|
|
|
def edit_time_callback(update: Update, context: CallbackContext):
|
|
update.callback_query.answer()
|
|
update.callback_query.edit_message_text("When do you want to receive updates?")
|
|
return EDIT_TIME
|
|
|
|
|
|
def edited_time_callback(update: Update, context: CallbackContext):
|
|
global users
|
|
user = users[update.effective_chat.id]
|
|
sub_in_edit = context.user_data['sub']
|
|
time_string = update.message.text
|
|
try:
|
|
if time_string.find(':') == -1:
|
|
sub_in_edit.edit_time(time.strptime(time_string, "%H"))
|
|
else:
|
|
sub_in_edit.edit_time(time.strptime(time_string, "%H:%M"))
|
|
except ValueError:
|
|
edit_message_and_delete_answer(chat_id=update.effective_chat.id, message_id=update.effective_message.message_id,
|
|
message="This time was not recognized! Try again")
|
|
return None
|
|
del context.user_data['sub']
|
|
edit_message_and_delete_answer(chat_id=update.effective_chat.id, message_id=update.effective_message.message_id,
|
|
message=f"Subscription now is {sub_in_edit}")
|
|
return ConversationHandler.END
|
|
|
|
|
|
def delete_subscription_callback(update: Update, context: CallbackContext):
|
|
global users
|
|
users[update.effective_chat.id].del_subscription(int(update.callback_query.data[18:]))
|
|
update.callback_query.answer()
|
|
update.callback_query.edit_message_text("Deleted")
|
|
schedule_subscriptions()
|
|
return ConversationHandler.END
|
|
|
|
|
|
def add_sub_callback(update: Update, context: CallbackContext):
|
|
update.callback_query.answer()
|
|
update.callback_query.edit_message_text("Add a new subscription.\nTell me the city you want information for:")
|
|
return ADD_CITY
|
|
|
|
|
|
def add_city_callback(update: Update, context: CallbackContext):
|
|
global users
|
|
user = users[update.effective_chat.id]
|
|
city_name = update.message.text
|
|
city = get_city_by_name(city_name)
|
|
if city.name == "none":
|
|
edit_message_and_delete_answer(chat_id=update.effective_chat.id, message_id=update.effective_message.message_id,
|
|
message="This city was not found! Try again")
|
|
return None
|
|
else:
|
|
edit_message_and_delete_answer(chat_id=update.effective_chat.id, message_id=update.effective_message.message_id,
|
|
message=f"I found {city.name}. When do you want to receive updates?")
|
|
context.user_data['sub'] = Subscription(user.chat_id, city)
|
|
return ADD_TIME
|
|
|
|
|
|
def add_time_callback(update: Update, context: CallbackContext):
|
|
global users
|
|
user = users[update.effective_chat.id]
|
|
sub_in_edit = context.user_data['sub']
|
|
time_string = update.message.text
|
|
try:
|
|
if time_string.find(':') == -1:
|
|
sub_in_edit.edit_time(time.strptime(time_string, "%H"))
|
|
else:
|
|
sub_in_edit.edit_time(time.strptime(time_string, "%H:%M"))
|
|
except ValueError:
|
|
edit_message_and_delete_answer(chat_id=update.effective_chat.id, message_id=update.effective_message.message_id,
|
|
message="This time was not recognized! Try again")
|
|
return None
|
|
user.add_subscription(sub_in_edit)
|
|
edit_message_and_delete_answer(chat_id=update.effective_chat.id, message_id=update.effective_message.message_id,
|
|
message=f"Subscription now is: {str(sub_in_edit)}")
|
|
del context.user_data['sub']
|
|
return ConversationHandler.END
|
|
|
|
|
|
def cancel_callback(update: Update, context: CallbackContext):
|
|
context.bot.delete_message(chat_id=update.effective_chat.id, message_id=update.effective_message.message_id)
|
|
return ConversationHandler.END
|
|
|
|
|
|
def cancel_button_callback(update: Update, context: CallbackContext):
|
|
update.callback_query.answer()
|
|
update.effective_message.delete()
|
|
return ConversationHandler.END
|
|
|
|
|
|
def __init__() -> ConversationHandler:
|
|
load_users_from_file()
|
|
|
|
push_handler = CommandHandler(command=["push", "subs"], callback=push_callback)
|
|
|
|
edit_sub_handler = CallbackQueryHandler(callback=edit_sub_callback, pattern="^\/push_edit ")
|
|
edit_city_handler = CallbackQueryHandler(callback=edit_city_callback, pattern="^\/push_edit_city")
|
|
edited_city_handler = MessageHandler(callback=edited_city_callback, filters=Filters.text)
|
|
edit_time_handler = CallbackQueryHandler(callback=edit_time_callback, pattern="^\/push_edit_time")
|
|
edited_time_handler = MessageHandler(callback=edited_time_callback, filters=Filters.text)
|
|
delete_subscription_handler = CallbackQueryHandler(callback=delete_subscription_callback,
|
|
pattern="^\/push_edit_delete")
|
|
|
|
add_sub_handler = CallbackQueryHandler(callback=add_sub_callback, pattern="^\/push_add")
|
|
add_city_handler = MessageHandler(callback=add_city_callback, filters=Filters.text)
|
|
add_time_handler = MessageHandler(callback=add_time_callback, filters=Filters.text)
|
|
|
|
fallback_handler = CommandHandler(command="cancel", callback=cancel_callback)
|
|
fallback_callback_handler = CallbackQueryHandler(callback=cancel_button_callback, pattern="^\/cancel")
|
|
|
|
return ConversationHandler(entry_points=[push_handler],
|
|
states={LIST: [edit_sub_handler, add_sub_handler], ADD_CITY: [add_city_handler],
|
|
EDIT: [edit_city_handler, edit_time_handler, delete_subscription_handler],
|
|
EDIT_CITY: [edited_city_handler], EDIT_TIME: [edited_time_handler],
|
|
ADD_TIME: [add_time_handler]},
|
|
fallbacks=[fallback_handler, fallback_callback_handler])
|