def load_jobs(bot, job_queue):
"""Load all existing jobs (pending reminders) into the given
'job_queue', and apologise if we missed any.
"""
if not os.path.isdir(bot.username):
return
now = datetime.now()
for chat_id in os.listdir(bot.username):
apologise = False
for reminder in os.listdir(get_user_dir(bot, chat_id)):
reminder_file = os.path.join(bot.username, chat_id, reminder)
reminder_date = datetime.fromtimestamp(int(reminder))
if reminder_date > now:
queue_message(job_queue, reminder_date,
int(chat_id), reminder_file)
else:
apologise = True
os.remove(reminder_file)
if apologise:
bot.send_message(chat_id,
text='Oops… looks like I missed some reminders. Sorry :(')
评论列表
文章目录