mirror of https://github.com/zulip/zulip.git
66 lines
2.5 KiB
Python
66 lines
2.5 KiB
Python
from __future__ import absolute_import
|
|
from __future__ import print_function
|
|
|
|
from typing import Any
|
|
|
|
from argparse import ArgumentParser
|
|
from optparse import make_option
|
|
|
|
from django.core.management.base import BaseCommand
|
|
|
|
from zerver.lib.actions import bulk_remove_subscriptions
|
|
from zerver.models import Realm, UserProfile, get_realm, get_stream, \
|
|
get_user_profile_by_email
|
|
|
|
class Command(BaseCommand):
|
|
help = """Remove some or all users in a realm from a stream."""
|
|
|
|
option_list = BaseCommand.option_list + (
|
|
make_option('-d', '--domain',
|
|
dest='domain',
|
|
type='str',
|
|
help='The name of the realm in which you are removing people.'),
|
|
make_option('-s', '--stream',
|
|
dest='stream',
|
|
type='str',
|
|
help='A stream name.'),
|
|
make_option('-u', '--users',
|
|
dest='users',
|
|
type='str',
|
|
help='A comma-separated list of email addresses.'),
|
|
make_option('-a', '--all-users',
|
|
dest='all_users',
|
|
action="store_true",
|
|
default=False,
|
|
help='Remove all users in this realm from this stream.'),
|
|
)
|
|
|
|
def handle(self, **options):
|
|
# type: (*Any, **Any) -> None
|
|
if options["domain"] is None or options["stream"] is None or \
|
|
(options["users"] is None and options["all_users"] is None):
|
|
self.print_help("python manage.py", "remove_users_from_stream")
|
|
exit(1)
|
|
|
|
realm = get_realm(options["domain"])
|
|
stream_name = options["stream"].strip()
|
|
stream = get_stream(stream_name, realm)
|
|
|
|
if options["all_users"]:
|
|
user_profiles = UserProfile.objects.filter(realm=realm)
|
|
else:
|
|
emails = set([email.strip() for email in options["users"].split(",")])
|
|
user_profiles = []
|
|
for email in emails:
|
|
user_profiles.append(get_user_profile_by_email(email))
|
|
|
|
result = bulk_remove_subscriptions(user_profiles, [stream])
|
|
not_subscribed = result[1]
|
|
not_subscribed_users = {tup[0] for tup in not_subscribed}
|
|
|
|
for user_profile in user_profiles:
|
|
if user_profile in not_subscribed_users:
|
|
print("%s was not subscribed" % (user_profile.email,))
|
|
else:
|
|
print("Removed %s from %s" % (user_profile.email, stream_name))
|