File: //home/arjun/projects/buyercall/buyercall/blueprints/mobile/__pycache__/models.cpython-310.pyc
o
�we�. � @ s� d dl Z d dlmZ d dlmZ d dlmZ d dlmZ d dl m Z d dl
m Z d dl m
Z
e �e�ZG d d
� d
eej�ZG d d � d eej�ZdS )
� N)�hybrid_property)�
ResourceMixin)�db)� bw_client)�datetime)�and_)� load_onlyc @ s� e Zd ZdZejejdd�Zeje�d�dd�Z eje�d�ddd�Z
eje�d�dd�Z eje�d�dd�Z eje�d �ddd�Z
eje�d
�dd�Zejejd dd �Zejejejd
dddd�ddd�Zejejejddddd�ddd�Zejejejddddd�ddd�Zejejejddddd�ddd�Zeje�� dd�Zeje�� dddd�Zeje�d
�ddd �Zeje�d�ddd �Zeje�d �ddd �Zeje�d�ddd �Z eje�d �ddd �Z eje�d �ddd �Z eje�d �ddd �Z eje�d�ddd �Z eje�d�ddd �Z!eje�d�ddd �Z"eje�d �ddd �Z#eje�d�ddd �Z$eje�d�ddd �Z%eje�d�ddd �Z&eje�d�ddd �Z'eje�d �ddd �Z(eje�d �ddd �Z)eje�d
�ddd �Z*eje�d �ddd �Z+eje�d �ddd �Z,e-d d � �Z.e.j/d d � �Z.e-d d!� �Z0e1d"d#� �Z2e1 $d/d%d&��Z3e1d'd(� �Z4e1d)d*� �Z5e1d+d,� �Z6e1d-d.� �Z7d$S )0�Endpoint�
sip_endpointsT�� primary_key� F��nullable� �r �index�@ � �t)�server_default�defaultzphonenumbers.id�sip_inbound_fkey�CASCADEzSET NULL��name�onupdate�ondelete�r r z agents.id�sip_agent_fkeyzpartnership_accounts.id� sip_partnership_account_fkeyzsip_domains.id�sip_domain_fkey�0�r r r � �r r c C s | j o| j jpdS �Nr$ )�inbound�
friendly_name��self� r+ �D/home/arjun/projects/buyercall/buyercall/blueprints/mobile/models.py�sourceL s ��zEndpoint.sourcec C s ddl m} |jS )N� )�Phone)�phonenumbers.modelsr/ r( )�clsr/ r+ r+ r, r- R s c C s | j ot| j�p dS r& )r' �str�
inbound_idr) r+ r+ r, � source_idX s ��zEndpoint.source_idc C sR t j�tt j|kt j|k���� }|dur'd|_d|_t �
� |_ t j
�� dS dS )zf
Deactivate sip endpoint. The is_deactivated flag will be set.
:return: bool
NTF)r �query�filterr �id�partnership_account_id�first�is_deactivated�enabledr �now�deactivated_onr �session�commit)r1 �id_r8 �endpointr+ r+ r, �
deactivate^ s ��
zEndpoint.deactivateNc C s> t ||||||||| |
| | |
|d�}tj�|� tj�� dS )zA
Create new sip endpoint.
:return: bool
)� description�provider� provider_id�sip_uri� sip_username� sip_passwordr; r3 �agent_idr8 � domain_idr: �
sip_hash_1� sip_hash_1_bT)r r r> �addr? )r1 rC rD rE rF rG rH r; r3 rI r8 rJ r: �hash_1�hash_1_b� new_endpointr+ r+ r, �createq s �
zEndpoint.createc C sN t j�tt j|kt j|k���� }|dur%||_||_||_ t
j � � dS dS )�E
Update the endpoint details.
:return: bool
NTF)
r r5 r6 r r7 r8 r9 rH r; rI r r> r? )r1 r@ r8 rH r; rI rA r+ r+ r, �update� s �
zEndpoint.updatec C s4 t j�tt j|kt j�d����� }|du rdS dS )z[
Check to see if the username exists in the domain.
:return: bool
FNT)r r5 r6 r rG r: �is_r9 )r1 rG rA r+ r+ r, �api_username_check� s �zEndpoint.api_username_checkc C sL | j �t| j|k| j�d����� }t�d� |j
�� |du r#d}|S |j
S )z^
Return the agent id associated with the sip endpoint.
:return: bool
FzThe sip agent id is:{}N) r5 r6 r rF r: rT r9 �log�info�formatrI )r1 rF rA rI r+ r+ r, � sip_agent_id� s $zEndpoint.sip_agent_idc
C s� z�|du r|du r|du rW dS t j�tt j|kt j|k���� }tj�tj|jk��� }ddl m
} | j�| j|j k��� }
t |
jdd�} |r�|j
} |r�||_ddl m}
|
j�|
j|k��� }ddlm}m} ||j||j|j|j�}|r�||_
| r�|| � |r�||_|r�||_|r�||_tj�� |j d kr�| j j |j|j |j |j|d
� W dS W d S t!y� } zt"�#d �$|�� W Y d}~d S d}~ww )
rR NTr. )� Partnership�mobile)�tn_type)�PartnershipAccount)�qr_code�delete_qr_code� bandwidth)�realm_id�realm� endpoint_idrG rH Fz)Error updating mobile endpoint. Error: {})%r r5 r6 r r7 r8 r9 �DomainrJ �partnership.modelsrZ �partnership_idr �qr_urlrH r] � mobile.tasksr^ r_ rG r �cloud_idr; rC rI r r> r? rD �realms�update_sip_credentials� sip_realmrE � ExceptionrV �errorrX )r1 r@ r8 rH �sip_descriptionr; rI rA �domainrZ �partner�client�
old_qr_urlr] �partnership_actr^ r_ �qr�er+ r+ r, �
api_update� sp �� ���
���zEndpoint.api_update)NN)8�__name__�
__module__� __qualname__�
__tablename__r �Column�Integerr7 �StringrC rD rE rF rG rH �Booleanr; �
ForeignKeyr3 rI r8 rJ �DateTimer= r: � device_token�selector�app_id�
install_id�imei� unique_id�build�platform�platform_version�version�app_name�locale�cpu�device�production_build�last_sms_received_id�last_sms_sent_idrg rK rL r r- �
expressionr4 � classmethodrB rQ rS rU rY rw r+ r+ r+ r, r s� �� �� �� �� �
�
r c @ s e Zd ZdZejejdd�Zeje�d�dd�Z eje�d�ddd�Z
eje�d �dd�Z eje�d�ddd�Z ejejej
d
d d d d
�ddd�Zeje�� dd�Zeje�� dddd�Zeje�d �dd�Zeje�� dddd�Zeje�d�ddd�Zeje�d�ddd�ZdS )rd � sip_domainsTr r Fr � r r
zpartnerships.id�sip_domain_partnership_fkeyr r r r" r# r r$ r% r N)rx ry rz r{ r r| r} r7 r~ rJ r rC rD r� rf r� r= r r: ri �default_domain�call_urirl r+ r+ r+ r, rd s, �� � �rd )�logging�sqlalchemy.ext.hybridr � buyercall.lib.util_sqlalchemyr �buyercall.extensionsr � buyercall.lib.util_bandwidthr r �
sqlalchemyr �sqlalchemy.ormr � getLoggerrx rV �Modelr rd r+ r+ r+ r, �<module> s
{