mirror of
				https://github.com/zulip/zulip.git
				synced 2025-11-04 05:53:43 +00:00 
			
		
		
		
	
		
			
				
	
	
		
			992 lines
		
	
	
		
			33 KiB
		
	
	
	
		
			JavaScript
		
	
	
	
	
	
			
		
		
	
	
			992 lines
		
	
	
		
			33 KiB
		
	
	
	
		
			JavaScript
		
	
	
	
	
	
import Handlebars from "handlebars/runtime";
 | 
						|
import _ from "lodash";
 | 
						|
 | 
						|
import {$t} from "./i18n";
 | 
						|
import * as message_parser from "./message_parser";
 | 
						|
import * as message_store from "./message_store";
 | 
						|
import {page_params} from "./page_params";
 | 
						|
import * as people from "./people";
 | 
						|
import * as stream_data from "./stream_data";
 | 
						|
import * as unread from "./unread";
 | 
						|
import * as util from "./util";
 | 
						|
 | 
						|
function zephyr_stream_name_match(message, operand) {
 | 
						|
    // Zephyr users expect narrowing to "social" to also show messages to /^(un)*social(.d)*$/
 | 
						|
    // (unsocial, ununsocial, social.d, etc)
 | 
						|
    // TODO: hoist the regex compiling out of the closure
 | 
						|
    const m = /^(?:un)*(.+?)(?:\.d)*$/i.exec(operand);
 | 
						|
    let base_stream_name = operand;
 | 
						|
    if (m !== null && m[1] !== undefined) {
 | 
						|
        base_stream_name = m[1];
 | 
						|
    }
 | 
						|
    const related_regexp = new RegExp(
 | 
						|
        /^(un)*/.source + _.escapeRegExp(base_stream_name) + /(\.d)*$/.source,
 | 
						|
        "i",
 | 
						|
    );
 | 
						|
    return related_regexp.test(message.stream);
 | 
						|
}
 | 
						|
 | 
						|
function zephyr_topic_name_match(message, operand) {
 | 
						|
    // Zephyr users expect narrowing to topic "foo" to also show messages to /^foo(.d)*$/
 | 
						|
    // (foo, foo.d, foo.d.d, etc)
 | 
						|
    // TODO: hoist the regex compiling out of the closure
 | 
						|
    const m = /^(.*?)(?:\.d)*$/i.exec(operand);
 | 
						|
    const base_topic = m[1];
 | 
						|
    let related_regexp;
 | 
						|
 | 
						|
    // Additionally, Zephyr users expect the empty instance and
 | 
						|
    // instance "personal" to be the same.
 | 
						|
    if (
 | 
						|
        base_topic === "" ||
 | 
						|
        base_topic.toLowerCase() === "personal" ||
 | 
						|
        base_topic.toLowerCase() === '(instance "")'
 | 
						|
    ) {
 | 
						|
        related_regexp = /^(|personal|\(instance ""\))(\.d)*$/i;
 | 
						|
    } else {
 | 
						|
        related_regexp = new RegExp(
 | 
						|
            /^/.source + _.escapeRegExp(base_topic) + /(\.d)*$/.source,
 | 
						|
            "i",
 | 
						|
        );
 | 
						|
    }
 | 
						|
 | 
						|
    return related_regexp.test(message.topic);
 | 
						|
}
 | 
						|
 | 
						|
function message_in_home(message) {
 | 
						|
    if (
 | 
						|
        message.type === "private" ||
 | 
						|
        message.mentioned ||
 | 
						|
        (page_params.narrow_stream !== undefined &&
 | 
						|
            message.stream.toLowerCase() === page_params.narrow_stream.toLowerCase())
 | 
						|
    ) {
 | 
						|
        return true;
 | 
						|
    }
 | 
						|
 | 
						|
    // We don't display muted streams in 'All messages' view
 | 
						|
    return !stream_data.is_muted(message.stream_id);
 | 
						|
}
 | 
						|
 | 
						|
function message_matches_search_term(message, operator, operand) {
 | 
						|
    switch (operator) {
 | 
						|
        case "has":
 | 
						|
            switch (operand) {
 | 
						|
                case "image":
 | 
						|
                    return message_parser.message_has_image(message);
 | 
						|
                case "link":
 | 
						|
                    return message_parser.message_has_link(message);
 | 
						|
                case "attachment":
 | 
						|
                    return message_parser.message_has_attachment(message);
 | 
						|
                default:
 | 
						|
                    return false; // has:something_else returns false
 | 
						|
            }
 | 
						|
 | 
						|
        case "is":
 | 
						|
            switch (operand) {
 | 
						|
                case "private":
 | 
						|
                    return message.type === "private";
 | 
						|
                case "starred":
 | 
						|
                    return message.starred;
 | 
						|
                case "mentioned":
 | 
						|
                    return message.mentioned;
 | 
						|
                case "alerted":
 | 
						|
                    return message.alerted;
 | 
						|
                case "unread":
 | 
						|
                    return unread.message_unread(message);
 | 
						|
                default:
 | 
						|
                    return false; // is:whatever returns false
 | 
						|
            }
 | 
						|
 | 
						|
        case "in":
 | 
						|
            switch (operand) {
 | 
						|
                case "home":
 | 
						|
                    return message_in_home(message);
 | 
						|
                case "all":
 | 
						|
                    return true;
 | 
						|
                default:
 | 
						|
                    return false; // in:whatever returns false
 | 
						|
            }
 | 
						|
 | 
						|
        case "near":
 | 
						|
            // this is all handled server side
 | 
						|
            return true;
 | 
						|
 | 
						|
        case "id":
 | 
						|
            return message.id.toString() === operand;
 | 
						|
 | 
						|
        case "stream": {
 | 
						|
            if (message.type !== "stream") {
 | 
						|
                return false;
 | 
						|
            }
 | 
						|
 | 
						|
            operand = operand.toLowerCase();
 | 
						|
            if (page_params.realm_is_zephyr_mirror_realm) {
 | 
						|
                return zephyr_stream_name_match(message, operand);
 | 
						|
            }
 | 
						|
 | 
						|
            // Try to match by stream_id if have a valid sub for
 | 
						|
            // the operand.
 | 
						|
            const stream_id = stream_data.get_stream_id(operand);
 | 
						|
            if (stream_id) {
 | 
						|
                return message.stream_id === stream_id;
 | 
						|
            }
 | 
						|
 | 
						|
            // We need this fallback logic in case we have a message
 | 
						|
            // loaded for a stream that we are no longer
 | 
						|
            // subscribed to (or that was deleted).
 | 
						|
            return message.stream.toLowerCase() === operand;
 | 
						|
        }
 | 
						|
 | 
						|
        case "topic":
 | 
						|
            if (message.type !== "stream") {
 | 
						|
                return false;
 | 
						|
            }
 | 
						|
 | 
						|
            operand = operand.toLowerCase();
 | 
						|
            if (page_params.realm_is_zephyr_mirror_realm) {
 | 
						|
                return zephyr_topic_name_match(message, operand);
 | 
						|
            }
 | 
						|
            return message.topic.toLowerCase() === operand;
 | 
						|
 | 
						|
        case "sender":
 | 
						|
            return people.id_matches_email_operand(message.sender_id, operand);
 | 
						|
 | 
						|
        case "group-pm-with": {
 | 
						|
            const operand_ids = people.pm_with_operand_ids(operand);
 | 
						|
            if (!operand_ids) {
 | 
						|
                return false;
 | 
						|
            }
 | 
						|
            const user_ids = people.group_pm_with_user_ids(message);
 | 
						|
            if (!user_ids) {
 | 
						|
                return false;
 | 
						|
            }
 | 
						|
            return user_ids.includes(operand_ids[0]);
 | 
						|
            // We should also check if the current user is in the recipient list (user_ids) of the
 | 
						|
            // message, but it is implicit by the fact that the current user has access to the message.
 | 
						|
        }
 | 
						|
 | 
						|
        case "pm-with": {
 | 
						|
            // TODO: use user_ids, not emails here
 | 
						|
            if (message.type !== "private") {
 | 
						|
                return false;
 | 
						|
            }
 | 
						|
            const operand_ids = people.pm_with_operand_ids(operand);
 | 
						|
            if (!operand_ids) {
 | 
						|
                return false;
 | 
						|
            }
 | 
						|
            const user_ids = people.pm_with_user_ids(message);
 | 
						|
            if (!user_ids) {
 | 
						|
                return false;
 | 
						|
            }
 | 
						|
 | 
						|
            return _.isEqual(operand_ids, user_ids);
 | 
						|
        }
 | 
						|
    }
 | 
						|
 | 
						|
    return true; // unknown operators return true (effectively ignored)
 | 
						|
}
 | 
						|
 | 
						|
export class Filter {
 | 
						|
    constructor(operators) {
 | 
						|
        if (operators === undefined) {
 | 
						|
            this._operators = [];
 | 
						|
            this._sub = undefined;
 | 
						|
        } else {
 | 
						|
            this._operators = this.fix_operators(operators);
 | 
						|
            if (this.has_operator("stream")) {
 | 
						|
                this._sub = stream_data.get_sub_by_name(this.operands("stream")[0]);
 | 
						|
            }
 | 
						|
        }
 | 
						|
    }
 | 
						|
 | 
						|
    static canonicalize_operator(operator) {
 | 
						|
        operator = operator.toLowerCase();
 | 
						|
 | 
						|
        if (operator === "from") {
 | 
						|
            return "sender";
 | 
						|
        }
 | 
						|
 | 
						|
        if (util.is_topic_synonym(operator)) {
 | 
						|
            return "topic";
 | 
						|
        }
 | 
						|
        return operator;
 | 
						|
    }
 | 
						|
 | 
						|
    static canonicalize_term({negated = false, operator, operand}) {
 | 
						|
        // Make negated explicitly default to false for both clarity and
 | 
						|
        // simplifying deepEqual checks in the tests.
 | 
						|
        operator = Filter.canonicalize_operator(operator);
 | 
						|
 | 
						|
        switch (operator) {
 | 
						|
            case "has":
 | 
						|
                // images -> image, etc.
 | 
						|
                operand = operand.replace(/s$/, "");
 | 
						|
                break;
 | 
						|
 | 
						|
            case "stream":
 | 
						|
                operand = stream_data.get_name(operand);
 | 
						|
                break;
 | 
						|
            case "topic":
 | 
						|
                break;
 | 
						|
            case "sender":
 | 
						|
            case "pm-with":
 | 
						|
                operand = operand.toString().toLowerCase();
 | 
						|
                if (operand === "me") {
 | 
						|
                    operand = people.my_current_email();
 | 
						|
                }
 | 
						|
                break;
 | 
						|
            case "group-pm-with":
 | 
						|
                operand = operand.toString().toLowerCase();
 | 
						|
                break;
 | 
						|
            case "search":
 | 
						|
                // The mac app automatically substitutes regular quotes with curly
 | 
						|
                // quotes when typing in the search bar.  Curly quotes don't trigger our
 | 
						|
                // phrase search behavior, however.  So, we replace all instances of
 | 
						|
                // curly quotes with regular quotes when doing a search.  This is
 | 
						|
                // unlikely to cause any problems and is probably what the user wants.
 | 
						|
                operand = operand
 | 
						|
                    .toString()
 | 
						|
                    .toLowerCase()
 | 
						|
                    .replace(/[\u201C\u201D]/g, '"');
 | 
						|
                break;
 | 
						|
            default:
 | 
						|
                operand = operand.toString().toLowerCase();
 | 
						|
        }
 | 
						|
 | 
						|
        // We may want to consider allowing mixed-case operators at some point
 | 
						|
        return {
 | 
						|
            negated,
 | 
						|
            operator,
 | 
						|
            operand,
 | 
						|
        };
 | 
						|
    }
 | 
						|
 | 
						|
    /* We use a variant of URI encoding which looks reasonably
 | 
						|
       nice and still handles unambiguously cases such as
 | 
						|
       spaces in operands.
 | 
						|
 | 
						|
       This is just for the search bar, not for saving the
 | 
						|
       narrow in the URL fragment.  There we do use full
 | 
						|
       URI encoding to avoid problematic characters. */
 | 
						|
    static encodeOperand(operand) {
 | 
						|
        return operand
 | 
						|
            .replace(/%/g, "%25")
 | 
						|
            .replace(/\+/g, "%2B")
 | 
						|
            .replace(/ /g, "+")
 | 
						|
            .replace(/"/g, "%22");
 | 
						|
    }
 | 
						|
 | 
						|
    static decodeOperand(encoded, operator) {
 | 
						|
        encoded = encoded.replace(/"/g, "");
 | 
						|
        if (["group-pm-with", "pm-with", "sender", "from"].includes(operator) === false) {
 | 
						|
            encoded = encoded.replace(/\+/g, " ");
 | 
						|
        }
 | 
						|
        return util.robust_uri_decode(encoded).trim();
 | 
						|
    }
 | 
						|
 | 
						|
    // Parse a string into a list of operators (see below).
 | 
						|
    static parse(str) {
 | 
						|
        const operators = [];
 | 
						|
        const search_term = [];
 | 
						|
        let negated;
 | 
						|
        let operator;
 | 
						|
        let operand;
 | 
						|
        let term;
 | 
						|
 | 
						|
        // Match all operands that either have no spaces, or are surrounded by
 | 
						|
        // quotes, preceded by an optional operator that may have a space after it.
 | 
						|
        const matches = str.match(/([^\s:]+: ?)?("[^"]+"?|\S+)/g);
 | 
						|
        if (matches === null) {
 | 
						|
            return operators;
 | 
						|
        }
 | 
						|
 | 
						|
        for (const token of matches) {
 | 
						|
            let operator;
 | 
						|
            const parts = token.split(":");
 | 
						|
            if (token[0] === '"' || parts.length === 1) {
 | 
						|
                // Looks like a normal search term.
 | 
						|
                search_term.push(token);
 | 
						|
            } else {
 | 
						|
                // Looks like an operator.
 | 
						|
                negated = false;
 | 
						|
                operator = parts.shift();
 | 
						|
                if (operator[0] === "-") {
 | 
						|
                    negated = true;
 | 
						|
                    operator = operator.slice(1);
 | 
						|
                }
 | 
						|
                operand = Filter.decodeOperand(parts.join(":"), operator);
 | 
						|
 | 
						|
                // We use Filter.operator_to_prefix() checks if the
 | 
						|
                // operator is known.  If it is not known, then we treat
 | 
						|
                // it as a search for the given string (which may contain
 | 
						|
                // a `:`), not as a search operator.
 | 
						|
                if (Filter.operator_to_prefix(operator, negated) === "") {
 | 
						|
                    // Put it as a search term, to not have duplicate operators
 | 
						|
                    search_term.push(token);
 | 
						|
                    continue;
 | 
						|
                }
 | 
						|
                term = {negated, operator, operand};
 | 
						|
                operators.push(term);
 | 
						|
            }
 | 
						|
        }
 | 
						|
 | 
						|
        // NB: Callers of 'parse' can assume that the 'search' operator is last.
 | 
						|
        if (search_term.length > 0) {
 | 
						|
            operator = "search";
 | 
						|
            operand = search_term.join(" ");
 | 
						|
            term = {operator, operand, negated: false};
 | 
						|
            operators.push(term);
 | 
						|
        }
 | 
						|
        return operators;
 | 
						|
    }
 | 
						|
 | 
						|
    /* Convert a list of operators to a string.
 | 
						|
   Each operator is a key-value pair like
 | 
						|
 | 
						|
       ['topic', 'my amazing topic']
 | 
						|
 | 
						|
   These are not keys in a JavaScript object, because we
 | 
						|
   might need to support multiple operators of the same type.
 | 
						|
*/
 | 
						|
    static unparse(operators) {
 | 
						|
        const parts = operators.map((elem) => {
 | 
						|
            if (elem.operator === "search") {
 | 
						|
                // Search terms are the catch-all case.
 | 
						|
                // All tokens that don't start with a known operator and
 | 
						|
                // a colon are glued together to form a search term.
 | 
						|
                return elem.operand;
 | 
						|
            }
 | 
						|
            const sign = elem.negated ? "-" : "";
 | 
						|
            if (elem.operator === "") {
 | 
						|
                return elem.operand;
 | 
						|
            }
 | 
						|
            return sign + elem.operator + ":" + Filter.encodeOperand(elem.operand.toString());
 | 
						|
        });
 | 
						|
        return parts.join(" ");
 | 
						|
    }
 | 
						|
 | 
						|
    predicate() {
 | 
						|
        if (this._predicate === undefined) {
 | 
						|
            this._predicate = this._build_predicate();
 | 
						|
        }
 | 
						|
        return this._predicate;
 | 
						|
    }
 | 
						|
 | 
						|
    operators() {
 | 
						|
        return this._operators;
 | 
						|
    }
 | 
						|
 | 
						|
    public_operators() {
 | 
						|
        const safe_to_return = this._operators.filter(
 | 
						|
            // Filter out the embedded narrow (if any).
 | 
						|
            (value) =>
 | 
						|
                !(
 | 
						|
                    page_params.narrow_stream !== undefined &&
 | 
						|
                    value.operator === "stream" &&
 | 
						|
                    value.operand.toLowerCase() === page_params.narrow_stream.toLowerCase()
 | 
						|
                ),
 | 
						|
        );
 | 
						|
        return safe_to_return;
 | 
						|
    }
 | 
						|
 | 
						|
    operands(operator) {
 | 
						|
        return this._operators
 | 
						|
            .filter((elem) => !elem.negated && elem.operator === operator)
 | 
						|
            .map((elem) => elem.operand);
 | 
						|
    }
 | 
						|
 | 
						|
    has_negated_operand(operator, operand) {
 | 
						|
        return this._operators.some(
 | 
						|
            (elem) => elem.negated && elem.operator === operator && elem.operand === operand,
 | 
						|
        );
 | 
						|
    }
 | 
						|
 | 
						|
    has_operand(operator, operand) {
 | 
						|
        return this._operators.some(
 | 
						|
            (elem) => !elem.negated && elem.operator === operator && elem.operand === operand,
 | 
						|
        );
 | 
						|
    }
 | 
						|
 | 
						|
    has_operator(operator) {
 | 
						|
        return this._operators.some((elem) => {
 | 
						|
            if (elem.negated && !["search", "has"].includes(elem.operator)) {
 | 
						|
                return false;
 | 
						|
            }
 | 
						|
            return elem.operator === operator;
 | 
						|
        });
 | 
						|
    }
 | 
						|
 | 
						|
    is_search() {
 | 
						|
        return this.has_operator("search");
 | 
						|
    }
 | 
						|
 | 
						|
    is_non_huddle_pm() {
 | 
						|
        return this.has_operator("pm-with") && this.operands("pm-with")[0].split(",").length === 1;
 | 
						|
    }
 | 
						|
 | 
						|
    calc_can_mark_messages_read() {
 | 
						|
        const term_types = this.sorted_term_types();
 | 
						|
 | 
						|
        if (_.isEqual(term_types, ["stream", "topic"])) {
 | 
						|
            return true;
 | 
						|
        }
 | 
						|
 | 
						|
        if (_.isEqual(term_types, ["pm-with"])) {
 | 
						|
            return true;
 | 
						|
        }
 | 
						|
 | 
						|
        // TODO: Some users really hate it when Zulip marks messages as read
 | 
						|
        // in interleaved views, so we will eventually have a setting
 | 
						|
        // that early-exits before the subsequent checks.
 | 
						|
        // (in which case, is_common_narrow would also need to be modified)
 | 
						|
 | 
						|
        if (_.isEqual(term_types, ["stream"])) {
 | 
						|
            return true;
 | 
						|
        }
 | 
						|
 | 
						|
        if (_.isEqual(term_types, ["is-private"])) {
 | 
						|
            return true;
 | 
						|
        }
 | 
						|
 | 
						|
        if (_.isEqual(term_types, ["is-mentioned"])) {
 | 
						|
            return true;
 | 
						|
        }
 | 
						|
 | 
						|
        if (_.isEqual(term_types, [])) {
 | 
						|
            // All view
 | 
						|
            return true;
 | 
						|
        }
 | 
						|
 | 
						|
        if (term_types.length === 1 && ["in-home", "in-all"].includes(term_types[0])) {
 | 
						|
            return true;
 | 
						|
        }
 | 
						|
 | 
						|
        return false;
 | 
						|
    }
 | 
						|
 | 
						|
    can_mark_messages_read() {
 | 
						|
        if (this._can_mark_messages_read === undefined) {
 | 
						|
            this._can_mark_messages_read = this.calc_can_mark_messages_read();
 | 
						|
        }
 | 
						|
        return this._can_mark_messages_read;
 | 
						|
    }
 | 
						|
 | 
						|
    // This is used to control the behaviour for "exiting search",
 | 
						|
    // given the ability to flip between displaying the search bar and the narrow description in UI
 | 
						|
    // here we define a narrow as a "common narrow" on the basis of
 | 
						|
    // https://paper.dropbox.com/doc/Navbar-behavior-table--AvnMKN4ogj3k2YF5jTbOiVv_AQ-cNOGtu7kSdtnKBizKXJge
 | 
						|
    // common narrows show a narrow description and allow the user to
 | 
						|
    // close search bar UI and show the narrow description UI.
 | 
						|
    //
 | 
						|
    // TODO: We likely will want to rewrite this to not piggy-back on
 | 
						|
    // can_mark_messages_read, since that might gain some more complex behavior
 | 
						|
    // with near: narrows.
 | 
						|
    is_common_narrow() {
 | 
						|
        // can_mark_messages_read tests the following filters:
 | 
						|
        // stream, stream + topic,
 | 
						|
        // is: private, pm-with:,
 | 
						|
        // is: mentioned
 | 
						|
        if (this.can_mark_messages_read()) {
 | 
						|
            return true;
 | 
						|
        }
 | 
						|
        // that leaves us with checking:
 | 
						|
        // is: starred
 | 
						|
        // (which can_mark_messages_read_does not check as starred messages are always read)
 | 
						|
        const term_types = this.sorted_term_types();
 | 
						|
 | 
						|
        if (_.isEqual(term_types, ["is-starred"])) {
 | 
						|
            return true;
 | 
						|
        }
 | 
						|
        if (_.isEqual(term_types, ["streams-public"])) {
 | 
						|
            return true;
 | 
						|
        }
 | 
						|
        return false;
 | 
						|
    }
 | 
						|
 | 
						|
    // This is used to control the behaviour for "exiting search"
 | 
						|
    // within a narrow (E.g. a stream/topic + search) to bring you to
 | 
						|
    // the containing common narrow (stream/topic, in the example)
 | 
						|
    // rather than "All messages".
 | 
						|
    //
 | 
						|
    // Note from tabbott: The slug-based approach may not be ideal; we
 | 
						|
    // may be able to do better another way.
 | 
						|
    generate_redirect_url() {
 | 
						|
        const term_types = this.sorted_term_types();
 | 
						|
 | 
						|
        // this comes first because it has 3 term_types but is not a "complex filter"
 | 
						|
        if (_.isEqual(term_types, ["stream", "topic", "search"])) {
 | 
						|
            // if stream does not exist, redirect to All
 | 
						|
            if (!this._sub) {
 | 
						|
                return "#";
 | 
						|
            }
 | 
						|
            return (
 | 
						|
                "/#narrow/stream/" +
 | 
						|
                stream_data.name_to_slug(this.operands("stream")[0]) +
 | 
						|
                "/topic/" +
 | 
						|
                this.operands("topic")[0]
 | 
						|
            );
 | 
						|
        }
 | 
						|
 | 
						|
        // eliminate "complex filters"
 | 
						|
        if (term_types.length >= 3) {
 | 
						|
            return "#"; // redirect to All
 | 
						|
        }
 | 
						|
 | 
						|
        if (term_types[1] === "search") {
 | 
						|
            switch (term_types[0]) {
 | 
						|
                case "stream":
 | 
						|
                    // if stream does not exist, redirect to All
 | 
						|
                    if (!this._sub) {
 | 
						|
                        return "#";
 | 
						|
                    }
 | 
						|
                    return (
 | 
						|
                        "/#narrow/stream/" + stream_data.name_to_slug(this.operands("stream")[0])
 | 
						|
                    );
 | 
						|
                case "is-private":
 | 
						|
                    return "/#narrow/is/private";
 | 
						|
                case "is-starred":
 | 
						|
                    return "/#narrow/is/starred";
 | 
						|
                case "is-mentioned":
 | 
						|
                    return "/#narrow/is/mentioned";
 | 
						|
                case "streams-public":
 | 
						|
                    return "/#narrow/streams/public";
 | 
						|
                case "pm-with":
 | 
						|
                    return (
 | 
						|
                        "/#narrow/pm-with/" +
 | 
						|
                        people.emails_to_slug(this.operands("pm-with").join(","))
 | 
						|
                    );
 | 
						|
                // TODO: It is ambiguous how we want to handle the 'sender' case,
 | 
						|
                // we may remove it in the future based on design decisions
 | 
						|
                case "sender":
 | 
						|
                    return "/#narrow/sender/" + people.emails_to_slug(this.operands("sender")[0]);
 | 
						|
            }
 | 
						|
        }
 | 
						|
 | 
						|
        return "#"; // redirect to All
 | 
						|
    }
 | 
						|
 | 
						|
    get_icon() {
 | 
						|
        // We have special icons for the simple narrows available for the via sidebars.
 | 
						|
        const term_types = this.sorted_term_types();
 | 
						|
        switch (term_types[0]) {
 | 
						|
            case "in-home":
 | 
						|
            case "in-all":
 | 
						|
                return "home";
 | 
						|
            case "stream":
 | 
						|
                if (!this._sub) {
 | 
						|
                    return "question-circle-o";
 | 
						|
                }
 | 
						|
                if (this._sub.invite_only) {
 | 
						|
                    return "lock";
 | 
						|
                }
 | 
						|
                if (this._sub.is_web_public) {
 | 
						|
                    return "globe";
 | 
						|
                }
 | 
						|
                return "hashtag";
 | 
						|
            case "is-private":
 | 
						|
                return "envelope";
 | 
						|
            case "is-starred":
 | 
						|
                return "star";
 | 
						|
            case "is-mentioned":
 | 
						|
                return "at";
 | 
						|
            case "pm-with":
 | 
						|
                return "envelope";
 | 
						|
            default:
 | 
						|
                return undefined;
 | 
						|
        }
 | 
						|
    }
 | 
						|
 | 
						|
    get_title() {
 | 
						|
        // Nice explanatory titles for common views.
 | 
						|
        const term_types = this.sorted_term_types();
 | 
						|
        if (
 | 
						|
            (term_types.length === 3 && _.isEqual(term_types, ["stream", "topic", "search"])) ||
 | 
						|
            (term_types.length === 2 && _.isEqual(term_types, ["stream", "topic"]))
 | 
						|
        ) {
 | 
						|
            if (!this._sub) {
 | 
						|
                return $t({defaultMessage: "Unknown stream"});
 | 
						|
            }
 | 
						|
            return this._sub.name;
 | 
						|
        }
 | 
						|
        if (term_types.length === 1 || (term_types.length === 2 && term_types[1] === "search")) {
 | 
						|
            switch (term_types[0]) {
 | 
						|
                case "in-home":
 | 
						|
                    return $t({defaultMessage: "All messages"});
 | 
						|
                case "in-all":
 | 
						|
                    return $t({defaultMessage: "All messages including muted streams"});
 | 
						|
                case "streams-public":
 | 
						|
                    return $t({defaultMessage: "Public stream messages in organization"});
 | 
						|
                case "stream":
 | 
						|
                    if (!this._sub) {
 | 
						|
                        return $t({defaultMessage: "Unknown stream"});
 | 
						|
                    }
 | 
						|
                    return this._sub.name;
 | 
						|
                case "is-starred":
 | 
						|
                    return $t({defaultMessage: "Starred messages"});
 | 
						|
                case "is-mentioned":
 | 
						|
                    return $t({defaultMessage: "Mentions"});
 | 
						|
                case "is-private":
 | 
						|
                    return $t({defaultMessage: "Private messages"});
 | 
						|
                case "pm-with": {
 | 
						|
                    const emails = this.operands("pm-with")[0].split(",");
 | 
						|
                    const names = emails.map((email) => {
 | 
						|
                        if (!people.get_by_email(email)) {
 | 
						|
                            return email;
 | 
						|
                        }
 | 
						|
                        return people.get_by_email(email).full_name;
 | 
						|
                    });
 | 
						|
 | 
						|
                    // We use join to handle the addition of a comma and space after every name
 | 
						|
                    // and also to ensure that we return a string and not an array so that we
 | 
						|
                    // can have the same return type as other cases.
 | 
						|
                    return names.join(", ");
 | 
						|
                }
 | 
						|
            }
 | 
						|
        }
 | 
						|
        /* istanbul ignore next */
 | 
						|
        return undefined;
 | 
						|
    }
 | 
						|
 | 
						|
    allow_use_first_unread_when_narrowing() {
 | 
						|
        return this.can_mark_messages_read() || this.has_operator("is");
 | 
						|
    }
 | 
						|
 | 
						|
    contains_only_private_messages() {
 | 
						|
        return (
 | 
						|
            (this.has_operator("is") && this.operands("is")[0] === "private") ||
 | 
						|
            this.has_operator("pm-with") ||
 | 
						|
            this.has_operator("group-pm-with")
 | 
						|
        );
 | 
						|
    }
 | 
						|
 | 
						|
    includes_full_stream_history() {
 | 
						|
        return this.has_operator("stream") || this.has_operator("streams");
 | 
						|
    }
 | 
						|
 | 
						|
    is_personal_filter() {
 | 
						|
        // Whether the filter filters for user-specific data in the
 | 
						|
        // UserMessage table, such as stars or mentions.
 | 
						|
        //
 | 
						|
        // Such filters should not advertise "streams:public" as it
 | 
						|
        // will never add additional results.
 | 
						|
        return this.has_operand("is", "mentioned") || this.has_operand("is", "starred");
 | 
						|
    }
 | 
						|
 | 
						|
    can_apply_locally(is_local_echo) {
 | 
						|
        // Since there can be multiple operators, each block should
 | 
						|
        // just return false here.
 | 
						|
 | 
						|
        if (this.is_search()) {
 | 
						|
            // The semantics for matching keywords are implemented
 | 
						|
            // by database plugins, and we don't have JS code for
 | 
						|
            // that, plus search queries tend to go too far back in
 | 
						|
            // history.
 | 
						|
            return false;
 | 
						|
        }
 | 
						|
 | 
						|
        if (this.has_operator("has") && is_local_echo) {
 | 
						|
            // The has: operators can be applied locally for messages
 | 
						|
            // rendered by the backend; links, attachments, and images
 | 
						|
            // are not handled properly by the local echo Markdown
 | 
						|
            // processor.
 | 
						|
            return false;
 | 
						|
        }
 | 
						|
 | 
						|
        if (this.has_operator("streams") || this.has_negated_operand("streams", "public")) {
 | 
						|
            return false;
 | 
						|
        }
 | 
						|
 | 
						|
        // If we get this far, we're good!
 | 
						|
        return true;
 | 
						|
    }
 | 
						|
 | 
						|
    fix_operators(operators) {
 | 
						|
        operators = this._canonicalize_operators(operators);
 | 
						|
        operators = this._fix_redundant_is_private(operators);
 | 
						|
        return operators;
 | 
						|
    }
 | 
						|
 | 
						|
    _fix_redundant_is_private(terms) {
 | 
						|
        if (!terms.some((term) => Filter.term_type(term) === "pm-with")) {
 | 
						|
            return terms;
 | 
						|
        }
 | 
						|
 | 
						|
        return terms.filter((term) => Filter.term_type(term) !== "is-private");
 | 
						|
    }
 | 
						|
 | 
						|
    _canonicalize_operators(operators_mixed_case) {
 | 
						|
        return operators_mixed_case.map((tuple) => Filter.canonicalize_term(tuple));
 | 
						|
    }
 | 
						|
 | 
						|
    filter_with_new_params(params) {
 | 
						|
        const terms = this._operators.map((term) => {
 | 
						|
            const new_term = {...term};
 | 
						|
            if (new_term.operator === params.operator && !new_term.negated) {
 | 
						|
                new_term.operand = params.operand;
 | 
						|
            }
 | 
						|
            return new_term;
 | 
						|
        });
 | 
						|
        return new Filter(terms);
 | 
						|
    }
 | 
						|
 | 
						|
    has_topic(stream_name, topic) {
 | 
						|
        return this.has_operand("stream", stream_name) && this.has_operand("topic", topic);
 | 
						|
    }
 | 
						|
 | 
						|
    sorted_term_types() {
 | 
						|
        if (this._sorted_term_types === undefined) {
 | 
						|
            this._sorted_term_types = this._build_sorted_term_types();
 | 
						|
        }
 | 
						|
        return this._sorted_term_types;
 | 
						|
    }
 | 
						|
 | 
						|
    _build_sorted_term_types() {
 | 
						|
        const terms = this._operators;
 | 
						|
        const term_types = terms.map((term) => Filter.term_type(term));
 | 
						|
        const sorted_terms = Filter.sorted_term_types(term_types);
 | 
						|
        return sorted_terms;
 | 
						|
    }
 | 
						|
 | 
						|
    can_bucket_by(...wanted_term_types) {
 | 
						|
        // Examples call:
 | 
						|
        //     filter.can_bucket_by('stream', 'topic')
 | 
						|
        //
 | 
						|
        // The use case of this function is that we want
 | 
						|
        // to know if a filter can start with a bucketing
 | 
						|
        // data structure similar to the ones we have in
 | 
						|
        // unread.js to pre-filter ids, rather than apply
 | 
						|
        // a predicate to a larger list of candidate ids.
 | 
						|
        //
 | 
						|
        // (It's for optimization, basically.)
 | 
						|
        const all_term_types = this.sorted_term_types();
 | 
						|
        const term_types = all_term_types.slice(0, wanted_term_types.length);
 | 
						|
 | 
						|
        return _.isEqual(term_types, wanted_term_types);
 | 
						|
    }
 | 
						|
 | 
						|
    first_valid_id_from(msg_ids) {
 | 
						|
        const predicate = this.predicate();
 | 
						|
 | 
						|
        const first_id = msg_ids.find((msg_id) => {
 | 
						|
            const message = message_store.get(msg_id);
 | 
						|
 | 
						|
            if (message === undefined) {
 | 
						|
                return false;
 | 
						|
            }
 | 
						|
 | 
						|
            return predicate(message);
 | 
						|
        });
 | 
						|
 | 
						|
        return first_id;
 | 
						|
    }
 | 
						|
 | 
						|
    update_email(user_id, new_email) {
 | 
						|
        for (const term of this._operators) {
 | 
						|
            switch (term.operator) {
 | 
						|
                case "group-pm-with":
 | 
						|
                case "pm-with":
 | 
						|
                case "sender":
 | 
						|
                case "from":
 | 
						|
                    term.operand = people.update_email_in_reply_to(
 | 
						|
                        term.operand,
 | 
						|
                        user_id,
 | 
						|
                        new_email,
 | 
						|
                    );
 | 
						|
            }
 | 
						|
        }
 | 
						|
    }
 | 
						|
 | 
						|
    // Build a filter function from a list of operators.
 | 
						|
    _build_predicate() {
 | 
						|
        const operators = this._operators;
 | 
						|
 | 
						|
        if (!this.can_apply_locally()) {
 | 
						|
            return () => true;
 | 
						|
        }
 | 
						|
 | 
						|
        // FIXME: This is probably pretty slow.
 | 
						|
        // We could turn it into something more like a compiler:
 | 
						|
        // build JavaScript code in a string and then eval() it.
 | 
						|
 | 
						|
        return (message) =>
 | 
						|
            operators.every((term) => {
 | 
						|
                let ok = message_matches_search_term(message, term.operator, term.operand);
 | 
						|
                if (term.negated) {
 | 
						|
                    ok = !ok;
 | 
						|
                }
 | 
						|
                return ok;
 | 
						|
            });
 | 
						|
    }
 | 
						|
 | 
						|
    static term_type(term) {
 | 
						|
        const operator = term.operator;
 | 
						|
        const operand = term.operand;
 | 
						|
        const negated = term.negated;
 | 
						|
 | 
						|
        let result = negated ? "not-" : "";
 | 
						|
 | 
						|
        result += operator;
 | 
						|
 | 
						|
        if (["is", "has", "in", "streams"].includes(operator)) {
 | 
						|
            result += "-" + operand;
 | 
						|
        }
 | 
						|
 | 
						|
        return result;
 | 
						|
    }
 | 
						|
 | 
						|
    static sorted_term_types(term_types) {
 | 
						|
        const levels = [
 | 
						|
            "in",
 | 
						|
            "streams-public",
 | 
						|
            "stream",
 | 
						|
            "topic",
 | 
						|
            "pm-with",
 | 
						|
            "group-pm-with",
 | 
						|
            "sender",
 | 
						|
            "near",
 | 
						|
            "id",
 | 
						|
            "is-alerted",
 | 
						|
            "is-mentioned",
 | 
						|
            "is-private",
 | 
						|
            "is-starred",
 | 
						|
            "is-unread",
 | 
						|
            "has-link",
 | 
						|
            "has-image",
 | 
						|
            "has-attachment",
 | 
						|
            "search",
 | 
						|
        ];
 | 
						|
 | 
						|
        const level = (term_type) => {
 | 
						|
            let i = levels.indexOf(term_type);
 | 
						|
            if (i === -1) {
 | 
						|
                i = 999;
 | 
						|
            }
 | 
						|
            return i;
 | 
						|
        };
 | 
						|
 | 
						|
        const compare = (a, b) => {
 | 
						|
            const diff = level(a) - level(b);
 | 
						|
            if (diff !== 0) {
 | 
						|
                return diff;
 | 
						|
            }
 | 
						|
            return util.strcmp(a, b);
 | 
						|
        };
 | 
						|
 | 
						|
        return term_types.slice().sort(compare);
 | 
						|
    }
 | 
						|
 | 
						|
    static operator_to_prefix(operator, negated) {
 | 
						|
        operator = Filter.canonicalize_operator(operator);
 | 
						|
 | 
						|
        if (operator === "search") {
 | 
						|
            return negated ? "exclude" : "search for";
 | 
						|
        }
 | 
						|
 | 
						|
        const verb = negated ? "exclude " : "";
 | 
						|
 | 
						|
        switch (operator) {
 | 
						|
            case "stream":
 | 
						|
                return verb + "stream";
 | 
						|
            case "streams":
 | 
						|
                return verb + "streams";
 | 
						|
            case "near":
 | 
						|
                return verb + "messages around";
 | 
						|
 | 
						|
            // Note: We hack around using this in "describe" below.
 | 
						|
            case "has":
 | 
						|
                return verb + "messages with one or more";
 | 
						|
 | 
						|
            case "id":
 | 
						|
                return verb + "message ID";
 | 
						|
 | 
						|
            case "topic":
 | 
						|
                return verb + "topic";
 | 
						|
 | 
						|
            case "sender":
 | 
						|
                return verb + "sent by";
 | 
						|
 | 
						|
            case "pm-with":
 | 
						|
                return verb + "private messages with";
 | 
						|
 | 
						|
            case "in":
 | 
						|
                return verb + "messages in";
 | 
						|
 | 
						|
            // Note: We hack around using this in "describe" below.
 | 
						|
            case "is":
 | 
						|
                return verb + "messages that are";
 | 
						|
 | 
						|
            case "group-pm-with":
 | 
						|
                return verb + "group private messages including";
 | 
						|
        }
 | 
						|
        return "";
 | 
						|
    }
 | 
						|
 | 
						|
    static describe_is_operator(operator) {
 | 
						|
        const verb = operator.negated ? "exclude " : "";
 | 
						|
        const operand = operator.operand;
 | 
						|
        const operand_list = ["private", "starred", "alerted", "unread"];
 | 
						|
        if (operand_list.includes(operand)) {
 | 
						|
            return verb + operand + " messages";
 | 
						|
        } else if (operand === "mentioned") {
 | 
						|
            return verb + "@-mentions";
 | 
						|
        }
 | 
						|
        return "invalid " + operand + " operand for is operator";
 | 
						|
    }
 | 
						|
 | 
						|
    // Convert a list of operators to a human-readable description.
 | 
						|
    static describe_unescaped(operators) {
 | 
						|
        if (operators.length === 0) {
 | 
						|
            return "all messages";
 | 
						|
        }
 | 
						|
 | 
						|
        let parts = [];
 | 
						|
 | 
						|
        if (operators.length >= 2) {
 | 
						|
            const is = (term, expected) => term.operator === expected && !term.negated;
 | 
						|
 | 
						|
            if (is(operators[0], "stream") && is(operators[1], "topic")) {
 | 
						|
                const stream = operators[0].operand;
 | 
						|
                const topic = operators[1].operand;
 | 
						|
                const part = "stream " + stream + " > " + topic;
 | 
						|
                parts = [part];
 | 
						|
                operators = operators.slice(2);
 | 
						|
            }
 | 
						|
        }
 | 
						|
 | 
						|
        const more_parts = operators.map((elem) => {
 | 
						|
            const operand = elem.operand;
 | 
						|
            const canonicalized_operator = Filter.canonicalize_operator(elem.operator);
 | 
						|
            if (canonicalized_operator === "is") {
 | 
						|
                return Filter.describe_is_operator(elem);
 | 
						|
            }
 | 
						|
            if (canonicalized_operator === "has") {
 | 
						|
                // search_suggestion.get_suggestions takes care that this message will
 | 
						|
                // only be shown if the `has` operator is not at the last.
 | 
						|
                const valid_has_operands = [
 | 
						|
                    "image",
 | 
						|
                    "images",
 | 
						|
                    "link",
 | 
						|
                    "links",
 | 
						|
                    "attachment",
 | 
						|
                    "attachments",
 | 
						|
                ];
 | 
						|
                if (!valid_has_operands.includes(operand)) {
 | 
						|
                    return "invalid " + operand + " operand for has operator";
 | 
						|
                }
 | 
						|
            }
 | 
						|
            const prefix_for_operator = Filter.operator_to_prefix(
 | 
						|
                canonicalized_operator,
 | 
						|
                elem.negated,
 | 
						|
            );
 | 
						|
            if (prefix_for_operator !== "") {
 | 
						|
                return prefix_for_operator + " " + operand;
 | 
						|
            }
 | 
						|
            return "unknown operator";
 | 
						|
        });
 | 
						|
        return parts.concat(more_parts).join(", ");
 | 
						|
    }
 | 
						|
 | 
						|
    static describe(operators) {
 | 
						|
        return Handlebars.Utils.escapeExpression(Filter.describe_unescaped(operators));
 | 
						|
    }
 | 
						|
}
 |