paulmataruso/zulip
1
0
Fork 0
mirror of https://github.com/zulip/zulip.git synced 2025-11-19 14:08:23 +00:00
Code Issues Packages Projects Releases Wiki Activity

server_events: Rename messages to raw_messages.

Browse Source
This commit is contained in:
Evy Kassirer
2025-09-27 15:09:37 -07:00
committed by Tim Abbott
parent f186a0edbb
commit ec78f0551b
1 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
web/src/server_events.js
View File

@@ -34,7 +34,7 @@ const get_events_params = {};
let event_queue_expired = false; let event_queue_expired = false;
function get_events_success(events) { function get_events_success(events) {
let messages = []; let raw_messages = [];
const update_message_events = []; const update_message_events = [];
const post_message_events = []; const post_message_events = [];
@@ -73,7 +73,7 @@ function get_events_success(events) {
if (event.local_message_id) { if (event.local_message_id) {
msg.local_id = event.local_message_id; msg.local_id = event.local_message_id;
} }
messages.push(msg); raw_messages.push(msg);
break; break;
} }
@@ -100,16 +100,16 @@ function get_events_success(events) {
} }
} }
if (messages.length > 0) { if (raw_messages.length > 0) {
// Sort by ID, so that if we get multiple messages back from // Sort by ID, so that if we get multiple messages back from
// the server out-of-order, we'll still end up with our // the server out-of-order, we'll still end up with our
// message lists in order. // message lists in order.
messages = _.sortBy(messages, "id"); raw_messages = _.sortBy(raw_messages, "id");
try { try {
messages = echo.process_from_server(messages); raw_messages = echo.process_from_server(raw_messages);
if (messages.length > 0) { if (raw_messages.length > 0) {
let sent_by_this_client = false; let sent_by_this_client = false;
for (const msg of messages) { for (const msg of raw_messages) {
if (sent_messages.messages.has(msg.local_id)) { if (sent_messages.messages.has(msg.local_id)) {
sent_by_this_client = true; sent_by_this_client = true;
} }
@@ -124,7 +124,7 @@ function get_events_success(events) {
// correctly. // correctly.
message_events.insert_new_messages({ message_events.insert_new_messages({
type: "server_message", type: "server_message",
raw_messages: messages, raw_messages,
sent_by_this_client, sent_by_this_client,
}); });
} }