Ji lddlZddlmZmZmZddlmZmZddlm Z ddl m Z e Z GddeZ y)N)retrystop_after_attemptwait_exponential)NotificationChannelDeliveryResult) get_settings) get_vk_tokencreZdZdZedefdZeede ddd d ed ede fd Z y ) VKAdapterz(VK Messages API adapter with retry logicreturncy)Nvk)selfs )/var/www/notifications/app/channels/vk.py channel_namezVKAdapter.channel_name s ) multiplierminmax)stopwaittargetcontentcK|jd}|s tddSt|d{}|s tddSd}|||jdd |d d } tjd 4d{}|j ||d{} | j | j} d| vrw| djd} | djdd} | dk(r%tjd| | j| tdd| d| cdddd{Sd| vr+tdt| d| cdddd{Stddcdddd{S7Q7 77Z7-7#1d{7swYyxYw#tj$r#} tddt| cYd} ~ Sd} ~ wt$r#} tddt| cYd} ~ Sd} ~ wwxYww)a  Send message via VK Messages API Args: target: vk_user_id (customer.vk_user_id) content: message text kwargs: tenant_id (required) API docs: https://dev.vk.com/method/messages.send tenant_idFz$tenant_id is required for VK sending)successerrorNzANo VK group configured for this tenant. Add VK group in settings.z'https://api.vk.com/method/messages.send random_idrz5.131)user_idmessager# access_tokenvg>@)timeout)paramsr" error_code error_msgzUnknown VK errorzVK rate limit: )requestresponsez VK API error z: r.T)r! message_id response_metazUnexpected VK response formatz HTTP error: zUnexpected error: ) getrr httpx AsyncClientpostraise_for_statusjsonHTTPStatusErrorr-str HTTPError Exception)rrrkwargsr r&urlr)clientr.datar*r+es rsendzVKAdapter.sends5JJ{+ !<  *)44 !Y  8K3(  , ((6  &!'S!@@))+}}d?!%g!2!2FFB F# F%/F 0F%4H5F F%F F%#H$ F0 F%<F=F%HF%F F% F%F%F"F F"F%!H"F%%H8GHH H"H:H;HHHN) __name__ __module__ __qualname____doc__propertyr8rrrrrr@rrrr r se2 c  " r :OOsOO Orr )r2tenacityrrrapp.channels.baserrapp.core.configrapp.services.vk_senderr settingsr rrrrKs- @@A(/ >Z#Zr