113 lines
3.5 KiB
JavaScript
113 lines
3.5 KiB
JavaScript
import EJSON from 'ejson';
|
|
import { lt, coerce } from 'semver';
|
|
|
|
import normalizeMessage from './normalizeMessage';
|
|
import findSubscriptionsRooms from './findSubscriptionsRooms';
|
|
import { Encryption } from '../../encryption';
|
|
import reduxStore from '../../createStore';
|
|
// TODO: delete and update
|
|
|
|
export const merge = (subscription, room) => {
|
|
const serverVersion = reduxStore.getState().server.version;
|
|
subscription = EJSON.fromJSONValue(subscription);
|
|
room = EJSON.fromJSONValue(room);
|
|
|
|
if (!subscription) {
|
|
return;
|
|
}
|
|
if (room) {
|
|
if (room._updatedAt) {
|
|
subscription.lastMessage = normalizeMessage(room.lastMessage);
|
|
subscription.description = room.description;
|
|
subscription.topic = room.topic;
|
|
subscription.announcement = room.announcement;
|
|
subscription.reactWhenReadOnly = room.reactWhenReadOnly;
|
|
subscription.archived = room.archived || false;
|
|
subscription.joinCodeRequired = room.joinCodeRequired;
|
|
subscription.jitsiTimeout = room.jitsiTimeout;
|
|
subscription.usernames = room.usernames;
|
|
subscription.uids = room.uids;
|
|
}
|
|
if (serverVersion && lt(coerce(serverVersion), '3.7.0')) {
|
|
const updatedAt = room?._updatedAt ? new Date(room._updatedAt) : null;
|
|
const lastMessageTs = subscription?.lastMessage?.ts ? new Date(subscription.lastMessage.ts) : null;
|
|
subscription.roomUpdatedAt = Math.max(updatedAt, lastMessageTs);
|
|
} else {
|
|
// https://github.com/RocketChat/Rocket.Chat/blob/develop/app/ui-sidenav/client/roomList.js#L180
|
|
const lastRoomUpdate = room.lm || subscription.ts || subscription._updatedAt;
|
|
subscription.roomUpdatedAt = subscription.lr ? Math.max(new Date(subscription.lr), new Date(lastRoomUpdate)) : lastRoomUpdate;
|
|
}
|
|
subscription.ro = room.ro;
|
|
subscription.broadcast = room.broadcast;
|
|
subscription.encrypted = room.encrypted;
|
|
subscription.e2eKeyId = room.e2eKeyId;
|
|
subscription.avatarETag = room.avatarETag;
|
|
if (!subscription.roles || !subscription.roles.length) {
|
|
subscription.roles = [];
|
|
}
|
|
if (!subscription.ignored?.length) {
|
|
subscription.ignored = [];
|
|
}
|
|
if (room.muted && room.muted.length) {
|
|
subscription.muted = room.muted.filter(muted => !!muted);
|
|
} else {
|
|
subscription.muted = [];
|
|
}
|
|
if (room.v) {
|
|
subscription.visitor = room.v;
|
|
}
|
|
if (room.departmentId) {
|
|
subscription.departmentId = room.departmentId;
|
|
}
|
|
if (room.servedBy) {
|
|
subscription.servedBy = room.servedBy;
|
|
}
|
|
if (room.livechatData) {
|
|
subscription.livechatData = room.livechatData;
|
|
}
|
|
if (room.tags) {
|
|
subscription.tags = room.tags;
|
|
}
|
|
subscription.sysMes = room.sysMes;
|
|
}
|
|
|
|
if (!subscription.name) {
|
|
subscription.name = subscription.fname;
|
|
}
|
|
|
|
if (!subscription.autoTranslate) {
|
|
subscription.autoTranslate = false;
|
|
}
|
|
|
|
subscription.blocker = !!subscription.blocker;
|
|
subscription.blocked = !!subscription.blocked;
|
|
return subscription;
|
|
};
|
|
|
|
export default async(subscriptions = [], rooms = []) => {
|
|
if (subscriptions.update) {
|
|
subscriptions = subscriptions.update;
|
|
rooms = rooms.update;
|
|
}
|
|
|
|
// Find missing rooms/subscriptions on local database
|
|
({ subscriptions, rooms } = await findSubscriptionsRooms(subscriptions, rooms));
|
|
// Merge each subscription into a room
|
|
subscriptions = subscriptions.map((s) => {
|
|
const index = rooms.findIndex(({ _id }) => _id === s.rid);
|
|
// Room not found
|
|
if (index < 0) {
|
|
return merge(s);
|
|
}
|
|
const [room] = rooms.splice(index, 1);
|
|
return merge(s, room);
|
|
});
|
|
// Decrypt all subscriptions missing decryption
|
|
subscriptions = await Encryption.decryptSubscriptions(subscriptions);
|
|
|
|
return {
|
|
subscriptions,
|
|
rooms
|
|
};
|
|
};
|