import config
import logging
from aiogram import Bot, Dispatcher, executor, types
from sqlighter import SQLighter
#log init
logging.basicConfig(level = logging.INFO)
#bot init
bot = Bot(token = '5456827121:AAEiHtdwVjU-pUQvjsVqj7L2kRmC4bzIo_8')
dp = Dispatcher(bot)
# инициализируем соединение с БД
db = SQLighter ('db.db')
# команды активации подписки
@db.message_handler(comands=['subscribe'])
async def subscribe(message: types.Message):
if(not db.subscriber_exists(message.from_user.id)):
# если юзера нет в базе, добавляем его
db.add_subscriber(message.from_user.id)
else:
# если он уже есть, то просто обновляем ему статус подписки
db.update_subscription(message.from_user.id, True)
await message.answer("Вы успешно подписались на рассылку!\nЖдите, скоро выйдут новые обзоры и вы узнаете о них первыми =)")
# Команда отписки
@db.message_handler(comands=['unsubscribe'])
async def unsubscribe(message: types.Message):
if(not db.subscriber_exists(message.from_user.id)):
# если юзера нет в базе, добавляем его с неактивной подпиской (запоминаем)
db.add_subscriber(message.from_user.id, False)
await message.answer("Вы итак не подписаны.")
else:
# если он уже есть, то просто обновляем ему статус подписки
db.update_subscription(message.from_user.id, False)
await message.answer("Вы успешно отписались от рассылки.")
#echo
@dp.message_handler()
async def echo(message: types.Message):
await message.answer(message.text)
#run long-polling
if __name__ == "__main__":
executor.start_polling(dp, skip_updates = True)
