File: //home/arjun/projects/buyercall/buyercall/lib/__pycache__/bandwidth.cpython-310.pyc
o
�we�L � @ s( d dl Z d dlZd dlZd dlZd dlmZ d dlm mZ d dl
Z
d dl m Z e�
e�Zdd� Zdd� ZG dd � d e�ZG d
d � d e�ZG d d
� d
e�ZG dd� de�ZG dd� de�ZG dd� de�ZG dd� de�ZG dd� de�ZG dd� de�Z G dd� de�Z G d d � d e�Z G d d � d e�Z G d d!� d!e�Z G d"d#� d#e�Z!G d$d%� d%e�Z"G d&d'� d'e�Z#G d(d)� d)e�Z$G d*d+� d+e�Z%G d,d-� d-e�Z&G d.d/� d/e�Z'G d0d1� d1e�Z(G d2d3� d3e�Z)G d4d5� d5e�Z*G d6d7� d7e�Z+d8d9� Z,G d:d;� d;e�Z-G d<d=� d=e�Z.G d>d?� d?e�Z/dS )@� N)�urlparse)�
HTTPBasicAuthc C sJ t | t�rdd� | �� D �S | �d�}|d d�dd� |dd � D �� S ) Nc S s i | ] \}}t |�|�qS � )�
camel_case��.0�key�valr r �9/home/arjun/projects/buyercall/buyercall/lib/bandwidth.py�
<dictcomp> s z camel_case.<locals>.<dictcomp>�_r � c s s � | ]}|� � V qd S �N)�
capitalize)r �xr r r
� <genexpr> s � z camel_case.<locals>.<genexpr>� )�
isinstance�dict�items�split�join)�thing�wordsr r r
r s
$r c C s t t| �j�S r )�boolr �netloc)�urlr r r
� is_absolute � r c @ s e Zd Zdd� ZdS )�BandwidthExceptionc C �
|| _ d S r )�message)�selfr! r r r
�__init__ �
zBandwidthException.__init__N)�__name__�
__module__� __qualname__r# r r r r
r s r c @ s e Zd Zej�dd�Zefdd�Zedd� �Z edd� �Z
ed d
� �Z ed d � �Z ed
d� �Z
edd� �Zedd� �Zedd� �Zedd� �Zedd� �Zdd� Zg dfd d �Z d2d d �Zd!d"� Zd#d$� Zd%d&� Zd'd(� Zd3d*d+�Zd3d,d-�Zd.d/� Zd0d1� Z d)S )4� Bandwidth�BANDWIDTH_API_ROOTz$https://api.catapult.inetwork.com/v1c C s. t ||�| _|| _|| _d�| j| j�| _d S �N�{}/{})r �auth�user_id�api_root�format�url_root)r" �token�secretr- r. r r r
r# % s zBandwidth.__init__c C � t | �S r )�Calls�r" r r r
�calls+ � zBandwidth.callsc C r3 r )�Bridgesr5 r r r
�bridges/ r7 zBandwidth.bridgesc C r3 r )�
Recordingsr5 r r r
�
recordings3 r7 zBandwidth.recordingsc C r3 r )�AvailableNumbersr5 r r r
�available_numbers7 r7 zBandwidth.available_numbersc C r3 r )� PhoneNumbersr5 r r r
�
phone_numbers; r7 zBandwidth.phone_numbersc C r3 r )� Applicationsr5 r r r
� applications? r7 zBandwidth.applicationsc C r3 r )� Conferencesr5 r r r
� conferencesC r7 zBandwidth.conferencesc C r3 r )�Messagesr5 r r r
�messagesG r7 zBandwidth.messagesc C r3 r )�Domainsr5 r r r
�domainsK r7 zBandwidth.domainsc C r3 r )�Mediar5 r r r
�mediaO r7 zBandwidth.mediac C sX t �d|�st�d�|�� dS z
d�| j|�}| �|�W S t�d�|�� Y dS )z2 Make a CNAM lookup on an E.123-formatted number. z^\+?\d+$zInvalid number format: {}Nz {}/phoneNumbers/numberInfo/{}z&No CNAM value was found for number: {})�re�match�log�errorr/ r. �get)r" �numberr r r r
� number_infoS s zBandwidth.number_infoTc C s | j | �d�||d�}t| |�S )z Create a new bridge. r9 )�call_ids� bridge_audio)�post� resource_url�Bridge)r" rQ rR r r r r
�bridge_ s
�
zBandwidth.bridge�GETc K s4 ||i |d�}|� |� | �| �d�|�}t| |�S )z Create a new call. )�from�to�
sipHeaders�callbackHttpMethodr6 )�updaterS rT �Call)r" �from_rY �callback_http_method�kwargs� json_data�call_urlr r r
�callg s �
zBandwidth.callc O s� |}|rt |d t�r|d }t|�}|�� D ]\}}t|�tu r)|r%dnd||< qt�d�|t �
|��� t j || j
|d�}d|jkr\t �|j�� �}td�|j|j|d |d ���|j�d
�S ) Nr �true�falsez POST {}
{}
�r, �json�, z7STATUS_CODE:{} - CATEGORY: {} - REASON: {} - DETAIL: {}�coder! �Location)r r r r �typer rL �debugr/ rg �dumps�requestsrS r, � status_code�loads�content�decoder �reason�headersrN ) r" r �argsr` �paramsr r �r�
error_contentr r r
rS u s �
� zBandwidth.postc
K s� dd� |� � D �}t�d�|d�dd� |� � D ���� tj|| jt|�d�}d|j krDt
� |j �
� �}td �|j |j|d
|d ���|�
� S ) Nc S s i | ] \}}|d ur||�qS r r )r �k�vr r r
r � s z!Bandwidth.get.<locals>.<dictcomp>z
GET {}?{}
�&c s s � | ] \}}d � ||�V qdS )z{}={}N)r/ r r r r
r � s � z Bandwidth.get.<locals>.<genexpr>)r, rv rh z5STATUS_CODE:{} - CATEGORY:{} - REASON:{} - DETAIL: {}ri r! )r rL rl r/ r rn rN r, r ro rg rp rq rr r rs )r" r r` rw rx r r r
rN � s �
�z
Bandwidth.getc C sH t �d�|�� tj|| jd�}d|jkr"t�|j �
� �}t |j ��d S )Nz
DELETE {}
)r, rh )
rL rl r/ rn �deleter, ro rg rp rq rr r rs )r" r rw rx r r r
r| � s
�zBandwidth.deletec C s d� | j|�S r* )r/ r. )r" �resourcer r r
�
global_url� r zBandwidth.global_urlNc C �. |d u r
d� | j| j|�S d� | j| j||�S �Nz{}/users/{}/{}z{}/users/{}/{}/{}�r/ r. r- �r" r} �id_r r r
rT � �
� �zBandwidth.resource_urlc C r r� r� r� r r r
�
domain_url� r� zBandwidth.domain_urlc C s< t jd�| j| j|�| jddid�}d|jkr t|j��d S )Nz{}/{}/calls/{}�state� completedrf rh ) rn rS r/ r. r- r, ro r rs )r" �sidrw r r r
�hangup� s ��
�zBandwidth.hangupc C s
t | |�S r )�
Conference)r" �conf_idr r r
�
conference� r$ zBandwidth.conference)rW r ) r% r& r' �os�environrN �API_ROOTr# �propertyr6 r9 r; r= r? rA rC rE rG rI rP rV rc rS r| r~ rT r� r� r� r r r r
r( sJ �
�
r( c @ s> e Zd Zddd�Zdd� Zdd� Zdd � Zd
d � Zd d
� ZdS )�
CollectionNc C s( ||| _ | _| j �| j�| _|| _d S r )�client�namerT �base_url� child_class)r" r� r� r� r r r
r# � �
zCollection.__init__c C s d� | j|�}| �| j|�S r* )r/ r� r� r� �r" r� r r r r
� __getitem__� s zCollection.__getitem__c K � | j j| jfi |��S r )r� rN r� �r" r` r r r
�search� � zCollection.searchc C s | j �d�| j|�� d S r* )r� r| r/ r� )r" r� r r r
r| � � zCollection.deletec K r� r )r� rS r� r� r r r
rS � r� zCollection.postc K s | � | j| jdi |���S )Nr )r� r� rS r� r r r
�create� r� zCollection.creater ) r% r& r' r# r� r� r| rS r� r r r r
r� � s
r� c @ s@ e Zd Zdd� Zedd� �Zdd� Zdd� Zd d
� Zd d � Z d
S )�Resourcec C s8 t |�s d�|j|�}|| _|| _| j�d�d | _d S )Nr+ �/���)r r/ r. r r� r r� )r" r� r r r r
r# � s
zResource.__init__c C s | j S r )r� r5 r r r
�id� s z Resource.idc C � | j �| j�S r �r� rN r r5 r r r
rN � r z Resource.getc C r� )z A synonym for `Resource.get` r� r5 r r r
�details� s zResource.detailsc K r� r )r� rS r r� r r r
rS � r� z
Resource.postc K s | j di |��S )z A synonym for `Resource.post` Nr �rS r� r r r
�set� s z Resource.setN)
r% r& r' r# r� r� rN r� rS r� r r r r
r� � s
r� c � e Zd Z� fdd�Z� ZS )rD c � t t| ��|dt� d S )NrE )�superrD r# �Message�r" r� �� __class__r r
r# � � zMessages.__init__�r% r& r' r# �
__classcell__r r r� r
rD � � rD c @ � e Zd ZdS )r� N�r% r& r' r r r r
r� � � r� c r� )rB c r� )NrC )r� rB r# r� r� r� r r
r# � r� zConferences.__init__r� r r r� r
rB � r� rB c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S )
r� c C s | j jd�| j�|d�S )N�
{}/members)�call_id�r� rS r/ r �r" r� r r r
�
add_member� s
�zConference.add_memberc C s | j jd�| j|�dd�S )Nz
{}/members/{}r� �r� r� r� r r r
�
remove_member s �zConference.remove_memberc C s | j �d�| j��S )Nr� )r� rN r/ r r5 r r r
�members s
�zConference.membersc K s | j jd�| j�fi |��S �N�{}/audior� r� r r r
�audio s
��zConference.audioN)r% r& r' r� r� r� r� r r r r
r� � s
r� c �$ e Zd Z� fdd�Zdd� Z� ZS )r@ c r� )NrA )r� r@ r# � Applicationr� r� r r
r# r� zApplications.__init__c C s d� | j|�}| jj||d�S )Nr+ )�incoming_message_url�r/ r� r� rS )r" �application_idr� �application_urlr r r
�update_incoming_message_url s z(Applications.update_incoming_message_url)r% r& r' r# r� r� r r r� r
r@ � r@ c @ r� )r� Nr� r r r r
r� r� r� c @ � e Zd Zdd� Zdd� ZdS )r8 c C r r �r� r� r r r
r# % r$ zBridges.__init__c C � | j �d|�}t| j |�S )Nr9 )r� rT rU r� r r r
r� ( � zBridges.__getitem__N�r% r& r' r# r� r r r r
r8 $ � r8 c @ r� )r: c C r r r� r� r r r
r# . r$ zRecordings.__init__c C r� )Nr; )r� rT � Recordingr� r r r
r� 1 r� zRecordings.__getitem__Nr� r r r r
r: - r� r: c r� )r� c s@ t t| ��||� |�� D ]\}}|dkrd}t| ||� q
d S )Nr� r� )r� r� r# r �setattr)r" r� r r` r r r� r r
r# 7 s �zRecording.__init__c C s t j| j| jjdd�}|S )z Assuming self.media is set T�r, �stream)rn rN rI r� r, )r" rw r r r
�data? s �zRecording.data)r% r& r' r# r� r� r r r� r
r� 6 s r� c s2 e Zd Z� fdd�Z ddd�Zddd�Z� ZS ) r> c r� )N� phoneNumbers)r� r> r# � PhoneNumberr� r� r r
r# J r� zPhoneNumbers.__init__Nc C s | j ||||d�}t| j|�S )N)rO r� r� �fallback_number�rS r� r� )r" rO r� r� r� r r r r
�purchaseM s
� zPhoneNumbers.purchasec C s | j ||||d�}t| j|�S )N)rO r� �
applicationId�providerr� )r" rO r� r� r� r r r r
�
import_numberX s
� zPhoneNumbers.import_number)NNNN)r% r& r' r# r� r� r� r r r� r
r> I s
� r> c @ r� )r� Nr� r r r r
r� a r� r� c @ s e Zd Zdd� Zddd�ZdS )r< c C s( |d| _ | _| j �| j�| _d | _d S )N�availableNumbers)r� r� r~ r� r� r� r r r
r# f r� zAvailableNumbers.__init__�localc K s" d� | j|�}| jj|fi |��S r* �r/ r� r� rN )r" rk r` r r r r
r� k � zAvailableNumbers.searchN)r� )r% r& r' r# r� r r r r
r< e s r< c sD e Zd Z� fdd�Zdd� Zdd� Zdd� Zd d
� Zd d � Z� Z S )
rF c r� )NrG )r� rF r# �Domainr� r� r r
r# q r� zDomains.__init__c C s4 d� | j|�}| jj|||||||d�}t| j|�S )N�{}/{}/endpoints)� domain_idr� � descriptionr� �enabled� credentials)r/ r� r� rS �Endpoint) r" r� r� r� r� r� r� � endpoint_urlr r r r
�create_endpointt s � zDomains.create_endpointc C s" d� | j||�}| jj|||d�S )N�{}/{}/endpoints/{})r� � endpoint_idr� )r" r� r� r r r r
� get_endpoint s
�zDomains.get_endpointc C s d� | j|�}| jj||d�S )Nr� )r� r� )r" r� r r r r
�
get_endpoints� s �zDomains.get_endpointsc C s$ d� | j||�}| jj||||d�S )Nr� )r� r� r� r� )r" r� r� r� r� r� r r r r
�update_endpoint� s ��zDomains.update_endpointc C s6 | j �d|�}d�||�}t�d�|�� | j �|�S )NrG z{}/endpoints/{}zThe url is: {})r� r� r/ rL �infor| )r" r� r� r� r� r r r
�delete_endpoint� s zDomains.delete_endpoint)
r% r& r' r# r� r� r� r� r� r� r r r� r
rF p s
rF c r� )rH c r� )NrI )r� rH r# �Mediasr� r� r r
r# � r� zMedia.__init__c C s( d� | j|�}tj|| jjdd�}|jS )Nr+ Tr� )r/ r� rn rN r� r, rq )r" �
media_namer rw r r r
� get_media� s �zMedia.get_media)r% r& r' r# r� r� r r r� r
rH � r� rH c @ r� )r� Nr� r r r r
r� � r� r� c @ r� )r� Nr� r r r r
r� � r� r� c @ r� )r� Nr� r r r r
r� � r� r� c s" e Zd Zg df� fdd� Z� ZS )rU Tc s t t| ��||� d S r )r� rU r� )r" r6 rR r� r r
r� � r� z
Bridge.set)r% r& r' r� r� r r r� r
rU � s rU c @ sD e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dS )r4 c C r r r� r� r r r
r# � r$ zCalls.__init__c C r� �Nr6 )r� rT r] )r" r� r r r r
r� � r� zCalls.__getitem__c C �" | j �d|�}| j j|dd� d S )Nr6 r� r� �r� rT rS �r" r� rb r r r
r� � r� z Calls.hangupc C �$ | j �d|�}| j j|d|d� d S )Nr6 �active)r� � callback_urlr� )r" r� r rb r r r
�redirect� s
�zCalls.redirectc C r� )Nr6 r� r� r� r� r r r
r\ � r� z Calls.updatec C r� )Nr6 � transferring)r� � transfer_tor� )r" r� � phone_numberrb r r r
�transfer� s zCalls.transferc C s | j �d|�}| j �|�S r� )r� rT rN r� r r r
r� � r� z
Calls.infoN)
r% r& r' r# r� r� r� r\ r� r� r r r r
r4 � s r4 c @ sP e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z ddd�Z
dS )r] c O s$ d� | j�}| jj|fi |�� d S r� �r/ r r� rS �r" ru r` r r r r
r� � s z
Call.audioc O s* d� | j�}| jj|g|�R i |�� d S )Nz {}/gatherr� r r r r
�gather� s z Call.gatherc C � | j dd� d S )N�rejectedr� �r� r5 r r r
�reject� � z Call.rejectc C r )Nr� r� r r5 r r r
�accept� r z Call.acceptc C r )Nr� r� r r5 r r r
r� � r z Call.hangupc C s | j |d� d S )N)r� r� �r" r r r r
r� � r z
Call.redirectc s& d� � j�}� fdd�� j�|�D �S )Nz
{}/recordingsc s. g | ]}t � jd �� j|d �fi |���qS )r+ r� )r� r� r/ r )r �itemr5 r r
�
<listcomp>� s ����z#Call.recordings.<locals>.<listcomp>)r/ r r� rN r r r5 r
r; � s
�zCall.recordings�female�en_US�susanc K s. d� | j�}| jj|f||||d�|�� d S )Nr� )�sentence�gender�locale�voicer� )r" �textr r r r` r r r r
�say� s ��
�zCall.sayN�r r r
) r% r& r' r� r r r r� r� r; r r r r r
r] � s �r] c s � fdd�}|S )Nc s> � | g|�R � }|� � D ]\}}|r |�t|�t|�� q |S r )r r� r �str)r" ru r` �eltr r ��methodr r
�wrapper s �zxattrs.<locals>.wrapperr )r r r r r
�xattrs s r c @ s� e Zd Zd dd�Zdd� Zed!d d
��Zed d � �Zed"dd��Zedd� �Z edd� �Z
edd� �Z dd� Z dd� Z
dd� Zd d � Zd d � ZdS )#�ResponseNc C s" |d ur || _d S t �d�| _d S )Nr )�ET�Element�root�r" r r r r
r# s "zResponse.__init__c C s t j| jdd�S )N�unicode)�encoding)r �tostringr r5 r r r
�__str__ r zResponse.__str__r r r
c C s( t jd|||d�}||_| j�|� |S )N�
SpeakSentence)r r r �r r r r �append)r" r r r r r r r r
r s � z Response.sayc C � t jddd�}| j�|� |S )N�Pause�4��length�r r r r& r r r r
�pause �
� zResponse.pause�2c C s t jd|d�}| j�|� |S )Nr( r* r, )r" r+ r r r r
� custom_pause# r. zResponse.custom_pausec C �$ t jddd�}||_| j�|� |S �N� PlayAudioz-4)�volumer% �r" r r r r r
�
play_audio+ s zResponse.play_audioc C � t �d�}| j�|� |S )a:
:param from_: Required.
:param status_callback_url: Optional.
:param join_tone: Optional. 'true'/'false'
:param leaving_tone: Optional. 'true'/'false'
:param tag: Optional.
:param mute: Optional. 'true'/'false'
:param hold: Optional. 'true'/'false'
r� r, r r r r
r� 2 s
zResponse.conferencec C s$ t jd|dd�d�}| j�|� |S )N�Redirect�5000)�
requestUrl�requestUrlTimeout)�attribr, )r" � request_urlr r r r
r� A s �� zResponse.redirectc C r7 )N�Hangupr, r r r r
r� M �
zResponse.hangupc C r7 )N�Rejectr, r r r r
r R r? zResponse.rejectc K sL t jd|d�}| j�|� |�� D ]\}}|r!|�t|�t|�� qt|�S )N�Gather)r: ) r r r r& r r� r r rA )r" r= r` r r r r r r
r W s � �zResponse.gatherc K �H t �d�}| j�|� |�� D ]\}}|r |�t|�t|�� qt|�S )N�Transfer� r r r r& r r� r r rC �r" r` r r r r r r
r� c � � �zResponse.transferc K rB �N�RecordrD rE r r r
�recordm rF zResponse.recordr r )r/ )r% r& r' r# r# r r r- r0 r6 r� r� r� r r r� rI r r r r
r s(
r c @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd S ) rA c C r r )r r r r r
r# z r$ zGather.__init__c C � | S r r r5 r r r
� __enter__} � zGather.__enter__c C � d S r r �r" �type_�value�tbr r r
�__exit__� rL zGather.__exit__c O s t | j�j|i |��S r )r r r �r" ru r` r r r
r � r� z
Gather.sayc C r1 r2 r% r5 r r r
r6 � � zGather.play_audioN)r% r& r' r# rK rR r r6 r r r r
rA x s rA c @ sL e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dS )rC c C s || _ t| j �| _d S r )r r �respr r r r
r# � s zTransfer.__init__c C rJ r r r5 r r r
rK � rL zTransfer.__enter__c C rM r r rN r r r
rR � rL zTransfer.__exit__c O s | j j|i |��S r )rU r rS r r r
r � s z Transfer.sayc C s t �d�}| j�|� ||_|S )Nr� )r r r r& r )r" r r r r r
r� � s � zTransfer.phone_numberc K sD t �d�}| j�|� |�� D ]\}}|r |�t|�t|�� q|S rG )r r r r& r r� r r rE r r r
rI � s � �zTransfer.recordc C r' )Nr( �3r* r, r r r r
r- � s
� zTransfer.pausec C r1 r2 r% r5 r r r
r6 � rT zTransfer.play_audioN) r% r& r' r# rK rR r r� rI r- r6 r r r r
rC � s
rC )0r� rg �loggingrJ � urllib.parser �xml.etree.ElementTree�etree� ElementTreer rn �
requests.authr � getLoggerr% rL r r � Exceptionr �objectr( r� r� rD r� rB r� r@ r� r8 r: r� r> r� r< rF rH r� r� r� rU r4 r] r r rA rC r r r r
�<module> sP
+ ' m