@luvio/service-store - npm Package Compare versions

Comparing version 5.8.0 to 5.9.0

dist/types/v1/in-memory.d.ts

 import { type Key } from './key';
 import { type KeySet } from './key-set';
 import { type StoreService } from './store';
-import type { StoreServiceDescriptor } from './store';
+import type { RecordableStore, StoreServiceDescriptor } from './store';
 /**
@@ -19,2 +19,3 @@ * A simple in-memory implementation of the Store interface.
     toKeySet(keys: Key[]): KeySet;
+    record(): RecordableStore;
 }
@@ -21,0 +22,0 @@ /**

dist/types/v1/index.d.ts

@@ -5,2 +5,1 @@ export { type Key } from './key';
 export { buildServiceDescriptor } from './in-memory';
-export { RecordableStore } from './recordable';

dist/types/v1/recordable.d.ts

@@ -8,3 +8,3 @@ import { type Key } from './key';
  */
-export declare class RecordableStore implements StoreService {
+export declare class DefaultRecordableStore implements StoreService {
     private baseStore;
@@ -21,2 +21,3 @@ keysRead: KeySetImpl;
     toKeySet(keys: Key[]): KeySet;
+    record(): import("./store").RecordableStore;
 }

dist/types/v1/store.d.ts

@@ -48,4 +48,13 @@ import { type Key } from './key';
     toKeySet(keys: Key[]): KeySet;
+    /**
+     * Returns a wrapper for this store that records access.
+     */
+    record(): RecordableStore;
 };
+export type RecordableStore = StoreService & {
+    keysRead: KeySet;
+    missingKeysRead: KeySet;
+    keysUpdated: KeySet;
+};
 export type NamedStoreService<Name extends string = 'store'> = NamedService<Name, StoreService>;
 export type StoreServiceDescriptor = ServiceDescriptor<StoreService, 'store', '1.0'>;

dist/v1/index.js

@@ -65,2 +65,43 @@ /**
 /**
+ * A RecordableStore wraps another Store and is used to record which keys in the
+ * other Store are read/written.
+ */
+class DefaultRecordableStore {
+    constructor(baseStore) {
+        this.baseStore = baseStore;
+        this.keysRead = new KeySetImpl();
+        this.missingKeysRead = new KeySetImpl();
+        this.keysUpdated = new KeySetImpl();
+    }
+    delete(key, options) {
+        this.keysUpdated.add(key);
+        this.baseStore.delete(key, options);
+    }
+    get(key, options) {
+        this.keysRead.add(key);
+        const value = this.baseStore.get(key, options);
+        if (value === undefined) {
+            this.missingKeysRead.add(key);
+        }
+        return value;
+    }
+    set(key, value, options) {
+        this.keysUpdated.add(key);
+        this.baseStore.set(key, value, options);
+    }
+    length() {
+        return this.baseStore.length();
+    }
+    keys() {
+        return this.baseStore.keys();
+    }
+    toKeySet(keys) {
+        return this.baseStore.toKeySet(keys);
+    }
+    record() {
+        return this.baseStore.record();
+    }
+}
+
+/**
  * A simple in-memory implementation of the Store interface.
@@ -97,2 +138,5 @@ *
     }
+    record() {
+        return new DefaultRecordableStore(this);
+    }
 }
@@ -112,40 +156,2 @@ /**
 
-/**
- * A RecordableStore wraps another Store and is used to record which keys in the
- * other Store are read/written.
- */
-class RecordableStore {
-    constructor(baseStore) {
-        this.baseStore = baseStore;
-        this.keysRead = new KeySetImpl();
-        this.missingKeysRead = new KeySetImpl();
-        this.keysUpdated = new KeySetImpl();
-    }
-    delete(key, options) {
-        this.keysUpdated.add(key);
-        this.baseStore.delete(key, options);
-    }
-    get(key, options) {
-        this.keysRead.add(key);
-        const value = this.baseStore.get(key, options);
-        if (value === undefined) {
-            this.missingKeysRead.add(key);
-        }
-        return value;
-    }
-    set(key, value, options) {
-        this.keysUpdated.add(key);
-        this.baseStore.set(key, value, options);
-    }
-    length() {
-        return this.baseStore.length();
-    }
-    keys() {
-        return this.baseStore.keys();
-    }
-    toKeySet(keys) {
-        return this.baseStore.toKeySet(keys);
-    }
-}
-
-export { KeySetImpl, RecordableStore, buildServiceDescriptor };
+export { KeySetImpl, buildServiceDescriptor };

dist/v1/types/v1/in-memory.d.ts

 import { type Key } from './key';
 import { type KeySet } from './key-set';
 import { type StoreService } from './store';
-import type { StoreServiceDescriptor } from './store';
+import type { RecordableStore, StoreServiceDescriptor } from './store';
 /**
@@ -19,2 +19,3 @@ * A simple in-memory implementation of the Store interface.
     toKeySet(keys: Key[]): KeySet;
+    record(): RecordableStore;
 }
@@ -21,0 +22,0 @@ /**

dist/v1/types/v1/index.d.ts

@@ -5,2 +5,1 @@ export { type Key } from './key';
 export { buildServiceDescriptor } from './in-memory';
-export { RecordableStore } from './recordable';

dist/v1/types/v1/recordable.d.ts

@@ -8,3 +8,3 @@ import { type Key } from './key';
  */
-export declare class RecordableStore implements StoreService {
+export declare class DefaultRecordableStore implements StoreService {
     private baseStore;
@@ -21,2 +21,3 @@ keysRead: KeySetImpl;
     toKeySet(keys: Key[]): KeySet;
+    record(): import("./store").RecordableStore;
 }

dist/v1/types/v1/store.d.ts

@@ -48,4 +48,13 @@ import { type Key } from './key';
     toKeySet(keys: Key[]): KeySet;
+    /**
+     * Returns a wrapper for this store that records access.
+     */
+    record(): RecordableStore;
 };
+export type RecordableStore = StoreService & {
+    keysRead: KeySet;
+    missingKeysRead: KeySet;
+    keysUpdated: KeySet;
+};
 export type NamedStoreService<Name extends string = 'store'> = NamedService<Name, StoreService>;
 export type StoreServiceDescriptor = ServiceDescriptor<StoreService, 'store', '1.0'>;

package.json

 {
     "name": "@luvio/service-store",
-    "version": "5.8.0",
+    "version": "5.9.0",
     "private": false,
@@ -33,5 +33,8 @@ "description": "Luvio request deduplication service",
     "dependencies": {
-        "@luvio/generator-ts": "^5.8.0",
-        "@luvio/utils": "^5.8.0"
+        "@luvio/generator-ts": "^5.9.0",
+        "@luvio/utils": "^5.9.0"
     },
+    "volta": {
+        "extends": "../../../../package.json"
+    },
     "bundlesize": [
@@ -38,0 +41,0 @@ {

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

20068

increased by3.98%

Lines of code

441

increased by6.27%

Dependency changes

• Updated@luvio/generator-ts@^5.9.0

• Updated@luvio/utils@^5.9.0