File: //home/arjun/projects/buyercall/buyercall/blueprints/widgets/__pycache__/endpoints.cpython-310.pyc
o
we�b � @ s� d dl Zd dlZd dlmZ d dlZd dlmZmZm Z d dl
m Z d dl m
Z
d dlmZ d dlmZ d dlmZ d d lmZmZ d d
lmZ d d lmZmZ d d l m Z d d
l m Z d dl m!Z! d dl"m#Z# d dl$m%Z% d dl&m'Z' d dl(m)Z)m*Z* ddl+m,Z,m-Z- ddl.m/Z/m0Z0m1Z1m2Z2m3Z3 ddl4m5Z5 e�6e7�Zede7ddd�Z8e � d d � �Z9e � d d � �Z:e � d d!� �Z;e � e!d"�d#d$� ��Z<e � d1d%d&��Z=e!d"�d'd(� �Z>d)d*� Z?e � e!d"�d+d,� ��Z@e � d1d-d.��ZAe � d/d0� �ZBdS )2� N)�uuid4)�request� Blueprint� current_app)� cross_origin)� current_user)�Agent)�Channel)�Chat)�Contact�ContactChannelTie��send_notifications�� Partnership�PartnershipAccount)�Phone)�Message)�api_role_required)�fix_name)� WidgetOutSelectedResponseSchema)� api_jsonify)� bw_client�subaccount_client� )�Widget�AgentAssignment)�BandwidthRouting�Routing�add_widget_lead�phonecall_inprogress�NoAgentsException� )�Email�chat_widget_api� templatesz /api/widget)�template_folder�
url_prefixc
C s� t jtjd tjd dd�}z)|�dt| �� ��}|dkr'tddidd d�W S |d
kr6td dd �dd d�W S W n tyS } ztd
|� t �
d� W Y d }~nd }~ww tdd idd d�S )N�REDIS_CONFIG_URL�REDIS_CONFIG_PORTT)�host�port�decode_responses�CONNECT�1� callConnect�� �Successz-1F)r/ �errorzError : z2Cannot retrieve lead status - is Redis accessible?) �redis� StrictRedisr �config�get�strr � Exception�print�logr2 )�lead_sid�redis_db�connect�e� r? �H/home/arjun/projects/buyercall/buyercall/blueprints/widgets/endpoints.py� call_status( s$ ��
��rA c C s� ddl m} t�� }tj�ttjf��t tj
f�� tj �� |j
��tjt| �k��� }t�d�|�� |r?d|v r?|d dv sId|v ro|d dv rot�dt|j� d t|j� d � tg d
dt|j�� d t|j�� �d �S |j j}|sz|j j
j}|jr�t�d
�|j�� tg dd|j� d�d �S d}d}zmt |fi |��}|r�tg ddd�W S t |fi |��}ddl m }m} |j�|j |jk��� } |j�|j | j k��� }
|
}|j!j"dkr�t#|
j �} t�d� t$| ��%||� nt�d� |j&} t'| |
j �} t(| ��%||� W no t)�yr g }
|j*D ] }|
�+|j,� �qddl m} ddl-m.} |j�|j |jk��� }d|
t|j,�t|j,�d�}||�}t/j,d d t/j0� d t/j1� �|j2� d �d �}dd!l3m4} |d&i |��}td d"|j,d#�dd$d� Y S w td|j,d%�dd$d�S )'z� The endpoint that gets called when the lead presses 'Call Now!' on the
widget.
Receives the widget GUID as a query string parameter, and the user's data
in the JSON body.
r )r z The call widget json request: {}� firstName�� � � phoneNumberz(No lead fields provided for call widget � - �.� �-Fz0partnership_account {} has exceeded their quota.i� zpartnership_account z has exceeded their quotaNr0 zCall in progressTr �trackingzCalling Bandwidth number...zCalling Twilio number...)� create_task�MISSED_CALL_FOLLOW_UP)�type�users�
partnershipId�partnershipAccountId� MISSED_CALL�You'verE � /settings��user_id�notify_message_type�user_related_entities�other_user_related_entities� hyperlinkr
�
ERR_NO_AGENTS)�success�code�callIdr1 )r\ r^ r? )5�'buyercall.blueprints.partnership.modelsr r �get_jsonr �query� outerjoinr � assignmentsr �agent�join�partnership_account� partnership�filter�guidr7 �firstr: �info�formatr2 �namer � subscription�usage_over_limit�warning�partnership_account_idr r r �id�partnership_id�inboundrN r r � call_lead�twilio_subaccount_sidr r r! �agents�append�sid�#buyercall.blueprints.chat.endpointsrL r � firstname�lastname� partner_url�+buyercall.blueprints.notification.utilitiesr )ri r �json�widgetrn �leadrg � lead_on_callr �partner_account�partner�client�subaccount_sid�all_agents_sidsrd rL rf � task_payload� task_resp�es_datar � es_responser? r? r@ �call= s� ��$�& �
���
�
���
� � r� c
C sf t �� }tj�tjt| �k��� }t� d�
|�� |r%d|v r%|d dv sCd|v r/|d dv sCd|v r9|d dv sCd|v r]|d dv r]t� dt|j � d t|j� d � t
g d
d d �S |�d
�}tj�tjtjk��� }|svtj�d�}|dkr�t|fddi|��}|j}ztjddtj� dtj� �|j� d�d�}W n ty� } zt� t�� � d}W Y d}~nd}~ww t
d|iddd�S |d k�rd }z%tj d i |��} tjd dtj� dtj� �|j� d�d�}t d i |��}
W n t�y
} zt� t�� � d}W Y d}~nd}~ww t
d|iddd�S |d k�rfd }z%t j d i |��} tjd dtj� dtj� �|j� d�d�}t d i |��}
W n t�y\ } zt� t�� � d}W Y d}~nd}~ww t
d|iddd�S |d k�r�d }z tjd dtj� dtj� �|j� d�d�}t d i |��}
W n t�y� } zt� t�� � d}W Y d}~nd}~ww t
d|iddd�S dS )!z� Saves the lead information in the database. Receives the widget GUID as a query string parameter,
and the user's data in the JSON body.�/The after hours call widget json request is: {}rB rC �lastNamerF � emailAddress�#No lead fields provided for widget rG rH rI � Missing parameters for widgetFrN r �CALL�status�missed�NEW_LEADrS rE rT rU N�leadIdr0 r1 T�CHATrD � TEXT_MESSAGE�
EMAIL_MESSAGEr? ) r r` r ra rh ri r7 rj r: rk rl r2 rm r r6 r rr r rs r ry r{ r| r} r8 � traceback�
format_excr
�creater r ) ri r r� �ityperg r� �lead_idr� r> �chatr� �messager? r? r@ � save_lead� s� &
���
���
���
���r� �adminc
C s d} d}d}t j�t jtjk��� }|st j�d�}d}t� � }|�rt
|�dd��}|�dd �}|�d
d�}t t � �} |�d d�}
|�d g �} |�d
i �} ddg d�ddiddd�ddd�ddd�gd�}
|
�
| � |jr�|j�dd �}d �dd � |D ��}tj�tj|jk��� d }|d kr�t |�}nd �|�}d d � | D �}||� |� d!�|j| |||
|tjd"� }t�||
�\}}|r�|j}tj�tjtjk��� }|s�tj�d�}tjd#d$tj� dtj� �|j� d%�d&�}t d-i |��}nd'|� �} d(}d}nd)} d*}d}t d+|i|| |d,�S ).ap Create omnichannel widget
Args:
name (str): widget name
description (str): widget description
type (str): widget type. Values: widget/adf
enabled (bool): widget enabled or not. Default: True
phonenumber_id (str): Phone number sid related to widget (optional)
options (json): widget configuration
channels (list): channel's sid
Returns (json):
data (json/None): contains widget guid if success else none
message (str): success or failure message
status_code (int): http status code
success (bool): Whether API was success
zWidget created successfullyTr0 r Nrm z
New widget� descriptionrD �enabled�phonenumber_id�channels�optionsF)�H �Z � rN r� r� z SEND CALL)rN �leadSubmitButtonName�EMAILz
SEND EMAILr� z
START CHAT)�enableNotifications�showPoweredBCIcon�widgetThemeColorr� rE c s s � | ] }|� � r|V qd S �N)�isalnum)�.0r> r? r? r@ � <genexpr>= s � z create_widget.<locals>.<genexpr>r z0{}c S � g | ]}t �|��qS r? )r � get_by_id�r� ry r? r? r@ �
<listcomp>H � z!create_widget.<locals>.<listcomp>z@inbound.buyercall.com) r� �emailrq ri rm r� r� r� �
created_by�NEW_WIDGET_CREATEDrS rT rU z Widget creation failed. Error: i� z Partnership account id is empty.i� � widget_id)� status_coder� r\ r? ) r ra rh rr r rq rj r6 r r` r r7 r �updaterm �replacere r �countrl �
api_createri r rs ry r{ r| r} r r )r� r\ r� rf r� �received� widget_name� widget_desc�widget_enabled� widget_guid�widget_phonenumber� channel_sidsr� �widget_options�company_before_format�company_after_format� widget_count�widget_count_stringr� �paramsr� r2 rg r� r� r? r? r@ �
create_widget� s�
��
������
��
�
�
r� c C s0 t j�t jt| �k��� }tt� �|�ddd�S )Nr0 �Widget fetch successfullyT) r ra rh ri r7 rj r r �dump)ri r� r? r? r@ �
get_widgetr s r� c C sd t j�dd �} | rt�| �}ntjpd}tj�tj dktj|k��
� }t dd�� |�}t
|ddd�S )N�unallocated_typer T��manyr0 z Widgets fetched successfully)r �argsr6 r �get_unallocated_typer rq ra rh �
is_options_v3�allr r� r )r� �widgetsrq �
response_listr? r? r@ �get_all_widgetsx s
��r� c C sF t jpd} tj�tjdktj| k��� }tdd��|�}t |ddd�S )Nr FTr� r0 r� )
r rq r ra rh r� r� r r� r )rq r� r� r? r? r@ �get_all_widget_v2� s
��r� c C s� t j�t jt| �k��� }t�� }|r�|r�|�d|j �}|�dd�}|�dd�}|�dd�}|�dd�}|�di �}|�dd �} |�d
g �}
d d � |
D �}
t
� |�} ||_ | |_ t
j|_|r`|n|j|_||_|rk|n|j |_ | rs| n|j|_|j} t| fi |��}
|
|_|
r�d
d � |
D �|_ng |_|�� t
�� }t
jddt| �gt
j� dt
j� �t| �g|j� d�d�}t di |��}t d|jiddd �S t ddiddd �S )z
Update widgetrm rN Nr� r� r� r� �isActiveTr� c S s g | ]}|d �qS )�valuer? )r� �csidr? r? r@ r� � s z!update_widget.<locals>.<listcomp>c S r� r? )r �
get_by_sidr� r? r? r@ r� � r� �
WIDGET_EDITEDrS rE rT rU r� r0 r1 r? ) r ra rh ri r7 rj r r` r6 rm r �get_id_from_sidr� r rr �
updated_byrN r� �
inbound_idr� �dictr� �save�get_partnershipry r{ r| r} r r )ri r� r� � result_name� result_typer� �result_enabled�result_phonenumber�result_options� is_activer� � phonenumber�existing_options� new_optionsrg r� r� r? r? r@ �
update_widget� sJ
�r� c C s� | r�t j�t jt| �k��� }t�� }|r=d|v r |d dv s=d|v r)|d dv s=d|v r3|d dv s=d|v rD|d dv rDti ddd�S t �
|� d�|� d��}|rvd }|j |� dd
�krd|� dd
�|_
|jsn|� dd �|_d |_|�� n d}|d |d |d |d |jd d
d�}t jdi |��}ddlm} |�d�}|� dd �|� dd �|� d�|j|jd d|j|j|d�
}tjdi |��} |j|j| jd�}
tjdi |
��} |� �d|||||j� ti ddd �S tg ddd�S )z3 Send email using the data getting from the widget rB rC r� rF r� rI r� FTNrD �newr� �r{ r| �
phonenumber_1r� rq r� �
bdc_statusr ��InteractionManagerr� )
�
first_name� last_namer� �source�channel�
is_inbound�
is_forward�
contact_idrq � meta_data)�contact�
channel_idr� r0 zMail sent successfully!r? )r ra rh ri r7 rj r r` r r �findr6 r� �
phonenumber_2r| r� r� rq r� �6buyercall.blueprints.widgets.utils.interaction_managerr� �get_channel_by_typer� rr r# r �run) �
widget_sidr� r� r �is_existing_contactr� r� r� � email_params� email_object� cc_params�contact_channelr? r? r@ �send_lead_mail� sf
�
� ��r c
C sL d}d}d}t �� }tj�tjt| �k��� }|�r t� d�
|�� |r.d|v r.|d dv sLd|v r8|d dv sLd|v rB|d dv sLd |v rf|d dv rft� d
t|j � d t|j� d � t
g d
dd�S t�|�d �|�d��}|r�d}|j|�dd �kr�|�dd �|_|js�|�dd�|_d|_|�� n d}|d |d |d |d |jddd�}tjd i |��}td|� ddlm} |�d�}
|s�|�dd�|�dd�|d |d |
j |
j |j |j |jd� } t jd i | ��} |j |
j | j d�}
t jd i |
��}| � � d||
|||j�}|j!|j |j"|j�p|j|d�}t
||d�S t
g d
dd�S ) NzChat started successfully!r0 Tr� rB rC r� rF r� r� rG rH rI r� FrD r� r� r� zis_existing_contact : r r� r� ) r� r� r� � phone_numberr� r� r� r� rq )r r r� )r� rm r� r �assigned_agent_id)�datar� r? )#r r` r ra rh ri r7 rj r: rk rl r2 rm r r r r6 r� r r| r� r� rq r� r9 r r� r r� rr r
r r ry r� )r r� r� r\ r� r� r r r� r� r� � chat_params� chat_objectr r
�assigned_agents_idsr r? r? r@ �
start_chat s~ &
�
� �� � r r� )C�loggingr: r� �uuidr r3 �flaskr r r �
flask_corsr � flask_loginr �"buyercall.blueprints.agents.modelsr �$buyercall.blueprints.channels.modelsr � buyercall.blueprints.chat.modelsr
�$buyercall.blueprints.contacts.modelsr r r~ r r_ r r �(buyercall.blueprints.phonenumbers.modelsr � buyercall.blueprints.sms.modelsr �$buyercall.blueprints.user.decoratorsr �%buyercall.blueprints.widgets.rest_apir �(buyercall.blueprints.widgets.serializersr �buyercall.lib.util_restr �buyercall.lib.util_twilior r �modelsr r �routingr r r r r! � email.modelsr# � getLogger�__name__�
widget_apirA r� r� r� r� r� r� r� r r r? r? r? r@ �<module> s\
]
^ v
1 O