Page MenuHomePhabricator
Differential D12745

[native][web] Introduce a method fetching messages by ID to SQLiteAPI
ClosedPublic
Actions

Authored by tomek on Jul 15 2024, 4:13 AM.
Tags
None
Referenced Files
Unknown Object (File)
Wed, Mar 12, 10:13 AM
Unknown Object (File)
Tue, Mar 11, 11:50 AM
Unknown Object (File)
Thu, Mar 6, 4:57 AM
Unknown Object (File)
Thu, Feb 27, 11:14 AM
Unknown Object (File)
Wed, Feb 26, 6:03 AM
Unknown Object (File)
Wed, Feb 26, 6:03 AM
Unknown Object (File)
Wed, Feb 26, 6:03 AM
Unknown Object (File)
Wed, Feb 26, 6:03 AM
View All Files
Subscribers
ashoat

Details

Reviewers
kamil
marcin
Commits
rCOMM98cf024dada2: [native][web] Introduce a method fetching messages by ID to SQLiteAPI
Summary

This method will be used to handle manual retries.

https://linear.app/comm/issue/ENG-8675/add-option-to-manually-retry-a-message

Depends on D12744

Test Plan

Tested in combination with the rest of the stack. Sending messages requires calling this API so checking if messages are sent tests it.

Diff Detail

Repository
rCOMM Comm
Lint
Lint Not Applicable
Unit
Tests Not Applicable

Event Timeline

tomek created this revision.Jul 15 2024, 4:13 AM
Herald added a subscriber: ashoat. · View Herald TranscriptJul 15 2024, 4:13 AM
tomek added a child revision: D12746: [lib] Disable automatic retries of all messages and enable manual retries.Jul 15 2024, 4:20 AM
Harbormaster returned this revision to the author for changes because remote builds failed.Jul 15 2024, 4:38 AM
Harbormaster failed remote builds in B30322: Diff 42283!
tomek updated this revision to Diff 42342.Jul 16 2024, 4:42 AM

Rebase

Harbormaster completed remote builds in B30379: Diff 42342.Jul 16 2024, 5:14 AM
tomek requested review of this revision.Jul 16 2024, 5:14 AM
ashoat added inline comments.Jul 16 2024, 6:50 AM
lib/types/sqlite-types.js
42–43 ↗(On Diff #42342)

Looks like there was a typo here and the s at the end was left out (it's included in other uses of this name)

tomek updated this revision to Diff 42390.Jul 17 2024, 8:29 AM

Rebase

Harbormaster completed remote builds in B30418: Diff 42390.Jul 17 2024, 8:55 AM
tomek edited the test plan for this revision. (Show Details)Jul 17 2024, 9:21 AM
kamil accepted this revision.Jul 18 2024, 6:23 AM
kamil added inline comments.
lib/types/sqlite-types.js
48 ↗(On Diff #42390)

I prefer to return OutboundP2PMessage[] here but up to you

42–43 ↗(On Diff #42342)

Looks like there was a typo here and the s at the end was left out (it's included in other uses of this name)

Yeah, this is my oversight

web/types/worker-types.js
199 ↗(On Diff #42390)

TO avoid confusing with GetOutboundP2PMessagesRequestMessage above

This revision is now accepted and ready to land.Jul 18 2024, 6:23 AM
tomek updated this revision to Diff 42474.Jul 18 2024, 8:17 AM
tomek marked 2 inline comments as done.

Update types and names

lib/types/sqlite-types.js
48 ↗(On Diff #42390)

OutboundP2PMessage[] syntax is recommended to be avoided by Flow. But we can use Array<OutboundP2PMessage>

42–43 ↗(On Diff #42342)

Will put up a separate diff fixing it

web/types/worker-types.js
199 ↗(On Diff #42390)

Makes sense!

Harbormaster completed remote builds in B30475: Diff 42474.Jul 18 2024, 8:38 AM
Closed by commit rCOMM98cf024dada2: [native][web] Introduce a method fetching messages by ID to SQLiteAPI (authored by tomek). · Explain WhyJul 19 2024, 7:47 AM
This revision was automatically updated to reflect the committed changes.
tomek added a commit: rCOMM98cf024dada2: [native][web] Introduce a method fetching messages by ID to SQLiteAPI.
tomek added inline comments.Jul 19 2024, 8:38 AM
lib/types/sqlite-types.js
42–43 ↗(On Diff #42342)

Fixed in D12804

Revision Contents
Changeset List

PathSize
lib/
types/
11 lines
utils/
__mocks__/
1 line
native/
database/
1 line
schema/
2 lines
web/
database/
14 lines
shared-worker/
worker/
9 lines
types/
9 lines

Diff 42541

View Options

lib/types/sqlite-types.js

// @flow // @flow
import _keyBy from 'lodash/fp/keyBy.js';
import _mapValues from 'lodash/fp/mapValues.js';
import * as React from 'react'; import * as React from 'react';
import { createSelector } from 'reselect'; import { createSelector } from 'reselect';
import { useENSNames } from '../hooks/ens-cache.js'; import { useENSNames } from '../hooks/ens-cache.js';
import SearchIndex from '../shared/search-index.js'; import SearchIndex from '../shared/search-index.js';
import { roleIsAdminRole } from '../shared/thread-utils.js'; import {
roleIsAdminRole,
useCommunityRootMembersToRole,
} from '../shared/thread-utils.js';
import type { Platform } from '../types/device-types.js'; import type { Platform } from '../types/device-types.js';
import { import {
type CalendarQuery, type CalendarQuery,
defaultCalendarQuery, defaultCalendarQuery,
} from '../types/entry-types.js'; } from '../types/entry-types.js';
import type { CalendarFilter } from '../types/filter-types.js'; import type { CalendarFilter } from '../types/filter-types.js';
import type { import type {
ThreadInfo, ThreadInfo,
RelativeMemberInfo, RelativeMemberInfo,
RawThreadInfo, RawThreadInfo,
MemberInfo,
} from '../types/minimally-encoded-thread-permissions-types.js'; } from '../types/minimally-encoded-thread-permissions-types.js';
import type { BaseNavInfo } from '../types/nav-types.js'; import type { BaseNavInfo } from '../types/nav-types.js';
import type { BaseAppState } from '../types/redux-types.js'; import type { BaseAppState } from '../types/redux-types.js';
import { threadTypeIsCommunityRoot } from '../types/thread-types-enum.js';
import type { UserInfo } from '../types/user-types.js'; import type { UserInfo } from '../types/user-types.js';
import { getConfig } from '../utils/config.js'; import { getConfig } from '../utils/config.js';
import { values } from '../utils/objects.js'; import { values } from '../utils/objects.js';
import { useSelector } from '../utils/redux-utils.js'; import { useSelector } from '../utils/redux-utils.js';
function timeUntilCalendarRangeExpiration( function timeUntilCalendarRangeExpiration(
lastUserInteractionCalendar: number, lastUserInteractionCalendar: number,
): ?number { ): ?number {
▲ Show 20 Lines • Show All 92 Lines • ▼ Show 20 Lines
function useThreadSearchIndex( function useThreadSearchIndex(
threadInfos: $ReadOnlyArray<RawThreadInfo | ThreadInfo>, threadInfos: $ReadOnlyArray<RawThreadInfo | ThreadInfo>,
): SearchIndex { ): SearchIndex {
const userInfos = useSelector(state => state.userStore.userInfos); const userInfos = useSelector(state => state.userStore.userInfos);
const viewerID = useSelector( const viewerID = useSelector(
state => state.currentUserInfo && state.currentUserInfo.id, state => state.currentUserInfo && state.currentUserInfo.id,
); );
const communityRootMembersToRole = React.useMemo(() => { const communityRootMembersToRole = useCommunityRootMembersToRole(threadInfos);
const communityThreadInfos = threadInfos.filter(threadInfo =>
threadTypeIsCommunityRoot(threadInfo.type),
);
const communityRoots = _keyBy('id')(communityThreadInfos);
return _mapValues((threadInfo: ThreadInfo | RawThreadInfo) => {
const keyedMembers = _keyBy('id')(threadInfo.members);
const keyedMembersToRole = _mapValues(
(member: MemberInfo | RelativeMemberInfo) => {
return member.role ? threadInfo.roles[member.role] : null;
},
)(keyedMembers);
return keyedMembersToRole;
})(communityRoots);
}, [threadInfos]);
const nonViewerMembers = React.useMemo(() => { const nonViewerMembers = React.useMemo(() => {
const allMembersOfAllThreads = new Map<string, UserInfo>(); const allMembersOfAllThreads = new Map<string, UserInfo>();
for (const threadInfo of threadInfos) { for (const threadInfo of threadInfos) {
for (const member of threadInfo.members) { for (const member of threadInfo.members) {
const communityRole = const communityRole =
communityRootMembersToRole[threadInfo.community]?.[member.id]; communityRootMembersToRole[threadInfo.community]?.[member.id];
const isParentAdmin = roleIsAdminRole(communityRole); const isParentAdmin = roleIsAdminRole(communityRole);
▲ Show 20 Lines • Show All 84 Lines • Show Last 20 Lines
View Options

lib/utils/__mocks__/config.js

// @flow // @flow
import _keyBy from 'lodash/fp/keyBy.js';
import _mapValues from 'lodash/fp/mapValues.js';
import * as React from 'react'; import * as React from 'react';
import { createSelector } from 'reselect'; import { createSelector } from 'reselect';
import { useENSNames } from '../hooks/ens-cache.js'; import { useENSNames } from '../hooks/ens-cache.js';
import SearchIndex from '../shared/search-index.js'; import SearchIndex from '../shared/search-index.js';
import { roleIsAdminRole } from '../shared/thread-utils.js'; import {
roleIsAdminRole,
useCommunityRootMembersToRole,
} from '../shared/thread-utils.js';
import type { Platform } from '../types/device-types.js'; import type { Platform } from '../types/device-types.js';
import { import {
type CalendarQuery, type CalendarQuery,
defaultCalendarQuery, defaultCalendarQuery,
} from '../types/entry-types.js'; } from '../types/entry-types.js';
import type { CalendarFilter } from '../types/filter-types.js'; import type { CalendarFilter } from '../types/filter-types.js';
import type { import type {
ThreadInfo, ThreadInfo,
RelativeMemberInfo, RelativeMemberInfo,
RawThreadInfo, RawThreadInfo,
MemberInfo,
} from '../types/minimally-encoded-thread-permissions-types.js'; } from '../types/minimally-encoded-thread-permissions-types.js';
import type { BaseNavInfo } from '../types/nav-types.js'; import type { BaseNavInfo } from '../types/nav-types.js';
import type { BaseAppState } from '../types/redux-types.js'; import type { BaseAppState } from '../types/redux-types.js';
import { threadTypeIsCommunityRoot } from '../types/thread-types-enum.js';
import type { UserInfo } from '../types/user-types.js'; import type { UserInfo } from '../types/user-types.js';
import { getConfig } from '../utils/config.js'; import { getConfig } from '../utils/config.js';
import { values } from '../utils/objects.js'; import { values } from '../utils/objects.js';
import { useSelector } from '../utils/redux-utils.js'; import { useSelector } from '../utils/redux-utils.js';
function timeUntilCalendarRangeExpiration( function timeUntilCalendarRangeExpiration(
lastUserInteractionCalendar: number, lastUserInteractionCalendar: number,
): ?number { ): ?number {
▲ Show 20 Lines • Show All 92 Lines • ▼ Show 20 Lines
function useThreadSearchIndex( function useThreadSearchIndex(
threadInfos: $ReadOnlyArray<RawThreadInfo | ThreadInfo>, threadInfos: $ReadOnlyArray<RawThreadInfo | ThreadInfo>,
): SearchIndex { ): SearchIndex {
const userInfos = useSelector(state => state.userStore.userInfos); const userInfos = useSelector(state => state.userStore.userInfos);
const viewerID = useSelector( const viewerID = useSelector(
state => state.currentUserInfo && state.currentUserInfo.id, state => state.currentUserInfo && state.currentUserInfo.id,
); );
const communityRootMembersToRole = React.useMemo(() => { const communityRootMembersToRole = useCommunityRootMembersToRole(threadInfos);
const communityThreadInfos = threadInfos.filter(threadInfo =>
threadTypeIsCommunityRoot(threadInfo.type),
);
const communityRoots = _keyBy('id')(communityThreadInfos);
return _mapValues((threadInfo: ThreadInfo | RawThreadInfo) => {
const keyedMembers = _keyBy('id')(threadInfo.members);
const keyedMembersToRole = _mapValues(
(member: MemberInfo | RelativeMemberInfo) => {
return member.role ? threadInfo.roles[member.role] : null;
},
)(keyedMembers);
return keyedMembersToRole;
})(communityRoots);
}, [threadInfos]);
const nonViewerMembers = React.useMemo(() => { const nonViewerMembers = React.useMemo(() => {
const allMembersOfAllThreads = new Map<string, UserInfo>(); const allMembersOfAllThreads = new Map<string, UserInfo>();
for (const threadInfo of threadInfos) { for (const threadInfo of threadInfos) {
for (const member of threadInfo.members) { for (const member of threadInfo.members) {
const communityRole = const communityRole =
communityRootMembersToRole[threadInfo.community]?.[member.id]; communityRootMembersToRole[threadInfo.community]?.[member.id];
const isParentAdmin = roleIsAdminRole(communityRole); const isParentAdmin = roleIsAdminRole(communityRole);
▲ Show 20 Lines • Show All 84 Lines • Show Last 20 Lines
View Options

native/database/sqlite-api.js

// @flow // @flow
import _keyBy from 'lodash/fp/keyBy.js';
import _mapValues from 'lodash/fp/mapValues.js';
import * as React from 'react'; import * as React from 'react';
import { createSelector } from 'reselect'; import { createSelector } from 'reselect';
import { useENSNames } from '../hooks/ens-cache.js'; import { useENSNames } from '../hooks/ens-cache.js';
import SearchIndex from '../shared/search-index.js'; import SearchIndex from '../shared/search-index.js';
import { roleIsAdminRole } from '../shared/thread-utils.js'; import {
roleIsAdminRole,
useCommunityRootMembersToRole,
} from '../shared/thread-utils.js';
import type { Platform } from '../types/device-types.js'; import type { Platform } from '../types/device-types.js';
import { import {
type CalendarQuery, type CalendarQuery,
defaultCalendarQuery, defaultCalendarQuery,
} from '../types/entry-types.js'; } from '../types/entry-types.js';
import type { CalendarFilter } from '../types/filter-types.js'; import type { CalendarFilter } from '../types/filter-types.js';
import type { import type {
ThreadInfo, ThreadInfo,
RelativeMemberInfo, RelativeMemberInfo,
RawThreadInfo, RawThreadInfo,
MemberInfo,
} from '../types/minimally-encoded-thread-permissions-types.js'; } from '../types/minimally-encoded-thread-permissions-types.js';
import type { BaseNavInfo } from '../types/nav-types.js'; import type { BaseNavInfo } from '../types/nav-types.js';
import type { BaseAppState } from '../types/redux-types.js'; import type { BaseAppState } from '../types/redux-types.js';
import { threadTypeIsCommunityRoot } from '../types/thread-types-enum.js';
import type { UserInfo } from '../types/user-types.js'; import type { UserInfo } from '../types/user-types.js';
import { getConfig } from '../utils/config.js'; import { getConfig } from '../utils/config.js';
import { values } from '../utils/objects.js'; import { values } from '../utils/objects.js';
import { useSelector } from '../utils/redux-utils.js'; import { useSelector } from '../utils/redux-utils.js';
function timeUntilCalendarRangeExpiration( function timeUntilCalendarRangeExpiration(
lastUserInteractionCalendar: number, lastUserInteractionCalendar: number,
): ?number { ): ?number {
▲ Show 20 Lines • Show All 92 Lines • ▼ Show 20 Lines
function useThreadSearchIndex( function useThreadSearchIndex(
threadInfos: $ReadOnlyArray<RawThreadInfo | ThreadInfo>, threadInfos: $ReadOnlyArray<RawThreadInfo | ThreadInfo>,
): SearchIndex { ): SearchIndex {
const userInfos = useSelector(state => state.userStore.userInfos); const userInfos = useSelector(state => state.userStore.userInfos);
const viewerID = useSelector( const viewerID = useSelector(
state => state.currentUserInfo && state.currentUserInfo.id, state => state.currentUserInfo && state.currentUserInfo.id,
); );
const communityRootMembersToRole = React.useMemo(() => { const communityRootMembersToRole = useCommunityRootMembersToRole(threadInfos);
const communityThreadInfos = threadInfos.filter(threadInfo =>
threadTypeIsCommunityRoot(threadInfo.type),
);
const communityRoots = _keyBy('id')(communityThreadInfos);
return _mapValues((threadInfo: ThreadInfo | RawThreadInfo) => {
const keyedMembers = _keyBy('id')(threadInfo.members);
const keyedMembersToRole = _mapValues(
(member: MemberInfo | RelativeMemberInfo) => {
return member.role ? threadInfo.roles[member.role] : null;
},
)(keyedMembers);
return keyedMembersToRole;
})(communityRoots);
}, [threadInfos]);
const nonViewerMembers = React.useMemo(() => { const nonViewerMembers = React.useMemo(() => {
const allMembersOfAllThreads = new Map<string, UserInfo>(); const allMembersOfAllThreads = new Map<string, UserInfo>();
for (const threadInfo of threadInfos) { for (const threadInfo of threadInfos) {
for (const member of threadInfo.members) { for (const member of threadInfo.members) {
const communityRole = const communityRole =
communityRootMembersToRole[threadInfo.community]?.[member.id]; communityRootMembersToRole[threadInfo.community]?.[member.id];
const isParentAdmin = roleIsAdminRole(communityRole); const isParentAdmin = roleIsAdminRole(communityRole);
▲ Show 20 Lines • Show All 84 Lines • Show Last 20 Lines
View Options

native/schema/CommCoreModuleSchema.js

// @flow // @flow
import _keyBy from 'lodash/fp/keyBy.js';
import _mapValues from 'lodash/fp/mapValues.js';
import * as React from 'react'; import * as React from 'react';
import { createSelector } from 'reselect'; import { createSelector } from 'reselect';
import { useENSNames } from '../hooks/ens-cache.js'; import { useENSNames } from '../hooks/ens-cache.js';
import SearchIndex from '../shared/search-index.js'; import SearchIndex from '../shared/search-index.js';
import { roleIsAdminRole } from '../shared/thread-utils.js'; import {
roleIsAdminRole,
useCommunityRootMembersToRole,
} from '../shared/thread-utils.js';
import type { Platform } from '../types/device-types.js'; import type { Platform } from '../types/device-types.js';
import { import {
type CalendarQuery, type CalendarQuery,
defaultCalendarQuery, defaultCalendarQuery,
} from '../types/entry-types.js'; } from '../types/entry-types.js';
import type { CalendarFilter } from '../types/filter-types.js'; import type { CalendarFilter } from '../types/filter-types.js';
import type { import type {
ThreadInfo, ThreadInfo,
RelativeMemberInfo, RelativeMemberInfo,
RawThreadInfo, RawThreadInfo,
MemberInfo,
} from '../types/minimally-encoded-thread-permissions-types.js'; } from '../types/minimally-encoded-thread-permissions-types.js';
import type { BaseNavInfo } from '../types/nav-types.js'; import type { BaseNavInfo } from '../types/nav-types.js';
import type { BaseAppState } from '../types/redux-types.js'; import type { BaseAppState } from '../types/redux-types.js';
import { threadTypeIsCommunityRoot } from '../types/thread-types-enum.js';
import type { UserInfo } from '../types/user-types.js'; import type { UserInfo } from '../types/user-types.js';
import { getConfig } from '../utils/config.js'; import { getConfig } from '../utils/config.js';
import { values } from '../utils/objects.js'; import { values } from '../utils/objects.js';
import { useSelector } from '../utils/redux-utils.js'; import { useSelector } from '../utils/redux-utils.js';
function timeUntilCalendarRangeExpiration( function timeUntilCalendarRangeExpiration(
lastUserInteractionCalendar: number, lastUserInteractionCalendar: number,
): ?number { ): ?number {
▲ Show 20 Lines • Show All 92 Lines • ▼ Show 20 Lines
function useThreadSearchIndex( function useThreadSearchIndex(
threadInfos: $ReadOnlyArray<RawThreadInfo | ThreadInfo>, threadInfos: $ReadOnlyArray<RawThreadInfo | ThreadInfo>,
): SearchIndex { ): SearchIndex {
const userInfos = useSelector(state => state.userStore.userInfos); const userInfos = useSelector(state => state.userStore.userInfos);
const viewerID = useSelector( const viewerID = useSelector(
state => state.currentUserInfo && state.currentUserInfo.id, state => state.currentUserInfo && state.currentUserInfo.id,
); );
const communityRootMembersToRole = React.useMemo(() => { const communityRootMembersToRole = useCommunityRootMembersToRole(threadInfos);
const communityThreadInfos = threadInfos.filter(threadInfo =>
threadTypeIsCommunityRoot(threadInfo.type),
);
const communityRoots = _keyBy('id')(communityThreadInfos);
return _mapValues((threadInfo: ThreadInfo | RawThreadInfo) => {
const keyedMembers = _keyBy('id')(threadInfo.members);
const keyedMembersToRole = _mapValues(
(member: MemberInfo | RelativeMemberInfo) => {
return member.role ? threadInfo.roles[member.role] : null;
},
)(keyedMembers);
return keyedMembersToRole;
})(communityRoots);
}, [threadInfos]);
const nonViewerMembers = React.useMemo(() => { const nonViewerMembers = React.useMemo(() => {
const allMembersOfAllThreads = new Map<string, UserInfo>(); const allMembersOfAllThreads = new Map<string, UserInfo>();
for (const threadInfo of threadInfos) { for (const threadInfo of threadInfos) {
for (const member of threadInfo.members) { for (const member of threadInfo.members) {
const communityRole = const communityRole =
communityRootMembersToRole[threadInfo.community]?.[member.id]; communityRootMembersToRole[threadInfo.community]?.[member.id];
const isParentAdmin = roleIsAdminRole(communityRole); const isParentAdmin = roleIsAdminRole(communityRole);
▲ Show 20 Lines • Show All 84 Lines • Show Last 20 Lines
View Options

web/database/sqlite-api.js

// @flow // @flow
import _keyBy from 'lodash/fp/keyBy.js';
import _mapValues from 'lodash/fp/mapValues.js';
import * as React from 'react'; import * as React from 'react';
import { createSelector } from 'reselect'; import { createSelector } from 'reselect';
import { useENSNames } from '../hooks/ens-cache.js'; import { useENSNames } from '../hooks/ens-cache.js';
import SearchIndex from '../shared/search-index.js'; import SearchIndex from '../shared/search-index.js';
import { roleIsAdminRole } from '../shared/thread-utils.js'; import {
roleIsAdminRole,
useCommunityRootMembersToRole,
} from '../shared/thread-utils.js';
import type { Platform } from '../types/device-types.js'; import type { Platform } from '../types/device-types.js';
import { import {
type CalendarQuery, type CalendarQuery,
defaultCalendarQuery, defaultCalendarQuery,
} from '../types/entry-types.js'; } from '../types/entry-types.js';
import type { CalendarFilter } from '../types/filter-types.js'; import type { CalendarFilter } from '../types/filter-types.js';
import type { import type {
ThreadInfo, ThreadInfo,
RelativeMemberInfo, RelativeMemberInfo,
RawThreadInfo, RawThreadInfo,
MemberInfo,
} from '../types/minimally-encoded-thread-permissions-types.js'; } from '../types/minimally-encoded-thread-permissions-types.js';
import type { BaseNavInfo } from '../types/nav-types.js'; import type { BaseNavInfo } from '../types/nav-types.js';
import type { BaseAppState } from '../types/redux-types.js'; import type { BaseAppState } from '../types/redux-types.js';
import { threadTypeIsCommunityRoot } from '../types/thread-types-enum.js';
import type { UserInfo } from '../types/user-types.js'; import type { UserInfo } from '../types/user-types.js';
import { getConfig } from '../utils/config.js'; import { getConfig } from '../utils/config.js';
import { values } from '../utils/objects.js'; import { values } from '../utils/objects.js';
import { useSelector } from '../utils/redux-utils.js'; import { useSelector } from '../utils/redux-utils.js';
function timeUntilCalendarRangeExpiration( function timeUntilCalendarRangeExpiration(
lastUserInteractionCalendar: number, lastUserInteractionCalendar: number,
): ?number { ): ?number {
▲ Show 20 Lines • Show All 92 Lines • ▼ Show 20 Lines
function useThreadSearchIndex( function useThreadSearchIndex(
threadInfos: $ReadOnlyArray<RawThreadInfo | ThreadInfo>, threadInfos: $ReadOnlyArray<RawThreadInfo | ThreadInfo>,
): SearchIndex { ): SearchIndex {
const userInfos = useSelector(state => state.userStore.userInfos); const userInfos = useSelector(state => state.userStore.userInfos);
const viewerID = useSelector( const viewerID = useSelector(
state => state.currentUserInfo && state.currentUserInfo.id, state => state.currentUserInfo && state.currentUserInfo.id,
); );
const communityRootMembersToRole = React.useMemo(() => { const communityRootMembersToRole = useCommunityRootMembersToRole(threadInfos);
const communityThreadInfos = threadInfos.filter(threadInfo =>
threadTypeIsCommunityRoot(threadInfo.type),
);
const communityRoots = _keyBy('id')(communityThreadInfos);
return _mapValues((threadInfo: ThreadInfo | RawThreadInfo) => {
const keyedMembers = _keyBy('id')(threadInfo.members);
const keyedMembersToRole = _mapValues(
(member: MemberInfo | RelativeMemberInfo) => {
return member.role ? threadInfo.roles[member.role] : null;
},
)(keyedMembers);
return keyedMembersToRole;
})(communityRoots);
}, [threadInfos]);
const nonViewerMembers = React.useMemo(() => { const nonViewerMembers = React.useMemo(() => {
const allMembersOfAllThreads = new Map<string, UserInfo>(); const allMembersOfAllThreads = new Map<string, UserInfo>();
for (const threadInfo of threadInfos) { for (const threadInfo of threadInfos) {
for (const member of threadInfo.members) { for (const member of threadInfo.members) {
const communityRole = const communityRole =
communityRootMembersToRole[threadInfo.community]?.[member.id]; communityRootMembersToRole[threadInfo.community]?.[member.id];
const isParentAdmin = roleIsAdminRole(communityRole); const isParentAdmin = roleIsAdminRole(communityRole);
▲ Show 20 Lines • Show All 84 Lines • Show Last 20 Lines
View Options

web/shared-worker/worker/shared-worker.js

Loading...
View Options

web/types/worker-types.js

Loading...