Как ассинхронно подключить AD?

Question

[xynd98]

Пишу телеграмм бота для работы и первый делом хочу настроить 2FA по почте.
1. Юзер вводит почту (рабочую доменную)
2. Скрипт ищет почту в AD
3. Далее если находит почту, то отправляет код далее на почту
4. Юзер вводит код с почты и авторизация пройдена.

НО возникает сложность, я использую ldap3, но насколько я понимаю он не работает асинхронно и соответственно при проверки почты он выдает мне, что найдено 0 записей и отбивает, что почта не найдена.

Вопрос возникает в том, как настроить 2FA по проверке почты из AD? И есть ли другой способ, рекомендации по настройке 2FA?

Есть мысли, что одновременно происходит два подключения, к серверам телеграмма и к серверу с AD.

Comments

[Влад Григорьев]

документация говорит, что работает асинхронно, и раз что-то возвращает, а не ошибку, то проблема, в том что не верный запрос

[xynd98]

Влад Григорьев, если отдельно запускать файл по поиску email в AD, то выводит все необходимы значения.
Если запускать бота полностью, то отбивает, что найдено 0 записей.

Фрагмент кода по поиску записей в AD:

import os

from ldap3 import Server, Connection, ALL_ATTRIBUTES, ALL


# Установка параметров подключения к Active Directory
def get_emails():
    server = Server('172.XXXX', get_info=ALL)

    # Указываем учетные данные для подключения
    username = os.getenv("user_adm")
    password = os.getenv("user_pw")

    # Устанавливаем соединение с Active Directory
    conn = Connection(server, user=username, password=password)
    conn.bind()

    # Выполняем поиск пользователей по полю email
    email = '*'
    filter_str = f'(&(mail={email})(userAccountControl:1.2.840.113556.1.4.803:=512)(!(userAccountControl:1.2.840.113556.1.4.803:=2)))'
    conn.search('DC=smmretail,DC=ru', filter_str, attributes=ALL_ATTRIBUTES)

    emails = [
        entry.mail for entry in conn.entries
    ]
    #
    # if conn.result:
    #     print('Ошибка при выполнении поиска:', conn.result)
    #
    # if conn.bind():
    #     print('Успешная привязка к серверу')
    # else:
    #     print('Ошибка привязки к серверу')
    print(emails)
    print('Количество найденных записей:', len(conn.entries))

    # Закрываем соединение
    conn.unbind()
    # exit()
    #return emails

main:

import os

from aiogram import Bot, Dispatcher, types
from aiogram.utils import executor
from validators import email
from ad import get_emails
from db import Db


bot = Bot(token=os.getenv("bot_token"))
dp = Dispatcher(bot)


@dp.message_handler(lambda message: '@' in message.text and message.text.endswith('.ru'))
async def echo_send(message: types.Message):
    if email(message.text.strip()):
        emails = await get_emails()
        print(emails)
        if message.text.strip() in emails:
            # Проверка email в ад. Вызываю функцию генерации кода для авторизации.
            unicode = Db.generation_unicode()
            await Db().add_to_db(
                mail_sender='telegram_bot@XXXXX',
                mail_receiver=message.text.strip(),
                mail_text=f'Ваш код для авторизации {unicode}',
                tg_id=message.from_user.id,
                msg_code=unicode
            )
            await bot.send_message(message.chat.id, 'Введите полученый код с почты.')
        else:
            await bot.send_message(message.chat.id, 'Вашей почты нету в базе данных.')
    else:
        await bot.send_message(message.chat.id, 'Введеная почта некорректна.')


if __name__ == '__main__':
    executor.start_polling(dp, skip_updates=True)

[Алан Гибизов]

xynd98, Фрагменты кода надо размещать в виде текста и оборачивать тэгом code для корректного отображения. Удобно делать кнопкой </>
Это обязательно, см.п.3.8 Регламента.
Сюда же относится traceback, ввод и вывод в консоли и другая структурированная текстовая инфа.

[Модератор]

Не надо ставить как можно больше тэгов. Лучше оставить один, но конкретный, с которым проблема.
См.п.3.1 Регламента. Также обратите внимание на п.3.4

[xynd98]

Что не так? Можно поподробнее?

[xynd98]

Justa Gain, Ситуации не изменило. Количество найденных записей: 0. Нету выгрузки с AD. Соответственно нету проверки по emails

[xynd98]

Justa Gain, если отдельно запускать AD.py выгрузку не одновременно с ботом, он выгружает всех активных пользователей которые есть - Количество найденных записей: 251. Запрос составлен корректно.

[xynd98]

Justa Gain, был устаревший пасс в переменной окружения. Все отработало. Спасибо за напоминание.