x'h&dZ ddlZddlmZmZddlZddlmZm Z m Z m Z ddl Z ddl mZmZde de fd e de ffd Zde de fd e de ffd ZGd d eZy#e$rdZYUwxYw)TN)RedisConnectionPoolF)OptionalUnionCallable Coroutine)StateStorageBaseStateDataContextfunc.returncfd}|S)NcK|j4d{|g|i|d{cdddd{S7)77 #1d{7swYyxYwwN)lock)selfargskwargsr s ]/var/www/flask-api/venv/lib/python3.12/site-packages/telebot/asyncio_storage/redis_storage.pywrapperz async_with_lock..wrappersV99 5 5d4T4V44 5 5 54 5 5 5 5sPA>AAAA AAAAAA A AAr rs` rasync_with_lockrs5 Ncfd}|S)Nc,K|jj4d{}|j||g|i|d{}|jd{|cdddd{S7T7177 #1d{7swYyxYwwr)redispipelinemultiexecute)rrrpiperesultr s rrz$async_with_pipeline..wrappers::&&(  D JJLdNOP P::d#DDI))D&$**T*:; ; ;-# :value - Old format: {prefix}chat_id: {user_id: {'state': None, 'data': {}}, ...} - New format: {prefix}{separator}{bot_id}{separator}{business_connection_id}{separator}{message_thread_id}{separator}{chat_id}{separator}{user_id}: {'state': ..., 'data': {}} This function will help you to migrate from the old format to the new one in order to avoid data loss. :param bot_id: Bot ID; To get it, call a getMe request and grab the id from the response. :type bot_id: int :param prefix: Prefix for keys, default is "telebot_"(old default value) :type prefix: Optional[str] *rGNrr7r=)r:)rkeysrHgetrBrRlenlistr?intr.r&rArCrL) rr:r.r_rNold_keyrOr5r6r7 state_datanew_keys rmigrate_formatz StateRedisStorage.migrate_format's&zz&|, 'Cjj)GJJNN7+EJJu%Ec&km,G5::<(+G'N7+Ew/JmmG c'lDKKPV$G JJOOGWe 4 JJOOGVTZZ -C D JJ  g &' 'rc"d|jdS)NzStateRedisStorage())r)rs r__str__zStateRedisStorage.__str__Qs#DJJrzs3 77S(3 >2xY7OhsI~68CN;Sq2(q2;Os AA&%A&