mirror of
https://github.com/zulip/zulip.git
synced 2025-11-09 08:26:11 +00:00
No change in behavior. Also makes the first step towards converting all uses of settings.ZULIP_ADMINISTRATOR and settings.NOREPLY_EMAIL_ADDRESS to FromAddress.*. Once everything is converted, it will be easier to ensure that future development doesn't break backwards compatibility with the old style of settings emails.
252 lines
12 KiB
Python
252 lines
12 KiB
Python
from __future__ import absolute_import
|
|
from typing import Optional, Any
|
|
from typing import Dict, Text
|
|
|
|
from django.utils.translation import ugettext as _
|
|
from django.conf import settings
|
|
from django.contrib.auth import authenticate, update_session_auth_hash
|
|
from django.http import HttpRequest, HttpResponse
|
|
from django.shortcuts import redirect, render
|
|
from django.urls import reverse
|
|
|
|
from zerver.decorator import authenticated_json_post_view, has_request_variables, \
|
|
zulip_login_required, REQ, human_users_only
|
|
from zerver.lib.actions import do_change_password, \
|
|
do_change_enter_sends, do_change_notification_settings, \
|
|
do_change_default_desktop_notifications, do_change_autoscroll_forever, \
|
|
do_regenerate_api_key, do_change_avatar_fields, do_set_user_display_setting, \
|
|
validate_email, do_change_user_email, do_start_email_change_process
|
|
from zerver.lib.avatar import avatar_url
|
|
from zerver.lib.send_email import send_email, display_email, FromAddress
|
|
from zerver.lib.i18n import get_available_language_codes
|
|
from zerver.lib.response import json_success, json_error
|
|
from zerver.lib.upload import upload_avatar_image
|
|
from zerver.lib.validator import check_bool, check_string
|
|
from zerver.lib.request import JsonableError
|
|
from zerver.lib.users import check_change_full_name
|
|
from zerver.lib.timezone import get_all_timezones
|
|
from zerver.models import UserProfile, Realm, name_changes_disabled, \
|
|
EmailChangeStatus
|
|
from confirmation.models import EmailChangeConfirmation
|
|
|
|
@zulip_login_required
|
|
def confirm_email_change(request, confirmation_key):
|
|
# type: (HttpRequest, str) -> HttpResponse
|
|
user_profile = request.user
|
|
if user_profile.realm.email_changes_disabled:
|
|
raise JsonableError(_("Email address changes are disabled in this organization."))
|
|
|
|
confirmation_key = confirmation_key.lower()
|
|
obj = EmailChangeConfirmation.objects.confirm(confirmation_key)
|
|
confirmed = False
|
|
new_email = old_email = None # type: Text
|
|
if obj:
|
|
confirmed = True
|
|
assert isinstance(obj, EmailChangeStatus)
|
|
new_email = obj.new_email
|
|
old_email = obj.old_email
|
|
|
|
do_change_user_email(obj.user_profile, obj.new_email)
|
|
|
|
context = {'realm': obj.realm,
|
|
'new_email': new_email,
|
|
}
|
|
send_email('zerver/emails/notify_change_in_email', old_email,
|
|
from_address=FromAddress.SUPPORT, context=context)
|
|
|
|
ctx = {
|
|
'confirmed': confirmed,
|
|
'new_email': new_email,
|
|
'old_email': old_email,
|
|
}
|
|
return render(request, 'confirmation/confirm_email_change.html', context=ctx)
|
|
|
|
@human_users_only
|
|
@has_request_variables
|
|
def json_change_ui_settings(request, user_profile,
|
|
autoscroll_forever=REQ(validator=check_bool,
|
|
default=None),
|
|
default_desktop_notifications=REQ(validator=check_bool,
|
|
default=None)):
|
|
# type: (HttpRequest, UserProfile, Optional[bool], Optional[bool]) -> HttpResponse
|
|
|
|
result = {}
|
|
|
|
if autoscroll_forever is not None and \
|
|
user_profile.autoscroll_forever != autoscroll_forever:
|
|
do_change_autoscroll_forever(user_profile, autoscroll_forever)
|
|
result['autoscroll_forever'] = autoscroll_forever
|
|
|
|
if default_desktop_notifications is not None and \
|
|
user_profile.default_desktop_notifications != default_desktop_notifications:
|
|
do_change_default_desktop_notifications(user_profile, default_desktop_notifications)
|
|
result['default_desktop_notifications'] = default_desktop_notifications
|
|
|
|
return json_success(result)
|
|
|
|
@authenticated_json_post_view
|
|
@has_request_variables
|
|
def json_change_settings(request, user_profile,
|
|
full_name=REQ(default=""),
|
|
email=REQ(default=""),
|
|
old_password=REQ(default=""),
|
|
new_password=REQ(default=""),
|
|
confirm_password=REQ(default="")):
|
|
# type: (HttpRequest, UserProfile, Text, Text, Text, Text, Text) -> HttpResponse
|
|
if not (full_name or new_password or email):
|
|
return json_error(_("No new data supplied"))
|
|
|
|
if new_password != "" or confirm_password != "":
|
|
if new_password != confirm_password:
|
|
return json_error(_("New password must match confirmation password!"))
|
|
if not authenticate(username=user_profile.email, password=old_password):
|
|
return json_error(_("Wrong password!"))
|
|
do_change_password(user_profile, new_password)
|
|
# In Django 1.10, password changes invalidates sessions, see
|
|
# https://docs.djangoproject.com/en/1.10/topics/auth/default/#session-invalidation-on-password-change
|
|
# for details. To avoid this logging the user out of his own
|
|
# session (which would provide a confusing UX at best), we
|
|
# update the session hash here.
|
|
update_session_auth_hash(request, user_profile)
|
|
# We also save the session to the DB immediately to mitigate
|
|
# race conditions. In theory, there is still a race condition
|
|
# and to completely avoid it we will have to use some kind of
|
|
# mutex lock in `django.contrib.auth.get_user` where session
|
|
# is verified. To make that lock work we will have to control
|
|
# the AuthenticationMiddleware which is currently controlled
|
|
# by Django,
|
|
request.session.save()
|
|
|
|
result = {} # type: Dict[str, Any]
|
|
new_email = email.strip()
|
|
if user_profile.email != email and new_email != '':
|
|
if user_profile.realm.email_changes_disabled:
|
|
return json_error(_("Email address changes are disabled in this organization."))
|
|
error, skipped = validate_email(user_profile, new_email)
|
|
if error or skipped:
|
|
return json_error(error or skipped)
|
|
|
|
do_start_email_change_process(user_profile, new_email)
|
|
result['account_email'] = _("Check your email for a confirmation link.")
|
|
|
|
if user_profile.full_name != full_name and full_name.strip() != "":
|
|
if name_changes_disabled(user_profile.realm):
|
|
# Failingly silently is fine -- they can't do it through the UI, so
|
|
# they'd have to be trying to break the rules.
|
|
pass
|
|
else:
|
|
# Note that check_change_full_name strips the passed name automatically
|
|
result['full_name'] = check_change_full_name(user_profile, full_name, user_profile)
|
|
|
|
return json_success(result)
|
|
|
|
@human_users_only
|
|
@has_request_variables
|
|
def update_display_settings_backend(request, user_profile,
|
|
twenty_four_hour_time=REQ(validator=check_bool, default=None),
|
|
default_language=REQ(validator=check_string, default=None),
|
|
left_side_userlist=REQ(validator=check_bool, default=None),
|
|
emoji_alt_code=REQ(validator=check_bool, default=None),
|
|
emojiset=REQ(validator=check_string, default=None),
|
|
timezone=REQ(validator=check_string, default=None)):
|
|
# type: (HttpRequest, UserProfile, Optional[bool], Optional[str], Optional[bool], Optional[bool], Optional[Text], Optional[Text]) -> HttpResponse
|
|
if (default_language is not None and
|
|
default_language not in get_available_language_codes()):
|
|
raise JsonableError(_("Invalid language '%s'" % (default_language,)))
|
|
|
|
if (timezone is not None and
|
|
timezone not in get_all_timezones()):
|
|
raise JsonableError(_("Invalid timezone '%s'" % (timezone,)))
|
|
|
|
if (emojiset is not None and
|
|
emojiset not in UserProfile.emojiset_choices()):
|
|
raise JsonableError(_("Invalid emojiset '%s'" % (emojiset,)))
|
|
|
|
request_settings = {k: v for k, v in list(locals().items()) if k in user_profile.property_types}
|
|
result = {} # type: Dict[str, Any]
|
|
for k, v in list(request_settings.items()):
|
|
if v is not None and getattr(user_profile, k) != v:
|
|
do_set_user_display_setting(user_profile, k, v)
|
|
result[k] = v
|
|
|
|
return json_success(result)
|
|
|
|
@human_users_only
|
|
@has_request_variables
|
|
def json_change_notify_settings(request, user_profile,
|
|
enable_stream_desktop_notifications=REQ(validator=check_bool,
|
|
default=None),
|
|
enable_stream_sounds=REQ(validator=check_bool,
|
|
default=None),
|
|
enable_desktop_notifications=REQ(validator=check_bool,
|
|
default=None),
|
|
enable_sounds=REQ(validator=check_bool,
|
|
default=None),
|
|
enable_offline_email_notifications=REQ(validator=check_bool,
|
|
default=None),
|
|
enable_offline_push_notifications=REQ(validator=check_bool,
|
|
default=None),
|
|
enable_online_push_notifications=REQ(validator=check_bool,
|
|
default=None),
|
|
enable_digest_emails=REQ(validator=check_bool,
|
|
default=None),
|
|
pm_content_in_desktop_notifications=REQ(validator=check_bool,
|
|
default=None)):
|
|
# type: (HttpRequest, UserProfile, Optional[bool], Optional[bool], Optional[bool], Optional[bool], Optional[bool], Optional[bool], Optional[bool], Optional[bool], Optional[bool]) -> HttpResponse
|
|
result = {}
|
|
|
|
# Stream notification settings.
|
|
|
|
req_vars = {k: v for k, v in list(locals().items()) if k in user_profile.notification_setting_types}
|
|
|
|
for k, v in list(req_vars.items()):
|
|
if v is not None and getattr(user_profile, k) != v:
|
|
do_change_notification_settings(user_profile, k, v)
|
|
result[k] = v
|
|
|
|
return json_success(result)
|
|
|
|
def set_avatar_backend(request, user_profile):
|
|
# type: (HttpRequest, UserProfile) -> HttpResponse
|
|
if len(request.FILES) != 1:
|
|
return json_error(_("You must upload exactly one avatar."))
|
|
|
|
user_file = list(request.FILES.values())[0]
|
|
if ((settings.MAX_AVATAR_FILE_SIZE * 1024 * 1024) < user_file.size):
|
|
return json_error(_("Uploaded file is larger than the allowed limit of %s MB") % (
|
|
settings.MAX_AVATAR_FILE_SIZE))
|
|
upload_avatar_image(user_file, user_profile, user_profile)
|
|
do_change_avatar_fields(user_profile, UserProfile.AVATAR_FROM_USER)
|
|
user_avatar_url = avatar_url(user_profile)
|
|
|
|
json_result = dict(
|
|
avatar_url = user_avatar_url
|
|
)
|
|
return json_success(json_result)
|
|
|
|
def delete_avatar_backend(request, user_profile):
|
|
# type: (HttpRequest, UserProfile) -> HttpResponse
|
|
do_change_avatar_fields(user_profile, UserProfile.AVATAR_FROM_GRAVATAR)
|
|
gravatar_url = avatar_url(user_profile)
|
|
|
|
json_result = dict(
|
|
avatar_url = gravatar_url
|
|
)
|
|
return json_success(json_result)
|
|
|
|
@has_request_variables
|
|
def regenerate_api_key(request, user_profile):
|
|
# type: (HttpRequest, UserProfile) -> HttpResponse
|
|
do_regenerate_api_key(user_profile, user_profile)
|
|
json_result = dict(
|
|
api_key = user_profile.api_key
|
|
)
|
|
return json_success(json_result)
|
|
|
|
@has_request_variables
|
|
def change_enter_sends(request, user_profile,
|
|
enter_sends=REQ(validator=check_bool)):
|
|
# type: (HttpRequest, UserProfile, bool) -> HttpResponse
|
|
do_change_enter_sends(user_profile, enter_sends)
|
|
return json_success()
|