mirror of
https://github.com/zulip/zulip.git
synced 2025-11-19 14:08:23 +00:00
Move users views into their own file.
This commit is contained in:
@@ -25,16 +25,12 @@ from zerver.models import Message, UserProfile, Stream, Subscription, Huddle, \
|
|||||||
completely_open, get_unique_open_realm, remote_user_to_email
|
completely_open, get_unique_open_realm, remote_user_to_email
|
||||||
from zerver.lib.actions import do_change_password, do_change_full_name, do_change_is_admin, \
|
from zerver.lib.actions import do_change_password, do_change_full_name, do_change_is_admin, \
|
||||||
do_activate_user, do_create_user, \
|
do_activate_user, do_create_user, \
|
||||||
internal_send_message, subscribed_to_stream, update_user_presence, do_events_register, \
|
internal_send_message, update_user_presence, do_events_register, \
|
||||||
get_status_dict, do_change_enable_offline_email_notifications, \
|
get_status_dict, do_change_enable_offline_email_notifications, \
|
||||||
do_change_enable_digest_emails, do_set_realm_name, do_set_realm_restricted_to_domain, \
|
do_change_enable_digest_emails, do_set_realm_name, do_set_realm_restricted_to_domain, \
|
||||||
do_set_realm_invite_required, do_set_realm_invite_by_admins_only, \
|
do_set_realm_invite_required, do_set_realm_invite_by_admins_only, get_default_subs, \
|
||||||
get_default_subs, do_deactivate_user, do_reactivate_user, \
|
|
||||||
user_email_is_unique, do_invite_users, do_refer_friend, compute_mit_user_fullname, \
|
user_email_is_unique, do_invite_users, do_refer_friend, compute_mit_user_fullname, \
|
||||||
do_set_muted_topics, clear_followup_emails_queue, do_change_default_all_public_streams, \
|
do_set_muted_topics, clear_followup_emails_queue, do_update_pointer, realm_user_count
|
||||||
do_change_default_events_register_stream, do_change_default_sending_stream, \
|
|
||||||
do_regenerate_api_key, do_update_pointer, do_change_avatar_source, realm_user_count
|
|
||||||
|
|
||||||
from zerver.lib.push_notifications import num_push_devices_for_user
|
from zerver.lib.push_notifications import num_push_devices_for_user
|
||||||
from zerver.forms import RegistrationForm, HomepageForm, ToSForm, \
|
from zerver.forms import RegistrationForm, HomepageForm, ToSForm, \
|
||||||
CreateUserForm, is_inactive, OurAuthenticationForm
|
CreateUserForm, is_inactive, OurAuthenticationForm
|
||||||
@@ -45,8 +41,8 @@ from zerver.lib.validator import check_string, check_list, check_bool
|
|||||||
from zerver.decorator import require_post, authenticated_json_post_view, \
|
from zerver.decorator import require_post, authenticated_json_post_view, \
|
||||||
has_request_variables, authenticated_json_view, to_non_negative_int, \
|
has_request_variables, authenticated_json_view, to_non_negative_int, \
|
||||||
JsonableError, get_user_profile_by_email, REQ, require_realm_admin
|
JsonableError, get_user_profile_by_email, REQ, require_realm_admin
|
||||||
from zerver.lib.avatar import avatar_url, get_avatar_url
|
from zerver.lib.avatar import avatar_url
|
||||||
from zerver.lib.upload import upload_message_image_through_web_client, upload_avatar_image, \
|
from zerver.lib.upload import upload_message_image_through_web_client, \
|
||||||
get_signed_upload_url, get_realm_for_filename
|
get_signed_upload_url, get_realm_for_filename
|
||||||
from zerver.lib.response import json_success, json_error
|
from zerver.lib.response import json_success, json_error
|
||||||
from zerver.lib.utils import statsd, generate_random_token
|
from zerver.lib.utils import statsd, generate_random_token
|
||||||
@@ -71,7 +67,6 @@ import hashlib
|
|||||||
import hmac
|
import hmac
|
||||||
|
|
||||||
from zerver.lib.rest import rest_dispatch as _rest_dispatch
|
from zerver.lib.rest import rest_dispatch as _rest_dispatch
|
||||||
from six.moves import map
|
|
||||||
rest_dispatch = csrf_exempt((lambda request, *args, **kwargs: _rest_dispatch(request, globals(), *args, **kwargs)))
|
rest_dispatch = csrf_exempt((lambda request, *args, **kwargs: _rest_dispatch(request, globals(), *args, **kwargs)))
|
||||||
|
|
||||||
def name_changes_disabled(realm):
|
def name_changes_disabled(realm):
|
||||||
@@ -1026,26 +1021,6 @@ def update_realm(request, user_profile, name=REQ(validator=check_string, default
|
|||||||
data['invite_by_admins_only'] = invite_by_admins_only
|
data['invite_by_admins_only'] = invite_by_admins_only
|
||||||
return json_success(data)
|
return json_success(data)
|
||||||
|
|
||||||
def get_members_backend(request, user_profile):
|
|
||||||
realm = user_profile.realm
|
|
||||||
admins = set(user_profile.realm.get_admin_users())
|
|
||||||
members = []
|
|
||||||
for profile in UserProfile.objects.select_related().filter(realm=realm):
|
|
||||||
avatar_url = get_avatar_url(
|
|
||||||
profile.avatar_source,
|
|
||||||
profile.email
|
|
||||||
)
|
|
||||||
member = {"full_name": profile.full_name,
|
|
||||||
"is_bot": profile.is_bot,
|
|
||||||
"is_active": profile.is_active,
|
|
||||||
"is_admin": (profile in admins),
|
|
||||||
"email": profile.email,
|
|
||||||
"avatar_url": avatar_url,}
|
|
||||||
if profile.is_bot and profile.bot_owner is not None:
|
|
||||||
member["bot_owner"] = profile.bot_owner.email
|
|
||||||
members.append(member)
|
|
||||||
return json_success({'members': members})
|
|
||||||
|
|
||||||
@authenticated_json_post_view
|
@authenticated_json_post_view
|
||||||
@has_request_variables
|
@has_request_variables
|
||||||
def json_upload_file(request, user_profile):
|
def json_upload_file(request, user_profile):
|
||||||
@@ -1216,228 +1191,6 @@ def events_register_backend(request, user_profile, apply_markdown=True,
|
|||||||
return json_success(ret)
|
return json_success(ret)
|
||||||
|
|
||||||
|
|
||||||
def deactivate_user_backend(request, user_profile, email):
|
|
||||||
try:
|
|
||||||
target = get_user_profile_by_email(email)
|
|
||||||
except UserProfile.DoesNotExist:
|
|
||||||
return json_error('No such user')
|
|
||||||
if target.is_bot:
|
|
||||||
return json_error('No such user')
|
|
||||||
return _deactivate_user_profile_backend(request, user_profile, target)
|
|
||||||
|
|
||||||
def deactivate_bot_backend(request, user_profile, email):
|
|
||||||
try:
|
|
||||||
target = get_user_profile_by_email(email)
|
|
||||||
except UserProfile.DoesNotExist:
|
|
||||||
return json_error('No such bot')
|
|
||||||
if not target.is_bot:
|
|
||||||
return json_error('No such bot')
|
|
||||||
return _deactivate_user_profile_backend(request, user_profile, target)
|
|
||||||
|
|
||||||
def _deactivate_user_profile_backend(request, user_profile, target):
|
|
||||||
if not user_profile.can_admin_user(target):
|
|
||||||
return json_error('Insufficient permission')
|
|
||||||
|
|
||||||
do_deactivate_user(target)
|
|
||||||
return json_success({})
|
|
||||||
|
|
||||||
def reactivate_user_backend(request, user_profile, email):
|
|
||||||
try:
|
|
||||||
target = get_user_profile_by_email(email)
|
|
||||||
except UserProfile.DoesNotExist:
|
|
||||||
return json_error('No such user')
|
|
||||||
|
|
||||||
if not user_profile.can_admin_user(target):
|
|
||||||
return json_error('Insufficient permission')
|
|
||||||
|
|
||||||
do_reactivate_user(target)
|
|
||||||
return json_success({})
|
|
||||||
|
|
||||||
@has_request_variables
|
|
||||||
def update_user_backend(request, user_profile, email,
|
|
||||||
is_admin=REQ(default=None, validator=check_bool)):
|
|
||||||
try:
|
|
||||||
target = get_user_profile_by_email(email)
|
|
||||||
except UserProfile.DoesNotExist:
|
|
||||||
return json_error('No such user')
|
|
||||||
|
|
||||||
if not user_profile.can_admin_user(target):
|
|
||||||
return json_error('Insufficient permission')
|
|
||||||
|
|
||||||
if is_admin is not None:
|
|
||||||
do_change_is_admin(target, is_admin)
|
|
||||||
return json_success({})
|
|
||||||
|
|
||||||
def avatar(request, email):
|
|
||||||
try:
|
|
||||||
user_profile = get_user_profile_by_email(email)
|
|
||||||
avatar_source = user_profile.avatar_source
|
|
||||||
except UserProfile.DoesNotExist:
|
|
||||||
avatar_source = 'G'
|
|
||||||
url = get_avatar_url(avatar_source, email)
|
|
||||||
if '?' in url:
|
|
||||||
sep = '&'
|
|
||||||
else:
|
|
||||||
sep = '?'
|
|
||||||
url += sep + request.META['QUERY_STRING']
|
|
||||||
return redirect(url)
|
|
||||||
|
|
||||||
def get_stream_name(stream):
|
|
||||||
if stream:
|
|
||||||
name = stream.name
|
|
||||||
else :
|
|
||||||
name = None
|
|
||||||
return name
|
|
||||||
|
|
||||||
def stream_or_none(stream_name, realm):
|
|
||||||
if stream_name == '':
|
|
||||||
return None
|
|
||||||
else:
|
|
||||||
stream = get_stream(stream_name, realm)
|
|
||||||
if not stream:
|
|
||||||
raise JsonableError('No such stream \'%s\'' % (stream_name, ))
|
|
||||||
return stream
|
|
||||||
|
|
||||||
@has_request_variables
|
|
||||||
def patch_bot_backend(request, user_profile, email,
|
|
||||||
full_name=REQ(default=None),
|
|
||||||
default_sending_stream=REQ(default=None),
|
|
||||||
default_events_register_stream=REQ(default=None),
|
|
||||||
default_all_public_streams=REQ(default=None, validator=check_bool)):
|
|
||||||
try:
|
|
||||||
bot = get_user_profile_by_email(email)
|
|
||||||
except:
|
|
||||||
return json_error('No such user')
|
|
||||||
|
|
||||||
if not user_profile.can_admin_user(bot):
|
|
||||||
return json_error('Insufficient permission')
|
|
||||||
|
|
||||||
if full_name is not None:
|
|
||||||
do_change_full_name(bot, full_name)
|
|
||||||
if default_sending_stream is not None:
|
|
||||||
stream = stream_or_none(default_sending_stream, bot.realm)
|
|
||||||
do_change_default_sending_stream(bot, stream)
|
|
||||||
if default_events_register_stream is not None:
|
|
||||||
stream = stream_or_none(default_events_register_stream, bot.realm)
|
|
||||||
do_change_default_events_register_stream(bot, stream)
|
|
||||||
if default_all_public_streams is not None:
|
|
||||||
do_change_default_all_public_streams(bot, default_all_public_streams)
|
|
||||||
|
|
||||||
if len(request.FILES) == 0:
|
|
||||||
pass
|
|
||||||
elif len(request.FILES) == 1:
|
|
||||||
user_file = request.FILES.values()[0]
|
|
||||||
upload_avatar_image(user_file, user_profile, bot.email)
|
|
||||||
avatar_source = UserProfile.AVATAR_FROM_USER
|
|
||||||
do_change_avatar_source(bot, avatar_source)
|
|
||||||
else:
|
|
||||||
return json_error("You may only upload one file at a time")
|
|
||||||
|
|
||||||
json_result = dict(
|
|
||||||
full_name=bot.full_name,
|
|
||||||
avatar_url=avatar_url(bot),
|
|
||||||
default_sending_stream=get_stream_name(bot.default_sending_stream),
|
|
||||||
default_events_register_stream=get_stream_name(bot.default_events_register_stream),
|
|
||||||
default_all_public_streams=bot.default_all_public_streams,
|
|
||||||
)
|
|
||||||
return json_success(json_result)
|
|
||||||
|
|
||||||
@has_request_variables
|
|
||||||
def regenerate_bot_api_key(request, user_profile, email):
|
|
||||||
try:
|
|
||||||
bot = get_user_profile_by_email(email)
|
|
||||||
except:
|
|
||||||
return json_error('No such user')
|
|
||||||
|
|
||||||
if not user_profile.can_admin_user(bot):
|
|
||||||
return json_error('Insufficient permission')
|
|
||||||
|
|
||||||
do_regenerate_api_key(bot)
|
|
||||||
json_result = dict(
|
|
||||||
api_key = bot.api_key
|
|
||||||
)
|
|
||||||
return json_success(json_result)
|
|
||||||
|
|
||||||
@has_request_variables
|
|
||||||
def add_bot_backend(request, user_profile, full_name=REQ, short_name=REQ,
|
|
||||||
default_sending_stream=REQ(default=None),
|
|
||||||
default_events_register_stream=REQ(default=None),
|
|
||||||
default_all_public_streams=REQ(validator=check_bool, default=None)):
|
|
||||||
short_name += "-bot"
|
|
||||||
email = short_name + "@" + user_profile.realm.domain
|
|
||||||
form = CreateUserForm({'full_name': full_name, 'email': email})
|
|
||||||
if not form.is_valid():
|
|
||||||
# We validate client-side as well
|
|
||||||
return json_error('Bad name or username')
|
|
||||||
|
|
||||||
try:
|
|
||||||
get_user_profile_by_email(email)
|
|
||||||
return json_error("Username already in use")
|
|
||||||
except UserProfile.DoesNotExist:
|
|
||||||
pass
|
|
||||||
|
|
||||||
if len(request.FILES) == 0:
|
|
||||||
avatar_source = UserProfile.AVATAR_FROM_GRAVATAR
|
|
||||||
elif len(request.FILES) != 1:
|
|
||||||
return json_error("You may only upload one file at a time")
|
|
||||||
else:
|
|
||||||
user_file = request.FILES.values()[0]
|
|
||||||
upload_avatar_image(user_file, user_profile, email)
|
|
||||||
avatar_source = UserProfile.AVATAR_FROM_USER
|
|
||||||
|
|
||||||
if default_sending_stream is not None:
|
|
||||||
default_sending_stream = stream_or_none(default_sending_stream, user_profile.realm)
|
|
||||||
if default_sending_stream and not default_sending_stream.is_public() and not \
|
|
||||||
subscribed_to_stream(user_profile, default_sending_stream):
|
|
||||||
return json_error('Insufficient permission')
|
|
||||||
|
|
||||||
if default_events_register_stream is not None:
|
|
||||||
default_events_register_stream = stream_or_none(default_events_register_stream,
|
|
||||||
user_profile.realm)
|
|
||||||
if default_events_register_stream and not default_events_register_stream.is_public() and not \
|
|
||||||
subscribed_to_stream(user_profile, default_events_register_stream):
|
|
||||||
return json_error('Insufficient permission')
|
|
||||||
|
|
||||||
|
|
||||||
bot_profile = do_create_user(email=email, password='',
|
|
||||||
realm=user_profile.realm, full_name=full_name,
|
|
||||||
short_name=short_name, active=True, bot=True,
|
|
||||||
bot_owner=user_profile,
|
|
||||||
avatar_source=avatar_source,
|
|
||||||
default_sending_stream=default_sending_stream,
|
|
||||||
default_events_register_stream=default_events_register_stream,
|
|
||||||
default_all_public_streams=default_all_public_streams)
|
|
||||||
json_result = dict(
|
|
||||||
api_key=bot_profile.api_key,
|
|
||||||
avatar_url=avatar_url(bot_profile),
|
|
||||||
default_sending_stream=get_stream_name(bot_profile.default_sending_stream),
|
|
||||||
default_events_register_stream=get_stream_name(bot_profile.default_events_register_stream),
|
|
||||||
default_all_public_streams=bot_profile.default_all_public_streams,
|
|
||||||
)
|
|
||||||
return json_success(json_result)
|
|
||||||
|
|
||||||
def get_bots_backend(request, user_profile):
|
|
||||||
bot_profiles = UserProfile.objects.filter(is_bot=True, is_active=True,
|
|
||||||
bot_owner=user_profile)
|
|
||||||
bot_profiles = bot_profiles.select_related('default_sending_stream', 'default_events_register_stream')
|
|
||||||
bot_profiles = bot_profiles.order_by('date_joined')
|
|
||||||
|
|
||||||
def bot_info(bot_profile):
|
|
||||||
default_sending_stream = get_stream_name(bot_profile.default_sending_stream)
|
|
||||||
default_events_register_stream = get_stream_name(bot_profile.default_events_register_stream)
|
|
||||||
|
|
||||||
return dict(
|
|
||||||
username=bot_profile.email,
|
|
||||||
full_name=bot_profile.full_name,
|
|
||||||
api_key=bot_profile.api_key,
|
|
||||||
avatar_url=avatar_url(bot_profile),
|
|
||||||
default_sending_stream=default_sending_stream,
|
|
||||||
default_events_register_stream=default_events_register_stream,
|
|
||||||
default_all_public_streams=bot_profile.default_all_public_streams,
|
|
||||||
)
|
|
||||||
|
|
||||||
return json_success({'bots': list(map(bot_info, bot_profiles))})
|
|
||||||
|
|
||||||
@authenticated_json_post_view
|
@authenticated_json_post_view
|
||||||
@has_request_variables
|
@has_request_variables
|
||||||
def json_refer_friend(request, user_profile, email=REQ):
|
def json_refer_friend(request, user_profile, email=REQ):
|
||||||
|
|||||||
262
zerver/views/users.py
Normal file
262
zerver/views/users.py
Normal file
@@ -0,0 +1,262 @@
|
|||||||
|
from __future__ import absolute_import
|
||||||
|
|
||||||
|
from django.shortcuts import redirect
|
||||||
|
from django.views.decorators.csrf import csrf_exempt
|
||||||
|
from six.moves import map
|
||||||
|
|
||||||
|
from zerver.decorator import has_request_variables, REQ, JsonableError
|
||||||
|
from zerver.forms import CreateUserForm
|
||||||
|
from zerver.lib.actions import do_change_full_name, do_change_is_admin, \
|
||||||
|
do_create_user, subscribed_to_stream, do_deactivate_user, do_reactivate_user, \
|
||||||
|
do_change_default_events_register_stream, do_change_default_sending_stream, \
|
||||||
|
do_change_default_all_public_streams, do_regenerate_api_key, do_change_avatar_source
|
||||||
|
from zerver.lib.avatar import avatar_url, get_avatar_url
|
||||||
|
from zerver.lib.response import json_error, json_success
|
||||||
|
from zerver.lib.upload import upload_avatar_image
|
||||||
|
from zerver.lib.validator import check_bool
|
||||||
|
from zerver.models import UserProfile, get_user_profile_by_email, get_stream
|
||||||
|
|
||||||
|
from zerver.lib.rest import rest_dispatch as _rest_dispatch
|
||||||
|
rest_dispatch = csrf_exempt((lambda request, *args, **kwargs: _rest_dispatch(request, globals(), *args, **kwargs)))
|
||||||
|
|
||||||
|
def deactivate_user_backend(request, user_profile, email):
|
||||||
|
try:
|
||||||
|
target = get_user_profile_by_email(email)
|
||||||
|
except UserProfile.DoesNotExist:
|
||||||
|
return json_error('No such user')
|
||||||
|
if target.is_bot:
|
||||||
|
return json_error('No such user')
|
||||||
|
return _deactivate_user_profile_backend(request, user_profile, target)
|
||||||
|
|
||||||
|
def deactivate_bot_backend(request, user_profile, email):
|
||||||
|
try:
|
||||||
|
target = get_user_profile_by_email(email)
|
||||||
|
except UserProfile.DoesNotExist:
|
||||||
|
return json_error('No such bot')
|
||||||
|
if not target.is_bot:
|
||||||
|
return json_error('No such bot')
|
||||||
|
return _deactivate_user_profile_backend(request, user_profile, target)
|
||||||
|
|
||||||
|
def _deactivate_user_profile_backend(request, user_profile, target):
|
||||||
|
if not user_profile.can_admin_user(target):
|
||||||
|
return json_error('Insufficient permission')
|
||||||
|
|
||||||
|
do_deactivate_user(target)
|
||||||
|
return json_success({})
|
||||||
|
|
||||||
|
def reactivate_user_backend(request, user_profile, email):
|
||||||
|
try:
|
||||||
|
target = get_user_profile_by_email(email)
|
||||||
|
except UserProfile.DoesNotExist:
|
||||||
|
return json_error('No such user')
|
||||||
|
|
||||||
|
if not user_profile.can_admin_user(target):
|
||||||
|
return json_error('Insufficient permission')
|
||||||
|
|
||||||
|
do_reactivate_user(target)
|
||||||
|
return json_success({})
|
||||||
|
|
||||||
|
@has_request_variables
|
||||||
|
def update_user_backend(request, user_profile, email,
|
||||||
|
is_admin=REQ(default=None, validator=check_bool)):
|
||||||
|
try:
|
||||||
|
target = get_user_profile_by_email(email)
|
||||||
|
except UserProfile.DoesNotExist:
|
||||||
|
return json_error('No such user')
|
||||||
|
|
||||||
|
if not user_profile.can_admin_user(target):
|
||||||
|
return json_error('Insufficient permission')
|
||||||
|
|
||||||
|
if is_admin is not None:
|
||||||
|
do_change_is_admin(target, is_admin)
|
||||||
|
return json_success({})
|
||||||
|
|
||||||
|
def avatar(request, email):
|
||||||
|
try:
|
||||||
|
user_profile = get_user_profile_by_email(email)
|
||||||
|
avatar_source = user_profile.avatar_source
|
||||||
|
except UserProfile.DoesNotExist:
|
||||||
|
avatar_source = 'G'
|
||||||
|
url = get_avatar_url(avatar_source, email)
|
||||||
|
if '?' in url:
|
||||||
|
sep = '&'
|
||||||
|
else:
|
||||||
|
sep = '?'
|
||||||
|
url += sep + request.META['QUERY_STRING']
|
||||||
|
return redirect(url)
|
||||||
|
|
||||||
|
def get_stream_name(stream):
|
||||||
|
if stream:
|
||||||
|
name = stream.name
|
||||||
|
else :
|
||||||
|
name = None
|
||||||
|
return name
|
||||||
|
|
||||||
|
def stream_or_none(stream_name, realm):
|
||||||
|
if stream_name == '':
|
||||||
|
return None
|
||||||
|
else:
|
||||||
|
stream = get_stream(stream_name, realm)
|
||||||
|
if not stream:
|
||||||
|
raise JsonableError('No such stream \'%s\'' % (stream_name, ))
|
||||||
|
return stream
|
||||||
|
|
||||||
|
@has_request_variables
|
||||||
|
def patch_bot_backend(request, user_profile, email,
|
||||||
|
full_name=REQ(default=None),
|
||||||
|
default_sending_stream=REQ(default=None),
|
||||||
|
default_events_register_stream=REQ(default=None),
|
||||||
|
default_all_public_streams=REQ(default=None, validator=check_bool)):
|
||||||
|
try:
|
||||||
|
bot = get_user_profile_by_email(email)
|
||||||
|
except:
|
||||||
|
return json_error('No such user')
|
||||||
|
|
||||||
|
if not user_profile.can_admin_user(bot):
|
||||||
|
return json_error('Insufficient permission')
|
||||||
|
|
||||||
|
if full_name is not None:
|
||||||
|
do_change_full_name(bot, full_name)
|
||||||
|
if default_sending_stream is not None:
|
||||||
|
stream = stream_or_none(default_sending_stream, bot.realm)
|
||||||
|
do_change_default_sending_stream(bot, stream)
|
||||||
|
if default_events_register_stream is not None:
|
||||||
|
stream = stream_or_none(default_events_register_stream, bot.realm)
|
||||||
|
do_change_default_events_register_stream(bot, stream)
|
||||||
|
if default_all_public_streams is not None:
|
||||||
|
do_change_default_all_public_streams(bot, default_all_public_streams)
|
||||||
|
|
||||||
|
if len(request.FILES) == 0:
|
||||||
|
pass
|
||||||
|
elif len(request.FILES) == 1:
|
||||||
|
user_file = request.FILES.values()[0]
|
||||||
|
upload_avatar_image(user_file, user_profile, bot.email)
|
||||||
|
avatar_source = UserProfile.AVATAR_FROM_USER
|
||||||
|
do_change_avatar_source(bot, avatar_source)
|
||||||
|
else:
|
||||||
|
return json_error("You may only upload one file at a time")
|
||||||
|
|
||||||
|
json_result = dict(
|
||||||
|
full_name=bot.full_name,
|
||||||
|
avatar_url=avatar_url(bot),
|
||||||
|
default_sending_stream=get_stream_name(bot.default_sending_stream),
|
||||||
|
default_events_register_stream=get_stream_name(bot.default_events_register_stream),
|
||||||
|
default_all_public_streams=bot.default_all_public_streams,
|
||||||
|
)
|
||||||
|
return json_success(json_result)
|
||||||
|
|
||||||
|
@has_request_variables
|
||||||
|
def regenerate_bot_api_key(request, user_profile, email):
|
||||||
|
try:
|
||||||
|
bot = get_user_profile_by_email(email)
|
||||||
|
except:
|
||||||
|
return json_error('No such user')
|
||||||
|
|
||||||
|
if not user_profile.can_admin_user(bot):
|
||||||
|
return json_error('Insufficient permission')
|
||||||
|
|
||||||
|
do_regenerate_api_key(bot)
|
||||||
|
json_result = dict(
|
||||||
|
api_key = bot.api_key
|
||||||
|
)
|
||||||
|
return json_success(json_result)
|
||||||
|
|
||||||
|
@has_request_variables
|
||||||
|
def add_bot_backend(request, user_profile, full_name=REQ, short_name=REQ,
|
||||||
|
default_sending_stream=REQ(default=None),
|
||||||
|
default_events_register_stream=REQ(default=None),
|
||||||
|
default_all_public_streams=REQ(validator=check_bool, default=None)):
|
||||||
|
short_name += "-bot"
|
||||||
|
email = short_name + "@" + user_profile.realm.domain
|
||||||
|
form = CreateUserForm({'full_name': full_name, 'email': email})
|
||||||
|
if not form.is_valid():
|
||||||
|
# We validate client-side as well
|
||||||
|
return json_error('Bad name or username')
|
||||||
|
|
||||||
|
try:
|
||||||
|
get_user_profile_by_email(email)
|
||||||
|
return json_error("Username already in use")
|
||||||
|
except UserProfile.DoesNotExist:
|
||||||
|
pass
|
||||||
|
|
||||||
|
if len(request.FILES) == 0:
|
||||||
|
avatar_source = UserProfile.AVATAR_FROM_GRAVATAR
|
||||||
|
elif len(request.FILES) != 1:
|
||||||
|
return json_error("You may only upload one file at a time")
|
||||||
|
else:
|
||||||
|
user_file = request.FILES.values()[0]
|
||||||
|
upload_avatar_image(user_file, user_profile, email)
|
||||||
|
avatar_source = UserProfile.AVATAR_FROM_USER
|
||||||
|
|
||||||
|
if default_sending_stream is not None:
|
||||||
|
default_sending_stream = stream_or_none(default_sending_stream, user_profile.realm)
|
||||||
|
if default_sending_stream and not default_sending_stream.is_public() and not \
|
||||||
|
subscribed_to_stream(user_profile, default_sending_stream):
|
||||||
|
return json_error('Insufficient permission')
|
||||||
|
|
||||||
|
if default_events_register_stream is not None:
|
||||||
|
default_events_register_stream = stream_or_none(default_events_register_stream,
|
||||||
|
user_profile.realm)
|
||||||
|
if default_events_register_stream and not default_events_register_stream.is_public() and not \
|
||||||
|
subscribed_to_stream(user_profile, default_events_register_stream):
|
||||||
|
return json_error('Insufficient permission')
|
||||||
|
|
||||||
|
|
||||||
|
bot_profile = do_create_user(email=email, password='',
|
||||||
|
realm=user_profile.realm, full_name=full_name,
|
||||||
|
short_name=short_name, active=True, bot=True,
|
||||||
|
bot_owner=user_profile,
|
||||||
|
avatar_source=avatar_source,
|
||||||
|
default_sending_stream=default_sending_stream,
|
||||||
|
default_events_register_stream=default_events_register_stream,
|
||||||
|
default_all_public_streams=default_all_public_streams)
|
||||||
|
json_result = dict(
|
||||||
|
api_key=bot_profile.api_key,
|
||||||
|
avatar_url=avatar_url(bot_profile),
|
||||||
|
default_sending_stream=get_stream_name(bot_profile.default_sending_stream),
|
||||||
|
default_events_register_stream=get_stream_name(bot_profile.default_events_register_stream),
|
||||||
|
default_all_public_streams=bot_profile.default_all_public_streams,
|
||||||
|
)
|
||||||
|
return json_success(json_result)
|
||||||
|
|
||||||
|
def get_bots_backend(request, user_profile):
|
||||||
|
bot_profiles = UserProfile.objects.filter(is_bot=True, is_active=True,
|
||||||
|
bot_owner=user_profile)
|
||||||
|
bot_profiles = bot_profiles.select_related('default_sending_stream', 'default_events_register_stream')
|
||||||
|
bot_profiles = bot_profiles.order_by('date_joined')
|
||||||
|
|
||||||
|
def bot_info(bot_profile):
|
||||||
|
default_sending_stream = get_stream_name(bot_profile.default_sending_stream)
|
||||||
|
default_events_register_stream = get_stream_name(bot_profile.default_events_register_stream)
|
||||||
|
|
||||||
|
return dict(
|
||||||
|
username=bot_profile.email,
|
||||||
|
full_name=bot_profile.full_name,
|
||||||
|
api_key=bot_profile.api_key,
|
||||||
|
avatar_url=avatar_url(bot_profile),
|
||||||
|
default_sending_stream=default_sending_stream,
|
||||||
|
default_events_register_stream=default_events_register_stream,
|
||||||
|
default_all_public_streams=bot_profile.default_all_public_streams,
|
||||||
|
)
|
||||||
|
|
||||||
|
return json_success({'bots': list(map(bot_info, bot_profiles))})
|
||||||
|
|
||||||
|
def get_members_backend(request, user_profile):
|
||||||
|
realm = user_profile.realm
|
||||||
|
admins = set(user_profile.realm.get_admin_users())
|
||||||
|
members = []
|
||||||
|
for profile in UserProfile.objects.select_related().filter(realm=realm):
|
||||||
|
avatar_url = get_avatar_url(
|
||||||
|
profile.avatar_source,
|
||||||
|
profile.email
|
||||||
|
)
|
||||||
|
member = {"full_name": profile.full_name,
|
||||||
|
"is_bot": profile.is_bot,
|
||||||
|
"is_active": profile.is_active,
|
||||||
|
"is_admin": (profile in admins),
|
||||||
|
"email": profile.email,
|
||||||
|
"avatar_url": avatar_url,}
|
||||||
|
if profile.is_bot and profile.bot_owner is not None:
|
||||||
|
member["bot_owner"] = profile.bot_owner.email
|
||||||
|
members.append(member)
|
||||||
|
return json_success({'members': members})
|
||||||
@@ -47,7 +47,7 @@ urlpatterns = patterns('',
|
|||||||
{'template_name': 'zerver/reset_done.html'}),
|
{'template_name': 'zerver/reset_done.html'}),
|
||||||
|
|
||||||
# Avatar
|
# Avatar
|
||||||
url(r'^avatar/(?P<email>[\S]+)?', 'zerver.views.avatar'),
|
url(r'^avatar/(?P<email>[\S]+)?', 'zerver.views.users.avatar'),
|
||||||
|
|
||||||
# Registration views, require a confirmation ID.
|
# Registration views, require a confirmation ID.
|
||||||
url(r'^accounts/home/', 'zerver.views.accounts_home'),
|
url(r'^accounts/home/', 'zerver.views.accounts_home'),
|
||||||
@@ -176,9 +176,6 @@ urlpatterns += patterns('zerver.views',
|
|||||||
v1_api_and_json_patterns = patterns('zerver.views',
|
v1_api_and_json_patterns = patterns('zerver.views',
|
||||||
url(r'^export$', 'rest_dispatch',
|
url(r'^export$', 'rest_dispatch',
|
||||||
{'GET': 'export'}),
|
{'GET': 'export'}),
|
||||||
url(r'^users$', 'rest_dispatch',
|
|
||||||
{'GET': 'get_members_backend',
|
|
||||||
'POST': 'create_user_backend'}),
|
|
||||||
url(r'^users/me$', 'rest_dispatch',
|
url(r'^users/me$', 'rest_dispatch',
|
||||||
{'GET': 'get_profile_backend'}),
|
{'GET': 'get_profile_backend'}),
|
||||||
url(r'^users/me/pointer$', 'rest_dispatch',
|
url(r'^users/me/pointer$', 'rest_dispatch',
|
||||||
@@ -196,25 +193,30 @@ v1_api_and_json_patterns = patterns('zerver.views',
|
|||||||
url(r'^users/me/android_gcm_reg_id$', 'rest_dispatch',
|
url(r'^users/me/android_gcm_reg_id$', 'rest_dispatch',
|
||||||
{'POST': 'add_android_reg_id',
|
{'POST': 'add_android_reg_id',
|
||||||
'DELETE': 'remove_android_reg_id'}),
|
'DELETE': 'remove_android_reg_id'}),
|
||||||
url(r'^users/(?P<email>.*)/reactivate$', 'rest_dispatch',
|
|
||||||
{'POST': 'reactivate_user_backend'}),
|
|
||||||
url(r'^users/(?P<email>[^/]*)$', 'rest_dispatch',
|
|
||||||
{'PATCH': 'update_user_backend',
|
|
||||||
'DELETE': 'deactivate_user_backend'}),
|
|
||||||
url(r'^bots$', 'rest_dispatch',
|
|
||||||
{'GET': 'get_bots_backend',
|
|
||||||
'POST': 'add_bot_backend'}),
|
|
||||||
url(r'^bots/(?P<email>.*)/api_key/regenerate$', 'rest_dispatch',
|
|
||||||
{'POST': 'regenerate_bot_api_key'}),
|
|
||||||
url(r'^bots/(?P<email>.*)$', 'rest_dispatch',
|
|
||||||
{'PATCH': 'patch_bot_backend',
|
|
||||||
'DELETE': 'deactivate_bot_backend'}),
|
|
||||||
url(r'^register$', 'rest_dispatch',
|
url(r'^register$', 'rest_dispatch',
|
||||||
{'POST': 'api_events_register'}),
|
{'POST': 'api_events_register'}),
|
||||||
|
|
||||||
# Returns a 204, used by desktop app to verify connectivity status
|
# Returns a 204, used by desktop app to verify connectivity status
|
||||||
url(r'generate_204$', 'generate_204'),
|
url(r'generate_204$', 'generate_204'),
|
||||||
|
|
||||||
|
) + patterns('zerver.views.users',
|
||||||
|
url(r'^users$', 'rest_dispatch',
|
||||||
|
{'GET': 'get_members_backend',
|
||||||
|
'POST': 'create_user_backend'}),
|
||||||
|
url(r'^users/(?P<email>.*)/reactivate$', 'rest_dispatch',
|
||||||
|
{'POST': 'reactivate_user_backend'}),
|
||||||
|
url(r'^users/(?P<email>[^/]*)$', 'rest_dispatch',
|
||||||
|
{'PATCH': 'update_user_backend',
|
||||||
|
'DELETE': 'deactivate_user_backend'}),
|
||||||
|
url(r'^bots$', 'rest_dispatch',
|
||||||
|
{'GET': 'get_bots_backend',
|
||||||
|
'POST': 'add_bot_backend'}),
|
||||||
|
url(r'^bots/(?P<email>.*)/api_key/regenerate$', 'rest_dispatch',
|
||||||
|
{'POST': 'regenerate_bot_api_key'}),
|
||||||
|
url(r'^bots/(?P<email>.*)$', 'rest_dispatch',
|
||||||
|
{'PATCH': 'patch_bot_backend',
|
||||||
|
'DELETE': 'deactivate_bot_backend'}),
|
||||||
|
|
||||||
) + patterns('zerver.views.messages',
|
) + patterns('zerver.views.messages',
|
||||||
# GET returns messages, possibly filtered, POST sends a message
|
# GET returns messages, possibly filtered, POST sends a message
|
||||||
url(r'^messages$', 'rest_dispatch',
|
url(r'^messages$', 'rest_dispatch',
|
||||||
|
|||||||
Reference in New Issue
Block a user