Page MenuHomePhabricator
Differential D7815 Diff 27184 keyserver/src/creators/message-creator.js

Changeset View

Standalone View

View Options

keyserver/src/creators/message-creator.js

Show First 20 Lines • Show All 46 Lines • ▼ Show 20 Lines
import { creationString } from '../utils/idempotent.js'; import { creationString } from '../utils/idempotent.js';
type UserThreadInfo = { type UserThreadInfo = {
+devices: Map< +devices: Map<
string, string,
{ {
+platform: string, +platform: string,
+deviceToken: string, +deviceToken: string,
+cookieID: string,
+codeVersion: ?string, +codeVersion: ?string,
}, },
>, >,
+threadIDs: Set<string>, +threadIDs: Set<string>,
+notFocusedThreadIDs: Set<string>, +notFocusedThreadIDs: Set<string>,
+userNotMemberOfSubthreads: Set<string>, +userNotMemberOfSubthreads: Set<string>,
+subthreadsCanSetToUnread: Set<string>, +subthreadsCanSetToUnread: Set<string>,
}; };
▲ Show 20 Lines • Show All 255 Lines • ▼ Show 20 Lines for (const subthread of subthreadPermissionsToCheck) {
join.append(SQL`thread = ${subthread} AND `); join.append(SQL`thread = ${subthread} AND `);
join.append(`stm${index}.user = m.user`); join.append(`stm${index}.user = m.user`);
subthreadJoins.push(join); subthreadJoins.push(join);
} }
const time = earliestFocusedTimeConsideredExpired(); const time = earliestFocusedTimeConsideredExpired();
const visibleExtractString = `$.${threadPermissions.VISIBLE}.value`; const visibleExtractString = `$.${threadPermissions.VISIBLE}.value`;
const query = SQL` const query = SQL`
SELECT m.user, m.thread, c.platform, c.device_token, c.versions, SELECT m.user, m.thread, c.platform, c.device_token, c.versions, c.id,
f.user AS focused_user f.user AS focused_user
`; `;
query.append(subthreadSelects); query.append(subthreadSelects);
query.append(SQL` query.append(SQL`
FROM memberships m FROM memberships m
LEFT JOIN cookies c ON c.user = m.user AND c.device_token IS NOT NULL LEFT JOIN cookies c ON c.user = m.user AND c.device_token IS NOT NULL
LEFT JOIN focused f ON f.user = m.user AND f.thread = m.thread LEFT JOIN focused f ON f.user = m.user AND f.thread = m.thread
AND f.time > ${time} AND f.time > ${time}
Show All 9 Lines) {
const [result] = await dbQuery(query); const [result] = await dbQuery(query);
for (const row of result) { for (const row of result) {
const userID = row.user.toString(); const userID = row.user.toString();
const threadID = row.thread.toString(); const threadID = row.thread.toString();
const deviceToken = row.device_token; const deviceToken = row.device_token;
const focusedUser = !!row.focused_user; const focusedUser = !!row.focused_user;
const { platform } = row; const { platform } = row;
const versions = JSON.parse(row.versions); const versions = JSON.parse(row.versions);
const cookieID = row.id;
let thisUserInfo = perUserInfo.get(userID); let thisUserInfo = perUserInfo.get(userID);
if (!thisUserInfo) { if (!thisUserInfo) {
thisUserInfo = { thisUserInfo = {
devices: new Map(), devices: new Map(),
threadIDs: new Set(), threadIDs: new Set(),
notFocusedThreadIDs: new Set(), notFocusedThreadIDs: new Set(),
userNotMemberOfSubthreads: new Set(), userNotMemberOfSubthreads: new Set(),
subthreadsCanSetToUnread: new Set(), subthreadsCanSetToUnread: new Set(),
Show All 19 Lines if (!thisUserInfo) {
if ( if (
!isSubthreadMember || !isSubthreadMember ||
!permissionLookup(subthreadPermissions, threadPermissions.VISIBLE) !permissionLookup(subthreadPermissions, threadPermissions.VISIBLE)
) { ) {
thisUserInfo.userNotMemberOfSubthreads.add(subthread); thisUserInfo.userNotMemberOfSubthreads.add(subthread);
} }
} }
} }
if (deviceToken) { if (deviceToken && cookieID) {
thisUserInfo.devices.set(deviceToken, { thisUserInfo.devices.set(deviceToken, {
platform, platform,
deviceToken, deviceToken,
cookieID: cookieID.toString(),
codeVersion: versions ? versions.codeVersion : null, codeVersion: versions ? versions.codeVersion : null,
}); });
} }
thisUserInfo.threadIDs.add(threadID); thisUserInfo.threadIDs.add(threadID);
if (!focusedUser) { if (!focusedUser) {
thisUserInfo.notFocusedThreadIDs.add(threadID); thisUserInfo.notFocusedThreadIDs.add(threadID);
} }
} }
▲ Show 20 Lines • Show All 292 Lines • Show Last 20 Lines