Page MenuHomePhabricator
Files F3281684

D10755.id35910.diff
No OneTemporary
Actions

D10755.id35910.diff
View Options

diff --git a/lib/ops/keyserver-store-ops.js b/lib/ops/keyserver-store-ops.js
new file mode 100644
--- /dev/null
+++ b/lib/ops/keyserver-store-ops.js
@@ -0,0 +1,130 @@
+// @flow
+
+import { type BaseStoreOpsHandlers } from './base-ops.js';
+import {
+ transformKeyserverInfoToPersistedKeyserverInfo,
+ transformPersistedKeyserverInfoToKeyserverInfo,
+} from '../shared/transforms/keyserver-store-transform.js';
+import type {
+ KeyserverInfo,
+ KeyserverInfos,
+} from '../types/keyserver-types.js';
+
+// client types
+export type ReplaceKeyserverOperation = {
+ +type: 'replace_keyserver',
+ +payload: { id: string, keyserverInfo: KeyserverInfo },
+};
+
+export type RemoveKeyserverOperation = {
+ +type: 'remove_keyserver',
+ +payload: { id: string },
+};
+
+export type RemoveAllKeyserversOperation = {
+ +type: 'remove_all_keyservers',
+};
+
+export type KeyserverStoreOperation =
+ | ReplaceKeyserverOperation
+ | RemoveKeyserverOperation
+ | RemoveAllKeyserversOperation;
+
+// SQLite types
+export type ClientDBKeyserverInfo = {
+ +id: string,
+ +keyserverInfo: string,
+};
+
+export type ClientDBReplaceKeyserverOperation = {
+ +type: 'replace_keyserver',
+ +payload: ClientDBKeyserverInfo,
+};
+
+export type ClientDBKeyserverStoreOperation =
+ | ClientDBReplaceKeyserverOperation
+ | RemoveKeyserverOperation
+ | RemoveAllKeyserversOperation;
+
+function convertKeyserverInfoToClientDBKeyserverInfo({
+ id,
+ keyserverInfo,
+}: {
+ id: string,
+ keyserverInfo: KeyserverInfo,
+}): ClientDBKeyserverInfo {
+ const persistedKeyserverInfo =
+ transformKeyserverInfoToPersistedKeyserverInfo(keyserverInfo);
+ return {
+ id,
+ keyserverInfo: JSON.stringify(persistedKeyserverInfo),
+ };
+}
+
+function convertClientDBKeyserverInfoToKeyserverInfo(
+ dbKeyserverInfo: ClientDBKeyserverInfo,
+): KeyserverInfo {
+ const persistedKeyserverInfo = JSON.parse(dbKeyserverInfo.keyserverInfo);
+ return transformPersistedKeyserverInfoToKeyserverInfo(persistedKeyserverInfo);
+}
+
+const keyserverStoreOpsHandlers: BaseStoreOpsHandlers<
+ KeyserverInfos,
+ KeyserverStoreOperation,
+ ClientDBKeyserverStoreOperation,
+ KeyserverInfos,
+ ClientDBKeyserverInfo,
+> = {
+ processStoreOperations(
+ keyserverInfos: KeyserverInfos,
+ ops: $ReadOnlyArray<KeyserverStoreOperation>,
+ ): KeyserverInfos {
+ if (ops.length === 0) {
+ return keyserverInfos;
+ }
+
+ let processedKeyserverInfos = { ...keyserverInfos };
+ for (const operation: KeyserverStoreOperation of ops) {
+ if (operation.type === 'replace_keyserver') {
+ processedKeyserverInfos[operation.payload.id] =
+ operation.payload.keyserverInfo;
+ } else if (operation.type === 'remove_keyserver') {
+ delete processedKeyserverInfos[operation.payload.id];
+ } else if (operation.type === 'remove_all_keyservers') {
+ processedKeyserverInfos = {};
+ }
+ }
+ return processedKeyserverInfos;
+ },
+
+ convertOpsToClientDBOps(
+ ops: $ReadOnlyArray<KeyserverStoreOperation>,
+ ): $ReadOnlyArray<ClientDBKeyserverStoreOperation> {
+ return ops.map(operation => {
+ if (
+ operation.type === 'remove_keyserver' ||
+ operation.type === 'remove_all_keyservers'
+ ) {
+ return operation;
+ }
+ return {
+ type: 'replace_keyserver',
+ payload: convertKeyserverInfoToClientDBKeyserverInfo(operation.payload),
+ };
+ });
+ },
+
+ translateClientDBData(
+ keyservers: $ReadOnlyArray<ClientDBKeyserverInfo>,
+ ): KeyserverInfos {
+ const keyserverInfos: { [id: string]: KeyserverInfo } = {};
+ keyservers.forEach(dbKeyserver => {
+ keyserverInfos[dbKeyserver.id] =
+ convertClientDBKeyserverInfoToKeyserverInfo(dbKeyserver);
+ });
+
+ return keyserverInfos;
+ },
+};
+
+export { keyserverStoreOpsHandlers };

File Metadata

Mime Type
text/plain
Expires
Sun, Nov 17, 9:52 AM (21 h, 6 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
2522085
Default Alt Text
D10755.id35910.diff (3 KB)

Event Timeline