37 lines
1.2 KiB
Python
37 lines
1.2 KiB
Python
"""Account app celery tasks."""
|
|
import logging
|
|
|
|
from celery import shared_task
|
|
from django.utils.translation import gettext_lazy as _
|
|
|
|
from . import models
|
|
|
|
logging.basicConfig(format='[%(levelname)s] %(message)s', level=logging.INFO)
|
|
logger = logging.getLogger(__name__)
|
|
|
|
|
|
@shared_task
|
|
def send_reset_password_email(request_id):
|
|
"""Send email to user for reset password."""
|
|
try:
|
|
obj = models.ResetPasswordToken.objects.get(id=request_id)
|
|
user = obj.user
|
|
user.send_email(subject=_('Password resetting'),
|
|
message=obj.reset_password_template)
|
|
except:
|
|
logger.error(f'METHOD_NAME: {send_reset_password_email.__name__}\n'
|
|
f'DETAIL: Exception occurred for ResetPasswordToken instance: '
|
|
f'{request_id}')
|
|
|
|
|
|
@shared_task
|
|
def confirm_new_email_address(user_id):
|
|
"""Send email to user new email."""
|
|
try:
|
|
user = models.User.objects.get(id=user_id)
|
|
user.send_email(subject=_('Validate new email address'),
|
|
message=user.change_email_template)
|
|
except:
|
|
logger.error(f'METHOD_NAME: {confirm_new_email_address.__name__}\n'
|
|
f'DETAIL: Exception occurred for user: {user_id}')
|