Page MenuHomePhorge
Files F32216482

D6688.1765167299.diff
No OneTemporary
Actions

Size
1 KB
Referenced Files
None
Subscribers
None

D6688.1765167299.diff
View Options

diff --git a/keyserver/src/creators/message-creator.js b/keyserver/src/creators/message-creator.js
--- a/keyserver/src/creators/message-creator.js
+++ b/keyserver/src/creators/message-creator.js
@@ -475,14 +475,14 @@
const [pushInfo] = await Promise.all([
promiseAll(userPushInfoPromises),
createReadStatusUpdates(latestMessages),
- redisPublish(viewer, messageInfosPerUser, updatesForCurrentSession),
+ messageBrokerPublish(viewer, messageInfosPerUser, updatesForCurrentSession),
updateLatestMessages(latestMessages),
]);
await sendPushNotifs(_pickBy(Boolean)(pushInfo));
}
-async function redisPublish(
+async function messageBrokerPublish(
viewer: Viewer,
messageInfosPerUser: { [userID: string]: $ReadOnlyArray<RawMessageInfo> },
updatesForCurrentSession: UpdatesForCurrentSession,
diff --git a/keyserver/src/creators/update-creator.js b/keyserver/src/creators/update-creator.js
--- a/keyserver/src/creators/update-creator.js
+++ b/keyserver/src/creators/update-creator.js
@@ -378,7 +378,10 @@
}
if (publishInfos.size > 0) {
- promises.redis = redisPublish(publishInfos.values(), dontBroadcastSession);
+ promises.messageBroker = messageBrokerPublish(
+ publishInfos.values(),
+ dontBroadcastSession,
+ );
}
if (deleteSQLConditions.length > 0) {
@@ -713,7 +716,7 @@
updateTarget: UpdateTarget,
rawUpdateInfos: RawUpdateInfo[],
};
-async function redisPublish(
+async function messageBrokerPublish(
publishInfos: Iterator<PublishInfo>,
dontBroadcastSession: ?string,
): Promise<void> {

File Metadata

Mime Type
text/plain
Expires
Mon, Dec 8, 4:14 AM (11 h, 41 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
5847013
Default Alt Text
D6688.1765167299.diff (1 KB)

Event Timeline