Page MenuHomePhabricator
Differential D3903

[services] Lib - Move cmake components
ClosedPublic
Actions

Authored by • karol on May 4 2022, 6:18 AM.
Tags
None
Referenced Files
Unknown Object (File)
Thu, Apr 17, 11:25 AM
Unknown Object (File)
Thu, Apr 17, 4:19 AM
Unknown Object (File)
Wed, Apr 16, 9:14 PM
Unknown Object (File)
Wed, Apr 16, 8:58 PM
Unknown Object (File)
Wed, Apr 16, 10:06 AM
Unknown Object (File)
Tue, Apr 8, 6:30 AM
Unknown Object (File)
Mon, Apr 7, 7:56 AM
Unknown Object (File)
Mon, Apr 7, 7:51 AM
View All Files
Subscribers
• abosh
• adrian
ashoat
atul
tomek

Details

Reviewers
tomek
ashoat
Commits
rCOMMad67c7406481: [services] Lib - Move cmake components
Summary

Moving cmake components from blob/backup to the mutual space

Test Plan

No real changes are applied, just moving stuff around, so services should still build and that's the test plan

cd services

yarn run-blob-service
yarn run-backup-service

Diff Detail

Repository
rCOMM Comm
Lint
Lint Not Applicable
Unit
Tests Not Applicable

Event Timeline

• karol created this revision.May 4 2022, 6:18 AM
Herald added subscribers: • abosh, atul, • adrian and 2 others. · View Herald TranscriptMay 4 2022, 6:18 AM
• karol edited the summary of this revision. (Show Details)May 4 2022, 6:40 AM
• karol edited the test plan for this revision. (Show Details)
• karol added a reviewer: tomek.
• karol added a parent revision: D3814: [services] Blob - Add holder to the blob DB if data exists.
• karol added a child revision: D3904: [services] Backup - rename docker to scripts.May 4 2022, 6:44 AM
Harbormaster completed remote builds in B8760: Diff 12206.May 4 2022, 6:46 AM
• karol requested review of this revision.May 4 2022, 6:46 AM
ashoat accepted this revision.May 4 2022, 9:05 AM
This revision is now accepted and ready to land.May 4 2022, 9:05 AM
• karol edited the summary of this revision. (Show Details)May 5 2022, 7:05 AM
• karol removed a parent revision: D3814: [services] Blob - Add holder to the blob DB if data exists.May 6 2022, 1:51 AM
• karol updated this revision to Diff 12347.May 6 2022, 5:14 AM

rebase

This revision was landed with ongoing or failed builds.May 6 2022, 5:15 AM
Closed by commit rCOMMad67c7406481: [services] Lib - Move cmake components (authored by • karol). · Explain Why
This revision was automatically updated to reflect the committed changes.
• karol added a commit: rCOMMad67c7406481: [services] Lib - Move cmake components.
Harbormaster completed remote builds in B8852: Diff 12347.May 6 2022, 5:18 AM

Revision Contents
Changeset List

PathSize
services/
backup/
1 line
cmake-components/
blob/
1 line
cmake-components/
lib/
cmake-components/
backup/
cmake-components/

Diff 12348

View Options

services/backup/Dockerfile

// @flow // @flow
import * as React from 'react'; import * as React from 'react';
import { messageID } from './message-utils.js';
import SearchIndex from './search-index.js'; import SearchIndex from './search-index.js';
import { import {
userIsMember, userIsMember,
threadMemberHasPermission, threadMemberHasPermission,
getContainingThreadID, getContainingThreadID,
} from './thread-utils.js'; } from './thread-utils.js';
import { import {
useSearchMessages as useSearchMessagesAction, useSearchMessages as useSearchMessagesAction,
searchMessagesActionTypes, searchMessagesActionTypes,
} from '../actions/message-actions.js'; } from '../actions/message-actions.js';
import { import {
searchUsers, searchUsers,
searchUsersActionTypes, searchUsersActionTypes,
} from '../actions/user-actions.js'; } from '../actions/user-actions.js';
import genesis from '../facts/genesis.js'; import genesis from '../facts/genesis.js';
import type { import type {
ChatMessageInfoItem, ChatMessageInfoItem,
MessageListData, MessageListData,
ChatMessageItem,
} from '../selectors/chat-selectors.js'; } from '../selectors/chat-selectors.js';
import type { MessageInfo, RawMessageInfo } from '../types/message-types.js'; import type { MessageInfo, RawMessageInfo } from '../types/message-types.js';
import { isComposableMessageType } from '../types/message-types.js';
import type { MinimallyEncodedThreadInfo } from '../types/minimally-encoded-thread-permissions-types.js'; import type { MinimallyEncodedThreadInfo } from '../types/minimally-encoded-thread-permissions-types.js';
import { userRelationshipStatus } from '../types/relationship-types.js'; import { userRelationshipStatus } from '../types/relationship-types.js';
import { threadPermissions } from '../types/thread-permission-types.js'; import { threadPermissions } from '../types/thread-permission-types.js';
import { type ThreadType, threadTypes } from '../types/thread-types-enum.js'; import { type ThreadType, threadTypes } from '../types/thread-types-enum.js';
import { type ThreadInfo } from '../types/thread-types.js'; import { type ThreadInfo } from '../types/thread-types.js';
import type { import type {
AccountUserInfo, AccountUserInfo,
UserListItem, UserListItem,
▲ Show 20 Lines • Show All 97 Lines • ▼ Show 20 Linesfunction getPotentialMemberItems({
const blockedRelationshipsStatuses = new Set([ const blockedRelationshipsStatuses = new Set([
userRelationshipStatus.BLOCKED_BY_VIEWER, userRelationshipStatus.BLOCKED_BY_VIEWER,
userRelationshipStatus.BLOCKED_VIEWER, userRelationshipStatus.BLOCKED_VIEWER,
userRelationshipStatus.BOTH_BLOCKED, userRelationshipStatus.BOTH_BLOCKED,
]); ]);
let userResults = values(results); let userResults = values(results);
if (text === '') { if (text === '') {
userResults = userResults.filter(userInfo => userResults = userResults.filter(userInfo => {
containingThreadInfo if (!containingThreadInfo) {
? userInfo.isMemberOfContainingThread && return userInfo.relationshipStatus === userRelationshipStatus.FRIEND;
!blockedRelationshipsStatuses.has(userInfo.relationshipStatus) }
: userInfo?.relationshipStatus === userRelationshipStatus.FRIEND, if (!userInfo.isMemberOfContainingThread) {
); return false;
}
const { relationshipStatus } = userInfo;
if (!relationshipStatus) {
return true;
}
return !blockedRelationshipsStatuses.has(relationshipStatus);
});
} }
const nonFriends = []; const nonFriends = [];
const blockedUsers = []; const blockedUsers = [];
const friends = []; const friends = [];
const containingThreadMembers = []; const containingThreadMembers = [];
const parentThreadMembers = []; const parentThreadMembers = [];
for (const userResult of userResults) { for (const userResult of userResults) {
const relationshipStatus = userResult.relationshipStatus; const { relationshipStatus } = userResult;
if (blockedRelationshipsStatuses.has(relationshipStatus)) { if (
relationshipStatus &&
blockedRelationshipsStatuses.has(relationshipStatus)
) {
blockedUsers.push(userResult); blockedUsers.push(userResult);
} else if (userResult.isMemberOfParentThread) { } else if (userResult.isMemberOfParentThread) {
parentThreadMembers.push(userResult); parentThreadMembers.push(userResult);
} else if (userResult.isMemberOfContainingThread) { } else if (userResult.isMemberOfContainingThread) {
containingThreadMembers.push(userResult); containingThreadMembers.push(userResult);
} else if (relationshipStatus === userRelationshipStatus.FRIEND) { } else if (relationshipStatus === userRelationshipStatus.FRIEND) {
friends.push(userResult); friends.push(userResult);
} else { } else {
Show All 11 Lines return sortedResults.map(
({ ({
isMemberOfContainingThread, isMemberOfContainingThread,
isMemberOfParentThread, isMemberOfParentThread,
relationshipStatus, relationshipStatus,
...result ...result
}) => { }) => {
let notice, alert; let notice, alert;
const username = result.username; const username = result.username;
if (blockedRelationshipsStatuses.has(relationshipStatus)) { if (
relationshipStatus &&
blockedRelationshipsStatuses.has(relationshipStatus)
) {
notice = 'user is blocked'; notice = 'user is blocked';
alert = { alert = {
title: 'User is blocked', title: 'User is blocked',
text: text:
`Before you add ${username} to this chat, ` + `Before you add ${username} to this chat, ` +
'you’ll need to unblock them. You can do this from the Block List ' + 'you’ll need to unblock them. You can do this from the Block List ' +
'in the Profile tab.', 'in the Profile tab.',
}; };
▲ Show 20 Lines • Show All 114 Lines • ▼ Show 20 Lines
function filterChatMessageInfosForSearch( function filterChatMessageInfosForSearch(
chatMessageInfos: MessageListData, chatMessageInfos: MessageListData,
translatedSearchResults: $ReadOnlyArray<MessageInfo>, translatedSearchResults: $ReadOnlyArray<MessageInfo>,
): ?(ChatMessageInfoItem[]) { ): ?(ChatMessageInfoItem[]) {
if (!chatMessageInfos) { if (!chatMessageInfos) {
return null; return null;
} }
const idSet = new Set(translatedSearchResults.map(item => item.id)); const idSet = new Set(translatedSearchResults.map(messageID));
const chatMessageInfoItems = chatMessageInfos.filter(
item =>
item.messageInfo &&
idSet.has(item.messageInfo.id) &&
isComposableMessageType(item.messageInfo.type),
);
const uniqueChatMessageInfoItemsMap = new Map<string, ChatMessageItem>(); const uniqueChatMessageInfoItemsMap = new Map<string, ChatMessageInfoItem>();
chatMessageInfoItems.forEach( for (const item of chatMessageInfos) {
item => if (item.itemType !== 'message' || item.messageInfoType !== 'composable') {
item.messageInfo && continue;
item.messageInfo.id && }
uniqueChatMessageInfoItemsMap.set(item.messageInfo.id, item), const id = messageID(item.messageInfo);
); if (idSet.has(id)) {
uniqueChatMessageInfoItemsMap.set(id, item);
}
}
const sortedChatMessageInfoItems = []; const sortedChatMessageInfoItems: ChatMessageInfoItem[] = [];
for (let i = 0; i < translatedSearchResults.length; i++) { for (let i = 0; i < translatedSearchResults.length; i++) {
sortedChatMessageInfoItems.push( const id = messageID(translatedSearchResults[i]);
uniqueChatMessageInfoItemsMap.get(translatedSearchResults[i].id), const match = uniqueChatMessageInfoItemsMap.get(id);
); if (match) {
sortedChatMessageInfoItems.push(match);
} }
}
return sortedChatMessageInfoItems.filter(Boolean); return sortedChatMessageInfoItems;
} }
export { export {
getPotentialMemberItems, getPotentialMemberItems,
notFriendNotice, notFriendNotice,
useSearchMessages, useSearchMessages,
useSearchUsers, useSearchUsers,
filterChatMessageInfosForSearch, filterChatMessageInfosForSearch,
}; };
View Options

services/backup/cmake-components/folly.cmake

// @flow // @flow
import * as React from 'react'; import * as React from 'react';
import { messageID } from './message-utils.js';
import SearchIndex from './search-index.js'; import SearchIndex from './search-index.js';
import { import {
userIsMember, userIsMember,
threadMemberHasPermission, threadMemberHasPermission,
getContainingThreadID, getContainingThreadID,
} from './thread-utils.js'; } from './thread-utils.js';
import { import {
useSearchMessages as useSearchMessagesAction, useSearchMessages as useSearchMessagesAction,
searchMessagesActionTypes, searchMessagesActionTypes,
} from '../actions/message-actions.js'; } from '../actions/message-actions.js';
import { import {
searchUsers, searchUsers,
searchUsersActionTypes, searchUsersActionTypes,
} from '../actions/user-actions.js'; } from '../actions/user-actions.js';
import genesis from '../facts/genesis.js'; import genesis from '../facts/genesis.js';
import type { import type {
ChatMessageInfoItem, ChatMessageInfoItem,
MessageListData, MessageListData,
ChatMessageItem,
} from '../selectors/chat-selectors.js'; } from '../selectors/chat-selectors.js';
import type { MessageInfo, RawMessageInfo } from '../types/message-types.js'; import type { MessageInfo, RawMessageInfo } from '../types/message-types.js';
import { isComposableMessageType } from '../types/message-types.js';
import type { MinimallyEncodedThreadInfo } from '../types/minimally-encoded-thread-permissions-types.js'; import type { MinimallyEncodedThreadInfo } from '../types/minimally-encoded-thread-permissions-types.js';
import { userRelationshipStatus } from '../types/relationship-types.js'; import { userRelationshipStatus } from '../types/relationship-types.js';
import { threadPermissions } from '../types/thread-permission-types.js'; import { threadPermissions } from '../types/thread-permission-types.js';
import { type ThreadType, threadTypes } from '../types/thread-types-enum.js'; import { type ThreadType, threadTypes } from '../types/thread-types-enum.js';
import { type ThreadInfo } from '../types/thread-types.js'; import { type ThreadInfo } from '../types/thread-types.js';
import type { import type {
AccountUserInfo, AccountUserInfo,
UserListItem, UserListItem,
▲ Show 20 Lines • Show All 97 Lines • ▼ Show 20 Linesfunction getPotentialMemberItems({
const blockedRelationshipsStatuses = new Set([ const blockedRelationshipsStatuses = new Set([
userRelationshipStatus.BLOCKED_BY_VIEWER, userRelationshipStatus.BLOCKED_BY_VIEWER,
userRelationshipStatus.BLOCKED_VIEWER, userRelationshipStatus.BLOCKED_VIEWER,
userRelationshipStatus.BOTH_BLOCKED, userRelationshipStatus.BOTH_BLOCKED,
]); ]);
let userResults = values(results); let userResults = values(results);
if (text === '') { if (text === '') {
userResults = userResults.filter(userInfo => userResults = userResults.filter(userInfo => {
containingThreadInfo if (!containingThreadInfo) {
? userInfo.isMemberOfContainingThread && return userInfo.relationshipStatus === userRelationshipStatus.FRIEND;
!blockedRelationshipsStatuses.has(userInfo.relationshipStatus) }
: userInfo?.relationshipStatus === userRelationshipStatus.FRIEND, if (!userInfo.isMemberOfContainingThread) {
); return false;
}
const { relationshipStatus } = userInfo;
if (!relationshipStatus) {
return true;
}
return !blockedRelationshipsStatuses.has(relationshipStatus);
});
} }
const nonFriends = []; const nonFriends = [];
const blockedUsers = []; const blockedUsers = [];
const friends = []; const friends = [];
const containingThreadMembers = []; const containingThreadMembers = [];
const parentThreadMembers = []; const parentThreadMembers = [];
for (const userResult of userResults) { for (const userResult of userResults) {
const relationshipStatus = userResult.relationshipStatus; const { relationshipStatus } = userResult;
if (blockedRelationshipsStatuses.has(relationshipStatus)) { if (
relationshipStatus &&
blockedRelationshipsStatuses.has(relationshipStatus)
) {
blockedUsers.push(userResult); blockedUsers.push(userResult);
} else if (userResult.isMemberOfParentThread) { } else if (userResult.isMemberOfParentThread) {
parentThreadMembers.push(userResult); parentThreadMembers.push(userResult);
} else if (userResult.isMemberOfContainingThread) { } else if (userResult.isMemberOfContainingThread) {
containingThreadMembers.push(userResult); containingThreadMembers.push(userResult);
} else if (relationshipStatus === userRelationshipStatus.FRIEND) { } else if (relationshipStatus === userRelationshipStatus.FRIEND) {
friends.push(userResult); friends.push(userResult);
} else { } else {
Show All 11 Lines return sortedResults.map(
({ ({
isMemberOfContainingThread, isMemberOfContainingThread,
isMemberOfParentThread, isMemberOfParentThread,
relationshipStatus, relationshipStatus,
...result ...result
}) => { }) => {
let notice, alert; let notice, alert;
const username = result.username; const username = result.username;
if (blockedRelationshipsStatuses.has(relationshipStatus)) { if (
relationshipStatus &&
blockedRelationshipsStatuses.has(relationshipStatus)
) {
notice = 'user is blocked'; notice = 'user is blocked';
alert = { alert = {
title: 'User is blocked', title: 'User is blocked',
text: text:
`Before you add ${username} to this chat, ` + `Before you add ${username} to this chat, ` +
'you’ll need to unblock them. You can do this from the Block List ' + 'you’ll need to unblock them. You can do this from the Block List ' +
'in the Profile tab.', 'in the Profile tab.',
}; };
▲ Show 20 Lines • Show All 114 Lines • ▼ Show 20 Lines
function filterChatMessageInfosForSearch( function filterChatMessageInfosForSearch(
chatMessageInfos: MessageListData, chatMessageInfos: MessageListData,
translatedSearchResults: $ReadOnlyArray<MessageInfo>, translatedSearchResults: $ReadOnlyArray<MessageInfo>,
): ?(ChatMessageInfoItem[]) { ): ?(ChatMessageInfoItem[]) {
if (!chatMessageInfos) { if (!chatMessageInfos) {
return null; return null;
} }
const idSet = new Set(translatedSearchResults.map(item => item.id)); const idSet = new Set(translatedSearchResults.map(messageID));
const chatMessageInfoItems = chatMessageInfos.filter(
item =>
item.messageInfo &&
idSet.has(item.messageInfo.id) &&
isComposableMessageType(item.messageInfo.type),
);
const uniqueChatMessageInfoItemsMap = new Map<string, ChatMessageItem>(); const uniqueChatMessageInfoItemsMap = new Map<string, ChatMessageInfoItem>();
chatMessageInfoItems.forEach( for (const item of chatMessageInfos) {
item => if (item.itemType !== 'message' || item.messageInfoType !== 'composable') {
item.messageInfo && continue;
item.messageInfo.id && }
uniqueChatMessageInfoItemsMap.set(item.messageInfo.id, item), const id = messageID(item.messageInfo);
); if (idSet.has(id)) {
uniqueChatMessageInfoItemsMap.set(id, item);
}
}
const sortedChatMessageInfoItems = []; const sortedChatMessageInfoItems: ChatMessageInfoItem[] = [];
for (let i = 0; i < translatedSearchResults.length; i++) { for (let i = 0; i < translatedSearchResults.length; i++) {
sortedChatMessageInfoItems.push( const id = messageID(translatedSearchResults[i]);
uniqueChatMessageInfoItemsMap.get(translatedSearchResults[i].id), const match = uniqueChatMessageInfoItemsMap.get(id);
); if (match) {
sortedChatMessageInfoItems.push(match);
} }
}
return sortedChatMessageInfoItems.filter(Boolean); return sortedChatMessageInfoItems;
} }
export { export {
getPotentialMemberItems, getPotentialMemberItems,
notFriendNotice, notFriendNotice,
useSearchMessages, useSearchMessages,
useSearchUsers, useSearchUsers,
filterChatMessageInfosForSearch, filterChatMessageInfosForSearch,
}; };
View Options

services/backup/cmake-components/grpc.cmake

// @flow // @flow
import * as React from 'react'; import * as React from 'react';
import { messageID } from './message-utils.js';
import SearchIndex from './search-index.js'; import SearchIndex from './search-index.js';
import { import {
userIsMember, userIsMember,
threadMemberHasPermission, threadMemberHasPermission,
getContainingThreadID, getContainingThreadID,
} from './thread-utils.js'; } from './thread-utils.js';
import { import {
useSearchMessages as useSearchMessagesAction, useSearchMessages as useSearchMessagesAction,
searchMessagesActionTypes, searchMessagesActionTypes,
} from '../actions/message-actions.js'; } from '../actions/message-actions.js';
import { import {
searchUsers, searchUsers,
searchUsersActionTypes, searchUsersActionTypes,
} from '../actions/user-actions.js'; } from '../actions/user-actions.js';
import genesis from '../facts/genesis.js'; import genesis from '../facts/genesis.js';
import type { import type {
ChatMessageInfoItem, ChatMessageInfoItem,
MessageListData, MessageListData,
ChatMessageItem,
} from '../selectors/chat-selectors.js'; } from '../selectors/chat-selectors.js';
import type { MessageInfo, RawMessageInfo } from '../types/message-types.js'; import type { MessageInfo, RawMessageInfo } from '../types/message-types.js';
import { isComposableMessageType } from '../types/message-types.js';
import type { MinimallyEncodedThreadInfo } from '../types/minimally-encoded-thread-permissions-types.js'; import type { MinimallyEncodedThreadInfo } from '../types/minimally-encoded-thread-permissions-types.js';
import { userRelationshipStatus } from '../types/relationship-types.js'; import { userRelationshipStatus } from '../types/relationship-types.js';
import { threadPermissions } from '../types/thread-permission-types.js'; import { threadPermissions } from '../types/thread-permission-types.js';
import { type ThreadType, threadTypes } from '../types/thread-types-enum.js'; import { type ThreadType, threadTypes } from '../types/thread-types-enum.js';
import { type ThreadInfo } from '../types/thread-types.js'; import { type ThreadInfo } from '../types/thread-types.js';
import type { import type {
AccountUserInfo, AccountUserInfo,
UserListItem, UserListItem,
▲ Show 20 Lines • Show All 97 Lines • ▼ Show 20 Linesfunction getPotentialMemberItems({
const blockedRelationshipsStatuses = new Set([ const blockedRelationshipsStatuses = new Set([
userRelationshipStatus.BLOCKED_BY_VIEWER, userRelationshipStatus.BLOCKED_BY_VIEWER,
userRelationshipStatus.BLOCKED_VIEWER, userRelationshipStatus.BLOCKED_VIEWER,
userRelationshipStatus.BOTH_BLOCKED, userRelationshipStatus.BOTH_BLOCKED,
]); ]);
let userResults = values(results); let userResults = values(results);
if (text === '') { if (text === '') {
userResults = userResults.filter(userInfo => userResults = userResults.filter(userInfo => {
containingThreadInfo if (!containingThreadInfo) {
? userInfo.isMemberOfContainingThread && return userInfo.relationshipStatus === userRelationshipStatus.FRIEND;
!blockedRelationshipsStatuses.has(userInfo.relationshipStatus) }
: userInfo?.relationshipStatus === userRelationshipStatus.FRIEND, if (!userInfo.isMemberOfContainingThread) {
); return false;
}
const { relationshipStatus } = userInfo;
if (!relationshipStatus) {
return true;
}
return !blockedRelationshipsStatuses.has(relationshipStatus);
});
} }
const nonFriends = []; const nonFriends = [];
const blockedUsers = []; const blockedUsers = [];
const friends = []; const friends = [];
const containingThreadMembers = []; const containingThreadMembers = [];
const parentThreadMembers = []; const parentThreadMembers = [];
for (const userResult of userResults) { for (const userResult of userResults) {
const relationshipStatus = userResult.relationshipStatus; const { relationshipStatus } = userResult;
if (blockedRelationshipsStatuses.has(relationshipStatus)) { if (
relationshipStatus &&
blockedRelationshipsStatuses.has(relationshipStatus)
) {
blockedUsers.push(userResult); blockedUsers.push(userResult);
} else if (userResult.isMemberOfParentThread) { } else if (userResult.isMemberOfParentThread) {
parentThreadMembers.push(userResult); parentThreadMembers.push(userResult);
} else if (userResult.isMemberOfContainingThread) { } else if (userResult.isMemberOfContainingThread) {
containingThreadMembers.push(userResult); containingThreadMembers.push(userResult);
} else if (relationshipStatus === userRelationshipStatus.FRIEND) { } else if (relationshipStatus === userRelationshipStatus.FRIEND) {
friends.push(userResult); friends.push(userResult);
} else { } else {
Show All 11 Lines return sortedResults.map(
({ ({
isMemberOfContainingThread, isMemberOfContainingThread,
isMemberOfParentThread, isMemberOfParentThread,
relationshipStatus, relationshipStatus,
...result ...result
}) => { }) => {
let notice, alert; let notice, alert;
const username = result.username; const username = result.username;
if (blockedRelationshipsStatuses.has(relationshipStatus)) { if (
relationshipStatus &&
blockedRelationshipsStatuses.has(relationshipStatus)
) {
notice = 'user is blocked'; notice = 'user is blocked';
alert = { alert = {
title: 'User is blocked', title: 'User is blocked',
text: text:
`Before you add ${username} to this chat, ` + `Before you add ${username} to this chat, ` +
'you’ll need to unblock them. You can do this from the Block List ' + 'you’ll need to unblock them. You can do this from the Block List ' +
'in the Profile tab.', 'in the Profile tab.',
}; };
▲ Show 20 Lines • Show All 114 Lines • ▼ Show 20 Lines
function filterChatMessageInfosForSearch( function filterChatMessageInfosForSearch(
chatMessageInfos: MessageListData, chatMessageInfos: MessageListData,
translatedSearchResults: $ReadOnlyArray<MessageInfo>, translatedSearchResults: $ReadOnlyArray<MessageInfo>,
): ?(ChatMessageInfoItem[]) { ): ?(ChatMessageInfoItem[]) {
if (!chatMessageInfos) { if (!chatMessageInfos) {
return null; return null;
} }
const idSet = new Set(translatedSearchResults.map(item => item.id)); const idSet = new Set(translatedSearchResults.map(messageID));
const chatMessageInfoItems = chatMessageInfos.filter(
item =>
item.messageInfo &&
idSet.has(item.messageInfo.id) &&
isComposableMessageType(item.messageInfo.type),
);
const uniqueChatMessageInfoItemsMap = new Map<string, ChatMessageItem>(); const uniqueChatMessageInfoItemsMap = new Map<string, ChatMessageInfoItem>();
chatMessageInfoItems.forEach( for (const item of chatMessageInfos) {
item => if (item.itemType !== 'message' || item.messageInfoType !== 'composable') {
item.messageInfo && continue;
item.messageInfo.id && }
uniqueChatMessageInfoItemsMap.set(item.messageInfo.id, item), const id = messageID(item.messageInfo);
); if (idSet.has(id)) {
uniqueChatMessageInfoItemsMap.set(id, item);
}
}
const sortedChatMessageInfoItems = []; const sortedChatMessageInfoItems: ChatMessageInfoItem[] = [];
for (let i = 0; i < translatedSearchResults.length; i++) { for (let i = 0; i < translatedSearchResults.length; i++) {
sortedChatMessageInfoItems.push( const id = messageID(translatedSearchResults[i]);
uniqueChatMessageInfoItemsMap.get(translatedSearchResults[i].id), const match = uniqueChatMessageInfoItemsMap.get(id);
); if (match) {
sortedChatMessageInfoItems.push(match);
} }
}
return sortedChatMessageInfoItems.filter(Boolean); return sortedChatMessageInfoItems;
} }
export { export {
getPotentialMemberItems, getPotentialMemberItems,
notFriendNotice, notFriendNotice,
useSearchMessages, useSearchMessages,
useSearchUsers, useSearchUsers,
filterChatMessageInfosForSearch, filterChatMessageInfosForSearch,
}; };
View Options

services/blob/Dockerfile

// @flow // @flow
import * as React from 'react'; import * as React from 'react';
import { messageID } from './message-utils.js';
import SearchIndex from './search-index.js'; import SearchIndex from './search-index.js';
import { import {
userIsMember, userIsMember,
threadMemberHasPermission, threadMemberHasPermission,
getContainingThreadID, getContainingThreadID,
} from './thread-utils.js'; } from './thread-utils.js';
import { import {
useSearchMessages as useSearchMessagesAction, useSearchMessages as useSearchMessagesAction,
searchMessagesActionTypes, searchMessagesActionTypes,
} from '../actions/message-actions.js'; } from '../actions/message-actions.js';
import { import {
searchUsers, searchUsers,
searchUsersActionTypes, searchUsersActionTypes,
} from '../actions/user-actions.js'; } from '../actions/user-actions.js';
import genesis from '../facts/genesis.js'; import genesis from '../facts/genesis.js';
import type { import type {
ChatMessageInfoItem, ChatMessageInfoItem,
MessageListData, MessageListData,
ChatMessageItem,
} from '../selectors/chat-selectors.js'; } from '../selectors/chat-selectors.js';
import type { MessageInfo, RawMessageInfo } from '../types/message-types.js'; import type { MessageInfo, RawMessageInfo } from '../types/message-types.js';
import { isComposableMessageType } from '../types/message-types.js';
import type { MinimallyEncodedThreadInfo } from '../types/minimally-encoded-thread-permissions-types.js'; import type { MinimallyEncodedThreadInfo } from '../types/minimally-encoded-thread-permissions-types.js';
import { userRelationshipStatus } from '../types/relationship-types.js'; import { userRelationshipStatus } from '../types/relationship-types.js';
import { threadPermissions } from '../types/thread-permission-types.js'; import { threadPermissions } from '../types/thread-permission-types.js';
import { type ThreadType, threadTypes } from '../types/thread-types-enum.js'; import { type ThreadType, threadTypes } from '../types/thread-types-enum.js';
import { type ThreadInfo } from '../types/thread-types.js'; import { type ThreadInfo } from '../types/thread-types.js';
import type { import type {
AccountUserInfo, AccountUserInfo,
UserListItem, UserListItem,
▲ Show 20 Lines • Show All 97 Lines • ▼ Show 20 Linesfunction getPotentialMemberItems({
const blockedRelationshipsStatuses = new Set([ const blockedRelationshipsStatuses = new Set([
userRelationshipStatus.BLOCKED_BY_VIEWER, userRelationshipStatus.BLOCKED_BY_VIEWER,
userRelationshipStatus.BLOCKED_VIEWER, userRelationshipStatus.BLOCKED_VIEWER,
userRelationshipStatus.BOTH_BLOCKED, userRelationshipStatus.BOTH_BLOCKED,
]); ]);
let userResults = values(results); let userResults = values(results);
if (text === '') { if (text === '') {
userResults = userResults.filter(userInfo => userResults = userResults.filter(userInfo => {
containingThreadInfo if (!containingThreadInfo) {
? userInfo.isMemberOfContainingThread && return userInfo.relationshipStatus === userRelationshipStatus.FRIEND;
!blockedRelationshipsStatuses.has(userInfo.relationshipStatus) }
: userInfo?.relationshipStatus === userRelationshipStatus.FRIEND, if (!userInfo.isMemberOfContainingThread) {
); return false;
}
const { relationshipStatus } = userInfo;
if (!relationshipStatus) {
return true;
}
return !blockedRelationshipsStatuses.has(relationshipStatus);
});
} }
const nonFriends = []; const nonFriends = [];
const blockedUsers = []; const blockedUsers = [];
const friends = []; const friends = [];
const containingThreadMembers = []; const containingThreadMembers = [];
const parentThreadMembers = []; const parentThreadMembers = [];
for (const userResult of userResults) { for (const userResult of userResults) {
const relationshipStatus = userResult.relationshipStatus; const { relationshipStatus } = userResult;
if (blockedRelationshipsStatuses.has(relationshipStatus)) { if (
relationshipStatus &&
blockedRelationshipsStatuses.has(relationshipStatus)
) {
blockedUsers.push(userResult); blockedUsers.push(userResult);
} else if (userResult.isMemberOfParentThread) { } else if (userResult.isMemberOfParentThread) {
parentThreadMembers.push(userResult); parentThreadMembers.push(userResult);
} else if (userResult.isMemberOfContainingThread) { } else if (userResult.isMemberOfContainingThread) {
containingThreadMembers.push(userResult); containingThreadMembers.push(userResult);
} else if (relationshipStatus === userRelationshipStatus.FRIEND) { } else if (relationshipStatus === userRelationshipStatus.FRIEND) {
friends.push(userResult); friends.push(userResult);
} else { } else {
Show All 11 Lines return sortedResults.map(
({ ({
isMemberOfContainingThread, isMemberOfContainingThread,
isMemberOfParentThread, isMemberOfParentThread,
relationshipStatus, relationshipStatus,
...result ...result
}) => { }) => {
let notice, alert; let notice, alert;
const username = result.username; const username = result.username;
if (blockedRelationshipsStatuses.has(relationshipStatus)) { if (
relationshipStatus &&
blockedRelationshipsStatuses.has(relationshipStatus)
) {
notice = 'user is blocked'; notice = 'user is blocked';
alert = { alert = {
title: 'User is blocked', title: 'User is blocked',
text: text:
`Before you add ${username} to this chat, ` + `Before you add ${username} to this chat, ` +
'you’ll need to unblock them. You can do this from the Block List ' + 'you’ll need to unblock them. You can do this from the Block List ' +
'in the Profile tab.', 'in the Profile tab.',
}; };
▲ Show 20 Lines • Show All 114 Lines • ▼ Show 20 Lines
function filterChatMessageInfosForSearch( function filterChatMessageInfosForSearch(
chatMessageInfos: MessageListData, chatMessageInfos: MessageListData,
translatedSearchResults: $ReadOnlyArray<MessageInfo>, translatedSearchResults: $ReadOnlyArray<MessageInfo>,
): ?(ChatMessageInfoItem[]) { ): ?(ChatMessageInfoItem[]) {
if (!chatMessageInfos) { if (!chatMessageInfos) {
return null; return null;
} }
const idSet = new Set(translatedSearchResults.map(item => item.id)); const idSet = new Set(translatedSearchResults.map(messageID));
const chatMessageInfoItems = chatMessageInfos.filter(
item =>
item.messageInfo &&
idSet.has(item.messageInfo.id) &&
isComposableMessageType(item.messageInfo.type),
);
const uniqueChatMessageInfoItemsMap = new Map<string, ChatMessageItem>(); const uniqueChatMessageInfoItemsMap = new Map<string, ChatMessageInfoItem>();
chatMessageInfoItems.forEach( for (const item of chatMessageInfos) {
item => if (item.itemType !== 'message' || item.messageInfoType !== 'composable') {
item.messageInfo && continue;
item.messageInfo.id && }
uniqueChatMessageInfoItemsMap.set(item.messageInfo.id, item), const id = messageID(item.messageInfo);
); if (idSet.has(id)) {
uniqueChatMessageInfoItemsMap.set(id, item);
}
}
const sortedChatMessageInfoItems = []; const sortedChatMessageInfoItems: ChatMessageInfoItem[] = [];
for (let i = 0; i < translatedSearchResults.length; i++) { for (let i = 0; i < translatedSearchResults.length; i++) {
sortedChatMessageInfoItems.push( const id = messageID(translatedSearchResults[i]);
uniqueChatMessageInfoItemsMap.get(translatedSearchResults[i].id), const match = uniqueChatMessageInfoItemsMap.get(id);
); if (match) {
sortedChatMessageInfoItems.push(match);
} }
}
return sortedChatMessageInfoItems.filter(Boolean); return sortedChatMessageInfoItems;
} }
export { export {
getPotentialMemberItems, getPotentialMemberItems,
notFriendNotice, notFriendNotice,
useSearchMessages, useSearchMessages,
useSearchUsers, useSearchUsers,
filterChatMessageInfosForSearch, filterChatMessageInfosForSearch,
}; };
View Options

services/blob/cmake-components/folly.cmake

// @flow // @flow
import * as React from 'react'; import * as React from 'react';
import { messageID } from './message-utils.js';
import SearchIndex from './search-index.js'; import SearchIndex from './search-index.js';
import { import {
userIsMember, userIsMember,
threadMemberHasPermission, threadMemberHasPermission,
getContainingThreadID, getContainingThreadID,
} from './thread-utils.js'; } from './thread-utils.js';
import { import {
useSearchMessages as useSearchMessagesAction, useSearchMessages as useSearchMessagesAction,
searchMessagesActionTypes, searchMessagesActionTypes,
} from '../actions/message-actions.js'; } from '../actions/message-actions.js';
import { import {
searchUsers, searchUsers,
searchUsersActionTypes, searchUsersActionTypes,
} from '../actions/user-actions.js'; } from '../actions/user-actions.js';
import genesis from '../facts/genesis.js'; import genesis from '../facts/genesis.js';
import type { import type {
ChatMessageInfoItem, ChatMessageInfoItem,
MessageListData, MessageListData,
ChatMessageItem,
} from '../selectors/chat-selectors.js'; } from '../selectors/chat-selectors.js';
import type { MessageInfo, RawMessageInfo } from '../types/message-types.js'; import type { MessageInfo, RawMessageInfo } from '../types/message-types.js';
import { isComposableMessageType } from '../types/message-types.js';
import type { MinimallyEncodedThreadInfo } from '../types/minimally-encoded-thread-permissions-types.js'; import type { MinimallyEncodedThreadInfo } from '../types/minimally-encoded-thread-permissions-types.js';
import { userRelationshipStatus } from '../types/relationship-types.js'; import { userRelationshipStatus } from '../types/relationship-types.js';
import { threadPermissions } from '../types/thread-permission-types.js'; import { threadPermissions } from '../types/thread-permission-types.js';
import { type ThreadType, threadTypes } from '../types/thread-types-enum.js'; import { type ThreadType, threadTypes } from '../types/thread-types-enum.js';
import { type ThreadInfo } from '../types/thread-types.js'; import { type ThreadInfo } from '../types/thread-types.js';
import type { import type {
AccountUserInfo, AccountUserInfo,
UserListItem, UserListItem,
▲ Show 20 Lines • Show All 97 Lines • ▼ Show 20 Linesfunction getPotentialMemberItems({
const blockedRelationshipsStatuses = new Set([ const blockedRelationshipsStatuses = new Set([
userRelationshipStatus.BLOCKED_BY_VIEWER, userRelationshipStatus.BLOCKED_BY_VIEWER,
userRelationshipStatus.BLOCKED_VIEWER, userRelationshipStatus.BLOCKED_VIEWER,
userRelationshipStatus.BOTH_BLOCKED, userRelationshipStatus.BOTH_BLOCKED,
]); ]);
let userResults = values(results); let userResults = values(results);
if (text === '') { if (text === '') {
userResults = userResults.filter(userInfo => userResults = userResults.filter(userInfo => {
containingThreadInfo if (!containingThreadInfo) {
? userInfo.isMemberOfContainingThread && return userInfo.relationshipStatus === userRelationshipStatus.FRIEND;
!blockedRelationshipsStatuses.has(userInfo.relationshipStatus) }
: userInfo?.relationshipStatus === userRelationshipStatus.FRIEND, if (!userInfo.isMemberOfContainingThread) {
); return false;
}
const { relationshipStatus } = userInfo;
if (!relationshipStatus) {
return true;
}
return !blockedRelationshipsStatuses.has(relationshipStatus);
});
} }
const nonFriends = []; const nonFriends = [];
const blockedUsers = []; const blockedUsers = [];
const friends = []; const friends = [];
const containingThreadMembers = []; const containingThreadMembers = [];
const parentThreadMembers = []; const parentThreadMembers = [];
for (const userResult of userResults) { for (const userResult of userResults) {
const relationshipStatus = userResult.relationshipStatus; const { relationshipStatus } = userResult;
if (blockedRelationshipsStatuses.has(relationshipStatus)) { if (
relationshipStatus &&
blockedRelationshipsStatuses.has(relationshipStatus)
) {
blockedUsers.push(userResult); blockedUsers.push(userResult);
} else if (userResult.isMemberOfParentThread) { } else if (userResult.isMemberOfParentThread) {
parentThreadMembers.push(userResult); parentThreadMembers.push(userResult);
} else if (userResult.isMemberOfContainingThread) { } else if (userResult.isMemberOfContainingThread) {
containingThreadMembers.push(userResult); containingThreadMembers.push(userResult);
} else if (relationshipStatus === userRelationshipStatus.FRIEND) { } else if (relationshipStatus === userRelationshipStatus.FRIEND) {
friends.push(userResult); friends.push(userResult);
} else { } else {
Show All 11 Lines return sortedResults.map(
({ ({
isMemberOfContainingThread, isMemberOfContainingThread,
isMemberOfParentThread, isMemberOfParentThread,
relationshipStatus, relationshipStatus,
...result ...result
}) => { }) => {
let notice, alert; let notice, alert;
const username = result.username; const username = result.username;
if (blockedRelationshipsStatuses.has(relationshipStatus)) { if (
relationshipStatus &&
blockedRelationshipsStatuses.has(relationshipStatus)
) {
notice = 'user is blocked'; notice = 'user is blocked';
alert = { alert = {
title: 'User is blocked', title: 'User is blocked',
text: text:
`Before you add ${username} to this chat, ` + `Before you add ${username} to this chat, ` +
'you’ll need to unblock them. You can do this from the Block List ' + 'you’ll need to unblock them. You can do this from the Block List ' +
'in the Profile tab.', 'in the Profile tab.',
}; };
▲ Show 20 Lines • Show All 114 Lines • ▼ Show 20 Lines
function filterChatMessageInfosForSearch( function filterChatMessageInfosForSearch(
chatMessageInfos: MessageListData, chatMessageInfos: MessageListData,
translatedSearchResults: $ReadOnlyArray<MessageInfo>, translatedSearchResults: $ReadOnlyArray<MessageInfo>,
): ?(ChatMessageInfoItem[]) { ): ?(ChatMessageInfoItem[]) {
if (!chatMessageInfos) { if (!chatMessageInfos) {
return null; return null;
} }
const idSet = new Set(translatedSearchResults.map(item => item.id)); const idSet = new Set(translatedSearchResults.map(messageID));
const chatMessageInfoItems = chatMessageInfos.filter(
item =>
item.messageInfo &&
idSet.has(item.messageInfo.id) &&
isComposableMessageType(item.messageInfo.type),
);
const uniqueChatMessageInfoItemsMap = new Map<string, ChatMessageItem>(); const uniqueChatMessageInfoItemsMap = new Map<string, ChatMessageInfoItem>();
chatMessageInfoItems.forEach( for (const item of chatMessageInfos) {
item => if (item.itemType !== 'message' || item.messageInfoType !== 'composable') {
item.messageInfo && continue;
item.messageInfo.id && }
uniqueChatMessageInfoItemsMap.set(item.messageInfo.id, item), const id = messageID(item.messageInfo);
); if (idSet.has(id)) {
uniqueChatMessageInfoItemsMap.set(id, item);
}
}
const sortedChatMessageInfoItems = []; const sortedChatMessageInfoItems: ChatMessageInfoItem[] = [];
for (let i = 0; i < translatedSearchResults.length; i++) { for (let i = 0; i < translatedSearchResults.length; i++) {
sortedChatMessageInfoItems.push( const id = messageID(translatedSearchResults[i]);
uniqueChatMessageInfoItemsMap.get(translatedSearchResults[i].id), const match = uniqueChatMessageInfoItemsMap.get(id);
); if (match) {
sortedChatMessageInfoItems.push(match);
} }
}
return sortedChatMessageInfoItems.filter(Boolean); return sortedChatMessageInfoItems;
} }
export { export {
getPotentialMemberItems, getPotentialMemberItems,
notFriendNotice, notFriendNotice,
useSearchMessages, useSearchMessages,
useSearchUsers, useSearchUsers,
filterChatMessageInfosForSearch, filterChatMessageInfosForSearch,
}; };
View Options

services/blob/cmake-components/grpc.cmake

// @flow // @flow
import * as React from 'react'; import * as React from 'react';
import { messageID } from './message-utils.js';
import SearchIndex from './search-index.js'; import SearchIndex from './search-index.js';
import { import {
userIsMember, userIsMember,
threadMemberHasPermission, threadMemberHasPermission,
getContainingThreadID, getContainingThreadID,
} from './thread-utils.js'; } from './thread-utils.js';
import { import {
useSearchMessages as useSearchMessagesAction, useSearchMessages as useSearchMessagesAction,
searchMessagesActionTypes, searchMessagesActionTypes,
} from '../actions/message-actions.js'; } from '../actions/message-actions.js';
import { import {
searchUsers, searchUsers,
searchUsersActionTypes, searchUsersActionTypes,
} from '../actions/user-actions.js'; } from '../actions/user-actions.js';
import genesis from '../facts/genesis.js'; import genesis from '../facts/genesis.js';
import type { import type {
ChatMessageInfoItem, ChatMessageInfoItem,
MessageListData, MessageListData,
ChatMessageItem,
} from '../selectors/chat-selectors.js'; } from '../selectors/chat-selectors.js';
import type { MessageInfo, RawMessageInfo } from '../types/message-types.js'; import type { MessageInfo, RawMessageInfo } from '../types/message-types.js';
import { isComposableMessageType } from '../types/message-types.js';
import type { MinimallyEncodedThreadInfo } from '../types/minimally-encoded-thread-permissions-types.js'; import type { MinimallyEncodedThreadInfo } from '../types/minimally-encoded-thread-permissions-types.js';
import { userRelationshipStatus } from '../types/relationship-types.js'; import { userRelationshipStatus } from '../types/relationship-types.js';
import { threadPermissions } from '../types/thread-permission-types.js'; import { threadPermissions } from '../types/thread-permission-types.js';
import { type ThreadType, threadTypes } from '../types/thread-types-enum.js'; import { type ThreadType, threadTypes } from '../types/thread-types-enum.js';
import { type ThreadInfo } from '../types/thread-types.js'; import { type ThreadInfo } from '../types/thread-types.js';
import type { import type {
AccountUserInfo, AccountUserInfo,
UserListItem, UserListItem,
▲ Show 20 Lines • Show All 97 Lines • ▼ Show 20 Linesfunction getPotentialMemberItems({
const blockedRelationshipsStatuses = new Set([ const blockedRelationshipsStatuses = new Set([
userRelationshipStatus.BLOCKED_BY_VIEWER, userRelationshipStatus.BLOCKED_BY_VIEWER,
userRelationshipStatus.BLOCKED_VIEWER, userRelationshipStatus.BLOCKED_VIEWER,
userRelationshipStatus.BOTH_BLOCKED, userRelationshipStatus.BOTH_BLOCKED,
]); ]);
let userResults = values(results); let userResults = values(results);
if (text === '') { if (text === '') {
userResults = userResults.filter(userInfo => userResults = userResults.filter(userInfo => {
containingThreadInfo if (!containingThreadInfo) {
? userInfo.isMemberOfContainingThread && return userInfo.relationshipStatus === userRelationshipStatus.FRIEND;
!blockedRelationshipsStatuses.has(userInfo.relationshipStatus) }
: userInfo?.relationshipStatus === userRelationshipStatus.FRIEND, if (!userInfo.isMemberOfContainingThread) {
); return false;
}
const { relationshipStatus } = userInfo;
if (!relationshipStatus) {
return true;
}
return !blockedRelationshipsStatuses.has(relationshipStatus);
});
} }
const nonFriends = []; const nonFriends = [];
const blockedUsers = []; const blockedUsers = [];
const friends = []; const friends = [];
const containingThreadMembers = []; const containingThreadMembers = [];
const parentThreadMembers = []; const parentThreadMembers = [];
for (const userResult of userResults) { for (const userResult of userResults) {
const relationshipStatus = userResult.relationshipStatus; const { relationshipStatus } = userResult;
if (blockedRelationshipsStatuses.has(relationshipStatus)) { if (
relationshipStatus &&
blockedRelationshipsStatuses.has(relationshipStatus)
) {
blockedUsers.push(userResult); blockedUsers.push(userResult);
} else if (userResult.isMemberOfParentThread) { } else if (userResult.isMemberOfParentThread) {
parentThreadMembers.push(userResult); parentThreadMembers.push(userResult);
} else if (userResult.isMemberOfContainingThread) { } else if (userResult.isMemberOfContainingThread) {
containingThreadMembers.push(userResult); containingThreadMembers.push(userResult);
} else if (relationshipStatus === userRelationshipStatus.FRIEND) { } else if (relationshipStatus === userRelationshipStatus.FRIEND) {
friends.push(userResult); friends.push(userResult);
} else { } else {
Show All 11 Lines return sortedResults.map(
({ ({
isMemberOfContainingThread, isMemberOfContainingThread,
isMemberOfParentThread, isMemberOfParentThread,
relationshipStatus, relationshipStatus,
...result ...result
}) => { }) => {
let notice, alert; let notice, alert;
const username = result.username; const username = result.username;
if (blockedRelationshipsStatuses.has(relationshipStatus)) { if (
relationshipStatus &&
blockedRelationshipsStatuses.has(relationshipStatus)
) {
notice = 'user is blocked'; notice = 'user is blocked';
alert = { alert = {
title: 'User is blocked', title: 'User is blocked',
text: text:
`Before you add ${username} to this chat, ` + `Before you add ${username} to this chat, ` +
'you’ll need to unblock them. You can do this from the Block List ' + 'you’ll need to unblock them. You can do this from the Block List ' +
'in the Profile tab.', 'in the Profile tab.',
}; };
▲ Show 20 Lines • Show All 114 Lines • ▼ Show 20 Lines
function filterChatMessageInfosForSearch( function filterChatMessageInfosForSearch(
chatMessageInfos: MessageListData, chatMessageInfos: MessageListData,
translatedSearchResults: $ReadOnlyArray<MessageInfo>, translatedSearchResults: $ReadOnlyArray<MessageInfo>,
): ?(ChatMessageInfoItem[]) { ): ?(ChatMessageInfoItem[]) {
if (!chatMessageInfos) { if (!chatMessageInfos) {
return null; return null;
} }
const idSet = new Set(translatedSearchResults.map(item => item.id)); const idSet = new Set(translatedSearchResults.map(messageID));
const chatMessageInfoItems = chatMessageInfos.filter(
item =>
item.messageInfo &&
idSet.has(item.messageInfo.id) &&
isComposableMessageType(item.messageInfo.type),
);
const uniqueChatMessageInfoItemsMap = new Map<string, ChatMessageItem>(); const uniqueChatMessageInfoItemsMap = new Map<string, ChatMessageInfoItem>();
chatMessageInfoItems.forEach( for (const item of chatMessageInfos) {
item => if (item.itemType !== 'message' || item.messageInfoType !== 'composable') {
item.messageInfo && continue;
item.messageInfo.id && }
uniqueChatMessageInfoItemsMap.set(item.messageInfo.id, item), const id = messageID(item.messageInfo);
); if (idSet.has(id)) {
uniqueChatMessageInfoItemsMap.set(id, item);
}
}
const sortedChatMessageInfoItems = []; const sortedChatMessageInfoItems: ChatMessageInfoItem[] = [];
for (let i = 0; i < translatedSearchResults.length; i++) { for (let i = 0; i < translatedSearchResults.length; i++) {
sortedChatMessageInfoItems.push( const id = messageID(translatedSearchResults[i]);
uniqueChatMessageInfoItemsMap.get(translatedSearchResults[i].id), const match = uniqueChatMessageInfoItemsMap.get(id);
); if (match) {
sortedChatMessageInfoItems.push(match);
} }
}
return sortedChatMessageInfoItems.filter(Boolean); return sortedChatMessageInfoItems;
} }
export { export {
getPotentialMemberItems, getPotentialMemberItems,
notFriendNotice, notFriendNotice,
useSearchMessages, useSearchMessages,
useSearchUsers, useSearchUsers,
filterChatMessageInfosForSearch, filterChatMessageInfosForSearch,
}; };
View Options

services/lib/cmake-components/folly.cmake

Loading...
View Options

services/lib/cmake-components/grpc.cmake

Loading...