79 lines
2.1 KiB
JavaScript
79 lines
2.1 KiB
JavaScript
|
import { Q } from '@nozbe/watermelondb';
|
||
|
|
|
||
|
|
import database from '../../database';
|
||
|
|
|
||
|
|
export default async(subscriptions = [], rooms = []) => {
|
||
|
|
try {
|
||
|
|
const db = database.active;
|
||
|
|
const subCollection = db.collections.get('subscriptions');
|
||
|
|
|
||
|
|
const roomIds = rooms.filter(r => !subscriptions.find(s => s.rid === r._id)).map(r => r._id);
|
||
|
|
let existingSubs = await subCollection.query(Q.where('rid', Q.oneOf(roomIds))).fetch();
|
||
|
|
existingSubs = existingSubs.map(s => ({
|
||
|
|
_id: s._id,
|
||
|
|
f: s.f,
|
||
|
|
t: s.t,
|
||
|
|
ts: s.ts,
|
||
|
|
ls: s.ls,
|
||
|
|
name: s.name,
|
||
|
|
fname: s.fname,
|
||
|
|
rid: s.rid,
|
||
|
|
open: s.open,
|
||
|
|
alert: s.alert,
|
||
|
|
unread: s.unread,
|
||
|
|
userMentions: s.userMentions,
|
||
|
|
roomUpdatedAt: s.roomUpdatedAt,
|
||
|
|
ro: s.ro,
|
||
|
|
lastOpen: s.lastOpen,
|
||
|
|
description: s.description,
|
||
|
|
announcement: s.announcement,
|
||
|
|
topic: s.topic,
|
||
|
|
blocked: s.blocked,
|
||
|
|
blocker: s.blocker,
|
||
|
|
reactWhenReadOnly: s.reactWhenReadOnly,
|
||
|
|
archived: s.archived,
|
||
|
|
joinCodeRequired: s.joinCodeRequired,
|
||
|
|
muted: s.muted,
|
||
|
|
broadcast: s.broadcast,
|
||
|
|
prid: s.prid,
|
||
|
|
draftMessage: s.draftMessage,
|
||
|
|
lastThreadSync: s.lastThreadSync,
|
||
|
|
jitsiTimeout: s.jitsiTimeout,
|
||
|
|
autoTranslate: s.autoTranslate,
|
||
|
|
autoTranslateLanguage: s.autoTranslateLanguage,
|
||
|
|
lastMessage: s.lastMessage,
|
||
|
|
usernames: s.usernames,
|
||
|
|
uids: s.uids
|
||
|
|
}));
|
||
|
|
subscriptions = subscriptions.concat(existingSubs);
|
||
|
|
|
||
|
|
const subsIds = subscriptions.filter(s => !rooms.find(r => s.rid === r._id)).map(s => s._id);
|
||
|
|
let existingRooms = await subCollection.query(Q.where('id', Q.oneOf(subsIds))).fetch();
|
||
|
|
existingRooms = existingRooms.map(r => ({
|
||
|
|
_updatedAt: r._updatedAt,
|
||
|
|
lastMessage: r.lastMessage,
|
||
|
|
description: r.description,
|
||
|
|
topic: r.topic,
|
||
|
|
announcement: r.announcement,
|
||
|
|
reactWhenReadOnly: r.reactWhenReadOnly,
|
||
|
|
archived: r.archived,
|
||
|
|
joinCodeRequired: r.joinCodeRequired,
|
||
|
|
jitsiTimeout: r.jitsiTimeout,
|
||
|
|
usernames: r.usernames,
|
||
|
|
uids: r.uids,
|
||
|
|
ro: r.ro,
|
||
|
|
broadcast: r.broadcast,
|
||
|
|
muted: r.muted,
|
||
|
|
sysMes: r.sysMes
|
||
|
|
}));
|
||
|
|
rooms = rooms.concat(existingRooms);
|
||
|
|
} catch {
|
||
|
|
// do nothing
|
||
|
|
}
|
||
|
|
|
||
|
|
return {
|
||
|
|
subscriptions,
|
||
|
|
rooms
|
||
|
|
};
|
||
|
|
};
|