mirror of
https://github.com/zulip/zulip.git
synced 2025-11-16 20:02:15 +00:00
365fe0b3d5
Fixes #2665. Regenerated by tabbott with `lint --fix` after a rebase and change in parameters. Note from tabbott: In a few cases, this converts technical debt in the form of unsorted imports into different technical debt in the form of our largest files having very long, ugly import sequences at the start. I expect this change will increase pressure for us to split those files, which isn't a bad thing. Signed-off-by: Anders Kaseorg <anders@zulip.com>
83 lines
2.9 KiB
Python
83 lines
2.9 KiB
Python
import datetime
|
|
from typing import Optional
|
|
|
|
from django.http import HttpRequest, HttpResponse
|
|
from django.utils.timezone import now as timezone_now
|
|
from django.utils.translation import ugettext as _
|
|
|
|
from zerver.lib.actions import do_mute_topic, do_unmute_topic
|
|
from zerver.lib.request import REQ, has_request_variables
|
|
from zerver.lib.response import json_error, json_success
|
|
from zerver.lib.streams import (
|
|
access_stream_by_id,
|
|
access_stream_by_name,
|
|
access_stream_for_unmute_topic_by_id,
|
|
access_stream_for_unmute_topic_by_name,
|
|
check_for_exactly_one_stream_arg,
|
|
)
|
|
from zerver.lib.topic_mutes import topic_is_muted
|
|
from zerver.lib.validator import check_int
|
|
from zerver.models import UserProfile
|
|
|
|
|
|
def mute_topic(user_profile: UserProfile,
|
|
stream_id: Optional[int],
|
|
stream_name: Optional[str],
|
|
topic_name: str,
|
|
date_muted: datetime.datetime) -> HttpResponse:
|
|
if stream_name is not None:
|
|
(stream, recipient, sub) = access_stream_by_name(user_profile, stream_name)
|
|
else:
|
|
assert stream_id is not None
|
|
(stream, recipient, sub) = access_stream_by_id(user_profile, stream_id)
|
|
|
|
if topic_is_muted(user_profile, stream.id, topic_name):
|
|
return json_error(_("Topic already muted"))
|
|
|
|
do_mute_topic(user_profile, stream, recipient, topic_name, date_muted)
|
|
return json_success()
|
|
|
|
def unmute_topic(user_profile: UserProfile,
|
|
stream_id: Optional[int],
|
|
stream_name: Optional[str],
|
|
topic_name: str) -> HttpResponse:
|
|
error = _("Topic is not muted")
|
|
|
|
if stream_name is not None:
|
|
stream = access_stream_for_unmute_topic_by_name(user_profile, stream_name, error)
|
|
else:
|
|
assert stream_id is not None
|
|
stream = access_stream_for_unmute_topic_by_id(user_profile, stream_id, error)
|
|
|
|
if not topic_is_muted(user_profile, stream.id, topic_name):
|
|
return json_error(error)
|
|
|
|
do_unmute_topic(user_profile, stream, topic_name)
|
|
return json_success()
|
|
|
|
@has_request_variables
|
|
def update_muted_topic(request: HttpRequest,
|
|
user_profile: UserProfile,
|
|
stream_id: Optional[int]=REQ(validator=check_int, default=None),
|
|
stream: Optional[str]=REQ(default=None),
|
|
topic: str=REQ(),
|
|
op: str=REQ()) -> HttpResponse:
|
|
|
|
check_for_exactly_one_stream_arg(stream_id=stream_id, stream=stream)
|
|
|
|
if op == 'add':
|
|
return mute_topic(
|
|
user_profile=user_profile,
|
|
stream_id=stream_id,
|
|
stream_name=stream,
|
|
topic_name=topic,
|
|
date_muted=timezone_now(),
|
|
)
|
|
elif op == 'remove':
|
|
return unmute_topic(
|
|
user_profile=user_profile,
|
|
stream_id=stream_id,
|
|
stream_name=stream,
|
|
topic_name=topic,
|
|
)
|