File: //home/arjun/projects/buyercall_forms/buyercall/buyercall/__pycache__/app.cpython-38.pyc
U
k�if� � @ s� d dl mZmZmZ d dlmZ d dlmZ d dlm Z m
Z
m Z m Z m
Z
mZmZmZ d dlmZmZ dddd d
d d d
dddddddddddgZd dd�Zedfd d �Zd!d d �ZdS )"� )�Flask�has_request_context�request)�Celery)�User)�api_keys�
blueprints�error_templates�exception_handler�
extensions�logging_handler�
middleware�template_processors)�authentication�localez#buyercall.blueprints.activity.tasksz buyercall.blueprints.user.tasksz buyercall.blueprints.issue.tasksz"buyercall.blueprints.billing.tasksz buyercall.blueprints.admin.tasksz+buyercall.blueprints.contacts.contact_tasksz"buyercall.blueprints.widgets.tasksz%buyercall.blueprints.widgets.bw_tasksz*buyercall.blueprints.form_leads.form_tasksz"buyercall.blueprints.reports.tasksz&buyercall.blueprints.partnership.tasksz'buyercall.blueprints.phonenumbers.tasksz*buyercall.blueprints.phonenumbers.bw_tasksz6buyercall.blueprints.phonenumbers.bw_operational_tasksz!buyercall.blueprints.mobile.tasksz%buyercall.blueprints.sms.bw_sms_tasksz%buyercall.blueprints.sms.tw_sms_tasksz buyercall.blueprints.sms.tasksz#buyercall.blueprints.sysadmin.tasksNc sj �pt � �t�j�jd �jd d�}|jtdd� |j��j� |j�G � ��fdd�d��� � |_|S )z�
Create a new celery object and tie together the celery config to the app's
config. Wrap all tasks in the context of the application.
:param app: Flask app
:return: Celery app
�CELERY_BROKER_URL�CELERY_RESULT_BACKEND)ZbrokerZresult_backendT)�forcec s> e Zd ZdZdZdd� Zd
�� fdd� Z��fdd �Z� ZS ) z&create_celery_app.<locals>.ContextTaskTZ_flask_request_contextc S sZ t � s
dS tjtjtjttj�d�}dtjkrLtjtj�d�d d� |d< ||| j < dS )zIncludes all the information about current HTTP request context
as an additional argument to the task.
N)�pathZbase_url�method�headers�?� Z query_string)
r r r Zurl_rootr �dictr �url�find�CONTEXT_ARG_NAME)�self�kwargs�context� r �?/home/arjun/projects/buyercall_forms/buyercall/buyercall/app.py�_include_request_context> s �
z?create_celery_app.<locals>.ContextTask._include_request_contextNc s0 |pd}|pi }| � |� t� | �j||f|�S )Nr )r" �super� apply_async)r �argsr �rest)� ContextTask� __class__r r! r$ P s
z2create_celery_app.<locals>.ContextTask.apply_asyncc
sd |� | jd �}|d ks t� r.� j| f|�|�S �jf |�� � j| f|�|�W 5 Q R � S Q R X d S )N)�popr r �__call__Ztest_request_context)r r% r r )�TaskBase�appr r! r* W s
z/create_celery_app.<locals>.ContextTask.__call__)NN) �__name__�
__module__� __qualname__Zabstractr r" r$ r* �
__classcell__r �r' r+ r, )r( r! r' 9 s
r' ) �
create_appr Z import_name�configZautodiscover_tasks�CELERY_TASK_LIST�conf�updateZTask)r, �celeryr r1 r! �create_celery_app) s
�&r8 c C st t | dd�}t||� t|� t|� t|� t|� t|� t|� t|� t |� t
|t � |j j
spt|� |S )a
Create an application using the Flask app factory pattern:
http://flask.pocoo.org/docs/0.10/patterns/appfactories
:param application_name: Name of the application
:param settings_override: Override settings
:type settings_override: dict
:return: Flask app
T)Zinstance_relative_config)r �configure_settingsr r
r r r r r
r r r Zbabel_instanceZlocale_selector_funcr )Zapplication_name�settings_overrider, r r r! r2 c s
r2 c C s: | j �d� | j jddd� d| j _|r4| j �|� | j S )z�
Modify the settings of the application (mutates the app passed in).
:param app: Flask application instance
:param settings_override: Override settings
:type settings_override: dict
:return: Add configuration settings
zconfig.settingsz settings.pyT)ZsilentZnone)r3 Z from_objectZ from_pyfileZSWAGGER_UI_DOC_EXPANSIONr6 )r, r: r r r! r9 � s r9 )N)N)Zflaskr r r r7 r Z buyercall.blueprints.user.modelsr Zbuyercall.registerr r r r
r r r
r Zbuyercall.initializer r r4 r8 r- r2 r9 r r r r! �<module> s6 (
�
: