fix: Export PersistentDataStoreWrapper. (#144)

Author: kinyoklion

package.json

@@ -17,7 +17,7 @@
   "private": true,
   "scripts": {
     "clean": "yarn workspaces foreach -pt run clean",
-    "build": "yarn workspaces foreach -pt run build",
+    "build": "yarn workspaces foreach -p --topological-dev run build",
     "//": "When using build:doc you need to specify the workspace. 'yarn run build:doc packages/shared/common' for example.",
     "build:doc": "./scripts/build-doc.sh $1",
     "lint": "npx eslint . --ext .ts",

packages/shared/sdk-server/src/api/interfaces/persistent_store/index.ts

@@ -1,6 +1,15 @@
 import ItemDescriptor from './ItemDescriptor';
-import PersistentDataStore from './PersistentDataStore';
+import KeyedItem from './KeyedItem';
+import PersistentDataStore, { KindKeyedStore } from './PersistentDataStore';
+
 import PersistentStoreDataKind from './PersistentStoreDataKind';
 import SerializedItemDescriptor from './SerializedItemDescriptor';
 
-export { ItemDescriptor, PersistentDataStore, PersistentStoreDataKind, SerializedItemDescriptor };
+export {
+  ItemDescriptor,
+  PersistentDataStore,
+  PersistentStoreDataKind,
+  SerializedItemDescriptor,
+  KeyedItem,
+  KindKeyedStore,
+};

packages/shared/sdk-server/src/options/Configuration.ts

@@ -199,12 +199,8 @@ export default class Configuration {
 
   public readonly diagnosticRecordingInterval: number;
 
-  // public readonly featureStore: LDFeatureStore;
-
   public readonly featureStoreFactory: (clientContext: LDClientContext) => LDFeatureStore;
 
-  // public readonly updateProcessor?: LDStreamProcessor;
-
   public readonly updateProcessorFactory?: (
     clientContext: LDClientContext,
     dataSourceUpdates: LDDataSourceUpdates

packages/shared/sdk-server/src/store/PersistentDataStoreWrapper.ts

@@ -86,8 +86,6 @@ function deserialize(
  * instance of {@link PersistentDataStore}. It provides optional caching behavior and other logic
  * that would otherwise be repeated in every data store implementation. This makes it easier to
  * create new database integrations by implementing only the database-specific logic.
- *
- * @internal
  */
 export default class PersistentDataStoreWrapper implements LDFeatureStore {
   private isInitialized = false;

packages/shared/sdk-server/src/store/UpdateQueue.ts

@@ -22,12 +22,13 @@ export default class UpdateQueue {
         // count could hit 0, and overlapping execution chains could be started.
         this.queue.shift();
         // There is more work to do, so schedule an update.
-        if (this.enqueue.length > 0) {
+        if (this.queue.length > 0) {
           setTimeout(() => this.executePendingUpdates(), 0);
         }
         // Call the original callback.
         cb?.();
       };
+
       fn(newCb);
     }
   }

packages/shared/sdk-server/src/store/index.ts

@@ -1,4 +1,5 @@
 import AsyncStoreFacade from './AsyncStoreFacade';
+import PersistentDataStoreWrapper from './PersistentDataStoreWrapper';
 import { deserializePoll } from './serialization';
 
-export { AsyncStoreFacade, deserializePoll };
+export { AsyncStoreFacade, PersistentDataStoreWrapper, deserializePoll };