Page MenuHomePhabricator
Differential D9732

[lib][web][native] Refactor sessionIDSelector
ClosedPublic
Actions

Authored by inka on Nov 6 2023, 9:26 AM.
Tags
None
Referenced Files
Unknown Object (File)
Thu, Mar 6, 5:03 PM
Unknown Object (File)
Sat, Mar 1, 7:35 AM
Unknown Object (File)
Sat, Mar 1, 7:35 AM
Unknown Object (File)
Sat, Mar 1, 7:35 AM
Unknown Object (File)
Sat, Mar 1, 7:29 AM
Unknown Object (File)
Feb 3 2025, 4:00 PM
Unknown Object (File)
Feb 3 2025, 4:00 PM
Unknown Object (File)
Feb 3 2025, 3:58 PM
View All 67 Files
Subscribers
ashoat
tomek
will

Details

Reviewers
michal
kamil
ginsu
Commits
rCOMMaa4a1a089ce0: [lib][web][native] Refactor sessionIDSelector
Summary

issue: https://linear.app/comm/issue/ENG-5004/refactor-sessionidselector

Test Plan

Tested that the refactored selectors work

Diff Detail

Repository
rCOMM Comm
Lint
Lint Not Applicable
Unit
Tests Not Applicable

Revision Contents
Changeset List

PathSize
lib/
selectors/
3 lines
9 lines
2 lines
shared/
2 lines
web/
selectors/
23 lines
4 lines

Diff 32997

View Options

lib/selectors/account-selectors.js

Show First 20 Lines • Show All 64 Lines • ▼ Show 20 Lines createSelector(stateSyncSpecSelectors, (...specs) => {
return { specsPerHashKey, specPerInnerHashKey }; return { specsPerHashKey, specPerInnerHashKey };
}); });
const getClientResponsesSelector: ( const getClientResponsesSelector: (
state: AppState, state: AppState,
) => ( ) => (
calendarActive: boolean, calendarActive: boolean,
oneTimeKeyGenerator: ?OneTimeKeyGenerator, oneTimeKeyGenerator: ?OneTimeKeyGenerator,
getSignedIdentityKeysBlob: ?() => Promise<SignedIdentityKeysBlob>, getSignedIdentityKeysBlob: () => Promise<SignedIdentityKeysBlob>,
getInitialNotificationsEncryptedMessage: ?() => Promise<string>, getInitialNotificationsEncryptedMessage: ?() => Promise<string>,
serverRequests: $ReadOnlyArray<ClientServerRequest>, serverRequests: $ReadOnlyArray<ClientServerRequest>,
) => Promise<$ReadOnlyArray<ClientClientResponse>> = createSelector( ) => Promise<$ReadOnlyArray<ClientClientResponse>> = createSelector(
boundStateSyncSpecsSelector, boundStateSyncSpecsSelector,
currentCalendarQuery, currentCalendarQuery,
( (
{ specsPerHashKey, specPerInnerHashKey }, { specsPerHashKey, specPerInnerHashKey },
calendarQuery: (calendarActive: boolean) => CalendarQuery, calendarQuery: (calendarActive: boolean) => CalendarQuery,
) => { ) => {
return async ( return async (
calendarActive: boolean, calendarActive: boolean,
oneTimeKeyGenerator: ?OneTimeKeyGenerator, oneTimeKeyGenerator: ?OneTimeKeyGenerator,
getSignedIdentityKeysBlob: ?() => Promise<SignedIdentityKeysBlob>, getSignedIdentityKeysBlob: () => Promise<SignedIdentityKeysBlob>,
getInitialNotificationsEncryptedMessage: ?() => Promise<string>, getInitialNotificationsEncryptedMessage: ?() => Promise<string>,
serverRequests: $ReadOnlyArray<ClientServerRequest>, serverRequests: $ReadOnlyArray<ClientServerRequest>,
): Promise<$ReadOnlyArray<ClientClientResponse>> => { ): Promise<$ReadOnlyArray<ClientClientResponse>> => {
const clientResponses = []; const clientResponses = [];
const serverRequestedPlatformDetails = serverRequests.some( const serverRequestedPlatformDetails = serverRequests.some(
request => request.type === serverRequestTypes.PLATFORM_DETAILS, request => request.type === serverRequestTypes.PLATFORM_DETAILS,
); );
for (const serverRequest of serverRequests) { for (const serverRequest of serverRequests) {
▲ Show 20 Lines • Show All 68 Lines • ▼ Show 20 Lines ): Promise<$ReadOnlyArray<ClientClientResponse>> => {
for (let i = 0; i < minimumOneTimeKeysRequired; ++i) { for (let i = 0; i < minimumOneTimeKeysRequired; ++i) {
keys.push(oneTimeKeyGenerator(i)); keys.push(oneTimeKeyGenerator(i));
} }
clientResponses.push({ clientResponses.push({
type: serverRequestTypes.MORE_ONE_TIME_KEYS, type: serverRequestTypes.MORE_ONE_TIME_KEYS,
keys, keys,
}); });
} else if ( } else if (
serverRequest.type === serverRequestTypes.SIGNED_IDENTITY_KEYS_BLOB && serverRequest.type === serverRequestTypes.SIGNED_IDENTITY_KEYS_BLOB
getSignedIdentityKeysBlob
) { ) {
const signedIdentityKeysBlob = await getSignedIdentityKeysBlob(); const signedIdentityKeysBlob = await getSignedIdentityKeysBlob();
clientResponses.push({ clientResponses.push({
type: serverRequestTypes.SIGNED_IDENTITY_KEYS_BLOB, type: serverRequestTypes.SIGNED_IDENTITY_KEYS_BLOB,
signedIdentityKeysBlob, signedIdentityKeysBlob,
}); });
} else if ( } else if (
serverRequest.type === serverRequest.type ===
▲ Show 20 Lines • Show All 45 Lines • Show Last 20 Lines
View Options

lib/selectors/keyserver-selectors.js

Show First 20 Lines • Show All 64 Lines • ▼ Show 20 Lines createSelector(stateSyncSpecSelectors, (...specs) => {
return { specsPerHashKey, specPerInnerHashKey }; return { specsPerHashKey, specPerInnerHashKey };
}); });
const getClientResponsesSelector: ( const getClientResponsesSelector: (
state: AppState, state: AppState,
) => ( ) => (
calendarActive: boolean, calendarActive: boolean,
oneTimeKeyGenerator: ?OneTimeKeyGenerator, oneTimeKeyGenerator: ?OneTimeKeyGenerator,
getSignedIdentityKeysBlob: ?() => Promise<SignedIdentityKeysBlob>, getSignedIdentityKeysBlob: () => Promise<SignedIdentityKeysBlob>,
getInitialNotificationsEncryptedMessage: ?() => Promise<string>, getInitialNotificationsEncryptedMessage: ?() => Promise<string>,
serverRequests: $ReadOnlyArray<ClientServerRequest>, serverRequests: $ReadOnlyArray<ClientServerRequest>,
) => Promise<$ReadOnlyArray<ClientClientResponse>> = createSelector( ) => Promise<$ReadOnlyArray<ClientClientResponse>> = createSelector(
boundStateSyncSpecsSelector, boundStateSyncSpecsSelector,
currentCalendarQuery, currentCalendarQuery,
( (
{ specsPerHashKey, specPerInnerHashKey }, { specsPerHashKey, specPerInnerHashKey },
calendarQuery: (calendarActive: boolean) => CalendarQuery, calendarQuery: (calendarActive: boolean) => CalendarQuery,
) => { ) => {
return async ( return async (
calendarActive: boolean, calendarActive: boolean,
oneTimeKeyGenerator: ?OneTimeKeyGenerator, oneTimeKeyGenerator: ?OneTimeKeyGenerator,
getSignedIdentityKeysBlob: ?() => Promise<SignedIdentityKeysBlob>, getSignedIdentityKeysBlob: () => Promise<SignedIdentityKeysBlob>,
getInitialNotificationsEncryptedMessage: ?() => Promise<string>, getInitialNotificationsEncryptedMessage: ?() => Promise<string>,
serverRequests: $ReadOnlyArray<ClientServerRequest>, serverRequests: $ReadOnlyArray<ClientServerRequest>,
): Promise<$ReadOnlyArray<ClientClientResponse>> => { ): Promise<$ReadOnlyArray<ClientClientResponse>> => {
const clientResponses = []; const clientResponses = [];
const serverRequestedPlatformDetails = serverRequests.some( const serverRequestedPlatformDetails = serverRequests.some(
request => request.type === serverRequestTypes.PLATFORM_DETAILS, request => request.type === serverRequestTypes.PLATFORM_DETAILS,
); );
for (const serverRequest of serverRequests) { for (const serverRequest of serverRequests) {
▲ Show 20 Lines • Show All 68 Lines • ▼ Show 20 Lines ): Promise<$ReadOnlyArray<ClientClientResponse>> => {
for (let i = 0; i < minimumOneTimeKeysRequired; ++i) { for (let i = 0; i < minimumOneTimeKeysRequired; ++i) {
keys.push(oneTimeKeyGenerator(i)); keys.push(oneTimeKeyGenerator(i));
} }
clientResponses.push({ clientResponses.push({
type: serverRequestTypes.MORE_ONE_TIME_KEYS, type: serverRequestTypes.MORE_ONE_TIME_KEYS,
keys, keys,
}); });
} else if ( } else if (
serverRequest.type === serverRequestTypes.SIGNED_IDENTITY_KEYS_BLOB && serverRequest.type === serverRequestTypes.SIGNED_IDENTITY_KEYS_BLOB
getSignedIdentityKeysBlob
) { ) {
const signedIdentityKeysBlob = await getSignedIdentityKeysBlob(); const signedIdentityKeysBlob = await getSignedIdentityKeysBlob();
clientResponses.push({ clientResponses.push({
type: serverRequestTypes.SIGNED_IDENTITY_KEYS_BLOB, type: serverRequestTypes.SIGNED_IDENTITY_KEYS_BLOB,
signedIdentityKeysBlob, signedIdentityKeysBlob,
}); });
} else if ( } else if (
serverRequest.type === serverRequest.type ===
▲ Show 20 Lines • Show All 45 Lines • Show Last 20 Lines
View Options

lib/selectors/server-calls.js

Show First 20 Lines • Show All 64 Lines • ▼ Show 20 Lines createSelector(stateSyncSpecSelectors, (...specs) => {
return { specsPerHashKey, specPerInnerHashKey }; return { specsPerHashKey, specPerInnerHashKey };
}); });
const getClientResponsesSelector: ( const getClientResponsesSelector: (
state: AppState, state: AppState,
) => ( ) => (
calendarActive: boolean, calendarActive: boolean,
oneTimeKeyGenerator: ?OneTimeKeyGenerator, oneTimeKeyGenerator: ?OneTimeKeyGenerator,
getSignedIdentityKeysBlob: ?() => Promise<SignedIdentityKeysBlob>, getSignedIdentityKeysBlob: () => Promise<SignedIdentityKeysBlob>,
getInitialNotificationsEncryptedMessage: ?() => Promise<string>, getInitialNotificationsEncryptedMessage: ?() => Promise<string>,
serverRequests: $ReadOnlyArray<ClientServerRequest>, serverRequests: $ReadOnlyArray<ClientServerRequest>,
) => Promise<$ReadOnlyArray<ClientClientResponse>> = createSelector( ) => Promise<$ReadOnlyArray<ClientClientResponse>> = createSelector(
boundStateSyncSpecsSelector, boundStateSyncSpecsSelector,
currentCalendarQuery, currentCalendarQuery,
( (
{ specsPerHashKey, specPerInnerHashKey }, { specsPerHashKey, specPerInnerHashKey },
calendarQuery: (calendarActive: boolean) => CalendarQuery, calendarQuery: (calendarActive: boolean) => CalendarQuery,
) => { ) => {
return async ( return async (
calendarActive: boolean, calendarActive: boolean,
oneTimeKeyGenerator: ?OneTimeKeyGenerator, oneTimeKeyGenerator: ?OneTimeKeyGenerator,
getSignedIdentityKeysBlob: ?() => Promise<SignedIdentityKeysBlob>, getSignedIdentityKeysBlob: () => Promise<SignedIdentityKeysBlob>,
getInitialNotificationsEncryptedMessage: ?() => Promise<string>, getInitialNotificationsEncryptedMessage: ?() => Promise<string>,
serverRequests: $ReadOnlyArray<ClientServerRequest>, serverRequests: $ReadOnlyArray<ClientServerRequest>,
): Promise<$ReadOnlyArray<ClientClientResponse>> => { ): Promise<$ReadOnlyArray<ClientClientResponse>> => {
const clientResponses = []; const clientResponses = [];
const serverRequestedPlatformDetails = serverRequests.some( const serverRequestedPlatformDetails = serverRequests.some(
request => request.type === serverRequestTypes.PLATFORM_DETAILS, request => request.type === serverRequestTypes.PLATFORM_DETAILS,
); );
for (const serverRequest of serverRequests) { for (const serverRequest of serverRequests) {
▲ Show 20 Lines • Show All 68 Lines • ▼ Show 20 Lines ): Promise<$ReadOnlyArray<ClientClientResponse>> => {
for (let i = 0; i < minimumOneTimeKeysRequired; ++i) { for (let i = 0; i < minimumOneTimeKeysRequired; ++i) {
keys.push(oneTimeKeyGenerator(i)); keys.push(oneTimeKeyGenerator(i));
} }
clientResponses.push({ clientResponses.push({
type: serverRequestTypes.MORE_ONE_TIME_KEYS, type: serverRequestTypes.MORE_ONE_TIME_KEYS,
keys, keys,
}); });
} else if ( } else if (
serverRequest.type === serverRequestTypes.SIGNED_IDENTITY_KEYS_BLOB && serverRequest.type === serverRequestTypes.SIGNED_IDENTITY_KEYS_BLOB
getSignedIdentityKeysBlob
) { ) {
const signedIdentityKeysBlob = await getSignedIdentityKeysBlob(); const signedIdentityKeysBlob = await getSignedIdentityKeysBlob();
clientResponses.push({ clientResponses.push({
type: serverRequestTypes.SIGNED_IDENTITY_KEYS_BLOB, type: serverRequestTypes.SIGNED_IDENTITY_KEYS_BLOB,
signedIdentityKeysBlob, signedIdentityKeysBlob,
}); });
} else if ( } else if (
serverRequest.type === serverRequest.type ===
▲ Show 20 Lines • Show All 45 Lines • Show Last 20 Lines
View Options

lib/shared/session-utils.js

Show First 20 Lines • Show All 64 Lines • ▼ Show 20 Lines createSelector(stateSyncSpecSelectors, (...specs) => {
return { specsPerHashKey, specPerInnerHashKey }; return { specsPerHashKey, specPerInnerHashKey };
}); });
const getClientResponsesSelector: ( const getClientResponsesSelector: (
state: AppState, state: AppState,
) => ( ) => (
calendarActive: boolean, calendarActive: boolean,
oneTimeKeyGenerator: ?OneTimeKeyGenerator, oneTimeKeyGenerator: ?OneTimeKeyGenerator,
getSignedIdentityKeysBlob: ?() => Promise<SignedIdentityKeysBlob>, getSignedIdentityKeysBlob: () => Promise<SignedIdentityKeysBlob>,
getInitialNotificationsEncryptedMessage: ?() => Promise<string>, getInitialNotificationsEncryptedMessage: ?() => Promise<string>,
serverRequests: $ReadOnlyArray<ClientServerRequest>, serverRequests: $ReadOnlyArray<ClientServerRequest>,
) => Promise<$ReadOnlyArray<ClientClientResponse>> = createSelector( ) => Promise<$ReadOnlyArray<ClientClientResponse>> = createSelector(
boundStateSyncSpecsSelector, boundStateSyncSpecsSelector,
currentCalendarQuery, currentCalendarQuery,
( (
{ specsPerHashKey, specPerInnerHashKey }, { specsPerHashKey, specPerInnerHashKey },
calendarQuery: (calendarActive: boolean) => CalendarQuery, calendarQuery: (calendarActive: boolean) => CalendarQuery,
) => { ) => {
return async ( return async (
calendarActive: boolean, calendarActive: boolean,
oneTimeKeyGenerator: ?OneTimeKeyGenerator, oneTimeKeyGenerator: ?OneTimeKeyGenerator,
getSignedIdentityKeysBlob: ?() => Promise<SignedIdentityKeysBlob>, getSignedIdentityKeysBlob: () => Promise<SignedIdentityKeysBlob>,
getInitialNotificationsEncryptedMessage: ?() => Promise<string>, getInitialNotificationsEncryptedMessage: ?() => Promise<string>,
serverRequests: $ReadOnlyArray<ClientServerRequest>, serverRequests: $ReadOnlyArray<ClientServerRequest>,
): Promise<$ReadOnlyArray<ClientClientResponse>> => { ): Promise<$ReadOnlyArray<ClientClientResponse>> => {
const clientResponses = []; const clientResponses = [];
const serverRequestedPlatformDetails = serverRequests.some( const serverRequestedPlatformDetails = serverRequests.some(
request => request.type === serverRequestTypes.PLATFORM_DETAILS, request => request.type === serverRequestTypes.PLATFORM_DETAILS,
); );
for (const serverRequest of serverRequests) { for (const serverRequest of serverRequests) {
▲ Show 20 Lines • Show All 68 Lines • ▼ Show 20 Lines ): Promise<$ReadOnlyArray<ClientClientResponse>> => {
for (let i = 0; i < minimumOneTimeKeysRequired; ++i) { for (let i = 0; i < minimumOneTimeKeysRequired; ++i) {
keys.push(oneTimeKeyGenerator(i)); keys.push(oneTimeKeyGenerator(i));
} }
clientResponses.push({ clientResponses.push({
type: serverRequestTypes.MORE_ONE_TIME_KEYS, type: serverRequestTypes.MORE_ONE_TIME_KEYS,
keys, keys,
}); });
} else if ( } else if (
serverRequest.type === serverRequestTypes.SIGNED_IDENTITY_KEYS_BLOB && serverRequest.type === serverRequestTypes.SIGNED_IDENTITY_KEYS_BLOB
getSignedIdentityKeysBlob
) { ) {
const signedIdentityKeysBlob = await getSignedIdentityKeysBlob(); const signedIdentityKeysBlob = await getSignedIdentityKeysBlob();
clientResponses.push({ clientResponses.push({
type: serverRequestTypes.SIGNED_IDENTITY_KEYS_BLOB, type: serverRequestTypes.SIGNED_IDENTITY_KEYS_BLOB,
signedIdentityKeysBlob, signedIdentityKeysBlob,
}); });
} else if ( } else if (
serverRequest.type === serverRequest.type ===
▲ Show 20 Lines • Show All 45 Lines • Show Last 20 Lines
View Options

web/selectors/socket-selectors.js

Show First 20 Lines • Show All 64 Lines • ▼ Show 20 Lines createSelector(stateSyncSpecSelectors, (...specs) => {
return { specsPerHashKey, specPerInnerHashKey }; return { specsPerHashKey, specPerInnerHashKey };
}); });
const getClientResponsesSelector: ( const getClientResponsesSelector: (
state: AppState, state: AppState,
) => ( ) => (
calendarActive: boolean, calendarActive: boolean,
oneTimeKeyGenerator: ?OneTimeKeyGenerator, oneTimeKeyGenerator: ?OneTimeKeyGenerator,
getSignedIdentityKeysBlob: ?() => Promise<SignedIdentityKeysBlob>, getSignedIdentityKeysBlob: () => Promise<SignedIdentityKeysBlob>,
getInitialNotificationsEncryptedMessage: ?() => Promise<string>, getInitialNotificationsEncryptedMessage: ?() => Promise<string>,
serverRequests: $ReadOnlyArray<ClientServerRequest>, serverRequests: $ReadOnlyArray<ClientServerRequest>,
) => Promise<$ReadOnlyArray<ClientClientResponse>> = createSelector( ) => Promise<$ReadOnlyArray<ClientClientResponse>> = createSelector(
boundStateSyncSpecsSelector, boundStateSyncSpecsSelector,
currentCalendarQuery, currentCalendarQuery,
( (
{ specsPerHashKey, specPerInnerHashKey }, { specsPerHashKey, specPerInnerHashKey },
calendarQuery: (calendarActive: boolean) => CalendarQuery, calendarQuery: (calendarActive: boolean) => CalendarQuery,
) => { ) => {
return async ( return async (
calendarActive: boolean, calendarActive: boolean,
oneTimeKeyGenerator: ?OneTimeKeyGenerator, oneTimeKeyGenerator: ?OneTimeKeyGenerator,
getSignedIdentityKeysBlob: ?() => Promise<SignedIdentityKeysBlob>, getSignedIdentityKeysBlob: () => Promise<SignedIdentityKeysBlob>,
getInitialNotificationsEncryptedMessage: ?() => Promise<string>, getInitialNotificationsEncryptedMessage: ?() => Promise<string>,
serverRequests: $ReadOnlyArray<ClientServerRequest>, serverRequests: $ReadOnlyArray<ClientServerRequest>,
): Promise<$ReadOnlyArray<ClientClientResponse>> => { ): Promise<$ReadOnlyArray<ClientClientResponse>> => {
const clientResponses = []; const clientResponses = [];
const serverRequestedPlatformDetails = serverRequests.some( const serverRequestedPlatformDetails = serverRequests.some(
request => request.type === serverRequestTypes.PLATFORM_DETAILS, request => request.type === serverRequestTypes.PLATFORM_DETAILS,
); );
for (const serverRequest of serverRequests) { for (const serverRequest of serverRequests) {
▲ Show 20 Lines • Show All 68 Lines • ▼ Show 20 Lines ): Promise<$ReadOnlyArray<ClientClientResponse>> => {
for (let i = 0; i < minimumOneTimeKeysRequired; ++i) { for (let i = 0; i < minimumOneTimeKeysRequired; ++i) {
keys.push(oneTimeKeyGenerator(i)); keys.push(oneTimeKeyGenerator(i));
} }
clientResponses.push({ clientResponses.push({
type: serverRequestTypes.MORE_ONE_TIME_KEYS, type: serverRequestTypes.MORE_ONE_TIME_KEYS,
keys, keys,
}); });
} else if ( } else if (
serverRequest.type === serverRequestTypes.SIGNED_IDENTITY_KEYS_BLOB && serverRequest.type === serverRequestTypes.SIGNED_IDENTITY_KEYS_BLOB
getSignedIdentityKeysBlob
) { ) {
const signedIdentityKeysBlob = await getSignedIdentityKeysBlob(); const signedIdentityKeysBlob = await getSignedIdentityKeysBlob();
clientResponses.push({ clientResponses.push({
type: serverRequestTypes.SIGNED_IDENTITY_KEYS_BLOB, type: serverRequestTypes.SIGNED_IDENTITY_KEYS_BLOB,
signedIdentityKeysBlob, signedIdentityKeysBlob,
}); });
} else if ( } else if (
serverRequest.type === serverRequest.type ===
▲ Show 20 Lines • Show All 45 Lines • Show Last 20 Lines
View Options

web/socket.react.js

Show First 20 Lines • Show All 64 Lines • ▼ Show 20 Lines createSelector(stateSyncSpecSelectors, (...specs) => {
return { specsPerHashKey, specPerInnerHashKey }; return { specsPerHashKey, specPerInnerHashKey };
}); });
const getClientResponsesSelector: ( const getClientResponsesSelector: (
state: AppState, state: AppState,
) => ( ) => (
calendarActive: boolean, calendarActive: boolean,
oneTimeKeyGenerator: ?OneTimeKeyGenerator, oneTimeKeyGenerator: ?OneTimeKeyGenerator,
getSignedIdentityKeysBlob: ?() => Promise<SignedIdentityKeysBlob>, getSignedIdentityKeysBlob: () => Promise<SignedIdentityKeysBlob>,
getInitialNotificationsEncryptedMessage: ?() => Promise<string>, getInitialNotificationsEncryptedMessage: ?() => Promise<string>,
serverRequests: $ReadOnlyArray<ClientServerRequest>, serverRequests: $ReadOnlyArray<ClientServerRequest>,
) => Promise<$ReadOnlyArray<ClientClientResponse>> = createSelector( ) => Promise<$ReadOnlyArray<ClientClientResponse>> = createSelector(
boundStateSyncSpecsSelector, boundStateSyncSpecsSelector,
currentCalendarQuery, currentCalendarQuery,
( (
{ specsPerHashKey, specPerInnerHashKey }, { specsPerHashKey, specPerInnerHashKey },
calendarQuery: (calendarActive: boolean) => CalendarQuery, calendarQuery: (calendarActive: boolean) => CalendarQuery,
) => { ) => {
return async ( return async (
calendarActive: boolean, calendarActive: boolean,
oneTimeKeyGenerator: ?OneTimeKeyGenerator, oneTimeKeyGenerator: ?OneTimeKeyGenerator,
getSignedIdentityKeysBlob: ?() => Promise<SignedIdentityKeysBlob>, getSignedIdentityKeysBlob: () => Promise<SignedIdentityKeysBlob>,
getInitialNotificationsEncryptedMessage: ?() => Promise<string>, getInitialNotificationsEncryptedMessage: ?() => Promise<string>,
serverRequests: $ReadOnlyArray<ClientServerRequest>, serverRequests: $ReadOnlyArray<ClientServerRequest>,
): Promise<$ReadOnlyArray<ClientClientResponse>> => { ): Promise<$ReadOnlyArray<ClientClientResponse>> => {
const clientResponses = []; const clientResponses = [];
const serverRequestedPlatformDetails = serverRequests.some( const serverRequestedPlatformDetails = serverRequests.some(
request => request.type === serverRequestTypes.PLATFORM_DETAILS, request => request.type === serverRequestTypes.PLATFORM_DETAILS,
); );
for (const serverRequest of serverRequests) { for (const serverRequest of serverRequests) {
▲ Show 20 Lines • Show All 68 Lines • ▼ Show 20 Lines ): Promise<$ReadOnlyArray<ClientClientResponse>> => {
for (let i = 0; i < minimumOneTimeKeysRequired; ++i) { for (let i = 0; i < minimumOneTimeKeysRequired; ++i) {
keys.push(oneTimeKeyGenerator(i)); keys.push(oneTimeKeyGenerator(i));
} }
clientResponses.push({ clientResponses.push({
type: serverRequestTypes.MORE_ONE_TIME_KEYS, type: serverRequestTypes.MORE_ONE_TIME_KEYS,
keys, keys,
}); });
} else if ( } else if (
serverRequest.type === serverRequestTypes.SIGNED_IDENTITY_KEYS_BLOB && serverRequest.type === serverRequestTypes.SIGNED_IDENTITY_KEYS_BLOB
getSignedIdentityKeysBlob
) { ) {
const signedIdentityKeysBlob = await getSignedIdentityKeysBlob(); const signedIdentityKeysBlob = await getSignedIdentityKeysBlob();
clientResponses.push({ clientResponses.push({
type: serverRequestTypes.SIGNED_IDENTITY_KEYS_BLOB, type: serverRequestTypes.SIGNED_IDENTITY_KEYS_BLOB,
signedIdentityKeysBlob, signedIdentityKeysBlob,
}); });
} else if ( } else if (
serverRequest.type === serverRequest.type ===
▲ Show 20 Lines • Show All 45 Lines • Show Last 20 Lines