B bEfi,@s\ddlZddlmZddlmZddlZddlmZddlTddl m Z Gddde Z dS) N)Path)rmtree)Template)*) CmfEntitycseZdZdZfddZddfdd Zedd d Zedd d Ze d e e e dddZ e e e dddZ ddZ ddfdd ZddZddZe dddZZS)! CmfMailboxu TODO: разделить приём настроек, приём почты, отправку в Eva Частично сделано разделением CmfLeadMailbox и CmfMailbox. cstdddddgS)Nlead_mailboxestype imap_serverparentz parent.id)supersave_preload_fields)self) __class__$./modules/mail/models/cmf_mailbox.pyr szCmfMailbox.save_preload_fieldsr)depthcs|jjr|jjs|j|_n$|jjr>|jjs>d|jjkr>|j|_|jr|jjr|jdd}dddd}||d|_|jdkrd|_|jr|j s| t j |d |i|S) u Здесь не хватает поддержки исправления адреса: старый ящик не удалится. @googlezmail.ruZyandex)z gmail.comzmail.ruz yandex.ruZcustomz imap.mail.rur) nameis_nullemailvaluer splitgetr Z is_changedZ cmf_deleted render_configr save)rrargskwargsdomaintypes)rrrrs   zCmfMailbox.save) message_rawcOs|d}|stdddd|kr4td|dd||}|jrRtddS|d gt|jd krtd t d dStd |d |jd }| |dS)uh Приём почту и вызываем "коллбэки" подключенных плагинов ruНе указан emailT)abortru!Не корректный email: uУдалось прикрепить сообщение к уже имеющейся сделке ещё на этапе создания!Nrru`Почтовый ящик не подключен ни к одной воронке продажuУ uf, не нашлось родителя-сделки, отправим его в лидоловушку) rZ cmf_alert_make_channel_messager gdebug load_fieldslenrloggingwarning receive_email)rr"rrr channel_msgZ lead_mailboxrrrr+)s"       zCmfMailbox.receive_emailc Cs|d}|s td|n\t|tr|t|dkr||dddd}t|dkrttd|t||dd}||d<|d  |d |d  |d id |d d |d }tj |||d|d dtj j|d d|d}| |dk st d|S)u Делаем всё что можем с ChannelMessage - создаём и парсим сырые данные для отображения в вебе message_idzMESSAGE WITHOUT ID: %s@<>uhДинный внешний message_id %s (%d символов), обрежем до 64 символовNZbodyZsubjectTz rin)r)Zchannelr"r- client_idZ message_flowZ person_fromtextu*Не создалось сообщение) rr)r*items isinstancestrr(replacemodelsZCmfChannelMessageZ CmfPersonrAssertionError)rr"Zmidr4r,rrrr$=s.   z CmfMailbox._make_channel_messager)r3 client_secret refresh_tokencCs`tjjdddgdd|gdddggd}|s2tdt|d krFtd |d }||||dS) up Уровень 1: валидация входящих данных и текущего состояния БД rz!=Nr z==r<)filteruНе найдены почтовые ящики, для которых была начата, но не закончена настройкаuНайдено больше одного почтового ящика, с незаконченной настройкой, удалите одинr)r9rlist IndexErrorr(setup_oauth_credentials)r3r;r<Z mailbox_typeZunconfigured_mailboxesmailboxrrrreceive_oauth_credentials[s z$CmfMailbox.receive_oauth_credentialscCsN|dk r|dk r|dk st|dddg||_||_|||dS)u9 Уровень 2: модификация объекта Nr r3r<)r:r'r3r<_update_oauth_secretsr)rr3r;r<rrrrAjs  z"CmfMailbox.setup_oauth_credentialscCs|jjrtd|jdSd|jjkrz/var/lib/eva-app/mail//) rrr)r*idrerrorrr)rZ user_nameZserverrrr _mail_dirts  zCmfMailbox._mail_dirF)forcecsV|dgtd|j|}|r2t|ntd|jtj|d|i|S)ub Нельзя тут использовать return, иначе не вызовется super()! ruУдаляем ящик u5Не удалили настройки ящика! %srI) r'printrrHrr)r*r delete)rrIrrmail_dir)rrrrKs  zCmfMailbox.deletec Cs|}|std|jdStd|jtd}t|}WdQRX|j||d}|j ddd|dd }| |WdQRXdS) u Порядок действий продиктован нежеланием писать в файловую систему, пока возможны ошибки уровнем выше u;Не сможем сохранить настройки! %sNu9Переписываем конфиг для offlineimap z8/opt/eva-app/modules/mail/templates/offlineimaprc.jinja2)rBZ localfoldersT)parentsexist_okz.offlineimaprcw) rHr)r*rrJopenrreadZrendermkdirwrite)rrLZtmplttemplatedatafdrrrrs zCmfMailbox.render_configc Cs~d}td|jd}|s"dS|dH}x@|D]4}||kr8||dd\}}||jkr8|Sq8WWdQRXdS)u Существует чтобы чтобы client_secret = mailbox.get_client_secret() во время рендеринга было попроще =z/opt/eva-app/custom/z _secrets.iniNr)rr existsrP readlinesstriprr3)rsep secrets_filerVline_idsecretrrrget_client_secrets  zCmfMailbox.get_client_secret)r;c si}td|jd}d|r|dB}x:|D].}|kr8|dd\}}|||<q8WWdQRXtt}|| j } | dkrt d| |j |kr|||j <|d "}|fd d |DWdQRXdS) up Уровень 3: сохранение секрета в конфиг для дальнейшей работы z/opt/eva-app/custom/z _secrets.inirWrXNrY uzWARNING: подозрительно частая попытка сменить авторизационные данныеrOc3s$|]\}}||dVqdS) Nr).0r`ra)r]rr sz3CmfMailbox._update_oauth_secrets..)rr rZrPr[r\rinttimestatst_mtime OverflowErrorrr3 writelinesr5) rr;Zsecretsr^rVr_r`raZnowZseconds_since_last_accessr)r]rrDs"    z CmfMailbox._update_oauth_secrets)r)__name__ __module__ __qualname____doc__r rdictr+r$ staticmethodr7rCrArHrKrrbrD __classcell__rr)rrr s    r) rhZpathlibrZshutilrZshlexZjinja2rZ cmf.includeZ cmf.modelsrrrrrrs