File: //home/arjun/projects/buyercall/buyercall/blueprints/widgets/__pycache__/rest_api.cpython-310.pyc
o
�we�Q � @ s: d dl Z d dlmZ d dlZd dlZd dlZd dlZd dlm m
Z d dl m
Z
mZmZmZmZ d dlmZ d dlmZmZ d dlmZmZ d dlmZ d dl m Z d d l m Z d d
l m!Z! d d l"m#Z#m$Z$ d d l%m&Z&m'Z' d d
l(m)Z) d dl*m+Z+ d dl,m-Z-m.Z. ddl/m0Z0m1Z1m2Z2 ddl3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9 d dl:m;Z; d dl<m=Z= d dl>m?Z? d dl@mAZA d dlBmCZC edeDdd�ZEdZFdOd d �ZGeEjHd d gd!�ed"d#� ��ZIeEjHd d$gd!�ed%d&� ��ZJeEjHd'd$gd!�ed(d)� ��ZKeEjHd*d$gd!�ed+d,� ��ZLeEjHd-d$d.gd!�ed/d0� ��ZMeEjHd1d gd!�ed2d3� ��ZNeEjHd1d4gd!�ed5d6� ��ZOeEjHd7d gd!�ee;d8d9� ���ZPeEjHd:d gd!�e� d;d<� ��ZQeEjHd=d$gd!�e'jRe� d>d?� ���ZSeEjHd@d$gd!�e'jRe� dAdB� ���ZTeEjHdCd gd!�e'jRe� dDdE� ���ZUdFdG� ZVeEjHdHd gd!�e-dIdJ� ��ZWdKdL� ZXdMdN� ZYdS )P� N)�uuid4)�request�jsonify�
make_response� Blueprint� current_app)� cross_origin)� current_user�login_required)�and_�or_)�IntegrityError)� load_only)�
NoResultFound)�text)�func�case)�db�csrf)�subaccount_client)� bw_client)� rest_method�rest_partnership_account� )�Widget�AgentAssignment�User)�BandwidthRouting�Routing�add_widget_lead�phonecall_inprogress�NoAgentsException�after_call_events)�subscription_required)�Phone)�Lead)�Agent)� Subscription� widgets_api� templates)�template_folderi�Q �� c C s t t| d�|�S )z9 Build an Ajax response with the given message and code. )�error)r r )�message�
error_code� r/ �G/home/arjun/projects/buyercall/buyercall/blueprints/widgets/rest_api.py�
json_error- s r1 z
/api/outbound�GET)�methodsc C s� t j�dd�} tt j�dd��}t j�dd�}tt j�dd��}tt j�d d
��}|d kr/d
}tj}tjr8tj}g d �}tj �
t d
dddd��� tj|k�}t
j � t
j|k��t
jt�d��d���t
j��� }|} | rzd�| �}
|� tj�|
��} | �|tj|jjkf��tjtjt |jj � d�dfg|jj d��d�tj tj tj!�} | } |t"t#|��v r�d�|| |�} | �$t%| ��} | �&|��'|�} dd� | �(� D �}
tj)}|
D ]}|r�t*|j+�|d< q�d|d< q�t,t jd | �-� |�-� |
d �S ) z5
Retrieves all widgets for the current user.
z
search[value]� zorder[0][column]�-1z
order[0][dir]�asc�startr �length�c ���)�id�name�
lead_count�
created_on�
updated_on�enabledr; r< r> r? r@ r r= z%{}%N��else_�{} {}c s& g | ]� � fd d�t t� ��D ��qS )c s i | ]}|� | �qS r/ r/ )�.0�i��rowr/ r0 �
<dictcomp>q s z*get_widgets.<locals>.<listcomp>.<dictcomp>)�range�len)rD r/ rF r0 �
<listcomp>p s �z get_widgets.<locals>.<listcomp>� F�draw)rM �recordsFiltered� recordsTotal�data).r �args�get�intr �partnership_account_id�is_viewing_partnership�'get_user_viewing_partnership_account_idr �query�optionsr �filterr% �
with_entities� widget_guidr �sum�label�group_by�subquery�formatr< �ilike� outerjoin�guid�cr; r r= �is_r> r? r@ rI rJ �order_byr �offset�limit�all� subscription�bool�usage_over_limitr �count)�search�order� directionrg rh rT �columns�total�leads�filtered�pattern�sorted_�
order_predrP rj rG r/ r/ r0 � get_widgets2 s� ����� �
�����
�rx �POSTc
C s t t� �} t�� }t|d �|d< | |d< tj}tjr tj}t j
� t j|k�� � }|j
�dd�}d�dd� |D ��}tj
� tj|k��� d }|dkrPt |�}nd �|�}td
�||�|| |d |d �}tj�|� tj
� tj|d ktj|k�� � } | r�| |_tj�� t|j|jd
�S )z^
Creates a new widget.
Returns the ID of the newly created database row, as JSON.
r< rc � r4 c s s � | ] }|� � r|V qd S �N)�isalnum)rD �er/ r/ r0 � <genexpr>� s � z add_widget.<locals>.<genexpr>r r z0{}z{}{}@inbound.buyercall.com)�emailrT rc r< rX � fromNumberId�r; r< ) �strr r �get_json�fix_namer rT rU rV r rW rY �first�company�replace�joinr rm r` r �session�addr$ r; �inbound�commitr r< )
rc rX rT � user_object�company_before_format�company_after_format� widget_count�widget_count_string�widget�phoner/ r/ r0 �
add_widget� sN
����
� ��
r� z /api/outbound/disable/<int:id_>c C �P t j}t jr t j}tj�tdd���tj | ktj|k��
� }d|_ t j
�� dS )Nr; r@ Fr4 �r rT rU rV r rW rX r rY r; r� r@ r r� r� ��id_rT r� r/ r/ r0 �disable_widget� � ��
r� z /api/outbound/enable/<int:id_>c C r� )Nr; r@ Tr4 r� r� r/ r/ r0 �
enable_widget� r� r� z /api/outbound/delete/<int:id_>�DELETEc C sT t j}t jr t j}tj�td���tj | ktj|k��
� }t j �
|� t j �� dS )Nr; r4 )r rT rU rV r rW rX r rY r; r� r r� �deleter� r� r/ r/ r0 �
delete_widget� s ��
r� z/api/outbound/<int:id>c C s� z8t j}t jr
t j}tj�ttj| ktj|k��� � }|j
|j d< |j |j d< |j|j d< |j
|j d< t|j �W S tyF tdd� Y S w )z. Retrieves a single widget with the given ID. r< rc r; r� zWidget not found.� )r rT rU rV r rW rY r r; �oner< rX rc �
inbound_idr r r )r; rT r� r/ r/ r0 �
get_widget� s" �� �r� �PUTc C s� t �� }tj}tjr
tj}tj�t tj
| ktj|k��� � }|d |_ ||_
tj�tj
|d ktj|k��� }|r=||_nd\|_|_tj�� t|j
|j d�S )z% Changes a widget with the given id. r< r� )NNr� )r r� r rT rU rV r rW rY r r; r� r< rX r$ r� r� r� r r� r� r )r; �jsonrT r� r� r/ r/ r0 �
change_widget s* ��
��
r� z/api/outbound/phonenumbersc C sd t j} t jr t j} tj�tjtj tj
tj �� tj| ktj �
d�tj�d���� }tdd� |D �d�S )zc Retrieves the list of all phone numbers which the user is entitled to use
in his widgets.
)�tracking�priorityFc S s* g | ]}|d |d |d |d d��qS )r r � � )r; �type�number�
friendly_namer/ )rD �nr/ r/ r0 rK 4 s �z phonenumbers.<locals>.<listcomp>)rP )r rT rU rV r r� rW r$ r; r� � phonenumberr� rY �in_�is_deactivatedre ri r )rT �resultr/ r/ r0 � phonenumbers s
��
�r� z /api/outbound/settings/<guid>c C s� zYddl m} tj�tj��|j�jtjj� � tj
| k�� � }|j s%W dS |jj
}|s0|jjj
}|jr?t�d�|j�� W dS t|j�}|j|d< dD ] }||v rT||= qKt|�W S tyg tdd � Y S w )
zA Called by the deployed widget to retrieve display settings.
r ��PartnershipAccount)zWidget disabled.i� z5Available minutes exceeded for partnership_account {})zAvailable minutes exceeded.i� �agentsAvailable)
�agents�scheduleTimezone�days�
availableFrom� availableTo� recordCalls� retryRouting�routeInSequence�
routeRandomly�routeSimultaneously� voicemail�voicemailMessage�whisperMessagez,Widget not found, or has no agents assigned.r� )�'buyercall.blueprints.partnership.modelsr� r rW r� �partnership_account� partnershipr� �attrrY rc r� r@ rj rl �log�infor` rT �dictrX �agents_availabler r r )rc r� r� rj r� �keyr/ r/ r0 � get_settings9 sH �����
�
��r� z /api/callc C sp ddl m} tj�d�}t�� }|r2tj�t tj
f��t t j f��
tj��
| j��tj|k��� }n
t�d� tdd�S t�d�|�� |du�r3z+|rVd |v rV|d d
v s`d |v rs|d d
v rst�d t|j� d
t|j� d � W n t�d t|j� d
t|j� d � tdd� Y S |jj}|s�|jjj}|jr�t� d�|j �� tdd�S zkt |fi |��}|r�tdd�W S t |fi |��}ddl m }m} | j�| j!|j k��� }|j�|j!|j"k��� } |j#j$dk�rt%| j!d�}
t�d� t&|
��'||� nt�d� |j(} t)| | j!�}
t*|
��'||� W n t+�y+ tdd|j!d� Y S w td|j!d�S tdd�S )z� The endpoint that gets called when the lead presses 'Talk!' on the
widget.
Receives the widget GUID as a query string parameter, and the user's data
in the JSON body.
r r� rc �No guid providedF��successz#The call widget json request is: {}N� firstName�r4 rz � phoneNumberz(No lead fields provided for call widget � - �.z0partnership_account {} has exceeded their quota.T)� Partnershipr� r� �voicezCalling Bandwidth number...zCalling Twilio number...�
ERR_NO_AGENTS)r� �code�lead_id)r� �callId),r� r� r rQ rR r� r rW rb r � assignmentsr& �agentr� r� r� rY rc r� r� r, r r� r` r� r< rj rl �warningrT r r r� r; �partnership_idr� r� r r � call_lead�twilio_subaccount_sidr r r! ) r� rc r� r� rj � lead_on_call�leadr� �partner_account�partner�client�subaccount_sidr/ r/ r0 �callh sp
�� �
&�&
�
�
��
r� z/api/save_leadc
C s� t j�d�} t �� }| rtj�tj| k��� }n
t �
d� t dd�S t � d�
|�� |dur�z?|r;d|v r;|d dv sYd |v rE|d dv sYd
|v rO|d
dv sYd |v rl|d dv rlt �
d t|j� d
t|j� d � W n t �
d t|j� d
t|j� d � t dd� Y S t|fddi|��}zt||� W n ty� } z
t �
t�� � W Y d}~nd}~ww t dd�S t dd�S )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.
rc r� Fr� z/The after hours call widget json request is: {}Nr� r� �lastNamer� � emailAddressz#No lead fields provided for widget r� r� �status�missedT)r rQ rR r� r rW rY rc r� r� r, r r� r` r� r< r r" � Exception� traceback�
format_exc)rc r� r� r� r} r/ r/ r0 � save_lead� s6
&�&��
r� z /api/call_status/<int:lead_id>c
C s� t jtjd tjd dd�}z |�d�| ��}|dkr!tdd�W S |dkr,td dd
�W S W n tyD } z t� d � W Y d }~nd }~ww td d�S ) N�REDIS_CONFIG_URL�REDIS_CONFIG_PORTT)�host�port�decode_responsesz CONNECT{}�1)� callConnectr5 F)r� r, z2Cannot retrieve lead status - is Redis accessible?)
�redis� StrictRedisr �configrR r` r r� r� r, )r� �redis_db�connectr} r/ r/ r0 � call_status� s" � ���
r� c sz � fdd�}� � dd�� dd�� dd�}tj�ttj�|d ����� }td d
� |D ��}|� D ]
}||vr:| S q0d S ) zp Queries the database for all names starting with `old_name` and ensures
no name clash is taking place.
c 3 s* � � V t �d�D ] } d�� | �V q d S )Nr� rC )� itertoolsrm r` )rE ��old_namer/ r0 �name_generator� s
��z fix_name.<locals>.name_generator�\z\\�%z\%�_z\_c s s � | ]}|j V qd S r{ )r< )rD r� r/ r/ r0 r~ s � zfix_name.<locals>.<genexpr>N) r� r rW rY r r< �likeri �set)r� r � escaped_name�same_name_widgets�db_namesr< r/ r� r0 r� � s ���
��r� z/api/v1/outboundc C s t j�t jtjk��t jt� d��
d��� t j�� � } t
j�tddddd���t
jtjk��| t
j| jjkf��t
jt
jt| jj�d�d fg| jjd
��
d�t
jt
jt
j��� }g }|D ]}|�t |j|j|j|j|j|jd �� q\t t |d ��}d
|j d< |S )zV
External REST API endpoint.
Retrieves all widgets for the current user.
r r= r; r< r> r? r@ Nr rA )r; r� r= r> r? r@ )�outboundzno-cachez
Cache-Control) r% rW rY rT r r; rZ r[ r r\ r] r^ r_ r rX r rb rc rd r< r r= re r> r? r@ ri �appendr� r r �headers)rs � all_outboundrP �o�responser/ r/ r0 � get_outbound sZ
�� ��
����
�
�
r c C s� t jtjd tjd d�}d| }|�dt| � dt |� |�dt| � dt |� |�dt| � dt |� |�d t| � dt |� d
S ) z� Sets a custom message to be used as the whisper message. The custom message will mostly be used for setting
vehicle details. The remaining fields that are set are specifically for the notification mail.
r� r� �r� r� z" . . Vehicle information is . . . zCUSTOM_LEAD_MESSAGE:r� zCUSTOM_LEAD_YEAR:zCUSTOM_LEAD_MAKE:zCUSTOM_LEAD_MODEL:N�r� r� r r� �setexr� �DAYS)r� �vehicle_details� vehicle_year� vehicle_make�
vehicle_modelr� r/ r/ r0 �set_custom_agent_lead_textF s � r c C s8 t jtjd tjd d�}|�dt| � dt |� dS )zH Saves the xml content in memory to be forwarded to CRM if need be.
r� r� r zCUSTOM_LEAD_XML:r� Nr )r� �
email_textr� r/ r/ r0 � set_lead_xmlU s � r )r+ )Zr� �uuidr �loggingr� r� �sysr� �xml.etree.ElementTree�etree� ElementTree�et�flaskr r r r r �
flask_corsr � flask_loginr r
�
sqlalchemyr r �sqlalchemy.excr
�sqlalchemy.ormr �sqlalchemy.orm.excr �sqlalchemy.sqlr �sqlalchemy.sql.expressionr r �buyercall.extensionsr r �buyercall.lib.util_twilior � buyercall.lib.util_bandwidthr �buyercall.lib.util_restr r �modelsr r r �routingr r r r r! r" �'buyercall.blueprints.billing.decoratorsr# �(buyercall.blueprints.phonenumbers.modelsr$ �!buyercall.blueprints.leads.modelsr% �"buyercall.blueprints.agents.modelsr& �0buyercall.blueprints.billing.models.subscriptionr' �__name__r( r r1 �routerx r� r� r� r� r� r� r� r� �exemptr� r� r� r� r r r r/ r/ r/ r0 �<module> s�
M 4 -I+ /