import config, asyncio
from datetime import datetime
from aiogram import Bot, Dispatcher, executor, types
from aiogram.dispatcher.filters import Command, Text
from aiogram.types.message import Message
import for_telegram

loop = asyncio.get_event_loop()
bot = Bot(token=config.TOKEN, parse_mode='HTML') #Инициализация бота
dp = Dispatcher(bot, loop=loop)

async def send_to_admin(dp):
    await bot.send_message(chat_id=config.admin_id, text='Бот запущен, введите команду \'/pars\', чтобы выбрать сервис, который вы хотите запарсить')

@dp.message_handler(Command('pars'))
async def send_to_admin_2(dp):
    await bot.send_message(chat_id=config.admin_id, text='''Выберите сайт, который будете парсить и напишите команду:
'/fb_on' - facebook, '/inst_on' - instagram, '/twit_on' - twitter, '/yt_on' - youtube, '/rss_on' - rss-летну, а чтобы отключить
'/fb_off' - facebook, '/inst_off' - instagram, '/twit_off' - twitter, '/yt_off' - youtube, '/rss_off' - rss-летну''')

@dp.message_handler(Command(['fb_on']))
async def fbp(wait_for):
    while True:
        await asyncio.sleep(wait_for)
        new_post = for_telegram.fb()
        if new_post != 'Изменений нет':
            await bot.send_message(chat_id=config.chat_id, text=new_post)


@dp.message_handler(Command(['inst_on']))
async def instp(wait_for):
    while True:
        await asyncio.sleep(wait_for)
        new_post = for_telegram.inst()
        if new_post != 'Изменений нет':
            await bot.send_message(chat_id=config.chat_id, text=new_post)


@dp.message_handler(Command(['twit']))
async def twitp(wait_for):
    while True:
        await asyncio.sleep(wait_for)
        new_post = for_telegram.twit()
        if new_post != 'Изменений нет':
            await bot.send_message(chat_id=config.chat_id, text=new_post)


@dp.message_handler(Command(['yt']))
async def ytp(wait_for):
    while True:
        await asyncio.sleep(wait_for)
        new_post = for_telegram.yt()
        if new_post != 'Изменений нет':
            await bot.send_message(chat_id=config.chat_id, text=new_post)


@dp.message_handler(Command(['rss']))
async def rssp(wait_for):
    while True:
        await asyncio.sleep(wait_for)
        new_post = for_telegram.rss()
        if new_post != 'Изменений нет':
            await bot.send_message(chat_id=config.chat_id, text=new_post)

if __name__ == '__main__': #Запус бота
    dp.loop.create_task(fbp(30))
    dp.loop.create_task(fbp(30))
    dp.loop.create_task(instp(30))
    dp.loop.create_task(twitp(30))
    dp.loop.create_task(ytp(30))
    dp.loop.create_task(rssp(30))
    executor.start_polling(dp, on_startup=send_to_admin, skip_updates=True)