mirror of
https://github.com/zulip/zulip.git
synced 2025-11-04 14:03:30 +00:00
1059 lines
36 KiB
JavaScript
1059 lines
36 KiB
JavaScript
var compose = (function () {
|
|
// Docs: https://zulip.readthedocs.io/en/latest/subsystems/sending-messages.html
|
|
|
|
var exports = {};
|
|
|
|
/* Track the state of the @all warning. The user must acknowledge that they are spamming the entire
|
|
stream before the warning will go away. If they try to send before explicitly dismissing the
|
|
warning, they will get an error message too.
|
|
|
|
undefined: no @all/@everyone in message;
|
|
false: user typed @all/@everyone;
|
|
true: user clicked YES */
|
|
|
|
var user_acknowledged_all_everyone;
|
|
var user_acknowledged_announce;
|
|
|
|
exports.all_everyone_warn_threshold = 15;
|
|
exports.announce_warn_threshold = 60;
|
|
|
|
exports.uploads_domain = document.location.protocol + '//' + document.location.host;
|
|
exports.uploads_path = '/user_uploads';
|
|
exports.uploads_re = new RegExp("\\]\\(" + exports.uploads_domain + "(" + exports.uploads_path + "[^\\)]+)\\)", 'g');
|
|
|
|
function make_uploads_relative(content) {
|
|
// Rewrite uploads in markdown links back to domain-relative form
|
|
return content.replace(exports.uploads_re, "]($1)");
|
|
}
|
|
|
|
function show_all_everyone_warnings() {
|
|
var stream_count = stream_data.get_subscriber_count(compose_state.stream_name()) || 0;
|
|
|
|
var all_everyone_template = templates.render("compose_all_everyone", {count: stream_count});
|
|
var error_area_all_everyone = $("#compose-all-everyone");
|
|
|
|
// only show one error for any number of @all or @everyone mentions
|
|
if (!error_area_all_everyone.is(':visible')) {
|
|
error_area_all_everyone.append(all_everyone_template);
|
|
}
|
|
|
|
error_area_all_everyone.show();
|
|
user_acknowledged_all_everyone = false;
|
|
}
|
|
|
|
exports.clear_all_everyone_warnings = function () {
|
|
$("#compose-all-everyone").hide();
|
|
$("#compose-all-everyone").empty();
|
|
$("#compose-send-status").hide();
|
|
};
|
|
|
|
function show_sending_indicator(whats_happening) {
|
|
if (whats_happening === undefined) {
|
|
whats_happening = 'Sending...';
|
|
}
|
|
$("#sending-indicator").html(i18n.t(whats_happening));
|
|
$("#sending-indicator").show();
|
|
}
|
|
|
|
function show_announce_warnings() {
|
|
var stream_count = stream_data.get_subscriber_count(compose_state.stream_name()) || 0;
|
|
|
|
var announce_template = templates.render("compose_announce", {count: stream_count});
|
|
var error_area_announce = $("#compose-announce");
|
|
|
|
if (!error_area_announce.is(':visible')) {
|
|
error_area_announce.append(announce_template);
|
|
}
|
|
|
|
error_area_announce.show();
|
|
user_acknowledged_announce = false;
|
|
}
|
|
|
|
exports.clear_announce_warnings = function () {
|
|
$("#compose-announce").hide();
|
|
$("#compose-announce").empty();
|
|
$("#compose-send-status").hide();
|
|
};
|
|
|
|
exports.clear_invites = function () {
|
|
$("#compose_invite_users").hide();
|
|
$("#compose_invite_users").empty();
|
|
};
|
|
|
|
exports.clear_private_stream_alert = function () {
|
|
$("#compose_private_stream_alert").hide();
|
|
$("#compose_private_stream_alert").empty();
|
|
};
|
|
|
|
exports.reset_user_acknowledged_all_everyone_flag = function () {
|
|
user_acknowledged_all_everyone = undefined;
|
|
};
|
|
|
|
exports.reset_user_acknowledged_announce_flag = function () {
|
|
user_acknowledged_announce = undefined;
|
|
};
|
|
|
|
exports.clear_preview_area = function () {
|
|
$("#compose-textarea").show();
|
|
$("#undo_markdown_preview").hide();
|
|
$("#preview_message_area").hide();
|
|
$("#preview_content").empty();
|
|
$("#markdown_preview").show();
|
|
};
|
|
|
|
function update_stream_button(btn_text, title) {
|
|
$("#left_bar_compose_stream_button_big").text(btn_text);
|
|
$("#left_bar_compose_stream_button_big").prop("title", title);
|
|
}
|
|
|
|
exports.update_stream_button_for_private = function () {
|
|
var text = i18n.t("New stream message");
|
|
var title = text + " (c)";
|
|
update_stream_button(text, title);
|
|
};
|
|
|
|
exports.update_stream_button_for_stream = function () {
|
|
var text = i18n.t("New topic");
|
|
var title = text + " (c)";
|
|
update_stream_button(text, title);
|
|
};
|
|
|
|
function update_fade() {
|
|
if (!compose_state.composing()) {
|
|
return;
|
|
}
|
|
|
|
var msg_type = compose_state.get_message_type();
|
|
compose_fade.set_focused_recipient(msg_type);
|
|
compose_fade.update_all();
|
|
}
|
|
|
|
exports.abort_xhr = function () {
|
|
$("#compose-send-button").prop("disabled", false);
|
|
var xhr = $("#compose").data("filedrop_xhr");
|
|
if (xhr !== undefined) {
|
|
xhr.abort();
|
|
$("#compose").removeData("filedrop_xhr");
|
|
}
|
|
};
|
|
|
|
exports.empty_topic_placeholder = function () {
|
|
return i18n.t("(no topic)");
|
|
};
|
|
|
|
function create_message_object() {
|
|
// Topics are optional, and we provide a placeholder if one isn't given.
|
|
var topic = compose_state.topic();
|
|
if (topic === "") {
|
|
topic = compose.empty_topic_placeholder();
|
|
}
|
|
|
|
var content = make_uploads_relative(compose_state.message_content());
|
|
|
|
// Changes here must also be kept in sync with echo.try_deliver_locally
|
|
var message = {
|
|
type: compose_state.get_message_type(),
|
|
content: content,
|
|
sender_id: page_params.user_id,
|
|
queue_id: page_params.queue_id,
|
|
stream: '',
|
|
};
|
|
util.set_message_topic(message, '');
|
|
|
|
if (message.type === "private") {
|
|
// TODO: this should be collapsed with the code in composebox_typeahead.js
|
|
var recipient = compose_state.recipient();
|
|
var emails = util.extract_pm_recipients(recipient);
|
|
message.to = emails;
|
|
message.reply_to = recipient;
|
|
message.private_message_recipient = recipient;
|
|
message.to_user_ids = people.email_list_to_user_ids_string(emails);
|
|
} else {
|
|
var stream_name = compose_state.stream_name();
|
|
message.to = stream_name;
|
|
message.stream = stream_name;
|
|
var sub = stream_data.get_sub(stream_name);
|
|
if (sub) {
|
|
message.stream_id = sub.stream_id;
|
|
}
|
|
util.set_message_topic(message, topic);
|
|
}
|
|
return message;
|
|
}
|
|
|
|
exports.create_message_object = create_message_object;
|
|
|
|
function compose_error(error_text, bad_input) {
|
|
$('#compose-send-status').removeClass(common.status_classes)
|
|
.addClass('alert-error')
|
|
.stop(true).fadeTo(0, 1);
|
|
$('#compose-error-msg').html(error_text);
|
|
$("#compose-send-button").prop('disabled', false);
|
|
$("#sending-indicator").hide();
|
|
if (bad_input !== undefined) {
|
|
bad_input.focus().select();
|
|
}
|
|
}
|
|
|
|
exports.compose_error = compose_error;
|
|
|
|
function nonexistent_stream_reply_error() {
|
|
$("#nonexistent_stream_reply_error").show();
|
|
$("#compose-reply-error-msg").html("There are no messages to reply to yet.");
|
|
setTimeout(function () {
|
|
$("#nonexistent_stream_reply_error").hide();
|
|
}, 5000);
|
|
}
|
|
|
|
function compose_not_subscribed_error(error_text, bad_input) {
|
|
$('#compose-send-status').removeClass(common.status_classes)
|
|
.addClass('home-error-bar')
|
|
.stop(true).fadeTo(0, 1);
|
|
$('#compose-error-msg').html(error_text);
|
|
$("#compose-send-button").prop('disabled', false);
|
|
$("#sending-indicator").hide();
|
|
$(".compose-send-status-close").hide();
|
|
if (bad_input !== undefined) {
|
|
bad_input.focus().select();
|
|
}
|
|
}
|
|
|
|
exports.nonexistent_stream_reply_error = nonexistent_stream_reply_error;
|
|
|
|
function clear_compose_box() {
|
|
$("#compose-textarea").val('').focus();
|
|
drafts.delete_draft_after_send();
|
|
compose_ui.autosize_textarea();
|
|
$("#compose-send-status").hide(0);
|
|
$("#compose-send-button").prop('disabled', false);
|
|
$("#sending-indicator").hide();
|
|
resize.resize_bottom_whitespace();
|
|
}
|
|
|
|
exports.clear_compose_box = clear_compose_box;
|
|
|
|
exports.send_message_success = function (local_id, message_id, locally_echoed) {
|
|
if (!locally_echoed) {
|
|
clear_compose_box();
|
|
}
|
|
|
|
echo.reify_message_id(local_id, message_id);
|
|
};
|
|
|
|
exports.send_message = function send_message(request) {
|
|
if (request === undefined) {
|
|
request = create_message_object();
|
|
}
|
|
|
|
if (request.type === "private") {
|
|
request.to = JSON.stringify(request.to);
|
|
} else {
|
|
request.to = JSON.stringify([request.to]);
|
|
}
|
|
|
|
var local_id;
|
|
var locally_echoed;
|
|
|
|
local_id = echo.try_deliver_locally(request);
|
|
if (local_id) {
|
|
// We are rendering this message locally with an id
|
|
// like 92l99.01 that corresponds to a reasonable
|
|
// approximation of the id we'll get from the server
|
|
// in terms of sorting messages.
|
|
locally_echoed = true;
|
|
} else {
|
|
// We are not rendering this message locally, but we
|
|
// track the message's life cycle with an id like
|
|
// loc-1, loc-2, loc-3,etc.
|
|
locally_echoed = false;
|
|
local_id = sent_messages.get_new_local_id();
|
|
}
|
|
|
|
request.local_id = local_id;
|
|
|
|
sent_messages.start_tracking_message({
|
|
local_id: local_id,
|
|
locally_echoed: locally_echoed,
|
|
});
|
|
|
|
request.locally_echoed = locally_echoed;
|
|
|
|
function success(data) {
|
|
exports.send_message_success(local_id, data.id, locally_echoed);
|
|
}
|
|
|
|
function error(response) {
|
|
// If we're not local echo'ing messages, or if this message was not
|
|
// locally echoed, show error in compose box
|
|
if (!locally_echoed) {
|
|
compose_error(response, $('#compose-textarea'));
|
|
return;
|
|
}
|
|
|
|
echo.message_send_error(local_id, response);
|
|
}
|
|
|
|
transmit.send_message(request, success, error);
|
|
server_events.assert_get_events_running("Restarting get_events because it was not running during send");
|
|
|
|
if (locally_echoed) {
|
|
clear_compose_box();
|
|
}
|
|
};
|
|
|
|
exports.enter_with_preview_open = function () {
|
|
exports.clear_preview_area();
|
|
if (page_params.enter_sends) {
|
|
// If enter_sends is enabled, we attempt to send the message
|
|
exports.finish();
|
|
} else {
|
|
// Otherwise, we return to the compose box and focus it
|
|
$("#compose-textarea").focus();
|
|
}
|
|
};
|
|
|
|
exports.finish = function () {
|
|
exports.clear_invites();
|
|
exports.clear_private_stream_alert();
|
|
notifications.clear_compose_notifications();
|
|
|
|
var message_content = compose_state.message_content();
|
|
|
|
// Skip normal validation for zcommands, since they aren't
|
|
// actual messages with recipients; users only send them
|
|
// from the compose box for convenience sake.
|
|
if (zcommand.process(message_content)) {
|
|
exports.do_post_send_tasks();
|
|
clear_compose_box();
|
|
return;
|
|
}
|
|
|
|
if (!compose.validate()) {
|
|
return false;
|
|
}
|
|
|
|
if (reminder.is_deferred_delivery(message_content)) {
|
|
reminder.schedule_message();
|
|
} else {
|
|
exports.send_message();
|
|
}
|
|
exports.do_post_send_tasks();
|
|
return true;
|
|
};
|
|
|
|
exports.do_post_send_tasks = function () {
|
|
exports.clear_preview_area();
|
|
// TODO: Do we want to fire the event even if the send failed due
|
|
// to a server-side error?
|
|
$(document).trigger($.Event('compose_finished.zulip'));
|
|
};
|
|
|
|
exports.update_email = function (user_id, new_email) {
|
|
var reply_to = compose_state.recipient();
|
|
|
|
if (!reply_to) {
|
|
return;
|
|
}
|
|
|
|
reply_to = people.update_email_in_reply_to(reply_to, user_id, new_email);
|
|
|
|
compose_state.recipient(reply_to);
|
|
};
|
|
|
|
exports.get_invalid_recipient_emails = function () {
|
|
var private_recipients = util.extract_pm_recipients(compose_state.recipient());
|
|
var invalid_recipients = _.reject(private_recipients, people.is_valid_email_for_compose);
|
|
|
|
return invalid_recipients;
|
|
};
|
|
|
|
function check_unsubscribed_stream_for_send(stream_name, autosubscribe) {
|
|
var stream_obj = stream_data.get_sub(stream_name);
|
|
var result;
|
|
if (!stream_obj) {
|
|
return "does-not-exist";
|
|
}
|
|
if (!autosubscribe) {
|
|
return "not-subscribed";
|
|
}
|
|
|
|
// In the rare circumstance of the autosubscribe option, we
|
|
// *Synchronously* try to subscribe to the stream before sending
|
|
// the message. This is deprecated and we hope to remove it; see
|
|
// #4650.
|
|
channel.post({
|
|
url: "/json/subscriptions/exists",
|
|
data: {stream: stream_name, autosubscribe: true},
|
|
async: false,
|
|
success: function (data) {
|
|
if (data.subscribed) {
|
|
result = "subscribed";
|
|
} else {
|
|
result = "not-subscribed";
|
|
}
|
|
},
|
|
error: function (xhr) {
|
|
if (xhr.status === 404) {
|
|
result = "does-not-exist";
|
|
} else {
|
|
result = "error";
|
|
}
|
|
},
|
|
});
|
|
return result;
|
|
}
|
|
|
|
function validate_stream_message_mentions(stream_name) {
|
|
var stream_count = stream_data.get_subscriber_count(stream_name) || 0;
|
|
|
|
// check if @all or @everyone is in the message
|
|
if (util.is_all_or_everyone_mentioned(compose_state.message_content()) &&
|
|
stream_count > compose.all_everyone_warn_threshold) {
|
|
if (user_acknowledged_all_everyone === undefined ||
|
|
user_acknowledged_all_everyone === false) {
|
|
// user has not seen a warning message yet if undefined
|
|
show_all_everyone_warnings();
|
|
|
|
$("#compose-send-button").prop('disabled', false);
|
|
$("#sending-indicator").hide();
|
|
return false;
|
|
}
|
|
} else {
|
|
// the message no longer contains @all or @everyone
|
|
exports.clear_all_everyone_warnings();
|
|
}
|
|
// at this point, the user has either acknowledged the warning or removed @all / @everyone
|
|
user_acknowledged_all_everyone = undefined;
|
|
|
|
return true;
|
|
}
|
|
|
|
function validate_stream_message_announce(stream_name) {
|
|
var stream_count = stream_data.get_subscriber_count(stream_name) || 0;
|
|
|
|
if (stream_name === "announce" &&
|
|
stream_count > compose.announce_warn_threshold) {
|
|
if (user_acknowledged_announce === undefined ||
|
|
user_acknowledged_announce === false) {
|
|
// user has not seen a warning message yet if undefined
|
|
show_announce_warnings();
|
|
|
|
$("#compose-send-button").prop('disabled', false);
|
|
$("#sending-indicator").hide();
|
|
return false;
|
|
}
|
|
} else {
|
|
exports.clear_announce_warnings();
|
|
}
|
|
// at this point, the user has acknowledged the warning
|
|
user_acknowledged_announce = undefined;
|
|
|
|
return true;
|
|
}
|
|
|
|
function validate_stream_message_announcement_only(stream_name) {
|
|
// Only allow realm admins to post to announcement_only streams.
|
|
var is_announcement_only = stream_data.get_announcement_only(stream_name);
|
|
if (is_announcement_only && !page_params.is_admin) {
|
|
compose_error(i18n.t("Only organization admins are allowed to post to this stream."));
|
|
return false;
|
|
}
|
|
return true;
|
|
}
|
|
|
|
exports.validation_error = function (error_type, stream_name) {
|
|
var response;
|
|
|
|
var context = {};
|
|
context.stream_name = Handlebars.Utils.escapeExpression(stream_name);
|
|
|
|
switch (error_type) {
|
|
case "does-not-exist":
|
|
response = i18n.t("<p>The stream <b>__stream_name__</b> does not exist.</p><p>Manage your subscriptions <a href='#streams/all'>on your Streams page</a>.</p>", context);
|
|
compose_error(response, $('#stream_message_recipient_stream'));
|
|
return false;
|
|
case "error":
|
|
compose_error(i18n.t("Error checking subscription"),
|
|
$("#stream_message_recipient_stream"));
|
|
return false;
|
|
case "not-subscribed":
|
|
var sub = stream_data.get_sub(stream_name);
|
|
var new_row = templates.render("compose_not_subscribed", {
|
|
should_display_sub_button: sub.should_display_subscription_button});
|
|
compose_not_subscribed_error(new_row, $('#stream_message_recipient_stream'));
|
|
return false;
|
|
}
|
|
return true;
|
|
};
|
|
|
|
exports.validate_stream_message_address_info = function (stream_name) {
|
|
if (stream_data.is_subscribed(stream_name)) {
|
|
return true;
|
|
}
|
|
var autosubscribe = page_params.narrow_stream !== undefined;
|
|
var error_type = check_unsubscribed_stream_for_send(stream_name, autosubscribe);
|
|
return exports.validation_error(error_type, stream_name);
|
|
};
|
|
|
|
function validate_stream_message() {
|
|
var stream_name = compose_state.stream_name();
|
|
if (stream_name === "") {
|
|
compose_error(i18n.t("Please specify a stream"), $("#stream_message_recipient_stream"));
|
|
return false;
|
|
}
|
|
|
|
if (page_params.realm_mandatory_topics) {
|
|
var topic = compose_state.topic();
|
|
if (topic === "") {
|
|
compose_error(i18n.t("Please specify a topic"), $("#stream_message_recipient_topic"));
|
|
return false;
|
|
}
|
|
}
|
|
|
|
if (!validate_stream_message_announcement_only(stream_name)) {
|
|
return false;
|
|
}
|
|
|
|
// If both `@all` is mentioned and it's in `#announce`, just validate
|
|
// for `@all`. Users shouldn't have to hit "yes" more than once.
|
|
if (util.is_all_or_everyone_mentioned(compose_state.message_content()) &&
|
|
stream_name === "announce") {
|
|
if (!exports.validate_stream_message_address_info(stream_name) ||
|
|
!validate_stream_message_mentions(stream_name)) {
|
|
return false;
|
|
}
|
|
// If either criteria isn't met, just do the normal validation.
|
|
} else {
|
|
if (!exports.validate_stream_message_address_info(stream_name) ||
|
|
!validate_stream_message_mentions(stream_name) ||
|
|
!validate_stream_message_announce(stream_name)) {
|
|
return false;
|
|
}
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
// The function checks whether the recipients are users of the realm or cross realm users (bots
|
|
// for now)
|
|
function validate_private_message() {
|
|
if (compose_state.recipient().length === 0) {
|
|
compose_error(i18n.t("Please specify at least one valid recipient"), $("#private_message_recipient"));
|
|
return false;
|
|
} else if (page_params.realm_is_zephyr_mirror_realm) {
|
|
// For Zephyr mirroring realms, the frontend doesn't know which users exist
|
|
return true;
|
|
}
|
|
|
|
var invalid_recipients = exports.get_invalid_recipient_emails();
|
|
|
|
var context = {};
|
|
if (invalid_recipients.length === 1) {
|
|
context = {recipient: invalid_recipients.join()};
|
|
compose_error(i18n.t("The recipient __recipient__ is not valid", context), $("#private_message_recipient"));
|
|
return false;
|
|
} else if (invalid_recipients.length > 1) {
|
|
context = {recipients: invalid_recipients.join()};
|
|
compose_error(i18n.t("The recipients __recipients__ are not valid", context), $("#private_message_recipient"));
|
|
return false;
|
|
}
|
|
return true;
|
|
}
|
|
|
|
exports.validate = function () {
|
|
$("#compose-send-button").attr('disabled', 'disabled').blur();
|
|
var message_content = compose_state.message_content();
|
|
if (reminder.is_deferred_delivery(message_content)) {
|
|
show_sending_indicator('Scheduling...');
|
|
} else {
|
|
show_sending_indicator();
|
|
}
|
|
|
|
if (/^\s*$/.test(message_content)) {
|
|
compose_error(i18n.t("You have nothing to send!"), $("#compose-textarea"));
|
|
return false;
|
|
}
|
|
|
|
if ($("#zephyr-mirror-error").is(":visible")) {
|
|
compose_error(i18n.t("You need to be running Zephyr mirroring in order to send messages!"));
|
|
return false;
|
|
}
|
|
|
|
if (compose_state.get_message_type() === 'private') {
|
|
return validate_private_message();
|
|
}
|
|
return validate_stream_message();
|
|
};
|
|
|
|
exports.handle_keydown = function (event, textarea) {
|
|
var code = event.keyCode || event.which;
|
|
var isBold = code === 66;
|
|
var isItalic = code === 73 && !event.shiftKey;
|
|
var isLink = code === 76 && event.shiftKey;
|
|
|
|
// detect command and ctrl key
|
|
var isCmdOrCtrl = /Mac/i.test(navigator.userAgent) ? event.metaKey : event.ctrlKey;
|
|
|
|
if ((isBold || isItalic || isLink) && isCmdOrCtrl) {
|
|
var range = textarea.range();
|
|
function wrap_text_with_markdown(prefix, suffix) {
|
|
if (!document.execCommand('insertText', false, prefix + range.text + suffix)) {
|
|
textarea.range(range.start, range.end).range(prefix + range.text + suffix);
|
|
}
|
|
event.preventDefault();
|
|
}
|
|
|
|
if (isBold) {
|
|
// ctrl + b: Convert selected text to bold text
|
|
wrap_text_with_markdown("**", "**");
|
|
if (!range.length) {
|
|
textarea.caret(textarea.caret() - 2);
|
|
}
|
|
}
|
|
if (isItalic) {
|
|
// ctrl + i: Convert selected text to italic text
|
|
wrap_text_with_markdown("*", "*");
|
|
if (!range.length) {
|
|
textarea.caret(textarea.caret() - 1);
|
|
}
|
|
}
|
|
if (isLink) {
|
|
// ctrl + l: Insert a link to selected text
|
|
wrap_text_with_markdown("[", "](url)");
|
|
var position = textarea.caret();
|
|
var txt = document.getElementById(textarea[0].id);
|
|
|
|
// Include selected text in between [] parantheses and insert '(url)'
|
|
// where "url" should be automatically selected.
|
|
// Position of cursor depends on whether browser supports exec
|
|
// command or not. So set cursor position accrodingly.
|
|
if (range.length > 0) {
|
|
if (document.queryCommandEnabled('insertText')) {
|
|
txt.selectionStart = position - 4;
|
|
txt.selectionEnd = position - 1;
|
|
} else {
|
|
txt.selectionStart = position + range.length + 3;
|
|
txt.selectionEnd = position + range.length + 6;
|
|
}
|
|
} else {
|
|
textarea.caret(textarea.caret() - 6);
|
|
}
|
|
}
|
|
|
|
compose_ui.autosize_textarea();
|
|
return;
|
|
}
|
|
};
|
|
|
|
exports.handle_keyup = function (event, textarea) {
|
|
// Set the rtl class if the text has an rtl direction, remove it otherwise
|
|
rtl.set_rtl_class_for_textarea(textarea);
|
|
};
|
|
|
|
exports.needs_subscribe_warning = function (email) {
|
|
// This returns true if all of these conditions are met:
|
|
// * the user is valid
|
|
// * the stream in the compose box is valid
|
|
// * the user is not already subscribed to the stream
|
|
// * the user has no back-door way to see stream messages
|
|
// (i.e. bots on public/private streams)
|
|
//
|
|
// You can think of this as roughly answering "is there an
|
|
// actionable way to subscribe the user and do they actually
|
|
// need it?".
|
|
//
|
|
// We expect the caller to already have verified that we're
|
|
// sending to a stream and trying to mention the user.
|
|
|
|
var user = people.get_active_user_for_email(email);
|
|
var stream_name = compose_state.stream_name();
|
|
|
|
if (!stream_name) {
|
|
return false;
|
|
}
|
|
|
|
var sub = stream_data.get_sub(stream_name);
|
|
|
|
if (!sub || !user) {
|
|
return false;
|
|
}
|
|
|
|
if (user.is_bot) {
|
|
// Bots may receive messages on public/private streams even if they are
|
|
// not subscribed.
|
|
return false;
|
|
}
|
|
|
|
if (stream_data.is_user_subscribed(stream_name, user.user_id)) {
|
|
// If our user is already subscribed
|
|
return false;
|
|
}
|
|
|
|
return true;
|
|
};
|
|
|
|
function insert_video_call_url(url, target_textarea) {
|
|
var video_call_link_text = '[' + _('Click to join video call') + '](' + url + ')';
|
|
compose_ui.insert_syntax_and_focus(video_call_link_text, target_textarea);
|
|
}
|
|
|
|
exports.render_and_show_preview = function (preview_spinner, preview_content_box, content) {
|
|
|
|
function show_preview(rendered_content, raw_content) {
|
|
// content is passed to check for status messages ("/me ...")
|
|
// and will be undefined in case of errors
|
|
var rendered_preview_html;
|
|
if (raw_content !== undefined &&
|
|
markdown.is_status_message(raw_content, rendered_content)) {
|
|
// Handle previews of /me messages
|
|
rendered_preview_html = "<p><strong>" + page_params.full_name + "</strong>" + rendered_content.slice("<p>/me".length);
|
|
} else {
|
|
rendered_preview_html = rendered_content;
|
|
}
|
|
|
|
preview_content_box.html(rendered_preview_html);
|
|
if (page_params.emojiset === "text") {
|
|
preview_content_box.find(".emoji").replaceWith(function () {
|
|
var text = $(this).attr("title");
|
|
return ":" + text + ":";
|
|
});
|
|
}
|
|
}
|
|
|
|
if (content.length === 0) {
|
|
show_preview(i18n.t("Nothing to preview"));
|
|
} else {
|
|
if (markdown.contains_backend_only_syntax(content)) {
|
|
var spinner = preview_spinner.expectOne();
|
|
loading.make_indicator(spinner);
|
|
} else {
|
|
// For messages that don't appear to contain
|
|
// bugdown-specific syntax not present in our
|
|
// marked.js frontend processor, we render using the
|
|
// frontend markdown processor message (but still
|
|
// render server-side to ensure the preview is
|
|
// accurate; if the `markdown.contains_backend_only_syntax` logic is
|
|
// incorrect wrong, users will see a brief flicker).
|
|
var message_obj = {
|
|
raw_content: content,
|
|
};
|
|
markdown.apply_markdown(message_obj);
|
|
}
|
|
channel.post({
|
|
url: '/json/messages/render',
|
|
idempotent: true,
|
|
data: {content: content},
|
|
success: function (response_data) {
|
|
if (markdown.contains_backend_only_syntax(content)) {
|
|
loading.destroy_indicator(preview_spinner);
|
|
}
|
|
show_preview(response_data.rendered, content);
|
|
},
|
|
error: function () {
|
|
if (markdown.contains_backend_only_syntax(content)) {
|
|
loading.destroy_indicator(preview_spinner);
|
|
}
|
|
show_preview(i18n.t("Failed to generate preview"));
|
|
},
|
|
});
|
|
}
|
|
};
|
|
|
|
exports.initialize = function () {
|
|
$('#stream_message_recipient_stream,#stream_message_recipient_topic,#private_message_recipient').on('keyup', update_fade);
|
|
$('#stream_message_recipient_stream,#stream_message_recipient_topic,#private_message_recipient').on('change', update_fade);
|
|
$('#compose-textarea').on('keydown', function (event) {
|
|
exports.handle_keydown(event, $("#compose-textarea").expectOne());
|
|
});
|
|
$('#compose-textarea').on('keyup', function (event) {
|
|
exports.handle_keyup(event, $("#compose-textarea").expectOne());
|
|
});
|
|
|
|
$("#compose form").on("submit", function (e) {
|
|
e.preventDefault();
|
|
compose.finish();
|
|
});
|
|
|
|
resize.watch_manual_resize("#compose-textarea");
|
|
|
|
upload.feature_check($("#compose #attach_files"));
|
|
|
|
// Show a warning if a user @-mentions someone who will not receive this message
|
|
$(document).on('usermention_completed.zulip', function (event, data) {
|
|
if (compose_state.get_message_type() !== 'stream') {
|
|
return;
|
|
}
|
|
if (data.is_silent) {
|
|
// We don't need to warn in case of silent mentions.
|
|
return;
|
|
}
|
|
|
|
// Disable for Zephyr mirroring realms, since we never have subscriber lists there
|
|
if (page_params.realm_is_zephyr_mirror_realm) {
|
|
return;
|
|
}
|
|
|
|
if (data !== undefined && data.mentioned !== undefined) {
|
|
var email = data.mentioned.email;
|
|
|
|
// warn if @all, @everyone or @stream is mentioned
|
|
if (data.mentioned.full_name === 'all' || data.mentioned.full_name === 'everyone' || data.mentioned.full_name === 'stream') {
|
|
return; // don't check if @all or @everyone is subscribed to a stream
|
|
}
|
|
|
|
if (exports.needs_subscribe_warning(email)) {
|
|
var error_area = $("#compose_invite_users");
|
|
var existing_invites_area = $('#compose_invite_users .compose_invite_user');
|
|
|
|
var existing_invites = _.map($(existing_invites_area), function (user_row) {
|
|
return $(user_row).data('useremail');
|
|
});
|
|
|
|
if (existing_invites.indexOf(email) === -1) {
|
|
var context = {
|
|
email: email,
|
|
name: data.mentioned.full_name,
|
|
can_subscribe_other_users: page_params.can_subscribe_other_users,
|
|
};
|
|
var new_row = templates.render("compose-invite-users", context);
|
|
error_area.append(new_row);
|
|
}
|
|
|
|
error_area.show();
|
|
}
|
|
}
|
|
|
|
// User group mentions will fall through here. In the future,
|
|
// we may want to add some sort of similar warning for cases
|
|
// where nobody in the group is subscribed, but that decision
|
|
// can wait on user feedback.
|
|
});
|
|
|
|
$("#compose-all-everyone").on('click', '.compose-all-everyone-confirm', function (event) {
|
|
event.preventDefault();
|
|
|
|
$(event.target).parents('.compose-all-everyone').remove();
|
|
user_acknowledged_all_everyone = true;
|
|
exports.clear_all_everyone_warnings();
|
|
compose.finish();
|
|
});
|
|
|
|
$("#compose-announce").on('click', '.compose-announce-confirm', function (event) {
|
|
event.preventDefault();
|
|
|
|
$(event.target).parents('.compose-announce').remove();
|
|
user_acknowledged_announce = true;
|
|
exports.clear_announce_warnings();
|
|
compose.finish();
|
|
});
|
|
|
|
$("#compose-send-status").on('click', '.sub_unsub_button', function (event) {
|
|
event.preventDefault();
|
|
|
|
var stream_name = $('#stream_message_recipient_stream').val();
|
|
if (stream_name === undefined) {
|
|
return;
|
|
}
|
|
var sub = stream_data.get_sub(stream_name);
|
|
subs.sub_or_unsub(sub);
|
|
$("#compose-send-status").hide();
|
|
});
|
|
|
|
$("#compose-send-status").on('click', '#compose_not_subscribed_close', function (event) {
|
|
event.preventDefault();
|
|
|
|
$("#compose-send-status").hide();
|
|
});
|
|
|
|
$("#compose_invite_users").on('click', '.compose_invite_link', function (event) {
|
|
event.preventDefault();
|
|
|
|
var invite_row = $(event.target).parents('.compose_invite_user');
|
|
|
|
var email = $(invite_row).data('useremail');
|
|
if (email === undefined) {
|
|
return;
|
|
}
|
|
|
|
function success() {
|
|
var all_invites = $("#compose_invite_users");
|
|
invite_row.remove();
|
|
|
|
if (all_invites.children().length === 0) {
|
|
all_invites.hide();
|
|
}
|
|
}
|
|
|
|
function failure(error_msg) {
|
|
exports.clear_invites();
|
|
compose_error(error_msg, $("#compose-textarea"));
|
|
$(event.target).attr('disabled', true);
|
|
}
|
|
|
|
function xhr_failure(xhr) {
|
|
var error = JSON.parse(xhr.responseText);
|
|
failure(error.msg);
|
|
}
|
|
|
|
var stream_name = compose_state.stream_name();
|
|
var sub = stream_data.get_sub(stream_name);
|
|
if (!sub) {
|
|
// This should only happen if a stream rename occurs
|
|
// before the user clicks. We could prevent this by
|
|
// putting a stream id in the link.
|
|
var error_msg = 'Stream no longer exists: ' + stream_name;
|
|
blueslip.warn(error_msg);
|
|
failure(error_msg);
|
|
return;
|
|
}
|
|
|
|
stream_edit.invite_user_to_stream(email, sub, success, xhr_failure);
|
|
});
|
|
|
|
$("#compose_invite_users").on('click', '.compose_invite_close', function (event) {
|
|
var invite_row = $(event.target).parents('.compose_invite_user');
|
|
var all_invites = $("#compose_invite_users");
|
|
|
|
invite_row.remove();
|
|
|
|
if (all_invites.children().length === 0) {
|
|
all_invites.hide();
|
|
}
|
|
});
|
|
|
|
// Show a warning if a private stream is linked
|
|
$(document).on('streamname_completed.zulip', function (event, data) {
|
|
// For PMs, we don't warn about links to private streams, since
|
|
// you are often specifically encouraging somebody to subscribe
|
|
// to the stream over PMs.
|
|
if (compose_state.get_message_type() !== 'stream') {
|
|
return;
|
|
}
|
|
|
|
if (data === undefined || data.stream === undefined) {
|
|
blueslip.error('Invalid options passed into handler.');
|
|
return;
|
|
}
|
|
|
|
var compose_stream = stream_data.get_sub(compose_state.stream_name());
|
|
if (compose_stream.subscribers && data.stream.subscribers) {
|
|
var compose_stream_sub = compose_stream.subscribers.keys();
|
|
var mentioned_stream_sub = data.stream.subscribers.keys();
|
|
// Don't warn if subscribers list of current compose_stream is a subset of
|
|
// mentioned_stream subscribers list.
|
|
if (_.difference(compose_stream_sub, mentioned_stream_sub).length === 0) {
|
|
return;
|
|
}
|
|
}
|
|
|
|
// data.stream refers to the stream we're linking to in
|
|
// typeahead. If it's not invite-only, then it's public, and
|
|
// there is no need to warn about it, since all users can already
|
|
// see all the public streams.
|
|
if (!data.stream.invite_only) {
|
|
return;
|
|
}
|
|
|
|
var stream_name = data.stream.name;
|
|
|
|
var warning_area = $("#compose_private_stream_alert");
|
|
var context = { stream_name: stream_name };
|
|
var new_row = templates.render("compose_private_stream_alert", context);
|
|
|
|
warning_area.append(new_row);
|
|
warning_area.show();
|
|
});
|
|
|
|
$("#compose_private_stream_alert").on('click', '.compose_private_stream_alert_close', function (event) {
|
|
var stream_alert_row = $(event.target).parents('.compose_private_stream_alert');
|
|
var stream_alert = $("#compose_private_stream_alert");
|
|
|
|
stream_alert_row.remove();
|
|
|
|
if (stream_alert.children().length === 0) {
|
|
stream_alert.hide();
|
|
}
|
|
});
|
|
|
|
// Click event binding for "Attach files" button
|
|
// Triggers a click on a hidden file input field
|
|
|
|
$("#compose").on("click", "#attach_files", function (e) {
|
|
e.preventDefault();
|
|
$("#compose #file_input").trigger("click");
|
|
});
|
|
|
|
$('body').on('click', '.video_link', function (e) {
|
|
e.preventDefault();
|
|
|
|
var target_textarea;
|
|
// The data-message-id atribute is only present in the video
|
|
// call icon present in the message edit form. If present,
|
|
// the request is for the edit UI; otherwise, it's for the
|
|
// compose box.
|
|
var edit_message_id = $(e.target).attr('data-message-id');
|
|
if (edit_message_id !== undefined) {
|
|
target_textarea = $("#message_edit_content_" + edit_message_id);
|
|
}
|
|
|
|
if (page_params.jitsi_server_url === null) {
|
|
return;
|
|
}
|
|
|
|
var video_call_link;
|
|
var video_call_id = util.random_int(100000000000000, 999999999999999);
|
|
if (page_params.realm_video_chat_provider === "Google Hangouts") {
|
|
video_call_link = "https://hangouts.google.com/hangouts/_/" + page_params.realm_google_hangouts_domain + "/" + video_call_id;
|
|
insert_video_call_url(video_call_link, target_textarea);
|
|
} else if (page_params.realm_video_chat_provider === "Zoom") {
|
|
channel.get({
|
|
url: '/json/calls/create',
|
|
success: function (response) {
|
|
insert_video_call_url(response.zoom_url, target_textarea);
|
|
},
|
|
});
|
|
} else {
|
|
video_call_link = page_params.jitsi_server_url + "/" + video_call_id;
|
|
insert_video_call_url(video_call_link, target_textarea);
|
|
}
|
|
});
|
|
|
|
$("#compose").on("click", "#markdown_preview", function (e) {
|
|
e.preventDefault();
|
|
var content = $("#compose-textarea").val();
|
|
$("#compose-textarea").hide();
|
|
$("#markdown_preview").hide();
|
|
$("#undo_markdown_preview").show();
|
|
$("#preview_message_area").show();
|
|
|
|
exports.render_and_show_preview($("#markdown_preview_spinner"), $("#preview_content"), content);
|
|
});
|
|
|
|
$("#compose").on("click", "#undo_markdown_preview", function (e) {
|
|
e.preventDefault();
|
|
exports.clear_preview_area();
|
|
});
|
|
|
|
$("#compose").filedrop(
|
|
upload.options({
|
|
mode: 'compose',
|
|
})
|
|
);
|
|
|
|
if (page_params.narrow !== undefined) {
|
|
if (page_params.narrow_topic !== undefined) {
|
|
compose_actions.start("stream", {topic: page_params.narrow_topic});
|
|
} else {
|
|
compose_actions.start("stream", {});
|
|
}
|
|
}
|
|
};
|
|
|
|
return exports;
|
|
}());
|
|
|
|
if (typeof module !== 'undefined') {
|
|
module.exports = compose;
|
|
}
|
|
window.compose = compose;
|