JuliusFreudenberger
d6debf6a46
Enables user to get weather information every day at a set time for a set city City and time can be changed and the subscription can be deleted. Formatting can be optimized
64 lines
1.9 KiB
Python
64 lines
1.9 KiB
Python
import logging
|
|
import threading
|
|
import time
|
|
|
|
import schedule
|
|
from telegram.ext import Updater, CommandHandler, InlineQueryHandler, CallbackQueryHandler
|
|
|
|
from exceptions import *
|
|
from vvs import inline_station_search, handle_vvs, handle_multiple_stations_reply
|
|
from weather_meteomedia import handle_meteomedia
|
|
from weather_openweathermap import handle_weather
|
|
from weather_openweathermap import __init__ as openweathermap_init
|
|
from push_information import __init__ as push_init
|
|
|
|
|
|
token_file = open("token", "r")
|
|
updater = Updater(token=token_file.read(), use_context=True)
|
|
token_file.close()
|
|
|
|
dispatcher = updater.dispatcher
|
|
|
|
logging.basicConfig(format='%(acstime)s - %(name)s - %(levelname)s - %(message)s', level=logging.INFO)
|
|
|
|
|
|
def send_message(chat_id: int, message: str):
|
|
dispatcher.bot.send_message(chat_id=chat_id, text=message, disable_notification=True, parse_mode="Markdown")
|
|
|
|
|
|
cease_continuous_run = threading.Event()
|
|
|
|
|
|
class ScheduleThread(threading.Thread):
|
|
@classmethod
|
|
def run(cls):
|
|
while not cease_continuous_run.is_set():
|
|
schedule.run_pending()
|
|
time.sleep(10)
|
|
|
|
|
|
def __main__():
|
|
inline_station_search_handler = InlineQueryHandler(inline_station_search)
|
|
dispatcher.add_handler(inline_station_search_handler)
|
|
dispatcher.add_handler(CommandHandler('vvs', handle_vvs))
|
|
dispatcher.add_handler(CommandHandler('meteomedia', handle_meteomedia))
|
|
dispatcher.add_handler(CommandHandler("weather", handle_weather))
|
|
|
|
openweathermap_init()
|
|
dispatcher.add_handler(push_init())
|
|
|
|
dispatcher.add_error_handler(error_callback)
|
|
|
|
dispatcher.add_handler(CallbackQueryHandler(handle_multiple_stations_reply, pattern="^\/vvs"))
|
|
|
|
continuous_thread = ScheduleThread()
|
|
continuous_thread.start()
|
|
|
|
updater.start_polling()
|
|
updater.idle()
|
|
|
|
cease_continuous_run.set()
|
|
|
|
|
|
if __name__ == "__main__":
|
|
__main__()
|