File: //home/arjun/projects/buyercall/buyercall/blueprints/channels/__pycache__/endpoints.cpython-310.pyc
o
we}P � @ s� d dl Zd dlmZ d dlmZmZmZ d dlm Z d dl
m Z d dl m
Z
d dlmZmZ d dlmZmZmZ d d lmZ 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) d dl(m*Z* ede+dd�Z,e�-e+�Z.G dd� de e)�Z/e!dd�dd � �Z0e!dd�d d � �Z1e!dd�d d � �Z2e!dd�d!d"� �Z3e!dd�d#d$� �Z4e!dd�d%d&� �Z5e!dd�d'd(� �Z6e!dd�d)d*� �Z7dS )+� N)� parseaddr)� Blueprint�request� current_app)�
MethodView)� current_user)�func)�Channel� ChannelType)�ChannelOutMiniSchema�ChannelTypeInSchema�ChannelTypeOutSchema)�
EmailIdentity)�AddEmailIdentity)� Partnership�PartnershipAccount)�Phone)�Source)�api_role_required)�User)�Widget)�
ses_client)�BlueprintMixin)� api_jsonify� channelsapiz
/api/channels)�
url_prefixc @ sR e Zd Zdeieed�eed�eed�d�Zdg iZd dd�Zdd � Zd
d � Z dS )
�ChannelTypeApi�out)�inr )�get�post�put�patchr Nc C sZ |st j�� }| jddd�}d}nt j�t j|k��� }| jdd�}d}t|�|�|d�S )NTr )�many�keyz#Channel types fetched successfully.�r$ z"Channel type fetched successfully.)�data�message) r
�query�all�get_serializer_class�filter�sid�firstr �dump)�self�channel_type_id�queryset�
serializerr' � r3 �I/home/arjun/projects/buyercall/buyercall/blueprints/channels/endpoints.pyr 1 s
zChannelTypeApi.getc C s@ | j dd�}|�t�� �}tjdi |�� d}d}tg ||d�S )Nr r% z"Channel type created successfully.i. )r& r' � status_coder3 )r* �loadr �get_jsonr
�creater )r/ r2 r& r' r5 r3 r3 r4 r = s zChannelTypeApi.postc C s� | j dd�}|�t�� �}t�|�}|jd ddi|��}|r0d}| j dd�}|�|�}d} d}
nd}i }d } d
}
t||| |
d �S )
Nr r% �
return_objectTz"Channel type updated successfully.r �� z Channel type update failure.�� F)r& r' r5 �successr3 ) r* r6 r r7 r
�
get_by_sidr! r. r ) r/ r0 �
serializer_inr& � channel_type�
updated_ctyper' �serializer_out�responser5 r< r3 r3 r4 r! E s
zChannelTypeApi.put)N)
�__name__�
__module__� __qualname__r
r � serializers�permission_classesr r r! r3 r3 r3 r4 r s$ ������
r �admin�partnerc C s� t j�t jtjk��� }|st j�d�}|j}t j
�dd �}|r/t j
�dd�r/| � d|� �}n| � d|� �}dt |�d v }t �
� }|rO||d vrOd}d}n |sTd }nd
}d}t|d |id �S )
N� �TEST_SERVER_DOMAIN�DEBUGF�@r& TzEmail address is validzInvalid email formatzEmail already exists�isValid)r' r& )r r( r+ �idr �partnership_idr- r � partner_urlr �configr r �list_email_identitiesr ) � email_prefix� partnershiprQ �test_server_domain�
email_address�is_valid�email_identites�is_email_validr' r3 r3 r4 rZ X s$ rZ c
C s t j�t j| k��� }i }|r�t�|j�}|j|d< |j|d< |j |d< t
� |j �}t
� |j
�}|r;|j� d|j� �nd |d< |rJ|j� d|j� �nd |d< |rS|jnd |d< |r\|jnd |d< |jrit�|j�nd |d < |jrvt�|j�nd |d
< |jr�t�|j�nd |d < |jr�t�|j�nd |d < |jr�t�|j�nd |d
< |j|d< |j|d< g }|jD ]}|�|j � q�||d< |dkr�t � |j �}|r�|j r�dnd|d< |j r�|j nd |d< |j|d< n|dkr�t!� |j �} | r�| j"|d< | j#|d< d}
d} d } nd }
d } d } t$||
| | d �S )!NrO �
updated_at�
created_at� �
created_by�
updated_by�created_by_agent_id�updated_by_agent_idrP �partnership_account_id�partnershipName�partnershipAccountname�sourceId�name� description�widget� phone-number�Local� Toll Free�
numberType�provisionedPhoneNumber�provisionedPhoneNumberId�email�
partnerDomain� emailprefixz Channel fetched successfully r: TzChannel does not existr; F�r' r5 r< )%r r( r+ r, r- r
�get_name_by_id�type�
updated_on�
created_onr � get_by_idr^ r_ � firstname�lastnamerP r �get_sid_from_idrb r �get_name�sourcer rf rg �widgets�append�guidr �
related_id�local� phonenumberr �domain�usernamer )
�cid�channel�_chr? r^ r_ �_widgets�widg�_phone�_emailr' r5 r< r3 r3 r4 �get_channel_by_id� sj
������
�
r� c C s t �� }tj�tj| k��� }|r�d}d}d}tj�|j �}g }d|�
� v r2|�dd �}|r0dnd}d|�
� v rc|�dg �} t | t �sF| g} | rc|rc|rc| D ]}
t
j�t
j|
k��� } | rb|�| � qNd|�
� v rxt�|�dd ��} | rvdnd}|r�|r�|r�|�dd �}|�dd �}
|�dd �}|�dd �}|�dd �}|r�||_|
r�|
|_|r�||_|r�d|v r�|n|j|_tj|_||_|r�t�|�d��} | r�| |_|�� d }t |d
�S d }d }|s�d }|s�|r�d
|� �nd}|s�|r�d|� �nd}d}d}nd}d}d}t |||d�S )NTrf Frh r| rg �content� is_activez Channel updated successfully)r' � zChannel name cannot be nullz Channel type cannot be null, zChannel type cannot be nullzSource does not exist, zSource does not exist� zChannel not found� rr ) r r7 r r( r+ r, r- r
r rt �keys�
isinstance�listr r r~ r �get_id_from_sidrf rg r� r� r rO r_ r} r| �saver )r� �receivedr� � name_status� type_status�
source_statusr? �filtered_widgetsrf �
widget_ids� widget_idrh � source_idrg r� r� r| r' �keywordr5 r< r3 r3 r4 �update_channel� sz
�
r� c C sL d}d}d}z�| rMz-t �| �}|r/tjpd}tj�tj|ktj|jk�� tj
� � tj � � �}nd}d}d}W n t
yL } z
t|� W Y d }~nd }~ww g }|D ]�} t�| j�}
t�| j�} | j| j
| j |
rp|
j� d|
j� �nd | r|| j� d| j� �nd |
r�|
jnd | r�| jnd | jr�t�| j�nd | jr�t�| j�nd | jr�t�| j�nd | jr�t�| j�nd | jr�t �| j�nd | j | j d �} | d
kr�t �| j �}
|
r�|
j!r�d nd | d
< |
j"r�|
j"nd | d< |
j| d< n| dkr�t#�| j �}|r�|j$| d< |j%| d< |�&| � qQW n t
�y } z g }t|� W Y d }~nd }~ww t'||||d�S )NTz Channels fetched successfully!r: rJ FzInvalid channel typer� r] )rO r[ r\ r^ r_ r` ra rP rb rc rd re rf rg ri rj rk rl rm rn ro rp rq �r' r< r5 )(r
� get_by_namer rb r r( r+ rt rO �order_byru �descrv � Exception�printr rw r^ r_ r, rx ry rP r rz r r{ r| r rf rg r r� r� r� r r� r� r~ r )r? r< r' r5 �
_channel_typerb �channels�e�
channels_listr� r^ r_ r� r� r� r3 r3 r4 �get_channels_by_type4 s�
������ �������
�
� ��r� c
C s� d} t jpd}g }ztj�tj|k��� }tdd�}W n ty: } zt|� t t
|�ddd�W Y d }~S d }~ww t |� |�| �S )Nz&Account channels fetched successfully!rJ T�r# r; Frr ) r rb r r( r+ r) r r� r� r �strr. )r' rb r2 r� r� r3 r3 r4 � get_channelso s
�� ��r� c C s4 d} d}d}t j�� }tdd�}t|�|�||| �S )NTz#Channel types fetched successfully!r: r� )r
r( r) r
r r. )r< r' r5 r1 r2 r3 r3 r4 �get_channel_types s
r� c
C s� d} d}d}i }z1t j�t j��tjt�t j ���
t j t j kt j
t j
k��tj��� }|D ]
}|d ||d < q-W n tyS } zd} t|�}d}W Y d }~nd }~ww t||| |d�S ) NTz*Channel meta details fetched successfully!r: rJ r Fr; r� )r r( �joinr? �
with_entitiesr
rf r �countrt r+ rP r rb �group_byr) r� r� r )r< r' r5 r& r� r� r� r3 r3 r4 �get_channel_type_count� s.
� ����r� c
C s~ t �� } | �dd �}| �dd �}| �dd �}t�|�}t�| �dd ��}d }g }|D ]'}|r7|r7t�|j |�nd}|rFt
j � t
j
|k��� nd } | rQ|sQ|�| � q*|r�|r�|r�d }
|dkr�| �dd�} | r�tj � tj tjk��� } | sztj �d �} t� �| | �}
|
�d
d �r�tj�d d �r�tj�d d�r�tj�d d �}n| j}| |tjp�d tjp�d d
�}tjd"i |��}
n ti dd|
�dd�d�S || �dd�|j | �di �|tjp�d tjp�d tj |d� }|
r�|
j |d< tjd"i |�� d}d}d}nCd}d}d}d}|�sd}|�s|�r d|� �nd}|�s|�r|� d �nd }|�r#|� d �}|�r7|�r1|� d |� d �nd!|� d �}ti |||d�S )#Nrf rt rh r| Fro � emailPrefixr� rJ �statusrK rL )r� r� rb rP r; r' )r5 r< r' rg r� ) rf rg rt r� r| rP rb r^ r} r� r: TzChannel added successfully.r� z Channel typezChannel name, z Channel namez and Sourcer z is requiredz. Widget with the z channel type already exists.zWidget with the r3 ) r r7 r r
r� r r� r � is_widget_channel_type_existrO r r( r+ r r- r~ r r rP r �addr rR rQ rb r r8 r )r� rf � type_namer� �type_r� r� r� r� rh r� r� rU �respr� �
email_datar& r5 r< r' r� r3 r3 r4 �create_channels� sz
� �
�
"r� )8�logging�log� email.utilsr �flaskr r r � flask.viewsr � flask_loginr �
sqlalchemyr �$buyercall.blueprints.channels.modelsr r
�)buyercall.blueprints.channels.serializersr r r
�!buyercall.blueprints.email.modelsr �3buyercall.blueprints.email.utils.add_email_identityr �'buyercall.blueprints.partnership.modelsr r �(buyercall.blueprints.phonenumbers.modelsr �#buyercall.blueprints.sources.modelsr �$buyercall.blueprints.user.decoratorsr � buyercall.blueprints.user.modelsr �#buyercall.blueprints.widgets.modelsr �buyercall.extensionsr �buyercall.lib.util_restr r rC � channels_api� getLogger�loggerr rZ r� r� r� r� r� r� r� r3 r3 r3 r4 �<module> sL
=
Q
5
S
: