File: //home/arjun/projects/buyercall/buyercall/lib/__pycache__/util_webhooks.cpython-310.pyc
o
�we�4 � @ s~ d dl Z d dlZd dlZd dlmZ d dlmZ d dlmZ d dl m
Z
d dl m Z d dl
mZ e �e�ZG dd � d e�ZdS )
� N)�ceil)�and_)�Lead)�Message)�Webhook)�dbc @ s\ e Zd Zg d�Zg d�ZddiZdd� Zdd� Zd d
� Zd d � Z d
d� Z
dd� Z dd� Z dS )� WebhookUtil)�operational_start_call�operational_agent_call�operational_end_call�mobile_start_call�mobile_end_call)�operational_send_message�operational_receive_message�mobile_send_message�mobile_receive_messagez Content-Typezapplication/jsonc C s� d}d}d}d}d}d}d} |j r+t|j �tkr%t�d�|j �� |j }n|j �d�}|jr?t|j�tkr9|j}n|j�d�}|| jv �rk|j dur[t|j �tkrU|j }n|j �d�}|j
durqt|j
�tkrk|j
}n|j
�d�}|dkr�ddl m }
|
j
�|
j|jk��� } | j} n|j} |jdur�t|j
�tkr�|jd }
n ttt|j�d ��}
t�d
�|j�� t�d �t|j��� t�d �|
�� n|j}
|jr�| �|j�r�d
}|jr�|jj�dd�r�d
}|�r|j�rddl m } ||j�}|�r|d �r|d �rddl m } ||d |d d�} i d|j �d|�d|�d| �d|j �d|j!�d|j"�d|j#�d |j�d |j$�d |j%�d |
�d |�d!|�d"|j&�d#|�d$| �|j|j'|j(||j)|j*d%d&��}t�d'�||j#�� |S || j+v �r�i d|j �d|�d|�d| �,|j��d|j#�d(|j-�d)|j.�d*|j/�d+|j0�d,|j(�d-|j1�d.|j2�d/|j3�d |j�d0|j)�d1|�d2d%�}t�d'�||j#�� |S t�4d3| d4 � |S )5zm
Creates the JSON payload object based on webhook event type.
:return: JSON Payload
NFzThe date is {}z%Y-%m-%d %H:%M:%Sr r )�Endpoint�< g N@zThe duration is {}zThe duration type is {}z The call duration is: {} minutesT� recordCalls� )�get_recording_url_details�key�bucket)�generate_presigned_aws_url�id�
created_on�
updated_on�agent_id� call_source�progress_status� caller_id�partnership_account_id�phonenumber_id� phonenumber�my_phone�duration� starttime�endtime� call_type�recording_enabled�
recording_url�phone)� widget_guid�
call_count�status�
event_type�originating_number�missed_call_cause�typezIA webhook was sent for the following event: {} and partner account id: {}�to�from� body_text� media_urlr. �
delivery_code�delivery_description� directionr0 r/ r2 zUnknown event type "z." provided. Cannot build webhook JSON payload.)5r r2 �str�log�info�format�strftimer �
call_typesr& r' �"buyercall.blueprints.mobile.modelsr �query�filter�
inbound_id�firstr r% �intr �float� is_recordedr, �widget�options�getr* �buyercall.lib.util_boto3_s3r r r r r r r! r# r$ r( r- r. r0 r1 �
message_types� get_agentr3 �from_r5 r6 r7 r8 r9 �error)�selfr/ �contact_object�payloadr r r& r' r) r* r �endpointr � duration_minr �recording_detailsr � rV �=/home/arjun/projects/buyercall/buyercall/lib/util_webhooks.py�populate_payload s
�������� �
� � �
������!
� ���� ����� �
� �
������
��z WebhookUtil.populate_payloadc C � t j�t j|k��� }|S �N)r rA rB r rD )rP �lead_id�lead_objrV rV rW �get_lead� � zWebhookUtil.get_leadc C rY rZ )r rA rB r rD )rP �
message_id� message_objrV rV rW � get_message� r^ zWebhookUtil.get_messagec C sN ddl m} |j�|j|k��� }|r%|j�d�r%|j�d�}|du r%dS dS )Nr ��Phoner TF)�(buyercall.blueprints.phonenumbers.modelsrc rA rB r rD �routing_configrJ )rP r" rc r+ �recordedrV rV rW rG � s zWebhookUtil.is_recordedc C s� ddl m} d}|j�|j|k��� }|rW|j�d�dkr%|j�d�g}n|j�d�dkr4|j�d�}nd S |rW|D ] }|�d
t� �D ]}|d rU|d rUt |d �} nqCq:|S ) Nr rb ���� routingType�default�defaultRouting�digit�
digitRoutingsr �agentsr )
rd rc rA rB r rD re rJ �listrE )rP r" rc �result_agent_idr+ �routings�r�agentrV rV rW rM � s" �zWebhookUtil.get_agentc C sb ddl m} |j�|j|k��� }|r/|jr/tj�t ��t
t j|jkt j dkt j dk���� }|S )Nr )�PartnershipAccountr F)
�'buyercall.blueprints.partnership.modelsrs rA rB r rD �partnership_idr �sessionr r � webhook_url�is_deactivated)rP r! rs �partnership_account�retrieved_webhookrV rV rW � get_webhook� s �
���zWebhookUtil.get_webhookc
C s> d}d}d}z||| j v r|dur| �|�}n|| jv r$|dur$| �|�}|durz|r}| �|j�}|r�|jrm|j}t�d� |j
�� | � ||�}|j rP|j | j
d< t�d|� dt�|�� �� tj|t�|�| j
d�}W dS t�d � ||j�� W dS W dS W dS W dS ty� } zt�d
� || �� W Y d} ~ dS d} ~ ww ) zb
Executes webhook based on event_type. operational_end_call
:return: N/A
r NTz*The medium triggered created on date is {}zSecurity-Tokenz
end_point z
, data : )�url�data�headerszKWebhook "{}" event found for partnership account {} but no webhook URL set.z-Error executing webhook event "{}". Error: {})r? r] rL ra r{ r! rw r; r< r= r rX �security_token�header_content�json�dumps�requests�postrO � Exception)
rP r/ � medium_id�post_end_point�medium_triggered�
post_eventrz rR rq �erV rV rW �trigger_generic_webhook� s8
� �
��z#WebhookUtil.trigger_generic_webhookN)
�__name__�
__module__� __qualname__r? rL r� rX r] ra rG rM r{ r� rV rV rV rW r s r )�loggingr� r� �mathr �
sqlalchemyr �!buyercall.blueprints.leads.modelsr � buyercall.blueprints.sms.modelsr �$buyercall.blueprints.webhooks.modelsr �buyercall.extensionsr � getLoggerr� r; �objectr rV rV rV rW �<module> s