mirror of https://github.com/zulip/zulip.git
115 lines
3.1 KiB
JavaScript
115 lines
3.1 KiB
JavaScript
var rs = zrequire('recent_senders');
|
|
|
|
run_test('process_message_for_senders', () => {
|
|
var stream1 = 1;
|
|
var stream2 = 2;
|
|
var stream3 = 3;
|
|
|
|
var topic1 = "topic-1";
|
|
var topic2 = "topic-2";
|
|
var topic3 = "topic-3";
|
|
|
|
var sender1 = 1;
|
|
var sender2 = 2;
|
|
var sender3 = 3;
|
|
|
|
// New stream
|
|
var message1 = {
|
|
stream_id: stream1,
|
|
id: _.uniqueId(),
|
|
subject: topic1,
|
|
sender_id: sender1,
|
|
};
|
|
var message2 = {
|
|
stream_id: stream2,
|
|
id: _.uniqueId(),
|
|
subject: topic1,
|
|
sender_id: sender2,
|
|
};
|
|
rs.process_message_for_senders(message1);
|
|
rs.process_message_for_senders(message2);
|
|
|
|
// Users have posted in only one of the streams
|
|
assert.equal(
|
|
rs.compare_by_recency({user_id: sender1}, {user_id: sender2}, stream1, topic1) < 0,
|
|
true);
|
|
assert.equal(
|
|
rs.compare_by_recency({user_id: sender1}, {user_id: sender2}, stream2, topic1) > 0,
|
|
true);
|
|
|
|
// Users haven't posted in this stream, return zero
|
|
assert.equal(
|
|
rs.compare_by_recency({user_id: sender1}, {user_id: sender2}, stream3, undefined) === 0,
|
|
true);
|
|
|
|
// New topic
|
|
var message3 = {
|
|
stream_id: stream1,
|
|
id: _.uniqueId(),
|
|
subject: topic2,
|
|
sender_id: sender3,
|
|
};
|
|
rs.process_message_for_senders(message3);
|
|
assert.equal(
|
|
rs.compare_by_recency({user_id: sender3}, {user_id: sender2}, stream1, topic2) < 0,
|
|
true);
|
|
|
|
// New sender
|
|
var message4 = {
|
|
stream_id: stream1,
|
|
id: _.uniqueId(),
|
|
subject: topic1,
|
|
sender_id: sender2,
|
|
};
|
|
rs.process_message_for_senders(message4);
|
|
assert.equal(
|
|
rs.compare_by_recency({user_id: sender1}, {user_id: sender2}, stream1, topic1) > 0,
|
|
true);
|
|
|
|
// More recent message
|
|
var message5 = {
|
|
stream_id: stream1,
|
|
id: _.uniqueId(),
|
|
subject: topic1,
|
|
sender_id: sender1,
|
|
};
|
|
rs.process_message_for_senders(message5);
|
|
assert.equal(
|
|
rs.compare_by_recency({user_id: sender1}, {user_id: sender2}, stream1, topic1) < 0,
|
|
true);
|
|
|
|
// Same stream, but different topics
|
|
var message6 = {
|
|
stream_id: stream3,
|
|
id: _.uniqueId(),
|
|
subject: topic1,
|
|
sender_id: sender1,
|
|
};
|
|
var message7 = {
|
|
stream_id: stream3,
|
|
id: _.uniqueId(),
|
|
subject: topic2,
|
|
sender_id: sender2,
|
|
};
|
|
var message8 = {
|
|
stream_id: stream3,
|
|
id: _.uniqueId(),
|
|
subject: topic3,
|
|
sender_id: sender3,
|
|
};
|
|
|
|
rs.process_message_for_senders(message6);
|
|
rs.process_message_for_senders(message7);
|
|
rs.process_message_for_senders(message8);
|
|
|
|
// topic3 has a message in it, but sender1 nor sender2 have participated, so sort by stream
|
|
assert.equal(
|
|
rs.compare_by_recency({user_id: sender1}, {user_id: sender2}, stream3, topic3) > 0,
|
|
true);
|
|
assert.equal(
|
|
rs.compare_by_recency({user_id: sender2}, {user_id: sender1}, stream3, topic3) < 0,
|
|
true);
|
|
|
|
assert.equal(rs.compare_by_recency({}, {}, _.uniqueId(), ''), 0);
|
|
});
|