File: //home/arjun/projects/buyercall/buyercall/__pycache__/app.cpython-310.pyc
o
�we� � @ s� d dl mZmZmZ d dlmZ d dlmZ d dlm Z m
Z
m Z m Z m
Z
mZmZmZmZmZ d dlmZmZ g d�Zddd �Zedfd
d �Zdd d
�ZdS )� )�Flask�has_request_context�request)�Celery)�User)
�api_keys�
blueprints�error_templates�exception_handler�
extensions�logging_handler�
middleware�template_processors�context_handlers�api_error_handlers)�authentication�locale)z#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.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)�broker�result_backendT)�forcec s> e Zd ZdZdZdd� Zd
�� fdd� Z��fdd �Z� ZS ) z&create_celery_app.<locals>.ContextTaskT�_flask_request_contextc S sZ t � sdS tjtjtjttj�d�}dtjv r&tjtj�d�d d� |d< ||| j < dS )zIncludes all the information about current HTTP request context
as an additional argument to the task.
N)�path�base_url�method�headers�?� � query_string)
r r r �url_rootr �dictr �url�find�CONTEXT_ARG_NAME)�self�kwargs�context� r( �//home/arjun/projects/buyercall/buyercall/app.py�_include_request_context> s �
z?create_celery_app.<locals>.ContextTask._include_request_contextNc s4 |pd}|pi }| � |� t� | �j||fi |��S �Nr( )r* �super� apply_async)r% �argsr& �rest)� ContextTask� __class__r( r) r- P s
z2create_celery_app.<locals>.ContextTask.apply_asyncc s� |� | jd �}|d u st� r� j| g|�R i |��S �jdi |��� � j| g|�R i |��W d � S 1 s9w Y d S r+ )�popr$ r �__call__�test_request_context)r% r. r& r' )�TaskBase�appr( r) r3 W s $�z/create_celery_app.<locals>.ContextTask.__call__)NN) �__name__�
__module__� __qualname__�abstractr$ r* r- r3 �
__classcell__r( �r0 r5 r6 )r1 r) r0 9 s r0 ) �
create_appr � import_name�config�autodiscover_tasks�CELERY_TASK_LIST�conf�update�Task)r6 �celeryr( r< r) �create_celery_app) s
�&rF c C s� t | dd�}t||� t|� t|� t|� t|� t|� t|� t|� t |� t
|� t |� t |t
� t|d�rGt|jd�rGt|� |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)�instance_relative_config�babel_instance�locale_selector_func)r �configure_settingsr r
r r r r r r
r r r r �hasattrrH r )�application_name�settings_overrider6 r( r( r) r= c s
r= c C s: | j �d� | j jddd� d| j _|r| 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)�silent�none)r? � from_object� from_pyfile�SWAGGER_UI_DOC_EXPANSIONrC )r6 rM r( r( r) rJ � s rJ )N)�flaskr r r rE r � buyercall.blueprints.user.modelsr �buyercall.registerr r r r
r r r
r r r �buyercall.initializer r rA rF r7 r= rJ r( r( r( r) �<module> s 0
:%