subscription: Clean functions peer_subscribe and peer_unsubscribe.

This commit is contained in:
YJDave
2018-04-08 11:03:49 +05:30
committed by Tim Abbott
parent dcf9355502
commit f5a7d125c9
3 changed files with 4 additions and 30 deletions

View File

@@ -246,9 +246,6 @@ exports.dispatch_normal_event = function dispatch_normal_event(event) {
break;
case 'subscription':
var person;
var email;
if (event.op === 'add') {
_.each(event.subscriptions, function (rec) {
var sub = stream_data.get_sub_by_id(rec.stream_id);
@@ -260,29 +257,17 @@ exports.dispatch_normal_event = function dispatch_normal_event(event) {
}
});
} else if (event.op === 'peer_add') {
// TODO: remove email shim here and fix called functions
// to use user_ids
person = people.get_person_from_user_id(event.user_id);
email = person.email;
_.each(event.subscriptions, function (sub) {
if (stream_data.add_subscriber(sub, event.user_id)) {
$(document).trigger(
'peer_subscribe.zulip',
{stream_name: sub, user_email: email});
$(document).trigger('peer_subscribe.zulip', {stream_name: sub});
} else {
blueslip.warn('Cannot process peer_add event');
}
});
} else if (event.op === 'peer_remove') {
// TODO: remove email shim here and fix called functions
// to use user_ids
person = people.get_person_from_user_id(event.user_id);
email = person.email;
_.each(event.subscriptions, function (sub) {
if (stream_data.remove_subscriber(sub, event.user_id)) {
$(document).trigger(
'peer_unsubscribe.zulip',
{stream_name: sub, user_email: email});
$(document).trigger('peer_unsubscribe.zulip', {stream_name: sub});
} else {
blueslip.warn('Cannot process peer_remove event.');
}

View File

@@ -632,12 +632,12 @@ $(function () {
$(document).on('peer_subscribe.zulip', function (e, data) {
var sub = stream_data.get_sub(data.stream_name);
exports.rerender_subscribers_list(sub);
subs.rerender_subscriptions_settings(sub);
});
$(document).on('peer_unsubscribe.zulip', function (e, data) {
var sub = stream_data.get_sub(data.stream_name);
exports.rerender_subscribers_list(sub);
subs.rerender_subscriptions_settings(sub);
});
});

View File

@@ -814,17 +814,6 @@ $(function () {
sub_arrow.removeClass('icon-vector-chevron-up');
sub_arrow.addClass('icon-vector-chevron-down');
});
$(document).on('peer_subscribe.zulip', function (e, data) {
var sub = stream_data.get_sub(data.stream_name);
exports.rerender_subscribers_count(sub);
});
$(document).on('peer_unsubscribe.zulip', function (e, data) {
var sub = stream_data.get_sub(data.stream_name);
exports.rerender_subscribers_count(sub);
});
});
function focus_on_narrowed_stream() {