U
Įwh. @ s d dl Z d dlZd dlZd dlmZ d dlmZ d dlmZ d dlm Z d dl
Z
d dl
m Z d dl m
Z
d dlT d d lmZ d d
lmZ d d lmZ G d d
d
ejZdS ) N)copy)Path)urlparse) safe_join)Linker)
BeautifulSoup)*fields)CmfActiveEntity)cmf_chat_messagec s e Zd Zejjdddg Zedd Zedd Zdd Z d
d Z
d d
Z fddZ dd Z
dd Z fddZ fddZdd Zd!dd Zd d d d fd d
Z ZS )"CmfChatMessageZlike mark_readall_relation_personsc sT fdd}t jjdd|d gdgd}tjj|d d d
tjjd }| |jk rZd S |d t j d }t jjdd|d gd
|_
|j
j d d |_
d d |_ d d rd|_|jdd }t j|}|sHt jj|d}|s`t j||j
j d}| |||d |j
j d |d d\} |_| d S n|j
|_|jr`| | }
||
_ d d s||
_t j j|jddgd} | r| j| jd gd } | j |
_ n$t j j|jd }
|
r|
|
_ n||
_ ||
j |d |j
j d |d d\} |
_| ||
_ |
t j j t!"d |
j j d d i t j #|
d d S )!Nc s t |}|| }tj| |d}| t| |}t|jj ddd t
|d} | t
| W 5 Q R X |dkrd|j d}
nd|j d d d
}
||
fS ) N)parentnameT)parentsexist_okzwb+Zimagez
z rA r& rB rC Z responsibler r? )rE Zcommentr0 rJ r# r# r$ rD m s z)CmfChatMessage._whatsapp_message_receivedc K s | dddg tjjdd| jgddtjjggd}| j dgd | jjrPg | _tjj j
| jj kr| jj
t
j
jt
jjd
tjj j
tjjj
d |r| | jD ](}|js|jtjjkrqd |_| q| jd
d d
S dS )Nzchannel_messages.channelz channel_messages.cmf_author_idz channel_messages.message_statusr< r' person_idr+ viewsr r* )r5 rK r readTZ only_dataF) load_fieldsr CmfChatTopicUnreadMessager4 r& gZcurrent_personrM is_nullrK r> Zjsonappendr5 Znowr6 r7 Z isoformatr deleteZchannel_messagesr: Z
cmf_author_idr2 r )selfkwargsZunread_messagemsgr# r# r$ r | s,
zCmfChatMessage.mark_readc C s | j r| j jjdkrd S | j jdddg | j| j j_| j j| j j_| j j | j j_
| j | j j_ | j jj
| j jjdd | | j _| j jjr| j d S )N CmfChatTopiczgroup.cache_last_topic_codezgroup.cache_last_topic_namezgroup.last_topicTrO )r r>
class_namerP r? groupZcache_last_comment_textrK Zcache_last_topic_coder Zcache_last_topic_nameZ
last_topicZcmf_modified_atZset_nowr rH r@ rV r# r# r$
_calc_chat s
zCmfChatMessage._calc_chatc
C sr d dd}| j jr| j jr dS tj}dddg|d< d g|d
< d g|d < d
ddg|d< tj}|d |d |d |d |d |d |d |d |d |d
tj| j jtj|d| _ t |gd}|
| j j| _ t | j jd}| d}t
|D ]P\}}|d} | d| |jd | jd< d | jd < d | jd < ||| q| | _ dS ) u
Защита от инжектов которые могу прилететь из внешних систем
:return:
Fc S s. | ds| S t| d }d| d< d| d< | S )N)Nhref_blank)NtargetZexternal)Nclass)r4 r )attrsnewpr# r# r$
set_target s
z.CmfChatMessage._clean_text..set_targetNsrcwidthZheightimgra spanr5 timeZcontrolsrK Zaudiord brZinsdelZfigureZ
figcaption)r? tags
attributes)Z callbacksz html.parserar r^ zchat-imgr_ r` )F)r? r@ rS bleachZALLOWED_ATTRIBUTESZ ALLOWED_TAGSrT Zcleanr> r Zlinkifyr Zfind_all enumerateZnew_taginsertrb Zprettify)
rV re rn rm ZlinkerZsoupZimagesirh linkr# r# r$ _clean_text s@
zCmfChatMessage._clean_textc s6 | | | | | t j||S N)r] _calc_notify _calc_cacheru r superr )rV argsrW __class__r# r$ r s zCmfChatMessage.savec K s& dS dS | jrd| _| | j j dS )u
Отправляем оповещения всем кроме автора комментария
:param kwargs:
:return:
NT)r? r@ r priorityZ importantZall_place_notifyr> )rV rW r# r# r$ rw s zCmfChatMessage._calc_notifyc C s( | j r$| j j| _| j j| _| j j| _d S rv )rA ZloginZcache_cmf_author_loginrK Zcache_cmf_author_coder Zcache_cmf_author_namer\ r# r# r$ rx s
zCmfChatMessage._calc_cachec s. | dg | jr | j tt| d S )Ndeal)rP r~ rC ry r
r\ r{ r# r$ rC s
zCmfChatMessage.emitc s t dddg S )Nz parent.grouprA r~ )ry save_preload_fieldsr\ r{ r# r$ r s z"CmfChatMessage.save_preload_fieldsc K s\ | j rB| j}|j}tjj| j|d|j d|j d| jj| j d tj || | jd
d S )Nu% Важное сообщение в «u » — « »)objpersonr rX r} )r r" Z
chat_topic) r} r r[ r Z CmfNotifyZ place_notifyr r? r> rQ r )rV rL rW ZctZcgr# r# r$
_place_notify s z CmfChatMessage._place_notifyNc K s | dg | jj S )Nr )rP r Z executorsZ
all_nested)rV r
rW r# r# r$ r
s z#CmfChatMessage.all_relation_personsFforceTEXKOM_db_deleteskip_owner_checkc sn |rTt jj| ddD ]}d |_|jdd qt jj| ddD ]}d |_|jdd q s