Coverage for website/thaliawebsite/tasks.py: 35.94%

1import logging 

2from importlib import import_module 

3 

4from django.conf import settings 

5 

6from celery import shared_task 

7from oauth2_provider.models import clear_expired 

8 

9from events import services as events_services 

10from facedetection import services as facedetection_services 

11from members import services as members_services 

12from payments import services as payments_services 

13from pizzas import services as pizzas_services 

14from reimbursements import services as reimbursements_services 

15from sales import services as sales_services 

16from utils.snippets import minimise_logentries_data 

17 

18logger = logging.getLogger(__name__) 

19 

20 

21@shared_task(bind=True, ignore_result=True) 

22def debug_task(self): 

23 print(f"Request: {self.request!r}") 

24 

25 

26@shared_task 

27def data_minimisation(): 

28 processed = members_services.execute_data_minimisation() 

29 for p in processed: 

30 logger.info(f"Removed data for {p}") 

31 

32 processed = events_services.execute_data_minimisation() 

33 for p in processed: 

34 logger.info(f"Removed registration information for {p}") 

35 

36 processed = payments_services.execute_data_minimisation() 

37 for p in processed: 

38 logger.info(f"Removed payments information for {p}") 

39 

40 processed = pizzas_services.execute_data_minimisation() 

41 for p in processed: 

42 logger.info(f"Removed food events information for {p}") 

43 

44 processed = sales_services.execute_data_minimisation() 

45 for p in processed: 

46 logger.info(f"Removed sales orders for {p}") 

47 

48 processed = facedetection_services.execute_data_minimisation() 

49 for p in processed: 

50 logger.info(f"Removed reference faces: {p}") 

51 

52 processed = members_services.execute_data_minimisation() 

53 for p in processed: 

54 logger.info(f"Removed data for {p}") 

55 

56 reimbursements_services.execute_data_minimisation() 

57 

58 processed = minimise_logentries_data() 

59 logger.info(f"Removed {processed} log entries") 

60 

61 

62@shared_task 

63def clean_up(): 

64 engine = import_module(settings.SESSION_ENGINE) 

65 engine.SessionStore.clear_expired() 

66 

67 

68@shared_task 

69def clear_tokens(): 

70 clear_expired()