@file-services/memory - npm Package Compare versions

Comparing version 0.3.1 to 0.4.0

cjs/memory-fs.js

@@ -42,3 +42,4 @@ "use strict";
     const root = createMemDirectory('memory-fs-root');
-    const watchListeners = new Set();
+    const pathListeners = new utils_1.SetMultiMap();
+    const globalListeners = new Set();
     return {
@@ -48,7 +49,19 @@ root,
         watchService: {
-            addListener: listener => { watchListeners.add(listener); },
-            removeListener: listener => watchListeners.delete(listener),
-            removeAllListeners: () => watchListeners.clear(),
-            async watchPath() { },
-            async unwatchAll() { }
+            async watchPath(path, listener) {
+                if (listener) {
+                    pathListeners.add(path, listener);
+                }
+            },
+            async unwatchPath(path, listener) {
+                if (listener) {
+                    pathListeners.delete(path, listener);
+                }
+                else {
+                    pathListeners.deleteKey(path);
+                }
+            },
+            async unwatchAllPaths() { pathListeners.clear(); },
+            addGlobalListener(listener) { globalListeners.add(listener); },
+            removeGlobalListener(listener) { globalListeners.delete(listener); },
+            clearGlobalListeners() { globalListeners.clear(); }
         },
@@ -212,5 +225,11 @@ caseSensitive: false,
     function emitWatchEvent(watchEvent) {
-        for (const listener of watchListeners) {
+        for (const listener of globalListeners) {
             listener(watchEvent);
         }
+        const listeners = pathListeners.get(watchEvent.path);
+        if (listeners) {
+            for (const listener of listeners) {
+                listener(watchEvent);
+            }
+        }
     }
@@ -217,0 +236,0 @@ }

esm/memory-fs.js

 import pathMain from 'path';
-import { syncToAsyncFs, createSyncFileSystem, createAsyncFileSystem } from '@file-services/utils';
+import { syncToAsyncFs, createSyncFileSystem, createAsyncFileSystem, SetMultiMap } from '@file-services/utils';
 import { FsErrorCodes } from './error-codes';
@@ -35,3 +35,4 @@ /**
     const root = createMemDirectory('memory-fs-root');
-    const watchListeners = new Set();
+    const pathListeners = new SetMultiMap();
+    const globalListeners = new Set();
     return {
@@ -41,7 +42,19 @@ root,
         watchService: {
-            addListener: listener => { watchListeners.add(listener); },
-            removeListener: listener => watchListeners.delete(listener),
-            removeAllListeners: () => watchListeners.clear(),
-            async watchPath() { },
-            async unwatchAll() { }
+            async watchPath(path, listener) {
+                if (listener) {
+                    pathListeners.add(path, listener);
+                }
+            },
+            async unwatchPath(path, listener) {
+                if (listener) {
+                    pathListeners.delete(path, listener);
+                }
+                else {
+                    pathListeners.deleteKey(path);
+                }
+            },
+            async unwatchAllPaths() { pathListeners.clear(); },
+            addGlobalListener(listener) { globalListeners.add(listener); },
+            removeGlobalListener(listener) { globalListeners.delete(listener); },
+            clearGlobalListeners() { globalListeners.clear(); }
         },
@@ -205,5 +218,11 @@ caseSensitive: false,
     function emitWatchEvent(watchEvent) {
-        for (const listener of watchListeners) {
+        for (const listener of globalListeners) {
             listener(watchEvent);
         }
+        const listeners = pathListeners.get(watchEvent.path);
+        if (listeners) {
+            for (const listener of listeners) {
+                listener(watchEvent);
+            }
+        }
     }
@@ -210,0 +229,0 @@ }

package.json

 {
   "name": "@file-services/memory",
   "description": "An in-memory, sync/async, file system implementation.",
-  "version": "0.3.1",
+  "version": "0.4.0",
   "main": "cjs/index.js",
@@ -18,7 +18,7 @@ "module": "esm/index.js",
   "dependencies": {
-    "@file-services/types": "^0.3.0",
-    "@file-services/utils": "^0.3.0"
+    "@file-services/types": "^0.4.0",
+    "@file-services/utils": "^0.4.0"
   },
   "devDependencies": {
-    "@file-services/test-kit": "^0.3.0"
+    "@file-services/test-kit": "^0.4.0"
   },
@@ -37,3 +37,3 @@ "files": [
   "sideEffects": false,
-  "gitHead": "55d86402ed36f91b0987e1bd54a934fc389adb8f"
+  "gitHead": "88403a745651cbbaf45b492b0b37d7f044cf3ea0"
 }

src/memory-fs.ts

 import pathMain from 'path'
-import { syncToAsyncFs, createSyncFileSystem, createAsyncFileSystem } from '@file-services/utils'
+import { syncToAsyncFs, createSyncFileSystem, createAsyncFileSystem, SetMultiMap } from '@file-services/utils'
 import {
@@ -51,3 +51,4 @@ IBaseFileSystem,
     const root: IFsMemDirectoryNode = createMemDirectory('memory-fs-root')
-    const watchListeners: Set<WatchEventListener> = new Set()
+    const pathListeners = new SetMultiMap<string, WatchEventListener>()
+    const globalListeners: Set<WatchEventListener> = new Set()
 
@@ -58,7 +59,18 @@ return {
         watchService: {
-            addListener: listener => { watchListeners.add(listener) },
-            removeListener: listener => watchListeners.delete(listener),
-            removeAllListeners: () => watchListeners.clear(),
-            async watchPath() { /* in-mem, so events are free */ },
-            async unwatchAll() { /* in-mem, so events are free */ }
+            async watchPath(path, listener) {
+                if (listener) {
+                    pathListeners.add(path, listener)
+                }
+            },
+            async unwatchPath(path, listener) {
+                if (listener) {
+                    pathListeners.delete(path, listener)
+                } else {
+                    pathListeners.deleteKey(path)
+                }
+            },
+            async unwatchAllPaths() { pathListeners.clear() },
+            addGlobalListener(listener) { globalListeners.add(listener) },
+            removeGlobalListener(listener) { globalListeners.delete(listener) },
+            clearGlobalListeners() { globalListeners.clear() }
         },
@@ -254,5 +266,11 @@ caseSensitive: false,
     function emitWatchEvent(watchEvent: IWatchEvent): void {
-        for (const listener of watchListeners) {
+        for (const listener of globalListeners) {
             listener(watchEvent)
         }
+        const listeners = pathListeners.get(watchEvent.path)
+        if (listeners) {
+            for (const listener of listeners) {
+                listener(watchEvent)
+            }
+        }
     }
@@ -259,0 +277,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

64263

increased by5%

Lines of code

947

increased by6.29%

Dependency changes

• + Added@file-services/types@0.4.11(transitive)

• + Added@file-services/utils@0.4.11(transitive)

• - Removed@file-services/types@0.3.0(transitive)

• - Removed@file-services/utils@0.3.0(transitive)

• Updated@file-services/types@^0.4.0

• Updated@file-services/utils@^0.4.0