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

[native] start processing user store ops on SQLiteClosedPublicActions

Details

Diff Detail

Event Timeline

Revision ContentsChangeset List

Diff 33425

native/redux/redux-utils.js

[native] start processing user store ops on SQLite
ClosedPublic
Actions

Revision Contents
Changeset List