Как проверить подписан ли пользователь на канал?

Question

[Дмитрий]

Подскажите, как сделать проверку подписки на канал, для группы, если подписан, то разблокировать стену в группе.

Пользователь на другом сайте, Мне написал так "Я бы на твоем месте вместо того, чтобы дёргать get_chat_member поставил хендлер на чатмембре и при ливе из канала обновлял в бд, что статус юзера "left", если чел зашёл - "joined". И чтобы проверить есть ли в канале, то просто смотрел значение из БД"

#База Данных
conn = sqlite3.connect("username.db")
c = conn.cursor()
c.execute('''CREATE TABLE IF NOT EXISTS users
        (id INTEGER PRIMARY KEY AUTOINCREMENT, user_id INTEGER, username TEXT, first_name TEXT, chat_id INTEGER)''')
conn.commit()
conn.close()

class SQLither:

    def __init__(self, database) -> object:
        self.conn = sqlite3.connect(database)
        self.c = self.conn.cursor()

    def exists_user(self, user_id):
        """Проверка существования пользователя в БД"""
        return bool(self.c.execute("SELECT * FROM users WHERE user_id=?", (user_id,)).fetchone())

    def add_to_db(self, user_id, username, first_name, chat_id):
        """Добавление пользователя в БД"""
        #self.c.execute("INSERT INTO users ('user_id') VALUES(?)", (user_id,)) and self.c.execute("INSERT INTO users ('username') VALUES(?)", (username,))
        self.c.execute("INSERT INTO users(user_id, username, first_name, chat_id) VALUES(?,?,?,?)", (user_id, username, first_name, chat_id))
        self.conn.commit()


#ID канала
chat_id = -100id

Вот код, что прописал, верно ли? создал отдельный хендлер для проверки подписки.

@dp.message_handler(content_types=['chat_member'])
async def on_joined(message: types.Message):
    for user_channel_status in message.text:
        if user_channel_status["status"] != 'member':
            user_channel_status = await bot.get_chat_member(chat_id=message.chat.id, user_id=message.from_user.id)
        if isinstance(user_channel_status, types.ChatMemberMember):
            await bot.restrict_chat_member(message.chat.id, message.from_user.id, can_send_messages=True)
            return
            print(user_channel_status)

Answer 1

[soremix]

Из документации телеграма:

new_chat_members: Optional. New members that were added to the group or supergroup and information about them (the bot itself may be one of these members)

Если у вас канал - то такие апдейты не будут приходить. Так что каждый раз нужно вызывать get_chat_member

Comments

[Дмитрий]

Спасибо, но как открыть стену в группе, если я пользователь уже на канале?

[soremix]

Дмитрий, если список пользователей есть в БД, то как пример можно сделать фоновую задачу, которая раз в Х минут пробегает по всем пользователям, взять из них тех, на которых есть ограничения, и проверить подписку у каждого. Либо можно сделать функцию принятия ЛС у бота, пусть люди пишут условный /unban, бот проверяет его подписку и открывает чат

[Дмитрий]

soremix, Все понятно на словах, но вот, как это прописать?

[soremix]

Дмитрий, ну если про второй вариант, то обычный хендлер на команду и делаем

@dp.message_handler(commands=['myCommand'])
async def my_command(message: types.Message):
    user_status =  await get_chat_member(channel_id, message.from_user.id)
    # ну и тут уже проверяем участник ли канала человек и снимаем ограничения

[Дмитрий]

soremix, Прописал так, не по команде, а чтобы разблокировал, но результата нет, стена закрыта.

@dp.message_handler()      
#async def check(message):
#async def on_joined(message: types.Message):
async def check_new_user(message: types.Message):
    for user_status in message.text:
        user_status = await bot.get_chat_member(chat_id=message.chat.id, user_id=message.from_user.id)
        if message.chat.type != "supergroup, private, channel":
            return
        if isinstance(user_status, types.ChatMemberMember):
          if user_status["status"] != 'left':
            await bot.restrict_chat_member(message.chat.id, message.from_user.id, can_send_messages=False)
            await bot.send_message(message.from_user.id, "Вы уже находитесь в канале!")
          else:
              if isinstance(user_status, types.ChatMemberMember):
                  if user_status["status"] != 'member':
                      await bot.unban_chat_member(chat_id=message.chat.id, user_id=message.from_user.id)
                      #await bot.restrict_chat_member(message.chat.id, message.from_user.id, can_send_messages=True)
                      print(user_status)
                      return

[Дмитрий]

soremix, Прописал так, но что то результата нет, хотя ошибок нет.

@dp.message_handler(commands=['myCommand'])
async def my_command(message: types.Message):
    if message.chat.type != "supergroup, private, channel":
        return
    user_status =  await get_chat_member(channel_id, message.from_user.id)
    #user_status = await bot.get_chat_member(chat_id=message.chat.id, user_id=message.from_user.id)
    if isinstance(user_status, types.ChatMemberMember):
        if user_status["status"] != 'member':
            await bot.restrict_chat_member(message.chat.id, message.from_user.id, can_send_messages=True)
            return

Эту команду прописал в боте /myCommand