CGM_Public/pretix_cgo
1
0
Fork 0
forked from CGM_Public/pretix_original
Code Pull Requests Actions Activity

AsyncFormTask: Pass session key

Browse Source
This commit is contained in:
Raphael Michel
2021-05-30 16:16:18 +02:00
parent 39dd8a1a64
commit 438ff3f5ea
1 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/pretix/base/views/tasks.py
View File

@@ -20,6 +20,7 @@
# <https://www.gnu.org/licenses/>. # <https://www.gnu.org/licenses/>.
# #
import logging import logging
from importlib import import_module
import celery.exceptions import celery.exceptions
import pytz import pytz
@@ -204,7 +205,7 @@ class AsyncFormView(AsyncMixin, FormView):
known_errortypes = ['ValidationError'] known_errortypes = ['ValidationError']
def __init_subclass__(cls): def __init_subclass__(cls):
def async_execute(self, *, request_path, form_kwargs, locale, tz, organizer=None, event=None, user=None): def async_execute(self, *, request_path, form_kwargs, locale, tz, organizer=None, event=None, user=None, session_key=None):
view_instance = cls() view_instance = cls()
form_kwargs['data'] = QueryDict(form_kwargs['data']) form_kwargs['data'] = QueryDict(form_kwargs['data'])
req = RequestFactory().post( req = RequestFactory().post(
@@ -220,6 +221,10 @@ class AsyncFormView(AsyncMixin, FormView):
view_instance.request.organizer = organizer view_instance.request.organizer = organizer
if user: if user:
view_instance.request.user = User.objects.get(pk=user) view_instance.request.user = User.objects.get(pk=user)
if session_key:
engine = import_module(settings.SESSION_ENGINE)
self.SessionStore = engine.SessionStore
view_instance.request.session = self.SessionStore(session_key)
with translation.override(locale), timezone.override(pytz.timezone(tz)): with translation.override(locale), timezone.override(pytz.timezone(tz)):
form_class = view_instance.get_form_class() form_class = view_instance.get_form_class()
@@ -276,6 +281,8 @@ class AsyncFormView(AsyncMixin, FormView):
kwargs['user'] = self.request.user.pk kwargs['user'] = self.request.user.pk
if hasattr(self.request, 'event'): if hasattr(self.request, 'event'):
kwargs['event'] = self.request.event.pk kwargs['event'] = self.request.event.pk
if hasattr(self.request, 'session'):
kwargs['session_key'] = self.request.session.session_key
try: try:
res = type(self).async_execute.apply_async(kwargs=kwargs) res = type(self).async_execute.apply_async(kwargs=kwargs)