main.py

#!/usr/bin/env python
# -*- coding: utf-8 -*-
from flask import request
from application import app, bot, scheduler, SECRET_TOKEN
from src.race.application.get_races import get_races
from src.race.domain.race import Race
from utils.schedule import schedule_next_race
from src.race.application.finish_race import finish_race
from webhook import set_webhook
import json
import logging
import model
import os
import sys
import telebot
import traceback

logging.basicConfig(stream=sys.stdout)
logging.getLogger().setLevel(logging.INFO)
logging.info('Starting...')

scheduler.start()

race = Race.get_current_race()
if race != None:
    finish_race()
else:
    schedule_next_race()


@ app.route('/me', methods=['GET'])
def send_me():
    """
    Devuelve información del bot
    """
    me = bot.get_me()
    return json.dumps(me, default=lambda o: o.__dict__, sort_keys=True, indent=4)


@ app.route('/webhook' + SECRET_TOKEN, methods=['POST'])
def get_messages():
    """
    Se encarga de procesar los mensajes recibidos por el bot
    """
    try:
        logging.info("Updating message")
        bot.process_new_updates(
            [telebot.types.Update.de_json(request.stream.read().decode("utf-8"))])
    except Exception as e:
        logging.error("Exception raised")
        logging.error(repr(e))
        logging.error(traceback.format_exc())
    return "!", 200


if bot.threaded:
    logging.info('Polling...')
    bot.remove_webhook()
    bot.polling()
    exit(0)

if __name__ == '__main__':
    set_webhook(True)
    port = int(os.environ.get('PORT', 5000))
    app.run(host='0.0.0.0', port=port, debug=True)