File: //home/arjun/projects/buyercall/buyercall/lib/__pycache__/bandwidth_api_v2.cpython-310.pyc
o
�we�R � @ sP d dl Z d dlZd dlZd dlm mZ d dlZd dlZ d dl
Z
d dl Z d dl m
Z
d dlmZ e�e�Zdd� Zdd� Zdd � ZG d
d � d e�Zd d
� ZG dd� de�ZG dd� de�ZG dd� de�Z G dd� de�Z G dd� de�Z G 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$dS )$� N)�
HTTPBasicAuth)�format_phone_numberc 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 �@/home/arjun/projects/buyercall/buyercall/lib/bandwidth_api_v2.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 O s$ t j| |g|�R i |��}||_|S r )�ET�
SubElement�text)�parent�tagr �args�kwargs�elementr r r
� text_element s r" c C s t tj�| �j�S r )�bool�urllib�parse�urlparse�netloc)�urlr r r
� is_absolute# � r) c @ s e Zd ZdS )�BandwidthExceptionN)�__name__�
__module__� __qualname__r r r r
r+ ' s r+ c C sF | dkr
t j�dd�}|S | dkrt j�dd�}|S t j�dd�}|S ) N� messaging� BANDWIDTH_MESSAGING_API_ROOTz,https://messaging.bandwidth.com/api/v2/users�voice�BANDWIDTH_VOICE_API_ROOTz+https://voice.bandwidth.com/api/v2/accounts� BANDWIDTH_DASHBOARD_API_ROOTz,https://dashboard.bandwidth.com/api/accounts)�os�environ�get)� request_type�api_rootr r r
� api_root_url/ s � ����r9 c @ s� e Zd Zdd� Zedd� �Zedd� �Zedd� �Zed d
� �Zed d � �Z ed
d� �Z
edd� �Z edd� �Z edd� �Z
d)dd�Zdd� Zdd� Zd*d d �Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'd(� Zd S )+� Bandwidthc
C sr t |�}
t||�| _|| _|
| _|| _|| _|| _|| _|| _ || _
| | _ d� | j| j�| _
t�d� | j
�� d S )N�{}/{}zThe root url is: {})r9 r �auth�
account_idr8 �username�password�site_id� location_id�sms_application_id�voice_application_id�
cnam_password�format�url_root�log�info) �selfr7 r> r? r= r@ rA rB rC rD r8 r r r
�__init__@ s zBandwidth.__init__c C � t | �S r )�AvailableNumbers�rI r r r
�available_numbersP � zBandwidth.available_numbersc C rK r )�
SubscriptionsrM r r r
�
subscriptionsT rO zBandwidth.subscriptionsc C rK r )� PhoneNumbersrM r r r
�
phone_numbersX rO zBandwidth.phone_numbersc C rK r )�PhoneNumbersOptionsrM r r r
�phone_numbers_options\ rO z Bandwidth.phone_numbers_optionsc C rK r )�InserviceNumberrM r r r
�in_service_number` rO zBandwidth.in_service_numberc C rK r )�MediarM r r r
�mediad rO zBandwidth.mediac C rK r )�MessagesrM r r r
�messagesh rO zBandwidth.messagesc C rK r )� PhoneCallrM r r r
�calll rO zBandwidth.callc C rK r )�RealmsrM r r r
�realmsp rO zBandwidth.realmsFc
C s� d}t j�| j�}t|�}| j||||d�}t j�|�}|j}tt j� |��} | �
|� t j� | �}
|j |
d�}t j�
|�} t�| �} d| jkrTtd�| j| j�� ���| j�� S )Nzhttps://cnam.dashcs.com/?)� companyIdr? �number�dnis�test)�query�, zSTATUS_CODE:{} - DETAIL: {})r$ r% �
quote_plusrD r r= r& rd r � parse_qsl�update� urlencode�_replace�
urlunparse�requestsr6 � status_coder+ rE �content�decode)
rI ra rc r( r? �
format_number�params� url_parserd �url_dict�
url_new_query�new_url�rr r r
� cnam_lookupt s& �
�
zBandwidth.cnam_lookupc C s d� | j| j|�S )Nz{}/{}/{})rE r8 r= )rI �resourcer r r
�
global_url� r* zBandwidth.global_urlc
K s� dd� |� � D �}t�d�|d�dd� |� � D ���� tj|| jt|�d�}d|j krZt
� |j �
� �}t�|�}t�|�}|d d
d }|d d
d }td
�|j |j||���|j �
� 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)rE r r r r
r � s � z Bandwidth.get.<locals>.<genexpr>)r< rq re � SearchResult�Error� Description�Code�7STATUS_CODE:{} - CATEGORY: {} - REASON: {} - DETAIL: {})r rG �debugrE r rl r6 r< r rm � xmltodictr% rn ro �json�dumps�loadsr+ �reason) rI r( r rv �
error_content�json_error_content�return_error_json�
error_desc�
error_coder r r
r6 � s �
�
z
Bandwidth.getNc C s t j|| j||d�}d|jkr�t�|j�� �}t� |�}t�
|�}|dkr:|d d d d } |d d d d }
n:|d krO|d
d d } |d
d d }
n%|d
krd|d d d } |d d d }
n|d d d } |d d d }
t d� |j|j
|
| ���|j�d�S )N�r< �data�headersre �order�
OrderResponse� ErrorListr~ r r� � subscription�SubscriptionResponse�ResponseStatus� ErrorCode� tn_option�TnOptionOrderResponser� �Location)rl �postr< rm r� r% rn ro r� r� r� r+ rE r� r� r6 ) rI r( r� r� r7 rv r� r� r� r� r� r r r
�post_tn� s(
� zBandwidth.post_tnc C �> t j|| j||d�}d|jkr td�|j|j|j�� ���|S �Nr� re �*STATUS_CODE:{} - CATEGORY: {} - DETAIL: {}) rl r� r< rm r+ rE r� rn ro �rI r( r� r� rv r r r
�post_sip� �
�zBandwidth.post_sipc C r� r� ) rl �putr< rm r+ rE r� rn ro r� r r r
�put_sip� r� zBandwidth.put_sipc C �. t j|| j||d�}t�d�|�� |j�� S )Nr� zThe msg request data: {}�rl r� r< rG rH rE rn ro r� r r r
�
post_msg_json� �
zBandwidth.post_msg_jsonc C r� )Nr� zThe request data: {}r� r� r r r
�post_call_json� r� zBandwidth.post_call_jsonc C sL t �d�|�� tj|| jd�}d|jkr#td�|j|j|j �
� ���|jS )Nz
DELETE {}
�r< re r� ) rG r� rE rl �deleter< rm r+ r� rn ro �rI r( rv r r r
r� � s
�zBandwidth.delete)Fr )r, r- r. rJ �propertyrN rQ rS rU rW rY r[ r] r_ rw ry r6 r� r� r� r� r� r� r r r r
r: ? s:
r: c @ s e Zd Zddd�Zdd� ZdS )�
CollectionNc C s( ||| _ | _| j �| j�| _|| _d S r )�client�name� resource_url�base_url� child_class)rI r� r� r� r r r
rJ � �
zCollection.__init__c C s d� | j|�}| �| j|�S �Nr; )rE r� r� r� )rI �id_r( r r r
� __getitem__� s zCollection.__getitem__r )r, r- r. rJ r� r r r r
r� � s
r� c @ � e Zd Zdd� Zdd� ZdS )rL c C sL |d| _ | _| j �| j�| _t�d�| j�� t�d�|j�� d | _d S )N�availableNumberszThe base url is: {}z$The client account id looks like: {}) r� r� ry r� rG rH rE r= r� �rI r� r r r
rJ � s
zAvailableNumbers.__init__c K s0 d� | j�}t�| jj|fi |���}t�|�S �N�{})rE r� r� r% r� r6 r� r� )rI r r( rv r r r
�search� s
zAvailableNumbers.searchN)r, r- r. rJ r� r r r r
rL � s rL c @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd S ) rP c C �( |d| _ | _| j �| j�| _d | _d S )NrQ �r� r� ry r� r� r� r r r
rJ � r� zSubscriptions.__init__c C s� d� | j�}t�d�}t|d|� t�|d�}t|d|� t|d|� t�|d�}t�|d�}t|d | jj� t|d
| jj� t� |�} d d i}
| j�
|| |
d
�S )Nr� � Subscription� OrderType�CallbackSubscription�URL�Expiry�CallbackCredentials�BasicAuthentication�Username�Password� Content-Type� application/xml; charset=UTF-8r� ) rE r� r �Elementr" r r� r> r? �tostringr� ) rI �
order_type� callback_url�expiryr( �root�callback_subscription_elt�callback_credentials_elt�callback_auth_elt�
subscribe_xmlr� r r r
� subscribe� s
zSubscriptions.subscribec C s$ | j �| j�| _| j �d�| j��S r� �r� ry r� r� r6 rE rM r r r
�all_subscriptions s z Subscriptions.all_subscriptionsc C �& | j �| j�| _| j �d�| j|��S r� r� �rI r� r r r
�single_subscription � z!Subscriptions.single_subscriptionc C r� r� )r� ry r� r� r� rE r� r r r
�delete_subscription r� z!Subscriptions.delete_subscriptionN)r, r- r. rJ r� r� r� r� r r r r
rP � s rP c @ �$ e Zd Zdd� Zdd� Zdd� ZdS )rR c C r� )N�ordersr� r� r r r
rJ r� zPhoneNumbers.__init__c
C s� d� | j�}t�d�}t|d|� t|d|� t�|d�}t�|d�}t|d|� t|d| jj� t|d | jj� t� |�}t
� d
� |�� d d i} | j� ||| d
�S )Nr� �Order�CustomerOrderId�Name� ExistingTelephoneNumberOrderType�TelephoneNumberList�TelephoneNumber�SiteId�PeerId�The xml looks like: {}r� r� r� )
rE r� r r� r" r r� r@ rA r� rG rH r� )
rI �partner_account_idr� � phonenumberr( r� �existing_pn_order�pn_list� order_xmlr� r r r
r� s
zPhoneNumbers.orderc C s~ d� | j�d��}t�d�}t|d|� t�|d�}t�|d�}t|d|� t�|�}t� d� |�� d d
i}| j�
|||�S ) Nr� � disconnects� DisconnectTelephoneNumberOrderr� �"DisconnectTelephoneNumberOrderTyper� r� r� r� r� ) rE r� ry r r� r" r r� rG rH r� ) rI �partner_account_namer� r( r� �disconnect_pn_orderr� �disconnect_xmlr� r r r
�
disconnect" s
zPhoneNumbers.disconnectN)r, r- r. rJ r� r� r r r r
rR
s rR c @ � e Zd Zdd� Zddd�ZdS )rZ c C r� )Nr[ r� r� r r r
rJ 0 r� zMessages.__init__Nc
C s^ d� | j�}|r|||| jj||d�}n
|||| jj|d�}t�|�}ddi} | j�||| �S )Nr� )�to�fromr �
applicationIdrY r )r� r� r r� r r� �application/json)rE r� r� rB r� r� r� )
rI �m_to�m_from�m_bodyrY �m_tagr( r� � json_datar� r r r
�create5 s$ ��
zMessages.create�NN)r, r- r. rJ r� r r r r
rZ / � rZ c @ sB e Zd Zdd� Z ddd�Zdd� Zd d
� Zd d � Zdd
d�ZdS )r\ c C r� )N�callsr� r� r r r
rJ K r� zPhoneCall.__init__� Nc
C sJ d� | j�} ||| jj||||||d� }
t�|
�} ddi} | j�| | | �S )Nr� ) r� r� r� � answerUrl�
disconnectUrl�answerFallbackUrl� callTimeoutr �machineDetectionr� r� )rE r� r� rC r� r� r� )
rI �c_from�c_to�answer_callback_url� answer_fallback_callback_url�disconnect_callback_url� call_timeoutr �machine_detectionr( r� r� r� r r r
r� P s �
zPhoneCall.createc C s( d� | j||�}tj|| jjdd�}|S )Nz{}/{}/recordings/{}/mediaT�r< �stream�rE r� rl r6 r� r< )rI �call_id� recording_idr( rv r r r
� recording` s �zPhoneCall.recordingc C s6 d� | j||�}tj|| jjd�}t�|j� � �}|S )Nz!{}/{}/recordings/{}/transcriptionr� �
rE r� rl r6 r� r< r� r� rn ro )rI r r r( rv �r_jsonr r r
�
transcriptionh s �zPhoneCall.transcriptionc C s4 d� | j|�}tj|| jjd�}t�|j� � �}|S �Nr; r� r )rI r r( rv r r r r
rH p s �zPhoneCall.infoc
C s> d� | j|�}||||d�}t�|�}ddi} | j�||| �S )Nr; )�state� redirectUrl�redirectFallbackUrlr r� r� )rE r� r� r� r� r� )
rI r r � redirect_url�redirect_fallback_urlr r( r� r� r� r r r
rh x s �
zPhoneCall.update)r NN)NNN) r, r- r. rJ r� r r rH rh r r r r
r\ J s
�r\ c @ r� )rT c C r� )N� tnoptionsr� r� r r r
rJ � r� z PhoneNumbersOptions.__init__Nc C s� d� | j�}t�d�}t|d|� t�|d�}t�|d�} t| d|� |dkrHt�| d�}
|rBt|
d |� t|
d
|� t|
d d � nt|
d d
� t�| d�} t| d|� t�|�} t�d� | �� ddi}
| j �
|| |
d�S )Nr� �
TnOptionOrderr� �TnOptionGroups�
TnOptionGroup�Sms�on� A2pSettings� MessageClass�
CampaignId�Action� asSpecified� unchanged�TelephoneNumbersr� r� r� r� r� ) rE r� r r� r" r r� rG rH r� r� )rI r� r� �
sms_option�sms_campaign_id�sms_campaign_classr( r� �tn_options_groups�tn_options_group� sms_settingsr� r� r� r r r
rh � s&
zPhoneNumbersOptions.updater� )r, r- r. rJ rh r r r r
rT � r� rT c @ r� )rV c C r� )N�inserviceNumbersr� r� r r r
rJ � r� zInserviceNumber.__init__c C s& d� | j|�}tj|| jjd�}|jS r )rE r� rl r6 r� r< rm )rI �tnr( rv r r r
�validate� s �zInserviceNumber.validateN)r, r- r. rJ r2 r r r r
rV � s rV c @ r� )rX c C r� )NrY r� r� r r r
rJ � r� zMedia.__init__c C s& d� | j�}tj|| jjdd�}|jS )Nr� Tr )rE r� rl r6 r� r< rn r� r r r
�
list_media� s �zMedia.list_mediac C s& d� | j|�}tj|| jjdd�}|S )Nr; Tr r )rI �
media_namer( rv r r r
� get_media� s �zMedia.get_mediaN)r, r- r. rJ r3 r5 r r r r
rX � s rX c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S )
r^ c C r� )Nr_ r� r� r r r
rJ � r� zRealms.__init__c C s� d� | j|�}t�d�}t�|d�}t|d|� |rP|d | d | �� }t�|�� � } |d | d | d | �� }
t�|
�� � } t|d| � t|d| � t|d | j
j � t� |�} t
�d
� | �� d d i}
| j
�|| |
�S )
Nz{}/{}/sipcredentials�SipCredentials�
SipCredential�UserName�:�@�Hash1�Hash1b�HttpVoiceV2AppIdr� r� r� )rE r� r r� r r" �encode�hashlib�md5� hexdigestr� rC r� rG rH r� )rI �realm_id�realm� sip_username� sip_passwordr( r� �sip_cred�hash_1_composite�hash_1�hash_1_b_composite�hash_1_br� r� r r r
�create_sip_credentials� s
z Realms.create_sip_credentialsc C s, d� | j||�}t�d� |�� | j�|�S )N�{}/{}/sipcredentials/{}zThe url is: {})rE r� rG rH r� r� )rI rB � endpoint_idr( r r r
�delete_sip_credentials� s z Realms.delete_sip_credentialsc C s� d� | j||�}t�d�}|rE|d | d | �� }t�|��� } |d | d | d | �� }
t�|
��� } t|d| � t|d| � t|d|� t|d|� t|d | j j
� t� |�} t �
d
� | �� d d i}
| j �|| |
�S )
NrL r7 r9 r: r; r< �Realm�RealmIdr= r� r� r� )rE r� r r� r> r? r@ rA r" r� rC r� rG rH r� )rI rB rC rM rD rE r( r� rG rH rI rJ r� r� r r r
�update_sip_credentials� s
z Realms.update_sip_credentialsN)r, r- r. rJ rK rN rQ r r r r
r^ � s
r^ )%r4 r� �logging�xml.etree.ElementTree�etree� ElementTreer r� � urllib.parser$ rl r? �
requests.authr � buyercall.blueprints.filtersr � getLoggerr, rG r r" r) � Exceptionr+ r9 �objectr: r� rL rP rR rZ r\ rT rV rX r^ r r r r
�<module> s8
"":