File: //home/arjun/projects/buyercall/buyercall/blueprints/sources/__pycache__/endpoints.cpython-310.pyc
o
we�\ � @ s� d dl m Z d dlmZmZ d dlmZ d dlmZmZ d dl m
Z
d dl m Z d dl
mZ d dlmZmZ d d lmZ d d
lmZmZ d d lZd d lmZ d d
lm Z d dl m Z d dl m Z m!Z! d dl"m#Z# d dl$m%Z% d dl&m'Z' d dl(m)Z) d dl*m+Z+ d dl,m-Z- d dl.m/Z/ d dl0m1Z1m2Z2 d dl
m3Z3 ede4dd�Z5e�6e4�Z7e
d d �d d � �Z8e
d d �d d!� �Z9e
d �d"d#� �Z:e
d �d$d%� �Z;e
d �d&d'� �Z<e
d d �d(d)� �Z=e
d d �d*d+� �Z>d,d-� Z?d.d.d.d.i fd/d0�Z@G d1d2� d2e/e3�ZAd S )3� )�datetime)� Partnership�PartnershipAccount)�Source)� ChannelType�Channel)�api_role_required)�User)� api_jsonify)�and_�cast)� current_user)� Blueprint�requestN)�send_notifications)�db)�contact_exists)�Contact�ContactChannelTie)�Email)�Chat)�Message)�Lead)� send_request)� bw_client)�
MethodView)�SourceInSchema�SourceOutSchema)�BlueprintMixin�
sourcesapiz /api/sources)�
url_prefix�admin�partnerc
C sV t �� } d}d}d}i }| �r tj�tjtjk��� }|s#tj� d�}t
j�t t
jtj kt
j|jk���� }| � dd �| � dd �|j|rG|jnd | � di �tjd�}t
jd i |��}|�r|j|d < |j|d< |j|d< |j|d< t�|j�|d
< |j r�t
�|j �nd |d < t�|j�|d < |j r�t
�|j �nd |d
< |jp�d |d< |jp�d |d< d } d }
|jr�tj�tj|jk��� }
|jr�tj�tj|jk��� } |
r�|
j� d|
j� �nd |d< | r�| j� d| j� �nd |d< |
r�|
jnd |d< | r�| jnd |d< tjddtj� dtj� �|j � d�d�} t d i | ��} n
d}d}d}nd}d }d}t ||||�S ) NTzSource added successfully!�� � �name� description� workflows)r% r& �partnership_id�partnership_account_idr' �
created_by�idr( r) �partnershipName�partnershipAccountName� updatedAt� createdAt� � updatedBy� createdBy�updated_user_id�created_user_id�SOURCE_CREATED�You've�/partnership/sources��user_id�notify_message_type�user_related_entities�other_user_related_entities� hyperlinkzSource name already exists� F�Invalid parameters!� ) r �get_jsonr �query�filterr+ r
r( �first�getr r r) r �create�sidr% r& r' �get_sid_from_id�get_name�
updated_on�
created_on�
updated_byr r* � firstname�lastname� partner_urlr r
)
�received�success�message� status_code�data� partnership�partnership_account�params�source� created_user� updated_user�es_data� es_responser@ r@ �H/home/arjun/projects/buyercall/buyercall/blueprints/sources/endpoints.py�
create_source s� �
�
������
�r^ c
C sf d}d}d}i }t �� }|�r&| �r tj�tj| k��� }tj�tjt j
k��� }|s1tj� d�}|�r|� dd �}|� |��s||_
|� dd �|_|� di �|_|� dt j�|_|�� |j|d < |j
|d< |j|d< |j|d< |j|d
< |jrt�|j�nd |d < |j
|d < |jr�t�|j�nd |d
< |jp�d |d< |jp�d |d< d } d }
|jr�tj�tj|jk��� }
|jr�tj�tj|jk��� } |
r�|
j� d|
j� �nd |d< | r�| j� d| j� �nd |d< |
r�|
jnd |d< | r�| jnd |d< t jddt j� dt j� �|j � d�d�} t d i | ��} nd}d}d}nd }d }d}n
d}d }d}nd}d }d}t ||||�S ) NT� Source updated successfully!r# r$ r% r& r' rL r+ r( r) r, r- r. r/ r0 r1 r2 r3 r4 �
SOURCE_EDITEDr6 r7 r8 r> zSource name already exists!F� �Source not found!r? r@ ) r rA r rB rC rG rD r r+ r
r( rE �is_name_existsr% r& r' rL �saver) r rH rI rJ rK r r* rM rN rO r r
)
rG rQ rR rS rT rP rX rU �new_source_namerY rZ r[ r\ r@ r@ r] �
update_sourcec s�
���
���
�rf c
C s� d} d}d}g }t j�t jtjk��� }|s t j�d�}tj�tj|jktj tj k��
tj � � tj
� � �}|D ]�}i }|j|d< |j|d< |j|d< t �|j�|d< |j r[t�|j �nd |d < |jpcd |d
< |j rot�|j �nd |d < |j pwd |d < |j
p~d |d
< d }d } |jr�tj�tj|jk��� } |jr�tj�tj|jk��� }| r�| j� d| j� �nd |d< |r�|j� d|j� �nd |d< | r�| jnd |d< |r�|jnd |d< |�|� q7t|||| �S )NTz Sources fetched successfully!r# r$ r+ r% r& r( r) r, r- r. r/ r0 r1 r2 r3 r4 )r rB rC r+ r
r( rD rE r r) �order_byrJ �descrK rG r% r& rH r rI rL r r* rM rN �appendr
)
rQ rR rS rT rU �sourcesrX �_datarY rZ r@ r@ r] � get_sources� sV �
������ rl c C s� d}d}d}i }t j�t j| kt jtjk��� }|r�|j|d< |j|d< |j|d< t �
|j �|d< |jr:t �
|j�nd |d< t �
|j �|d < |jrOt �
|j�nd |d
< |jpWd |d < |jp^d |d < d }d }|jrttj�tj|jk��� }|jr�tj�tj|jk��� }|r�|j� d
|j� �nd |d< |r�|j� d
|j� �nd |d< |r�|jnd |d< |r�|jnd |d< nd}d}d}t||||�S )NTz Source fetched successfully!r# r+ r% r& r( r) r, r- r. r/ r0 r1 r2 r3 r4 ra rb F)r rB rC rG r) r
rD r% r& r rH r( r rI rJ rK rL r r+ r* rM rN r
)rG rQ rR rS rT rX rY rZ r@ r@ r] �get_source_by_id� sV ��
������ #rm c C �~ d}d}d}i }t �� }|r2| r2|�dd�}tj�tj| k��� }|r+||_|� � n
d}d}d}nd}d }d}t
||||�S )
NTr_ r# �activeFra rb r> r? ) r rA rE r rB rC rG rD � is_activerd r
)rG rQ rR rS rT rP ro rX r@ r@ r] �update_metadata �$
rq c C rn )
NTr_ r# r' Fra rb r> r? ) r rA rE r rB rC rG rD r' rd r
)rG rQ rR rS rT rP r' rX r@ r@ r] �update_workflows3 rr rs c C sP d}d}d}i }| r!t j�t j| k��� }|r|j}nd}d}d}t||||�S )NTz&Source workflows fetched successfully!r# ra rb F)r rB rC rG rD r' r
)rG rQ rR rS rT rX r@ r@ r] �
get_workflowsK s rt c
C s� t �� } d| v r| d dv s8d| v r| d dv s8d| v r"| d dv s8d| v r,| d dv s8d| vs8d| vs8d| vr?tg d d
d �S | �d�}| �d�}| �d �}tj�tjtj k��
� }t j�t j |k��
� }|smtj�d
�}t
j�t
jtjk��
� }|jdk�rMt| �dd�| �dd��}|s�t| �dd�| �dd�tjd�}tj�| �d�tjktjtjk��
� }|dur�|j} |j}
nd} d}
td1i dtj�d| �d��d| �d��d| �d��d| �d��d| �dd�dt�� �dd �d d �d d�d d�d!d�d"|
�d#d�d$d��} tj�| � tj�� t � } || _ | j| _ t � |�| _!| �"� | j t � |�|||j |j di d%�}
t#d&|
�}t$|j�}t%�&d'� td(| j id)d*d+�S |d,k�r{z
td-did)d*d+�W S t'�yq } zd}W Y d}~nd}~ww td.|id)d*d+�S |d/k�r�z
t(j)d1i | ��}W n t'�y� } zd}W Y d}~nd}~ww td.|id)d*d+�S |d0k�r�zW n t'�y� } zd}W Y d}~nd}~ww td.|id)d*d+�S dS )2r0 � firstName)� r0 �lastName� phoneNumber� emailAddress� channelType�sourceId� channelIdi� zMissing parametersF�
channelTypeIdr$ �CALLNrv )�
phonenumber_1�emailr) z no statusr) rM rN r� � phonenumber�progress_status�question� starttime� call_type�outbound�status�ringing�my_phone�additional_info� call_source�agent_assigned_id�originating_number�
inbound_id��lead_id� source_id� channelID�channel_Type_Idr( r) �agent_id�payload� /call-logzCalling Bandwidth number...�leadr# �SuccessT�CHAT�contact�leadId� TEXT_MESSAGE�EMAILr@ )*r rA r
rE r rB rC r+ r
r( rD r rG r r) r% r r r r� r� r� r �utcnowr �session�add�commitr r� �callr �get_id_from_sidrX rd r r �log�info� Exceptionr rF )�json�
channel_idr� �channel_type_idrU � channel_typerV r� �
previous_leadr� �agent_assignedr� �contact_channelr� �response�client�er� rR r@ r@ r] �interaction_to_user^ s�
��
����
�
�
�
���� �
� � �
����
�
��
��
��r� rv c
C s� |dkrPt j�t j| k��� }tj�tj|k��� }tj�tjt j
p#dk��� }t j�t jt j p1dk��� }|jt
�|�||j|j|jt ji d�}td|�}dS |dkrjd} | jt
�|�||jt ji d�}td|�}dS ) Nr~ r$ r� r� r� rv )r� r� r� r� r� r� T)r rB rC rG rD r r% r r+ r
r( r r) r r� r )
r� r� r� r� r� r� rU rV r� r� r@ r@ r] �interaction_to_lead� s> �� �
��
r� c @ sR e Zd Zdeieed�eed�eed�d�Zdg iZd dd�Zdd � Zd
d � Z dS )
� SourceApi�out)�inr� )rE �post�put�patchrE Nc C sT |st j�� }| jdddd�}nt j�t j|k��� }| jdd�}t|�|�dd�S )NTr� )rG r% )�many�key�only�r� z Source(s) fetched successfully.)rT rR ) r rB �all�get_serializer_classrC rG rD r
�dump)�selfr� �queryset�
serializerr@ r@ r] rE s
z
SourceApi.getc C sz | j dd�}|�t�� �}tj|d< tj|d< t�|� dd��s/tj
di |�� d}d}d }nd
}d }d }t g |||d
�S )Nr� r� r( r) r% rv z Source created successfully.i. T�Source name already exists.� F)rT rR rS rQ r@ ) r� �loadr rA r
r( r) r � get_by_namerE rF r
)r� r� rT rR rS rQ r@ r@ r] r� ! s
zSourceApi.postc C sz | j dd�}|�t�� �}t�|�dd��s&tj|fi |��}d}d}d}nd}d }d
}| j d d�}t|� |�|||d �S )
Nr� r� r% rv z Source updated successfully.r# Tr� r� Fr� )rT rS rR rQ )
r� r� r rA r r� rE �updater
r� ) r� r� �
serializer_inrT rX rR rS rQ �serializer_outr@ r@ r] r� 4 s z
SourceApi.put)N)
�__name__�
__module__� __qualname__r r � serializers�permission_classesrE r� r� r@ r@ r@ r] r� s$ ������
r� )Br �'buyercall.blueprints.partnership.modelsr r �#buyercall.blueprints.sources.modelsr �$buyercall.blueprints.channels.modelsr r �$buyercall.blueprints.user.decoratorsr � buyercall.blueprints.user.modelsr �buyercall.lib.util_restr
�
sqlalchemyr r � flask_loginr
�flaskr r �loggingr� �+buyercall.blueprints.notification.utilitiesr �buyercall.extensionsr �#buyercall.blueprints.contacts.viewsr �$buyercall.blueprints.contacts.modelsr r �!buyercall.blueprints.email.modelsr � buyercall.blueprints.chat.modelsr � buyercall.blueprints.sms.modelsr �!buyercall.blueprints.leads.modelsr �buyercall.lib.util_requestsr �buyercall.lib.util_twilior � flask.viewsr �(buyercall.blueprints.sources.serializersr r r r� � sources_api� getLogger�loggerr^ rf rl rm rq rs rt r� r� r� r@ r@ r@ r] �<module> sV
D
F
(
G
r0