Page MenuHomePhabricator
Differential D11042

[web] Import backup client
ClosedPublic
Actions

Authored by michal on Feb 12 2024, 7:21 AM.
Tags
None
Referenced Files
F5081078: D11042.id37263.diff
Sat, Mar 29, 4:32 AM
Unknown Object (File)
Tue, Mar 25, 1:39 AM
Unknown Object (File)
Fri, Mar 7, 4:42 PM
Unknown Object (File)
Mon, Mar 3, 12:42 PM
Unknown Object (File)
Sat, Mar 1, 8:42 AM
Unknown Object (File)
Feb 23 2025, 7:48 PM
Unknown Object (File)
Feb 22 2025, 2:36 AM
Unknown Object (File)
Feb 22 2025, 2:36 AM
View All Files
Subscribers
ashoat
tomek

Details

Reviewers
marcin
bartek
kamil
Commits
rCOMM43658727a042: [web] Import backup client
Summary

Actually use the WASM backup client introduced in the previous diff.

  • webpack/keyserver machinery for downloading the wasm file
  • updated the worker init message so that it also intialized the backup client

Depends on D11041

Test Plan

Test on both:

  • yarn dev in web and keyserver
  • yarn prod, yarn prod-build

Send the worker init message, tested that there were no errors, and the WASM was correctly downloaded.

Diff Detail

Repository
rCOMM Comm
Lint
No Lint Coverage
Unit
No Test Coverage

Event Timeline

michal created this revision.Feb 12 2024, 7:21 AM
Herald added subscribers: tomek, ashoat. · View Herald TranscriptFeb 12 2024, 7:21 AM
Harbormaster returned this revision to the author for changes because remote builds failed.Feb 12 2024, 7:26 AM
Harbormaster failed remote builds in B26762: Diff 37001!
michal added a child revision: D11043: [web] Restore compaction.Feb 12 2024, 7:27 AM
michal updated this revision to Diff 37024.Feb 13 2024, 2:56 AM

Update keyserver dockerfile

Harbormaster returned this revision to the author for changes because remote builds failed.Feb 13 2024, 3:33 AM
Harbormaster failed remote builds in B26784: Diff 37024!
michal updated this revision to Diff 37071.Feb 14 2024, 5:29 AM

Rebase

Harbormaster completed remote builds in B26828: Diff 37071.Feb 14 2024, 5:44 AM
michal requested review of this revision.Feb 14 2024, 5:44 AM
ashoat mentioned this in D11041: [backup-client] Compile to wasm.Feb 14 2024, 10:56 AM
ashoat added inline comments.
web/package.json
46 ↗(On Diff #37071)

In the case of the opaque-ke-wasm, we appear to be using a published package. Can you explain why you chose to take a different approach here? (It looks comm_query_executor.wasm also doesn't use a separate NPM package – worth discussing that in your response as well.)

michal updated this revision to Diff 37263.Feb 15 2024, 7:30 AM

Rebase

Harbormaster failed remote builds in B26926: Diff 37263!Feb 15 2024, 7:31 AM
michal added inline comments.Feb 15 2024, 7:32 AM
web/package.json
46 ↗(On Diff #37071)

Modified the code, so there is no separate package and the approach is closer to comm_query_executor.wasm.

More detailed response about the chosen approach in the previous diff.

kamil requested changes to this revision.Feb 16 2024, 7:47 AM
kamil added inline comments.
keyserver/Dockerfile
129 ↗(On Diff #37263)

I don't think we need this?

web/database/worker/db-worker.js
108 ↗(On Diff #37263)

I think we should rename it

115 ↗(On Diff #37263)

do we need localhost? I think this issue is related to the comment below with propper directory in webpack config

171 ↗(On Diff #37263)

I think just undefined is enough without this hack - but maybe flow will complain

172 ↗(On Diff #37263)
web/types/worker-types.js
37 ↗(On Diff #37263)

perhaps we should make it more generic now?

web/webpack.config.cjs
159 ↗(On Diff #37263)

Could you make sure it works on dev?

This revision now requires changes to proceed.Feb 16 2024, 7:47 AM
michal updated this revision to Diff 37333.Feb 19 2024, 9:40 AM

Fix the webpack issue and the urls pointing to the wasm file. Renamed databaseModuleFilePath. Removed unnecessary code in the dockerfile.

Harbormaster completed remote builds in B26974: Diff 37333.Feb 19 2024, 9:56 AM
kamil accepted this revision.Feb 21 2024, 4:49 AM
kamil added inline comments.
web/database/worker/db-worker.js
112 ↗(On Diff #37333)

isn't this enough?

166–173 ↗(On Diff #37333)

nit

174 ↗(On Diff #37333)

because this field is typed backupClientFilename?: ?string not backupClientFilename: undefined | string I think the suggested condition is better but maybe I am missing something

This revision is now accepted and ready to land.Feb 21 2024, 4:49 AM
michal updated this revision to Diff 37439.Feb 22 2024, 6:16 AM

Simplify

web/database/worker/db-worker.js
174 ↗(On Diff #37333)

null is a valid value for `backupClientFilename on dev. In this case we also want to init the backup client (with the default value).

Harbormaster completed remote builds in B27061: Diff 37439.Feb 22 2024, 6:32 AM
Closed by commit rCOMM43658727a042: [web] Import backup client (authored by Michal Gniadek <michal.gniadek@swmansion.com>). · Explain WhyMar 6 2024, 6:11 AM
This revision was automatically updated to reflect the committed changes.
Michal Gniadek <michal.gniadek@swmansion.com> added a commit: rCOMM43658727a042: [web] Import backup client.

Revision Contents
Changeset List

PathSize
keyserver/
src/
responders/
5 lines
web/
database/
5 lines
6 lines
utils/
1 line
worker/
40 lines
types/
3 lines
21 lines

Diff 37439

View Options

keyserver/src/responders/website-responders.js

Show First 20 Lines • Show All 58 Lines • ▼ Show 20 Lines
} from '../types/message-types.js'; } from '../types/message-types.js';
import type { import type {
MinimallyEncodedRawThreadInfo, MinimallyEncodedRawThreadInfo,
MinimallyEncodedThreadCurrentUserInfo, MinimallyEncodedThreadCurrentUserInfo,
MinimallyEncodedThreadInfo, MinimallyEncodedThreadInfo,
} from '../types/minimally-encoded-thread-permissions-types.js'; } from '../types/minimally-encoded-thread-permissions-types.js';
import { import {
decodeMinimallyEncodedRoleInfo, decodeMinimallyEncodedRoleInfo,
minimallyEncodeRawThreadInfo,
minimallyEncodeThreadInfo, minimallyEncodeThreadInfo,
} from '../types/minimally-encoded-thread-permissions-types.js'; } from '../types/minimally-encoded-thread-permissions-types.js';
import { userRelationshipStatus } from '../types/relationship-types.js'; import { userRelationshipStatus } from '../types/relationship-types.js';
import { import {
threadPermissionPropagationPrefixes, threadPermissionPropagationPrefixes,
threadPermissions, threadPermissions,
configurableCommunityPermissions, configurableCommunityPermissions,
type ThreadPermission, type ThreadPermission,
▲ Show 20 Lines • Show All 655 Lines • ▼ Show 20 Linesasync function createRealThreadFromPendingThread({
return newThreadID; return newThreadID;
} }
type RawThreadInfoOptions = { type RawThreadInfoOptions = {
+filterThreadEditAvatarPermission?: boolean, +filterThreadEditAvatarPermission?: boolean,
+excludePinInfo?: boolean, +excludePinInfo?: boolean,
+filterManageInviteLinksPermission?: boolean, +filterManageInviteLinksPermission?: boolean,
+filterVoicedInAnnouncementChannelsPermission?: boolean, +filterVoicedInAnnouncementChannelsPermission?: boolean,
+minimallyEncodePermissions?: boolean,
}; };
function rawThreadInfoFromServerThreadInfo( function rawThreadInfoFromServerThreadInfo(
serverThreadInfo: ServerThreadInfo, serverThreadInfo: ServerThreadInfo,
viewerID: string, viewerID: string,
options?: RawThreadInfoOptions, options?: RawThreadInfoOptions,
): ?LegacyRawThreadInfo { ): ?RawThreadInfo {
const filterThreadEditAvatarPermission = const filterThreadEditAvatarPermission =
options?.filterThreadEditAvatarPermission; options?.filterThreadEditAvatarPermission;
const excludePinInfo = options?.excludePinInfo; const excludePinInfo = options?.excludePinInfo;
const filterManageInviteLinksPermission = const filterManageInviteLinksPermission =
options?.filterManageInviteLinksPermission; options?.filterManageInviteLinksPermission;
const filterVoicedInAnnouncementChannelsPermission = const filterVoicedInAnnouncementChannelsPermission =
options?.filterVoicedInAnnouncementChannelsPermission; options?.filterVoicedInAnnouncementChannelsPermission;
const shouldMinimallyEncodePermissions = options?.minimallyEncodePermissions;
const filterThreadPermissions = _omitBy( const filterThreadPermissions = _omitBy(
(v, k) => (v, k) =>
(filterThreadEditAvatarPermission && (filterThreadEditAvatarPermission &&
[ [
threadPermissions.EDIT_THREAD_AVATAR, threadPermissions.EDIT_THREAD_AVATAR,
threadPermissionPropagationPrefixes.DESCENDANT + threadPermissionPropagationPrefixes.DESCENDANT +
threadPermissions.EDIT_THREAD_AVATAR, threadPermissions.EDIT_THREAD_AVATAR,
▲ Show 20 Lines • Show All 88 Lines • ▼ Show 20 Lines): ?RawThreadInfo {
const sourceMessageID = serverThreadInfo.sourceMessageID; const sourceMessageID = serverThreadInfo.sourceMessageID;
if (sourceMessageID) { if (sourceMessageID) {
rawThreadInfo = { ...rawThreadInfo, sourceMessageID }; rawThreadInfo = { ...rawThreadInfo, sourceMessageID };
} }
if (serverThreadInfo.avatar) { if (serverThreadInfo.avatar) {
rawThreadInfo = { ...rawThreadInfo, avatar: serverThreadInfo.avatar }; rawThreadInfo = { ...rawThreadInfo, avatar: serverThreadInfo.avatar };
} }
if (!excludePinInfo) { if (!excludePinInfo) {
return { rawThreadInfo = {
...rawThreadInfo, ...rawThreadInfo,
pinnedCount: serverThreadInfo.pinnedCount, pinnedCount: serverThreadInfo.pinnedCount,
}; };
} }
return rawThreadInfo; return shouldMinimallyEncodePermissions
? minimallyEncodeRawThreadInfo(rawThreadInfo)
: rawThreadInfo;
} }
function threadUIName(threadInfo: ThreadInfo): string | ThreadEntity { function threadUIName(threadInfo: ThreadInfo): string | ThreadEntity {
if (threadInfo.name) { if (threadInfo.name) {
return firstLine(threadInfo.name); return firstLine(threadInfo.name);
} }
let threadMembers: $ReadOnlyArray<RelativeMemberInfo>; let threadMembers: $ReadOnlyArray<RelativeMemberInfo>;
▲ Show 20 Lines • Show All 1,000 Lines • Show Last 20 Lines
View Options

web/database/database-module-provider.js

Show First 20 Lines • Show All 58 Lines • ▼ Show 20 Lines
} from '../types/message-types.js'; } from '../types/message-types.js';
import type { import type {
MinimallyEncodedRawThreadInfo, MinimallyEncodedRawThreadInfo,
MinimallyEncodedThreadCurrentUserInfo, MinimallyEncodedThreadCurrentUserInfo,
MinimallyEncodedThreadInfo, MinimallyEncodedThreadInfo,
} from '../types/minimally-encoded-thread-permissions-types.js'; } from '../types/minimally-encoded-thread-permissions-types.js';
import { import {
decodeMinimallyEncodedRoleInfo, decodeMinimallyEncodedRoleInfo,
minimallyEncodeRawThreadInfo,
minimallyEncodeThreadInfo, minimallyEncodeThreadInfo,
} from '../types/minimally-encoded-thread-permissions-types.js'; } from '../types/minimally-encoded-thread-permissions-types.js';
import { userRelationshipStatus } from '../types/relationship-types.js'; import { userRelationshipStatus } from '../types/relationship-types.js';
import { import {
threadPermissionPropagationPrefixes, threadPermissionPropagationPrefixes,
threadPermissions, threadPermissions,
configurableCommunityPermissions, configurableCommunityPermissions,
type ThreadPermission, type ThreadPermission,
▲ Show 20 Lines • Show All 655 Lines • ▼ Show 20 Linesasync function createRealThreadFromPendingThread({
return newThreadID; return newThreadID;
} }
type RawThreadInfoOptions = { type RawThreadInfoOptions = {
+filterThreadEditAvatarPermission?: boolean, +filterThreadEditAvatarPermission?: boolean,
+excludePinInfo?: boolean, +excludePinInfo?: boolean,
+filterManageInviteLinksPermission?: boolean, +filterManageInviteLinksPermission?: boolean,
+filterVoicedInAnnouncementChannelsPermission?: boolean, +filterVoicedInAnnouncementChannelsPermission?: boolean,
+minimallyEncodePermissions?: boolean,
}; };
function rawThreadInfoFromServerThreadInfo( function rawThreadInfoFromServerThreadInfo(
serverThreadInfo: ServerThreadInfo, serverThreadInfo: ServerThreadInfo,
viewerID: string, viewerID: string,
options?: RawThreadInfoOptions, options?: RawThreadInfoOptions,
): ?LegacyRawThreadInfo { ): ?RawThreadInfo {
const filterThreadEditAvatarPermission = const filterThreadEditAvatarPermission =
options?.filterThreadEditAvatarPermission; options?.filterThreadEditAvatarPermission;
const excludePinInfo = options?.excludePinInfo; const excludePinInfo = options?.excludePinInfo;
const filterManageInviteLinksPermission = const filterManageInviteLinksPermission =
options?.filterManageInviteLinksPermission; options?.filterManageInviteLinksPermission;
const filterVoicedInAnnouncementChannelsPermission = const filterVoicedInAnnouncementChannelsPermission =
options?.filterVoicedInAnnouncementChannelsPermission; options?.filterVoicedInAnnouncementChannelsPermission;
const shouldMinimallyEncodePermissions = options?.minimallyEncodePermissions;
const filterThreadPermissions = _omitBy( const filterThreadPermissions = _omitBy(
(v, k) => (v, k) =>
(filterThreadEditAvatarPermission && (filterThreadEditAvatarPermission &&
[ [
threadPermissions.EDIT_THREAD_AVATAR, threadPermissions.EDIT_THREAD_AVATAR,
threadPermissionPropagationPrefixes.DESCENDANT + threadPermissionPropagationPrefixes.DESCENDANT +
threadPermissions.EDIT_THREAD_AVATAR, threadPermissions.EDIT_THREAD_AVATAR,
▲ Show 20 Lines • Show All 88 Lines • ▼ Show 20 Lines): ?RawThreadInfo {
const sourceMessageID = serverThreadInfo.sourceMessageID; const sourceMessageID = serverThreadInfo.sourceMessageID;
if (sourceMessageID) { if (sourceMessageID) {
rawThreadInfo = { ...rawThreadInfo, sourceMessageID }; rawThreadInfo = { ...rawThreadInfo, sourceMessageID };
} }
if (serverThreadInfo.avatar) { if (serverThreadInfo.avatar) {
rawThreadInfo = { ...rawThreadInfo, avatar: serverThreadInfo.avatar }; rawThreadInfo = { ...rawThreadInfo, avatar: serverThreadInfo.avatar };
} }
if (!excludePinInfo) { if (!excludePinInfo) {
return { rawThreadInfo = {
...rawThreadInfo, ...rawThreadInfo,
pinnedCount: serverThreadInfo.pinnedCount, pinnedCount: serverThreadInfo.pinnedCount,
}; };
} }
return rawThreadInfo; return shouldMinimallyEncodePermissions
? minimallyEncodeRawThreadInfo(rawThreadInfo)
: rawThreadInfo;
} }
function threadUIName(threadInfo: ThreadInfo): string | ThreadEntity { function threadUIName(threadInfo: ThreadInfo): string | ThreadEntity {
if (threadInfo.name) { if (threadInfo.name) {
return firstLine(threadInfo.name); return firstLine(threadInfo.name);
} }
let threadMembers: $ReadOnlyArray<RelativeMemberInfo>; let threadMembers: $ReadOnlyArray<RelativeMemberInfo>;
▲ Show 20 Lines • Show All 1,000 Lines • Show Last 20 Lines
View Options

web/database/db-module.js

Show First 20 Lines • Show All 58 Lines • ▼ Show 20 Lines
} from '../types/message-types.js'; } from '../types/message-types.js';
import type { import type {
MinimallyEncodedRawThreadInfo, MinimallyEncodedRawThreadInfo,
MinimallyEncodedThreadCurrentUserInfo, MinimallyEncodedThreadCurrentUserInfo,
MinimallyEncodedThreadInfo, MinimallyEncodedThreadInfo,
} from '../types/minimally-encoded-thread-permissions-types.js'; } from '../types/minimally-encoded-thread-permissions-types.js';
import { import {
decodeMinimallyEncodedRoleInfo, decodeMinimallyEncodedRoleInfo,
minimallyEncodeRawThreadInfo,
minimallyEncodeThreadInfo, minimallyEncodeThreadInfo,
} from '../types/minimally-encoded-thread-permissions-types.js'; } from '../types/minimally-encoded-thread-permissions-types.js';
import { userRelationshipStatus } from '../types/relationship-types.js'; import { userRelationshipStatus } from '../types/relationship-types.js';
import { import {
threadPermissionPropagationPrefixes, threadPermissionPropagationPrefixes,
threadPermissions, threadPermissions,
configurableCommunityPermissions, configurableCommunityPermissions,
type ThreadPermission, type ThreadPermission,
▲ Show 20 Lines • Show All 655 Lines • ▼ Show 20 Linesasync function createRealThreadFromPendingThread({
return newThreadID; return newThreadID;
} }
type RawThreadInfoOptions = { type RawThreadInfoOptions = {
+filterThreadEditAvatarPermission?: boolean, +filterThreadEditAvatarPermission?: boolean,
+excludePinInfo?: boolean, +excludePinInfo?: boolean,
+filterManageInviteLinksPermission?: boolean, +filterManageInviteLinksPermission?: boolean,
+filterVoicedInAnnouncementChannelsPermission?: boolean, +filterVoicedInAnnouncementChannelsPermission?: boolean,
+minimallyEncodePermissions?: boolean,
}; };
function rawThreadInfoFromServerThreadInfo( function rawThreadInfoFromServerThreadInfo(
serverThreadInfo: ServerThreadInfo, serverThreadInfo: ServerThreadInfo,
viewerID: string, viewerID: string,
options?: RawThreadInfoOptions, options?: RawThreadInfoOptions,
): ?LegacyRawThreadInfo { ): ?RawThreadInfo {
const filterThreadEditAvatarPermission = const filterThreadEditAvatarPermission =
options?.filterThreadEditAvatarPermission; options?.filterThreadEditAvatarPermission;
const excludePinInfo = options?.excludePinInfo; const excludePinInfo = options?.excludePinInfo;
const filterManageInviteLinksPermission = const filterManageInviteLinksPermission =
options?.filterManageInviteLinksPermission; options?.filterManageInviteLinksPermission;
const filterVoicedInAnnouncementChannelsPermission = const filterVoicedInAnnouncementChannelsPermission =
options?.filterVoicedInAnnouncementChannelsPermission; options?.filterVoicedInAnnouncementChannelsPermission;
const shouldMinimallyEncodePermissions = options?.minimallyEncodePermissions;
const filterThreadPermissions = _omitBy( const filterThreadPermissions = _omitBy(
(v, k) => (v, k) =>
(filterThreadEditAvatarPermission && (filterThreadEditAvatarPermission &&
[ [
threadPermissions.EDIT_THREAD_AVATAR, threadPermissions.EDIT_THREAD_AVATAR,
threadPermissionPropagationPrefixes.DESCENDANT + threadPermissionPropagationPrefixes.DESCENDANT +
threadPermissions.EDIT_THREAD_AVATAR, threadPermissions.EDIT_THREAD_AVATAR,
▲ Show 20 Lines • Show All 88 Lines • ▼ Show 20 Lines): ?RawThreadInfo {
const sourceMessageID = serverThreadInfo.sourceMessageID; const sourceMessageID = serverThreadInfo.sourceMessageID;
if (sourceMessageID) { if (sourceMessageID) {
rawThreadInfo = { ...rawThreadInfo, sourceMessageID }; rawThreadInfo = { ...rawThreadInfo, sourceMessageID };
} }
if (serverThreadInfo.avatar) { if (serverThreadInfo.avatar) {
rawThreadInfo = { ...rawThreadInfo, avatar: serverThreadInfo.avatar }; rawThreadInfo = { ...rawThreadInfo, avatar: serverThreadInfo.avatar };
} }
if (!excludePinInfo) { if (!excludePinInfo) {
return { rawThreadInfo = {
...rawThreadInfo, ...rawThreadInfo,
pinnedCount: serverThreadInfo.pinnedCount, pinnedCount: serverThreadInfo.pinnedCount,
}; };
} }
return rawThreadInfo; return shouldMinimallyEncodePermissions
? minimallyEncodeRawThreadInfo(rawThreadInfo)
: rawThreadInfo;
} }
function threadUIName(threadInfo: ThreadInfo): string | ThreadEntity { function threadUIName(threadInfo: ThreadInfo): string | ThreadEntity {
if (threadInfo.name) { if (threadInfo.name) {
return firstLine(threadInfo.name); return firstLine(threadInfo.name);
} }
let threadMembers: $ReadOnlyArray<RelativeMemberInfo>; let threadMembers: $ReadOnlyArray<RelativeMemberInfo>;
▲ Show 20 Lines • Show All 1,000 Lines • Show Last 20 Lines
View Options

web/database/utils/constants.js

Show First 20 Lines • Show All 58 Lines • ▼ Show 20 Lines
} from '../types/message-types.js'; } from '../types/message-types.js';
import type { import type {
MinimallyEncodedRawThreadInfo, MinimallyEncodedRawThreadInfo,
MinimallyEncodedThreadCurrentUserInfo, MinimallyEncodedThreadCurrentUserInfo,
MinimallyEncodedThreadInfo, MinimallyEncodedThreadInfo,
} from '../types/minimally-encoded-thread-permissions-types.js'; } from '../types/minimally-encoded-thread-permissions-types.js';
import { import {
decodeMinimallyEncodedRoleInfo, decodeMinimallyEncodedRoleInfo,
minimallyEncodeRawThreadInfo,
minimallyEncodeThreadInfo, minimallyEncodeThreadInfo,
} from '../types/minimally-encoded-thread-permissions-types.js'; } from '../types/minimally-encoded-thread-permissions-types.js';
import { userRelationshipStatus } from '../types/relationship-types.js'; import { userRelationshipStatus } from '../types/relationship-types.js';
import { import {
threadPermissionPropagationPrefixes, threadPermissionPropagationPrefixes,
threadPermissions, threadPermissions,
configurableCommunityPermissions, configurableCommunityPermissions,
type ThreadPermission, type ThreadPermission,
▲ Show 20 Lines • Show All 655 Lines • ▼ Show 20 Linesasync function createRealThreadFromPendingThread({
return newThreadID; return newThreadID;
} }
type RawThreadInfoOptions = { type RawThreadInfoOptions = {
+filterThreadEditAvatarPermission?: boolean, +filterThreadEditAvatarPermission?: boolean,
+excludePinInfo?: boolean, +excludePinInfo?: boolean,
+filterManageInviteLinksPermission?: boolean, +filterManageInviteLinksPermission?: boolean,
+filterVoicedInAnnouncementChannelsPermission?: boolean, +filterVoicedInAnnouncementChannelsPermission?: boolean,
+minimallyEncodePermissions?: boolean,
}; };
function rawThreadInfoFromServerThreadInfo( function rawThreadInfoFromServerThreadInfo(
serverThreadInfo: ServerThreadInfo, serverThreadInfo: ServerThreadInfo,
viewerID: string, viewerID: string,
options?: RawThreadInfoOptions, options?: RawThreadInfoOptions,
): ?LegacyRawThreadInfo { ): ?RawThreadInfo {
const filterThreadEditAvatarPermission = const filterThreadEditAvatarPermission =
options?.filterThreadEditAvatarPermission; options?.filterThreadEditAvatarPermission;
const excludePinInfo = options?.excludePinInfo; const excludePinInfo = options?.excludePinInfo;
const filterManageInviteLinksPermission = const filterManageInviteLinksPermission =
options?.filterManageInviteLinksPermission; options?.filterManageInviteLinksPermission;
const filterVoicedInAnnouncementChannelsPermission = const filterVoicedInAnnouncementChannelsPermission =
options?.filterVoicedInAnnouncementChannelsPermission; options?.filterVoicedInAnnouncementChannelsPermission;
const shouldMinimallyEncodePermissions = options?.minimallyEncodePermissions;
const filterThreadPermissions = _omitBy( const filterThreadPermissions = _omitBy(
(v, k) => (v, k) =>
(filterThreadEditAvatarPermission && (filterThreadEditAvatarPermission &&
[ [
threadPermissions.EDIT_THREAD_AVATAR, threadPermissions.EDIT_THREAD_AVATAR,
threadPermissionPropagationPrefixes.DESCENDANT + threadPermissionPropagationPrefixes.DESCENDANT +
threadPermissions.EDIT_THREAD_AVATAR, threadPermissions.EDIT_THREAD_AVATAR,
▲ Show 20 Lines • Show All 88 Lines • ▼ Show 20 Lines): ?RawThreadInfo {
const sourceMessageID = serverThreadInfo.sourceMessageID; const sourceMessageID = serverThreadInfo.sourceMessageID;
if (sourceMessageID) { if (sourceMessageID) {
rawThreadInfo = { ...rawThreadInfo, sourceMessageID }; rawThreadInfo = { ...rawThreadInfo, sourceMessageID };
} }
if (serverThreadInfo.avatar) { if (serverThreadInfo.avatar) {
rawThreadInfo = { ...rawThreadInfo, avatar: serverThreadInfo.avatar }; rawThreadInfo = { ...rawThreadInfo, avatar: serverThreadInfo.avatar };
} }
if (!excludePinInfo) { if (!excludePinInfo) {
return { rawThreadInfo = {
...rawThreadInfo, ...rawThreadInfo,
pinnedCount: serverThreadInfo.pinnedCount, pinnedCount: serverThreadInfo.pinnedCount,
}; };
} }
return rawThreadInfo; return shouldMinimallyEncodePermissions
? minimallyEncodeRawThreadInfo(rawThreadInfo)
: rawThreadInfo;
} }
function threadUIName(threadInfo: ThreadInfo): string | ThreadEntity { function threadUIName(threadInfo: ThreadInfo): string | ThreadEntity {
if (threadInfo.name) { if (threadInfo.name) {
return firstLine(threadInfo.name); return firstLine(threadInfo.name);
} }
let threadMembers: $ReadOnlyArray<RelativeMemberInfo>; let threadMembers: $ReadOnlyArray<RelativeMemberInfo>;
▲ Show 20 Lines • Show All 1,000 Lines • Show Last 20 Lines
View Options

web/database/worker/db-worker.js

Loading...
View Options

web/types/worker-types.js

Loading...
View Options

web/webpack.config.cjs

Loading...