RuStore запустил функцию публичного бета‑тестирования приложений

А меню со списком приложений установленных с помощью RuStore на устройстве так и не добавили.

Реализация взаимодействия с БД через Middleware в Telegram-ботах

Суть та же, что и с сессией, только передаёшь unit of work.

def create_sqlmodel_engine(settings: DatabaseSettings, **kwargs) -> Engine:
    return create_engine(str(settings.dsn), **kwargs)


def sqlmodel_sessionmaker(settings: DatabaseSettings, engine: Engine) -> Callable[[], Session]:
    return lambda: Session(bind=engine, autoflush=settings.autoflush)


class BaseSQLModel(SQLModel):
    """Базовый класс для всех моделей данных"""
    __table_args__ = {'extend_existing': True}

    class Config:
        alias_generator = to_camel
        validate_by_name = True
        arbitrary_types_allowed = True


T = TypeVar('T', bound=BaseSQLModel)


class GenericRepository(Generic[T], ABC):
    @abstractmethod
    def get(self, id: EntityId) -> T | None: ...

    @abstractmethod
    def list(self, **filters) -> Sequence[T]: ...

    @abstractmethod
    def add(self, entity: T) -> T: ...

    @abstractmethod
    def update(self, entity_id: EntityId, entity: T) -> T: ...

    @abstractmethod
    def delete(self, id: EntityId) -> None: ...


class GenericSQLRepository(GenericRepository[T], ABC):
    def __init__(self, session: Session, model_cls: Type[T]):
        self._session = session
        self._model_cls = model_cls

    def _build_get_stmt(self, entity_id: EntityId) -> SelectOfScalar[T]:
        return select(self._model_cls).where(self._model_cls.id == entity_id)

    def get(self, id: EntityId) -> T | None:
        return self._session.exec(self._build_get_stmt(id)).one_or_none()
    # тут дальше реализация методов list/add/update/delete, где мы описываем
    # повторяющуюся для всех репозиториев логику. Суть та же, работаем с model_cls



class UserBaseRepository(GenericRepository[User], ABC):
    @abstractmethod
    def get_by_telegram_id(self, telegram_id: int) -> User | None: ...


class UserRepository(GenericSQLRepository[User], UserBaseRepository):
    def __init__(self, session: Session) -> None:
        super().__init__(session, User)

    def get_by_telegram_id(self, telegram_id: int) -> User | None:
        stmt = select(User).where(User.telegram_id == telegram_id)
        return self._session.exec(stmt).one_or_none()


class UnitOfWorkBase(ABC):
    users: UserBaseRepository  # здесь добавляются репозитории

    def __enter__(self) -> 'UnitOfWorkBase':
        return self

    @abstractmethod
    def __exit__(self, exc_type, exc_value, traceback) -> None: ...

    @abstractmethod
    def commit(self) -> None: ...

    @abstractmethod
    def rollback(self) -> None: ...


class UnitOfWork(UnitOfWorkBase):
    def __init__(self, session_factory: Callable[[], Session]) -> None:
        self._session_factory = session_factory

    def __enter__(self) -> UnitOfWorkBase:
        self._session = self._session_factory()
        self.users = UserRepository(self._session)  # И здесь добавляются репозитории
        return super().__enter__()

    def __exit__(self, exc_type, exc_value, traceback) -> None:
        if exc_type:
            self._session.rollback()
        try:
            self._session.commit()
        except Exception:
            self._session.rollback()
            raise

    def commit(self) -> None:
        self._session.commit()

    def rollback(self) -> None:
        self._session.rollback()


class UnitOfWorkMiddleware(BaseMiddleware):
    def __init__(self, settings: DatabaseSettings):
        self.settings = settings

    async def __call__(
        self,
        handler: Callable[[TelegramObject, dict[str, Any]], Awaitable[Any]],
        event: TelegramObject,
        data: dict[str, Any],
    ) -> Any:
        engine = create_sqlmodel_engine(self.settings)
        sessionmaker = sqlmodel_sessionmaker(self.settings, engine)

        with UnitOfWork(session_factory=sessionmaker) as uow:
            data['uow'] = uow
            return await handler(event, data)

Здесь используется SQLModel, но с SQLAlchemy будет аналогично. Если что, то могу скинуть код описания репозиториев и unit of work для алхимии.

Подумываю прикрутить сюда CQRS, но пока ещё не решился. Да и потребности пока такой нет.

Пример использования:

from aiogram.types import User as TelegramUser,
from m4dn355.state.sql.models import User as DBUser


async def create_user_from_telegram_bot(uow: UnitOfWorkBase, telegram_user: TelegramUser) -> DBUser:
    new_user = DBUser(
        username=telegram_user.username,
        telegram_id=telegram_user.id,
        telegram_username=telegram_user.username,
        is_verified=True,
    )
    new_db_user = uow.users.add(new_user)
    return new_db_user


async def get_or_create_telegram_user(
    uow: UnitOfWorkBase,
    telegram_user: TelegramUser,
) -> DBUser:
    db_user = uow.users.get_by_telegram_id(telegram_user.id)
    if db_user:
        return db_user
    return await create_user_from_telegram_bot(uow, telegram_user)

  
@commands_router.message(CommandStart())
async def command_start_handler(message: Message, uow: UnitOfWorkBase, dialog_manager: DialogManager) -> None:
    """/start - Приветственное сообщение"""
    await get_or_create_telegram_user(uow, message.from_user)
    await dialog_manager.start(MainState.START, mode=StartMode.RESET_STACK)

Надеюсь будет полезно.

Стоицизм, самурайство и пофигизм в ИТ

Было бы интересно почитать про то каково было работать в ЮКОС в те времена)

Безопасность AI-агентов в Web3. Часть 2: уязвимости современных LLM и соревновательный взлом

Пожалуй крайне полезная обзорная серия статей про инфобез относительно LLM. Спасибо

Каламический космологический аргумент и первопричина всего

Там траву не только трогали, судя по всему)

Обновление JetBrains AI Assistant: поддержка Gemini и улучшенное дополнение кода

Блин) страннно) нажимал ответить, а комментарий почему-то ниже отправился)

Смена региона вообще ни на что не повлияла, какой бы регион не выставил((( ни с Toolbox ничего не качается, ни внутри IDE ничего не качается и не обновляется(( короче, пойду решать вопрос с поиском и покупкой VPS в Европе

Обновление JetBrains AI Assistant: поддержка Gemini и улучшенное дополнение кода

Та вот скорей всего многим кто меня блочит не нравится что трафик идёт из Амстердама, но от VolgoGazTelecom)

Обновление JetBrains AI Assistant: поддержка Gemini и улучшенное дополнение кода

Можно в теории разные модельки потестить) uncensored модели, например)

Обновление JetBrains AI Assistant: поддержка Gemini и улучшенное дополнение кода

Смена региона не помогает(

По ходу нужно сменить VPS провайдера на котором свой wireguard держу.

Обновление JetBrains AI Assistant: поддержка Gemini и улучшенное дополнение кода

Благополучно пользовался и платил за Ai Assistant. Оч удобный был инструмент позволяющий в контексте проекта делать какой-нибудь рефакторинг где нужна рутина, например. И интеграции в IDE очень удобные были, можно трейсбеки из тестов анализировать. В итоге теперь вижу только сообщение "AI Assistant is not available in your location with the region selected in your IDE settings". Если раньше он худо-бедно под моим Wireguard VPN работал, то теперь и AI Assistant недоступен, и обновляться IDE отказывается, и даже устанавливать/обновлять плагины не даёт!

Если проблему с доступом решить до дня списания платежа не получится, то по ходу вообще от продуктов JetBrains отказываться придётся.

А так, судя по статье, обновление прикольное. Я бы сразу Ollama свою локальную прикрутил, если бы была такая возможность.

Неужели Banki.ru сливают ваши данные спамерам? Или как не угодить в ловушку микрозаймов

Автору за данное исследование жирнейший лайк, почтение, а всем родным и близким автора здоровья и благополучия!

Тоже сталкивался с волной спама из-за banki.ru

ORM для реальных приложений не окупается

Из моей практики приходится переходить между разными СУБД. Например в апреле прошлого года полностью переехать надо было 16 микросервисов с Oracle на PostgreSQL. И когда у тебя все запросы написаны с использованием ORM, то переписывать надо только лишь те маленькие участки где используется голый SQL. В моём случае это были рекурсивные оракловые запросы, которые я на орм переписывал под постгрес. Если бы не ORM, то переезд бы явно сильно затянулся. Да и ORM и читать, и писать, и валидировать и проверять проще, чем полотно текста. Плюс автокомплит из коробки.

Обход блокировки «Тиндера» — простой метод

Да камон) он умер в первый день блокировок) ну по крайней мере все с кем я там знакомился с первой секунды отключения просто перестали им пользоваться) это не инстаграм ради которого стоило заморачиваться обывателю)

VK Open: зачем разработчику открытые платформы

Поддерживаю полностью. Да и вообще API бы поправить, а то получать в ответе HTTP код 200, а внутри json с текстом Access Denied на запрос о получении постов на стене - это что-то за гранью. В итоге о том что там в ответе пусто узнаёшь только когда парсишь сам json с ответом с ответом, а не на этапе чтения HTTP кода ответа.

YAMAL DEV CONF — как это было

Круче чем Yamal.dev на Ямале никто мероприятия такого толка не проводит) так ещё и бесплатный вход для всех желающих) а это уже заявка на всероссийское первенство)