34e6ef0d8d
* chore: bug fix * dev: changes in api endpoints for invitations and inbox * chore: improvements * dev: update webhook send * dev: webhook validation and fix webhook flow for app * dev: error messages for deactivation * chore: api fixes * dev: update webhook and workspace leave * chore: issue comment * dev: default values for environment variables * dev: make the user active if he was already part of project member * chore: webhook cycle and module event * dev: disable ssl for emails * dev: webhooks restructuring * dev: updated webhook configuration * dev: webhooks * dev: state get object * dev: update workspace slug validation * dev: remove deactivation flag if max retries exceeded --------- Co-authored-by: NarayanBavisetti <narayan3119@gmail.com>
101 lines
3.4 KiB
Python
101 lines
3.4 KiB
Python
# Python import
|
|
import os
|
|
|
|
# Django imports
|
|
from django.core.mail import EmailMultiAlternatives, get_connection
|
|
from django.template.loader import render_to_string
|
|
from django.utils.html import strip_tags
|
|
from django.conf import settings
|
|
|
|
# Third party imports
|
|
from celery import shared_task
|
|
from sentry_sdk import capture_exception
|
|
|
|
# Module imports
|
|
from plane.db.models import Project, User, ProjectMemberInvite
|
|
from plane.license.models import InstanceConfiguration
|
|
from plane.license.utils.instance_value import get_configuration_value
|
|
|
|
@shared_task
|
|
def project_invitation(email, project_id, token, current_site, invitor):
|
|
try:
|
|
user = User.objects.get(email=invitor)
|
|
project = Project.objects.get(pk=project_id)
|
|
project_member_invite = ProjectMemberInvite.objects.get(
|
|
token=token, email=email
|
|
)
|
|
|
|
relativelink = f"/project-invitations/?invitation_id={project_member_invite.id}&email={email}&slug={project.workspace.slug}&project_id={str(project_id)}"
|
|
abs_url = current_site + relativelink
|
|
|
|
subject = f"{user.first_name or user.display_name or user.email} invited you to join {project.name} on Plane"
|
|
|
|
context = {
|
|
"email": email,
|
|
"first_name": user.first_name,
|
|
"project_name": project.name,
|
|
"invitation_url": abs_url,
|
|
}
|
|
|
|
html_content = render_to_string(
|
|
"emails/invitations/project_invitation.html", context
|
|
)
|
|
|
|
text_content = strip_tags(html_content)
|
|
|
|
project_member_invite.message = text_content
|
|
project_member_invite.save()
|
|
|
|
# Configure email connection from the database
|
|
instance_configuration = InstanceConfiguration.objects.filter(key__startswith='EMAIL_').values("key", "value")
|
|
connection = get_connection(
|
|
host=get_configuration_value(
|
|
instance_configuration, "EMAIL_HOST", os.environ.get("EMAIL_HOST")
|
|
),
|
|
port=int(
|
|
get_configuration_value(
|
|
instance_configuration, "EMAIL_PORT", os.environ.get("EMAIL_PORT")
|
|
)
|
|
),
|
|
username=get_configuration_value(
|
|
instance_configuration,
|
|
"EMAIL_HOST_USER",
|
|
os.environ.get("EMAIL_HOST_USER"),
|
|
),
|
|
password=get_configuration_value(
|
|
instance_configuration,
|
|
"EMAIL_HOST_PASSWORD",
|
|
os.environ.get("EMAIL_HOST_PASSWORD"),
|
|
),
|
|
use_tls=bool(
|
|
get_configuration_value(
|
|
instance_configuration,
|
|
"EMAIL_USE_TLS",
|
|
os.environ.get("EMAIL_USE_TLS", "1"),
|
|
)
|
|
),
|
|
)
|
|
|
|
msg = EmailMultiAlternatives(
|
|
subject=subject,
|
|
body=text_content,
|
|
from_email=get_configuration_value(
|
|
instance_configuration,
|
|
"EMAIL_FROM",
|
|
os.environ.get("EMAIL_FROM", "Team Plane <team@mailer.plane.so>"),
|
|
),
|
|
to=[email],
|
|
connection=connection,
|
|
)
|
|
|
|
msg.attach_alternative(html_content, "text/html")
|
|
msg.send()
|
|
return
|
|
except (Project.DoesNotExist, ProjectMemberInvite.DoesNotExist) as e:
|
|
return
|
|
except Exception as e:
|
|
# Print logs if in DEBUG mode
|
|
if settings.DEBUG:
|
|
print(e)
|
|
capture_exception(e)
|
|
return
|