o {g\ @sdZddlmZddlZddlZddlmZmZmZm Z ddl m Z ddl m Z dZeded efd Zdd dZejdkrFejZejZdSdddZdddZdS)z2Miscellaneous pieces that need to be synchronized.) annotationsN)AnyCallableTypeVarcast)OperationFailure)_REAUTHENTICATION_REQUIRED_CODETF.)boundfuncreturncsdfdd }tt|S)Nargsrkwargsr c s|dd}ddlm}ddlm}z|i|WSty`}z:|r%|jtkr[d}|D]}t||r9|}n t||rC|j }nq.|rM|j ddn|i|WYd}~Sd}~ww)N no_reauthFr)_BulkWriteContext) ConnectionT)reauthenticate) poppymongo.messagerpymongo.synchronous.poolrrcoder isinstanceconn authenticate)r rrrrexcrargr x/var/www/bot.gig.net.ua/public_html/telegram/P1/HellBot/venv/lib/python3.10/site-packages/pymongo/synchronous/helpers.pyinner's2      z_handle_reauth..inner)r rrrr r)rr )r rrrr_handle_reauth&s r ) clsrcC|SzhCompatibility function until we drop 3.9 support: https://docs.python.org/3/library/functions.html#next.)__next__r#rrrnextLr(cCr$r%)__iter__r'rrriterPr)r+)r r r r )r#rr r)__doc__ __future__rbuiltinssystypingrrrrpymongo.errorsrpymongo.helpers_sharedr_IS_SYNCr r version_infor(r+rrrrs     !