Page MenuHomePhabricator
Files F3723932

D11070.id.diff
No OneTemporary
Actions

D11070.id.diff
View Options

diff --git a/lib/ops/community-store-ops.js b/lib/ops/community-store-ops.js
new file mode 100644
--- /dev/null
+++ b/lib/ops/community-store-ops.js
@@ -0,0 +1,113 @@
+// @flow
+
+import type { BaseStoreOpsHandlers } from './base-ops.js';
+import type {
+ CommunityInfo,
+ CommunityInfos,
+ CommunityStore,
+} from '../types/community-types.js';
+
+// client types
+export type ReplaceCommunityOperation = {
+ +type: 'replace_community',
+ +payload: { +id: string, +communityInfo: CommunityInfo },
+};
+
+export type RemoveCommunitiesOperation = {
+ +type: 'remove_communities',
+ +payload: { +ids: $ReadOnlyArray<string> },
+};
+
+export type RemoveAllCommunitiesOperation = {
+ +type: 'remove_all_communities',
+};
+
+export type CommunityStoreOperation =
+ | ReplaceCommunityOperation
+ | RemoveCommunitiesOperation
+ | RemoveAllCommunitiesOperation;
+
+// SQLite types
+export type ClientDBCommunityInfo = {
+ +id: string,
+ +communityInfo: string,
+};
+
+export type ClientDBReplaceCommunityOperation = {
+ +type: 'replace_community',
+ +payload: ClientDBCommunityInfo,
+};
+
+export type ClientDBCommunityStoreOperation =
+ | ClientDBReplaceCommunityOperation
+ | RemoveCommunitiesOperation
+ | RemoveAllCommunitiesOperation;
+
+const communityStoreOpsHandlers: BaseStoreOpsHandlers<
+ CommunityStore,
+ CommunityStoreOperation,
+ ClientDBCommunityStoreOperation,
+ CommunityInfos,
+ ClientDBCommunityInfo,
+> = {
+ processStoreOperations(
+ communityStore: CommunityStore,
+ ops: $ReadOnlyArray<CommunityStoreOperation>,
+ ): CommunityStore {
+ if (ops.length === 0) {
+ return communityStore;
+ }
+
+ let processedCommunityInfos = { ...communityStore.communityInfos };
+
+ for (const operation of ops) {
+ if (operation.type === 'replace_community') {
+ processedCommunityInfos[operation.payload.id] =
+ operation.payload.communityInfo;
+ } else if (operation.type === 'remove_communities') {
+ for (const id of operation.payload.ids) {
+ delete processedCommunityInfos[id];
+ }
+ } else if (operation.type === 'remove_all_communities') {
+ processedCommunityInfos = {};
+ }
+ }
+
+ return { ...communityStore, communityInfos: processedCommunityInfos };
+ },
+
+ convertOpsToClientDBOps(
+ ops: $ReadOnlyArray<CommunityStoreOperation>,
+ ): $ReadOnlyArray<ClientDBCommunityStoreOperation> {
+ return ops.map(operation => {
+ if (
+ operation.type === 'remove_communities' ||
+ operation.type === 'remove_all_communities'
+ ) {
+ return operation;
+ }
+
+ return {
+ type: 'replace_community',
+ payload: {
+ id: operation.payload.id,
+ communityInfo: JSON.stringify(operation.payload.communityInfo),
+ },
+ };
+ });
+ },
+
+ translateClientDBData(
+ communites: $ReadOnlyArray<ClientDBCommunityInfo>,
+ ): CommunityInfos {
+ const communityInfos: { [id: string]: CommunityInfo } = {};
+
+ communites.forEach(dbCommunity => {
+ communityInfos[dbCommunity.id] = JSON.parse(dbCommunity.communityInfo);
+ });
+
+ return communityInfos;
+ },
+};
+
+export { communityStoreOpsHandlers };

File Metadata

Mime Type
text/plain
Expires
Thu, Jan 9, 4:31 PM (3 h, 38 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
2837041
Default Alt Text
D11070.id.diff (3 KB)

Event Timeline