Page MenuHomePhabricator
Differential D9911

[SQLite] implement C++ code to get users
ClosedPublic
Actions

Authored by kamil on Nov 16 2023, 6:35 AM.
Tags
None
Referenced Files
Unknown Object (File)
Mon, Mar 17, 8:07 PM
Unknown Object (File)
Mon, Mar 17, 8:07 PM
Unknown Object (File)
Mon, Mar 17, 8:07 PM
Unknown Object (File)
Mon, Mar 17, 8:06 PM
Unknown Object (File)
Mon, Mar 17, 8:00 PM
Unknown Object (File)
Mon, Mar 10, 4:34 PM
Unknown Object (File)
Wed, Mar 5, 12:37 PM
Unknown Object (File)
Feb 21 2025, 5:42 AM
View All 80 Files
Subscribers
ashoat

Details

Reviewers
tomek
Commits
rCOMM17ac5aa279aa: [SQLite] implement C++ code to get users
Summary

Code for native ops

Depends on D9910

Test Plan

Code for testing:

const { users } = await commCoreModule.getClientDBStore();
console.log(users);
await commCoreModule.processUserStoreOperations([
  {
    type: 'replace_user',
    payload: {
      id: '1',
      userInfo: 'test',
    },
  },
  {
    type: 'replace_user',
    payload: {
      id: '2',
      userInfo: 'test',
    },
  },
]);

const { users: users2 } = await commCoreModule.getClientDBStore();
console.log(users2);

await commCoreModule.processUserStoreOperations([
  {
    type: 'replace_user',
    payload: {
      id: '2',
      userInfo: 'test',
    },
  },
]);

const { users: users3 } = await commCoreModule.getClientDBStore();
console.log(users3);

await commCoreModule.processUserStoreOperations([
  {
    type: 'remove_users',
    payload: {
      ids: ['1'],
    },
  },
]);

const { users: users4 } = await commCoreModule.getClientDBStore();
console.log(users4);

await commCoreModule.processUserStoreOperations([
  {
    type: 'remove_all_users',
  },
]);

const { users: users5 } = await commCoreModule.getClientDBStore();
console.log(users5);

Diff Detail

Repository
rCOMM Comm
Lint
Lint Not Applicable
Unit
Tests Not Applicable

Revision Contents
Changeset List

PathSize
lib/
types/
6 lines
native/
cpp/
CommonCpp/
NativeModules/
11 lines
PersistentStorageUtilities/
DataStores/
10 lines
web/
database/
worker/
1 line

Diff 33422

View Options

lib/types/store-ops-types.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

native/cpp/CommonCpp/NativeModules/CommCoreModule.cpp

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

native/cpp/CommonCpp/NativeModules/PersistentStorageUtilities/DataStores/UserStore.cpp

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/database/worker/process-operations.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