File: //home/arjun/projects/buyercall/buyercall/blueprints/widgets/__pycache__/bw_tasks.cpython-310.pyc
o
�we � @ s� d dl Zd dlZd dlZd dlZd dlmZmZ d dlm Z d dl
m Z d dl m
Z
mZmZ d dlmZ d dlmZ d dlmZ d d lmZ d
Zd Zd Ze e�Z e � � d
d� �Z e j dd� �Z e j dd� �Z dS )� N)�url_for� current_app)�create_celery_app)�db)� CallStorage�InboundCallState� select_voice)� bw_client)�BandwidthException)�Lead)�Agenti�Q z=https://s3.amazonaws.com/buyercall-static-sounds/dialtone.mp3z1We're sorry, there was an error calling the leed.c
K s� t jtjd tjd d�}ddlm}m} t�d� t j
� t j | k��
� }|s1t�d�| �� d S dd lm}m} |j
� |j |jk��
� }|jj} | sP|jjj} | jrat�d
�|jj|j�� d S |jd v rmt�d � d S t||j �}
|
� � d |
_ d
d� t |j j dd� d�D �} | s�t�d� d S d|_| j!d7 _!t"j#�$� |j j%d r�t&|j � d S |j j%d r�t'�(| � t)|j*d�} || �}
z |
�+| |j |� W d S t,y� } z t�-t.�/� � d|_t"j#�$� |||j � W Y d }~d S d }~ww )N�REDIS_CONFIG_URL�REDIS_CONFIG_PORT��host�port� )�BandwidthRouting�send_notify_emailz Trying to call lead again...zLead {} not available.r �� Partnership�PartnershipAccountz5Partnership account {} ({}) has exceeded their quota.)�ringing� completedz!Lead is currently in another callc S s g | ] }|j jr|j�qS � )�agent�
available_now�agent_id)�.0�asgr r �G/home/arjun/projects/buyercall/buyercall/blueprints/widgets/bw_tasks.py�
<listcomp>I s ��z call_again.<locals>.<listcomp>c S s | j S )N)�order)�xr r r �<lambda>K s z call_again.<locals>.<lambda>)�keyz*No agents were configured for this widget.r �routeSimultaneously�
routeRandomly�voice�missed)0�redis� StrictRedis�celery�conf�routingr r �log�infor �query�filter�id�first�warning�format�'buyercall.blueprints.partnership.modelsr r �partnership_account_id�partnership_account� subscription� partnership�usage_over_limit�name�status�debugr �inc_callback_cntr �sorted�widget� assignments�
call_countr �session�commit�options�
call_parallel�random�shuffler �partnership_id�route_sequential� Exception�error� traceback�
format_exc)�lead_id�kwargs�redis_db�Routingr �leadr r �partner_accountr: �storage� agent_ids�client�r�er r r �
call_again sf
�
�
�
��r\ c K s� t jtjd tjd d�}ddlm}m}m} t� d� t
j � t
j
��t
j| k��� }|j
}ddlm}m} | j �| j|jk��� }
||�} td t| � � | sgt�d
�|j�� d |_tj � � |||j
� t || �} t j | _!| �"� d �| �}
d
�| �}d�| �}|�#|dt$ d� |�#|dt$ d� t%j �t%j�&| ���'� }t� d�t(|��� d }t)|
j*d�}||�}|D ]�}zi|�+d�|j��}t� d�|�� d �| �}
|�,|
dd�}t� d�|�� |�-|||�}| �.� �. | j/�r| j/t|j�k�r|�0� W d � W n@|�1|
d�|j|�� W d � n 1 �s w Y W q� t2�yG } zt�t3�4� � t�d�|j�� W Y d }~q�d }~ww |d u �r^|�#|dt$ d� d |_tj � � |�5|
dt$ � d S )Nr
r r r )r r �get_available_agent_idszParallel call task started.r r z Agent ids: z&No agents are available for widget {}.r) zLIST{}zSUCC{}z CONNECT{}� �0zCalling {} agents...r( zBUSY_{}zagent busy: {}���zThe calls are: {}z{}_{}zError calling agent {}...z-1)6r* r+ r, r- r. r r r] r/ r0 r r1 �joinrB r2 r3 �oner7 r r r8 r4 �print�strr5 r6 r> r rE rF r �State�NEW�state�clear_retry_cnt�setex�DAYSr �in_�all�lenr rK �get�lrange�call_agent_parallel�lockr �hangup�lpushrM rO rP �expire)rQ rR rS rT r r] rU rB r r rV rX rW �called_agents_key�lead_capture_key� connect_key�agents�callrY rZ r �
agent_busy�callsr[ r r r rH j sv
�
�� �����
rH c
K s� t jtjd tjd d�}t|| �}tj�tj�� tj
| k�� � }|j}ddl m
}m} |j� |j
|jk��� } |j� |j
| jk��� }
t|
j
�} |j�� } z | j| jtdd� W n tyj t�t� � � Y nw z&| j |j j |j t d|j
|d d
d �d |j!d
�}
|
j
|_"|
j
|_"t#j$�%� W dS ty� t�t� � � |jj&�'dd�}t(|�\}}}| j|j jdd� | j|j jt)d|||d� Y dS w )z; Play dial tone on the agent's side and call the lead.
r
r r r r �true)�file_url� loop_enabledz bw_outbound.lead_status_callbackT�https)rQ r � _external�_scheme�POST)�from_�to� callback_url�callback_http_method�
conference_id�language�en� )r} �lead_call_error)�sentence�tag�gender�localer( N)*r* r+ r, r- r r r1 ra rB r2 r3 rb r7 r r r8 r4 rK r �
agent_call_id�decoder{ �audio�
DIAL_TONE_URLr
r/ rN rO rP ry �inbound� phonenumberr �
bw_conf_id�call_sidr rE rF rG rn r �MSG_LEAD_CALL_ERROR)rQ r rR rS rW rU rB r r rV �partnerrY �agent_call_id_decoded� call_leadr� r� r� r( r r r � bw_call_lead� sb
�
� ��� ��r� )!�loggingr/ rI rO r* �flaskr r �
buyercall.appr �buyercall.extensionsr �buyercall.lib.util_twilior r re r � buyercall.lib.util_bandwidthr �buyercall.lib.bandwidthr
�!buyercall.blueprints.leads.modelsr �"buyercall.blueprints.agents.modelsr rj r� r� r, �taskr\ rH r� r r r r �<module> s,
I
Q