2017-01-07 21:34:32 +01:00
|
|
|
|
|
|
|
from django.http import HttpResponse, HttpRequest
|
2018-04-24 03:47:28 +02:00
|
|
|
from typing import List
|
2017-01-07 21:34:32 +01:00
|
|
|
|
2017-03-13 22:05:35 +01:00
|
|
|
import ujson
|
|
|
|
|
|
|
|
from django.utils.translation import ugettext as _
|
2017-08-30 02:19:34 +02:00
|
|
|
from zerver.lib.actions import do_mute_topic, do_unmute_topic
|
2017-01-07 21:34:32 +01:00
|
|
|
from zerver.lib.request import has_request_variables, REQ
|
2017-03-13 22:05:35 +01:00
|
|
|
from zerver.lib.response import json_success, json_error
|
2017-08-24 17:58:40 +02:00
|
|
|
from zerver.lib.topic_mutes import topic_is_muted
|
2017-08-30 02:19:34 +02:00
|
|
|
from zerver.lib.streams import access_stream_by_name, access_stream_for_unmute_topic
|
2017-01-07 21:34:32 +01:00
|
|
|
from zerver.lib.validator import check_string, check_list
|
2017-08-30 02:19:34 +02:00
|
|
|
from zerver.models import get_stream, Stream, UserProfile
|
|
|
|
|
2017-10-27 02:18:49 +02:00
|
|
|
def mute_topic(user_profile: UserProfile, stream_name: str,
|
|
|
|
topic_name: str) -> HttpResponse:
|
2017-08-30 02:19:34 +02:00
|
|
|
(stream, recipient, sub) = access_stream_by_name(user_profile, stream_name)
|
|
|
|
|
2017-10-05 15:36:44 +02:00
|
|
|
if topic_is_muted(user_profile, stream.id, topic_name):
|
2017-08-30 02:19:34 +02:00
|
|
|
return json_error(_("Topic already muted"))
|
|
|
|
|
|
|
|
do_mute_topic(user_profile, stream, recipient, topic_name)
|
|
|
|
return json_success()
|
|
|
|
|
2017-10-27 02:18:49 +02:00
|
|
|
def unmute_topic(user_profile: UserProfile, stream_name: str,
|
|
|
|
topic_name: str) -> HttpResponse:
|
2018-08-27 22:13:56 +02:00
|
|
|
error = _("Topic is not muted")
|
2017-08-30 02:19:34 +02:00
|
|
|
stream = access_stream_for_unmute_topic(user_profile, stream_name, error)
|
|
|
|
|
2017-10-05 15:36:44 +02:00
|
|
|
if not topic_is_muted(user_profile, stream.id, topic_name):
|
2017-08-30 02:19:34 +02:00
|
|
|
return json_error(error)
|
|
|
|
|
|
|
|
do_unmute_topic(user_profile, stream, topic_name)
|
|
|
|
return json_success()
|
2017-01-07 21:34:32 +01:00
|
|
|
|
2017-03-13 22:05:35 +01:00
|
|
|
@has_request_variables
|
2017-12-29 14:34:49 +01:00
|
|
|
def update_muted_topic(request: HttpRequest, user_profile: UserProfile, stream: str=REQ(),
|
|
|
|
topic: str=REQ(), op: str=REQ()) -> HttpResponse:
|
2017-08-30 02:19:34 +02:00
|
|
|
|
2017-03-13 22:05:35 +01:00
|
|
|
if op == 'add':
|
2017-08-30 02:19:34 +02:00
|
|
|
return mute_topic(user_profile, stream, topic)
|
2017-03-13 22:05:35 +01:00
|
|
|
elif op == 'remove':
|
2017-08-30 02:19:34 +02:00
|
|
|
return unmute_topic(user_profile, stream, topic)
|