File: //home/arjun/projects/buyercall/buyercall/blueprints/user/__pycache__/tasks.cpython-310.pyc
o
�we. � @ s� d dl mZmZ d dlmZ d dlmZ d dlm Z d dlm
Z
d dl m Z d dl
mZ d dlmZ e e�Ze�� d d
d ��Ze�� d d
� �Ze�� dd� �Ze�� dd� �Ze�� d dd��Ze�� d dd��Ze�� d dd��Ze�� dd� �ZdS ) � )� current_app�url_for)� lazy_gettext)�_try_renderer_template)�send_ses_email)�send_template_message)�create_celery_app)�User)�
ses_client� c K sJ t j�| �}|du r dS ||||d�} ttd�|��|jgd|d� dS )aq
Send a reset password e-mail to a user.
:param user_id: The user id
:type user_id: int
:param reset_token: The reset token
:type reset_token: str
:param partnership_name: partnership name
:type partnership_name: str
:param partnership_logo: The reset token
:type partnership_logo: str
:return: None if a user was not found
N)�user� reset_token�company�logoTz"{} - Password reset from buyercallzuser/mail/password_reset)�subject�
recipients�template�ctx)
r �query�getr �_�format�emailr r �partnership_id)�user_idr
�partnership_name�partnership_logo�kwargsr r � password_reset_email_template� r �A/home/arjun/projects/buyercall/buyercall/blueprints/user/tasks.py� deliver_password_reset_email s � r! c
K sz t j�| �}|du r dS |rd�||�}ntd|dd�}|||||d�}td dd i|��} t|jg|jd
�|�| d � dS )
a�
Send an invitation e-mail to an agent.
:param user_id: The user id
:type user_id: int
:param reset_token: The reset token
:type reset_token: str
:param reset_token: The reset token
:type partnership_name: str
:return: partner_name will be used in subject of the email
:type partnership_logo: str
:return: partnership_logo will be used as logo for email
:type partner_url: str
:return: partner_ulr will be used as partner url
Nz&{}/account/agent_invite?reset_token={}zagents.agent_inviteT)r
� _external)r r
r r �url�agents/mail/invitation�ext�html�Invitation to {}�r �p_idr r& )r$ ) r r r r r r r r r )
r r
r r � partner_urlr r �partnership_urlr �agent_invite_email_templater r r �send_agent_invitation_email5 s& � �r- c K sT t j�| �}|du r dS ||d�}tdddi|��}t|jg|jd�|�|d� dS ) a?
Send an invitation e-mail to an agent.
:param user_id: The user instance id
:type user_id: int
:param reset_token: The reset token
:type reset_token: str
:param reset_token: The reset token
:type partnership_name: str
:return: partnership_name will be used in subject of the email
N)r r
�partnership/mail/invitationr% r& r' r( )r. )r r r r r r r r )r r
r r r r � partner_invite_email_templater r r � send_partners_invitation_emailb s
�r0 c K s t j�| �}t|||� dS )a6
Send an invitation e-mail to an agent.
:param user_id: The user id
:type user_id: int
:param reset_token: The reset token
:type reset_token: str
:param reset_token: The reset token
:type partnership_name: str
:return: partnership_name will be used in subject of the email
N)r r r r0 )r r
r r r r r r �$send_partners_invitation_email_by_id� s
r1 Nc
K sR zt j|||| ||d�}W |S ty( } ztd|� d}W Y d }~|S d }~ww )N)r �config_set_name�senderr �textr& zError : F)r
�
send_email� Exception�print) r r r2 r4 r& r3 r � mail_status�er r r �send_generic_mail� s ��
��r: c K s t �||| ||�}|S )a
Send a notification email
:param subject: email subject
:param data: email content
:param recipients: email recipients
:param sender: email sender or from address
:return mail_status, type bool: Returns True if mail sent successfully.
)r
r5 )r �datar r3 r r8 r r r �send_notification_mail� s
r< Fc O sN ddl m} || ||�}t|t�s |s |�dd �s |S |S |s$ |S |S )Nr )�insert_data_by_index�status)�.buyercall.integrations.elasticsearch.utilitiesr= �
isinstance�boolr )r; � es_client�index�is_error�argsr r= �es_respr r r �put_to_elasticsearch� s ���rG c C s, ddl m} || |||�}|�dd �s |S )Nr )�update_index_by_queryr> )r? rH r )� update_queryrB �
index_name�scriptrH rF r r r �update_to_elasticsearch� s
rL )r r )r r r N)N)F)�flaskr r � flask_babelr r � buyercall.lib.flask_mailplusr � buyercall.lib.util_ses_emailr r �
buyercall.appr � buyercall.blueprints.user.modelsr �buyercall.extensionsr
�celery�taskr! r- r0 r1 r: r< rG rL r r r r �<module> s2 &
,