@file-services/cached - npm Package Compare versions

+1

-1

dist/cached-fs.d.ts

		@@ -1,2 +0,2 @@
		import type { IFileSystem } from '@file-services/types';
		import type { IFileSystem } from "@file-services/types";
		export interface ICachedFileSystem extends IFileSystem {
		@@ -3,0 +3,0 @@ /**

+1

-1

dist/fs-cached.cjs.map

		{
		"version": 3,
		"sources": ["../src/index.ts", "../src/cached-fs.ts"],
		"sourcesContent": ["export * from './cached-fs';\n", "import type { IFileSystem, IFileSystemStats, CallbackFnVoid } from '@file-services/types';\nimport { createFileSystem } from '@file-services/utils';\n\nconst identity = (val: string) => val;\nconst toLowerCase = (val: string) => val.toLowerCase();\n\nexport interface ICachedFileSystem extends IFileSystem {\n /*\n \n * @param path the file path to clear from the cache\n /\n invalidate(path: string, deep?: boolean): void;\n /\n invalidates all files\n */\n invalidateAll(): void;\n}\n\ninterface ISuccessCacheResult<T> {\n kind: 'success';\n value: T;\n}\n\ninterface IFailureCacheResult {\n kind: 'failure';\n error: Error;\n}\n\nexport function createCachedFs(fs: IFileSystem): ICachedFileSystem {\n const getCanonicalPath = fs.caseSensitive ? identity : toLowerCase;\n const statsCache = new Map<string, ISuccessCacheResult<IFileSystemStats \| undefined> \| IFailureCacheResult>();\n const realpathCache = new Map<string, string>();\n const realpathNativeCache = new Map<string, string>();\n const { promises, delimiter } = fs;\n\n const suffixTrue = delimiter + 'true';\n const suffixFalse = delimiter + 'false';\n\n const invalidateAbsolute = (absolutePath: string) => {\n const cachePath = getCanonicalPath(absolutePath);\n realpathCache.delete(cachePath);\n realpathNativeCache.delete(cachePath);\n statsCache.delete(cachePath + suffixTrue);\n statsCache.delete(cachePath + suffixFalse);\n };\n const invalidateAbsoluteByPrefix = (absolutePath: string) => {\n const prefix = getCanonicalPath(absolutePath);\n for (const key of realpathCache.keys()) {\n if (key.startsWith(prefix)) {\n realpathCache.delete(key);\n }\n }\n for (const key of realpathNativeCache.keys()) {\n if (key.startsWith(prefix)) {\n realpathNativeCache.delete(key);\n }\n }\n for (const key of statsCache.keys()) {\n if (key.startsWith(prefix)) {\n statsCache.delete(key);\n }\n }\n };\n\n function realpathSync(path: string): string {\n path = fs.resolve(path);\n const cacheKey = getCanonicalPath(path);\n const cachedActualPath = realpathCache.get(cacheKey);\n if (cachedActualPath !== undefined) {\n return cachedActualPath;\n }\n const actualPath = fs.realpathSync(path);\n realpathCache.set(cacheKey, actualPath);\n return actualPath;\n }\n\n realpathSync.native = function realpathSyncNative(path: string): string {\n path = fs.resolve(path);\n const cacheKey = getCanonicalPath(path);\n const cachedActualPath = realpathNativeCache.get(cacheKey);\n if (cachedActualPath !== undefined) {\n return cachedActualPath;\n }\n const actualPath = fs.realpathSync.native(path);\n realpathNativeCache.set(cacheKey, actualPath);\n return actualPath;\n };\n\n return {\n ...createFileSystem({\n ...fs,\n copyFile: function copyFile(sourcePath: string, destinationPath: string, ...args: [CallbackFnVoid]) {\n destinationPath = fs.resolve(destinationPath);\n invalidateAbsolute(destinationPath);\n return fs.copyFile(sourcePath, destinationPath, ...args);\n } as IFileSystem['copyFile'],\n copyFileSync(sourcePath, destinationPath, ...args) {\n destinationPath = fs.resolve(destinationPath);\n invalidateAbsolute(destinationPath);\n return fs.copyFileSync(sourcePath, destinationPath, ...args);\n },\n mkdir: function mkdir(directoryPath: string, ...args: [CallbackFnVoid]) {\n directoryPath = fs.resolve(directoryPath);\n invalidateAbsolute(directoryPath);\n return fs.mkdir(directoryPath, ...args);\n } as IFileSystem['mkdir'],\n mkdirSync(directoryPath, ...args) {\n directoryPath = fs.resolve(directoryPath);\n invalidateAbsolute(directoryPath);\n return fs.mkdirSync(directoryPath, ...args);\n },\n rename(sourcePath, destinationPath, callback) {\n sourcePath = fs.resolve(sourcePath);\n destinationPath = fs.resolve(destinationPath);\n invalidateAbsolute(sourcePath);\n invalidateAbsolute(destinationPath);\n return fs.rename(sourcePath, destinationPath, callback);\n },\n renameSync(sourcePath, destinationPath) {\n sourcePath = fs.resolve(sourcePath);\n destinationPath = fs.resolve(destinationPath);\n invalidateAbsolute(sourcePath);\n invalidateAbsolute(destinationPath);\n return fs.renameSync(sourcePath, destinationPath);\n },\n rmdir(directoryPath, callback) {\n directoryPath = fs.resolve(directoryPath);\n invalidateAbsolute(directoryPath);\n return fs.rmdir(directoryPath, callback);\n },\n rmdirSync(directoryPath) {\n directoryPath = fs.resolve(directoryPath);\n invalidateAbsolute(directoryPath);\n return fs.rmdirSync(directoryPath);\n },\n rmSync(targetPath, options) {\n targetPath = fs.resolve(targetPath);\n invalidateAbsolute(targetPath);\n return fs.rmSync(targetPath, options);\n },\n symlinkSync(target, path, type) {\n path = fs.resolve(path);\n invalidateAbsolute(path);\n return fs.symlinkSync(target, path, type);\n },\n unlink(filePath, callback) {\n filePath = fs.resolve(filePath);\n invalidateAbsolute(filePath);\n return fs.unlink(filePath, callback);\n },\n unlinkSync(filePath) {\n filePath = fs.resolve(filePath);\n invalidateAbsolute(filePath);\n return fs.unlinkSync(filePath);\n },\n writeFile: function writeFile(filePath: string, ...args: [string, CallbackFnVoid]) {\n if (filePath) {\n filePath = fs.resolve(filePath);\n invalidateAbsolute(filePath);\n }\n return fs.writeFile(filePath, ...args);\n } as IFileSystem['writeFile'],\n writeFileSync(filePath, ...args) {\n if (filePath) {\n filePath = fs.resolve(filePath);\n invalidateAbsolute(filePath);\n }\n return fs.writeFileSync(filePath, ...args);\n },\n statSync(path, options) {\n path = fs.resolve(path);\n const throwIfNoEntry = options?.throwIfNoEntry ?? true;\n const cacheKey = getCanonicalPath(path) + (throwIfNoEntry ? suffixTrue : suffixFalse);\n const cachedStats = statsCache.get(cacheKey);\n if (cachedStats) {\n if (cachedStats.kind === 'failure') {\n throw cachedStats.error;\n }\n return cachedStats.value as IFileSystemStats;\n }\n try {\n const stats = fs.statSync(path, options);\n statsCache.set(cacheKey, { kind: 'success', value: stats });\n return stats as IFileSystemStats;\n } catch (e) {\n statsCache.set(cacheKey, { kind: 'failure', error: e as Error });\n throw e;\n }\n },\n stat(path, callback) {\n path = fs.resolve(path);\n // force throwIfNoEntry, as callback version doesn't support it\n const cacheKey = getCanonicalPath(path) + suffixTrue;\n const cachedStats = statsCache.get(cacheKey);\n if (cachedStats) {\n if (cachedStats.kind === 'failure') {\n (callback as (e: Error) => void)(cachedStats.error);\n } else if (cachedStats.kind === 'success') {\n callback(null, cachedStats.value as IFileSystemStats);\n }\n } else {\n fs.stat(path, (error, stats) => {\n if (error) {\n statsCache.set(cacheKey, { kind: 'failure', error });\n } else {\n statsCache.set(cacheKey, { kind: 'success', value: stats });\n }\n\n callback(error, stats);\n });\n }\n },\n realpathSync,\n realpath(path, callback) {\n path = fs.resolve(path);\n const cacheKey = getCanonicalPath(path);\n const cachedActualPath = realpathCache.get(cacheKey);\n if (cachedActualPath !== undefined) {\n callback(null, cachedActualPath);\n } else {\n fs.realpath(path, (error, actualPath) => {\n if (!error) {\n realpathCache.set(cacheKey, actualPath);\n }\n callback(error, actualPath);\n });\n }\n },\n }),\n invalidate(path, deep = false) {\n const pathToInvalidate = fs.resolve(path);\n if (deep) {\n invalidateAbsoluteByPrefix(fs.join(pathToInvalidate, fs.sep));\n }\n return invalidateAbsolute(pathToInvalidate);\n },\n invalidateAll() {\n statsCache.clear();\n },\n promises: {\n ...promises,\n async realpath(path) {\n path = fs.resolve(path);\n const cacheKey = getCanonicalPath(path);\n const cachedActualPath = realpathCache.get(cacheKey);\n if (cachedActualPath !== undefined) {\n return cachedActualPath;\n }\n const actualPath = await promises.realpath(path);\n realpathCache.set(cacheKey, actualPath);\n return actualPath;\n },\n copyFile(sourcePath, destinationPath, ...args) {\n destinationPath = fs.resolve(destinationPath);\n invalidateAbsolute(destinationPath);\n return promises.copyFile(sourcePath, destinationPath, ...args);\n },\n mkdir(directoryPath, ...args) {\n directoryPath = fs.resolve(directoryPath);\n invalidateAbsolute(directoryPath);\n return promises.mkdir(directoryPath, ...args);\n },\n rename(sourcePath, destinationPath) {\n sourcePath = fs.resolve(sourcePath);\n destinationPath = fs.resolve(destinationPath);\n invalidateAbsolute(sourcePath);\n invalidateAbsolute(destinationPath);\n return promises.rename(sourcePath, destinationPath);\n },\n rmdir(directoryPath) {\n directoryPath = fs.resolve(directoryPath);\n invalidateAbsolute(directoryPath);\n return promises.rmdir(directoryPath);\n },\n rm(targetPath, options) {\n targetPath = fs.resolve(targetPath);\n invalidateAbsolute(targetPath);\n return promises.rm(targetPath, options);\n },\n unlink(filePath) {\n filePath = fs.resolve(filePath);\n invalidateAbsolute(filePath);\n return promises.unlink(filePath);\n },\n writeFile(filePath, ...args) {\n if (filePath) {\n filePath = fs.resolve(filePath);\n invalidateAbsolute(filePath);\n }\n return promises.writeFile(filePath, ...args);\n },\n async stat(path) {\n path = fs.resolve(path);\n // force throwIfNoEntry, as this function doesn't support it\n const cacheKey = getCanonicalPath(path) + suffixTrue;\n const cachedStats = statsCache.get(cacheKey);\n if (cachedStats) {\n if (cachedStats.kind === 'failure') {\n throw cachedStats.error;\n }\n return cachedStats.value as IFileSystemStats;\n }\n try {\n const stats = await promises.stat(path);\n statsCache.set(cacheKey, { kind: 'success', value: stats });\n return stats;\n } catch (e) {\n statsCache.set(cacheKey, { kind: 'failure', error: e as Error });\n throw e;\n }\n },\n symlink(target, path, type) {\n path = fs.resolve(path);\n invalidateAbsolute(path);\n return promises.symlink(target, path, type);\n },\n },\n };\n}\n"],
		"sourcesContent": ["export * from \"./cached-fs\";\n", "import type { IFileSystem, IFileSystemStats, CallbackFnVoid } from \"@file-services/types\";\nimport { createFileSystem } from \"@file-services/utils\";\n\nconst identity = (val: string) => val;\nconst toLowerCase = (val: string) => val.toLowerCase();\n\nexport interface ICachedFileSystem extends IFileSystem {\n /*\n \n * @param path the file path to clear from the cache\n /\n invalidate(path: string, deep?: boolean): void;\n /\n invalidates all files\n */\n invalidateAll(): void;\n}\n\ninterface ISuccessCacheResult<T> {\n kind: \"success\";\n value: T;\n}\n\ninterface IFailureCacheResult {\n kind: \"failure\";\n error: Error;\n}\n\nexport function createCachedFs(fs: IFileSystem): ICachedFileSystem {\n const getCanonicalPath = fs.caseSensitive ? identity : toLowerCase;\n const statsCache = new Map<string, ISuccessCacheResult<IFileSystemStats \| undefined> \| IFailureCacheResult>();\n const realpathCache = new Map<string, string>();\n const realpathNativeCache = new Map<string, string>();\n const { promises, delimiter } = fs;\n\n const suffixTrue = delimiter + \"true\";\n const suffixFalse = delimiter + \"false\";\n\n const invalidateAbsolute = (absolutePath: string) => {\n const cachePath = getCanonicalPath(absolutePath);\n realpathCache.delete(cachePath);\n realpathNativeCache.delete(cachePath);\n statsCache.delete(cachePath + suffixTrue);\n statsCache.delete(cachePath + suffixFalse);\n };\n const invalidateAbsoluteByPrefix = (absolutePath: string) => {\n const prefix = getCanonicalPath(absolutePath);\n for (const key of realpathCache.keys()) {\n if (key.startsWith(prefix)) {\n realpathCache.delete(key);\n }\n }\n for (const key of realpathNativeCache.keys()) {\n if (key.startsWith(prefix)) {\n realpathNativeCache.delete(key);\n }\n }\n for (const key of statsCache.keys()) {\n if (key.startsWith(prefix)) {\n statsCache.delete(key);\n }\n }\n };\n\n function realpathSync(path: string): string {\n path = fs.resolve(path);\n const cacheKey = getCanonicalPath(path);\n const cachedActualPath = realpathCache.get(cacheKey);\n if (cachedActualPath !== undefined) {\n return cachedActualPath;\n }\n const actualPath = fs.realpathSync(path);\n realpathCache.set(cacheKey, actualPath);\n return actualPath;\n }\n\n realpathSync.native = function realpathSyncNative(path: string): string {\n path = fs.resolve(path);\n const cacheKey = getCanonicalPath(path);\n const cachedActualPath = realpathNativeCache.get(cacheKey);\n if (cachedActualPath !== undefined) {\n return cachedActualPath;\n }\n const actualPath = fs.realpathSync.native(path);\n realpathNativeCache.set(cacheKey, actualPath);\n return actualPath;\n };\n\n return {\n ...createFileSystem({\n ...fs,\n copyFile: function copyFile(sourcePath: string, destinationPath: string, ...args: [CallbackFnVoid]) {\n destinationPath = fs.resolve(destinationPath);\n invalidateAbsolute(destinationPath);\n return fs.copyFile(sourcePath, destinationPath, ...args);\n } as IFileSystem[\"copyFile\"],\n copyFileSync(sourcePath, destinationPath, ...args) {\n destinationPath = fs.resolve(destinationPath);\n invalidateAbsolute(destinationPath);\n return fs.copyFileSync(sourcePath, destinationPath, ...args);\n },\n mkdir: function mkdir(directoryPath: string, ...args: [CallbackFnVoid]) {\n directoryPath = fs.resolve(directoryPath);\n invalidateAbsolute(directoryPath);\n return fs.mkdir(directoryPath, ...args);\n } as IFileSystem[\"mkdir\"],\n mkdirSync(directoryPath, ...args) {\n directoryPath = fs.resolve(directoryPath);\n invalidateAbsolute(directoryPath);\n return fs.mkdirSync(directoryPath, ...args);\n },\n rename(sourcePath, destinationPath, callback) {\n sourcePath = fs.resolve(sourcePath);\n destinationPath = fs.resolve(destinationPath);\n invalidateAbsolute(sourcePath);\n invalidateAbsolute(destinationPath);\n return fs.rename(sourcePath, destinationPath, callback);\n },\n renameSync(sourcePath, destinationPath) {\n sourcePath = fs.resolve(sourcePath);\n destinationPath = fs.resolve(destinationPath);\n invalidateAbsolute(sourcePath);\n invalidateAbsolute(destinationPath);\n return fs.renameSync(sourcePath, destinationPath);\n },\n rmdir(directoryPath, callback) {\n directoryPath = fs.resolve(directoryPath);\n invalidateAbsolute(directoryPath);\n return fs.rmdir(directoryPath, callback);\n },\n rmdirSync(directoryPath) {\n directoryPath = fs.resolve(directoryPath);\n invalidateAbsolute(directoryPath);\n return fs.rmdirSync(directoryPath);\n },\n rmSync(targetPath, options) {\n targetPath = fs.resolve(targetPath);\n invalidateAbsolute(targetPath);\n return fs.rmSync(targetPath, options);\n },\n symlinkSync(target, path, type) {\n path = fs.resolve(path);\n invalidateAbsolute(path);\n return fs.symlinkSync(target, path, type);\n },\n unlink(filePath, callback) {\n filePath = fs.resolve(filePath);\n invalidateAbsolute(filePath);\n return fs.unlink(filePath, callback);\n },\n unlinkSync(filePath) {\n filePath = fs.resolve(filePath);\n invalidateAbsolute(filePath);\n return fs.unlinkSync(filePath);\n },\n writeFile: function writeFile(filePath: string, ...args: [string, CallbackFnVoid]) {\n if (filePath) {\n filePath = fs.resolve(filePath);\n invalidateAbsolute(filePath);\n }\n return fs.writeFile(filePath, ...args);\n } as IFileSystem[\"writeFile\"],\n writeFileSync(filePath, ...args) {\n if (filePath) {\n filePath = fs.resolve(filePath);\n invalidateAbsolute(filePath);\n }\n return fs.writeFileSync(filePath, ...args);\n },\n statSync(path, options) {\n path = fs.resolve(path);\n const throwIfNoEntry = options?.throwIfNoEntry ?? true;\n const cacheKey = getCanonicalPath(path) + (throwIfNoEntry ? suffixTrue : suffixFalse);\n const cachedStats = statsCache.get(cacheKey);\n if (cachedStats) {\n if (cachedStats.kind === \"failure\") {\n throw cachedStats.error;\n }\n return cachedStats.value as IFileSystemStats;\n }\n try {\n const stats = fs.statSync(path, options);\n statsCache.set(cacheKey, { kind: \"success\", value: stats });\n return stats as IFileSystemStats;\n } catch (e) {\n statsCache.set(cacheKey, { kind: \"failure\", error: e as Error });\n throw e;\n }\n },\n stat(path, callback) {\n path = fs.resolve(path);\n // force throwIfNoEntry, as callback version doesn't support it\n const cacheKey = getCanonicalPath(path) + suffixTrue;\n const cachedStats = statsCache.get(cacheKey);\n if (cachedStats) {\n if (cachedStats.kind === \"failure\") {\n (callback as (e: Error) => void)(cachedStats.error);\n } else if (cachedStats.kind === \"success\") {\n callback(null, cachedStats.value as IFileSystemStats);\n }\n } else {\n fs.stat(path, (error, stats) => {\n if (error) {\n statsCache.set(cacheKey, { kind: \"failure\", error });\n } else {\n statsCache.set(cacheKey, { kind: \"success\", value: stats });\n }\n\n callback(error, stats);\n });\n }\n },\n realpathSync,\n realpath(path, callback) {\n path = fs.resolve(path);\n const cacheKey = getCanonicalPath(path);\n const cachedActualPath = realpathCache.get(cacheKey);\n if (cachedActualPath !== undefined) {\n callback(null, cachedActualPath);\n } else {\n fs.realpath(path, (error, actualPath) => {\n if (!error) {\n realpathCache.set(cacheKey, actualPath);\n }\n callback(error, actualPath);\n });\n }\n },\n }),\n invalidate(path, deep = false) {\n const pathToInvalidate = fs.resolve(path);\n if (deep) {\n invalidateAbsoluteByPrefix(fs.join(pathToInvalidate, fs.sep));\n }\n return invalidateAbsolute(pathToInvalidate);\n },\n invalidateAll() {\n statsCache.clear();\n },\n promises: {\n ...promises,\n async realpath(path) {\n path = fs.resolve(path);\n const cacheKey = getCanonicalPath(path);\n const cachedActualPath = realpathCache.get(cacheKey);\n if (cachedActualPath !== undefined) {\n return cachedActualPath;\n }\n const actualPath = await promises.realpath(path);\n realpathCache.set(cacheKey, actualPath);\n return actualPath;\n },\n copyFile(sourcePath, destinationPath, ...args) {\n destinationPath = fs.resolve(destinationPath);\n invalidateAbsolute(destinationPath);\n return promises.copyFile(sourcePath, destinationPath, ...args);\n },\n mkdir(directoryPath, ...args) {\n directoryPath = fs.resolve(directoryPath);\n invalidateAbsolute(directoryPath);\n return promises.mkdir(directoryPath, ...args);\n },\n rename(sourcePath, destinationPath) {\n sourcePath = fs.resolve(sourcePath);\n destinationPath = fs.resolve(destinationPath);\n invalidateAbsolute(sourcePath);\n invalidateAbsolute(destinationPath);\n return promises.rename(sourcePath, destinationPath);\n },\n rmdir(directoryPath) {\n directoryPath = fs.resolve(directoryPath);\n invalidateAbsolute(directoryPath);\n return promises.rmdir(directoryPath);\n },\n rm(targetPath, options) {\n targetPath = fs.resolve(targetPath);\n invalidateAbsolute(targetPath);\n return promises.rm(targetPath, options);\n },\n unlink(filePath) {\n filePath = fs.resolve(filePath);\n invalidateAbsolute(filePath);\n return promises.unlink(filePath);\n },\n writeFile(filePath, ...args) {\n if (filePath) {\n filePath = fs.resolve(filePath);\n invalidateAbsolute(filePath);\n }\n return promises.writeFile(filePath, ...args);\n },\n async stat(path) {\n path = fs.resolve(path);\n // force throwIfNoEntry, as this function doesn't support it\n const cacheKey = getCanonicalPath(path) + suffixTrue;\n const cachedStats = statsCache.get(cacheKey);\n if (cachedStats) {\n if (cachedStats.kind === \"failure\") {\n throw cachedStats.error;\n }\n return cachedStats.value as IFileSystemStats;\n }\n try {\n const stats = await promises.stat(path);\n statsCache.set(cacheKey, { kind: \"success\", value: stats });\n return stats;\n } catch (e) {\n statsCache.set(cacheKey, { kind: \"failure\", error: e as Error });\n throw e;\n }\n },\n symlink(target, path, type) {\n path = fs.resolve(path);\n invalidateAbsolute(path);\n return promises.symlink(target, path, type);\n },\n },\n };\n}\n"],
		"mappings": ";;;;;;;;;;;;;;;;;;;;AAAA;AAAA;AAAA;AAAA;AAAA;;;ACCA,mBAAiC;AAEjC,IAAM,WAAW,CAAC,QAAgB;AAClC,IAAM,cAAc,CAAC,QAAgB,IAAI,YAAY;AAwB9C,SAAS,eAAe,IAAoC;AACjE,QAAM,mBAAmB,GAAG,gBAAgB,WAAW;AACvD,QAAM,aAAa,oBAAI,IAAqF;AAC5G,QAAM,gBAAgB,oBAAI,IAAoB;AAC9C,QAAM,sBAAsB,oBAAI,IAAoB;AACpD,QAAM,EAAE,UAAU,UAAU,IAAI;AAEhC,QAAM,aAAa,YAAY;AAC/B,QAAM,cAAc,YAAY;AAEhC,QAAM,qBAAqB,CAAC,iBAAyB;AACnD,UAAM,YAAY,iBAAiB,YAAY;AAC/C,kBAAc,OAAO,SAAS;AAC9B,wBAAoB,OAAO,SAAS;AACpC,eAAW,OAAO,YAAY,UAAU;AACxC,eAAW,OAAO,YAAY,WAAW;AAAA,EAC3C;AACA,QAAM,6BAA6B,CAAC,iBAAyB;AAC3D,UAAM,SAAS,iBAAiB,YAAY;AAC5C,eAAW,OAAO,cAAc,KAAK,GAAG;AACtC,UAAI,IAAI,WAAW,MAAM,GAAG;AAC1B,sBAAc,OAAO,GAAG;AAAA,MAC1B;AAAA,IACF;AACA,eAAW,OAAO,oBAAoB,KAAK,GAAG;AAC5C,UAAI,IAAI,WAAW,MAAM,GAAG;AAC1B,4BAAoB,OAAO,GAAG;AAAA,MAChC;AAAA,IACF;AACA,eAAW,OAAO,WAAW,KAAK,GAAG;AACnC,UAAI,IAAI,WAAW,MAAM,GAAG;AAC1B,mBAAW,OAAO,GAAG;AAAA,MACvB;AAAA,IACF;AAAA,EACF;AAEA,WAAS,aAAa,MAAsB;AAC1C,WAAO,GAAG,QAAQ,IAAI;AACtB,UAAM,WAAW,iBAAiB,IAAI;AACtC,UAAM,mBAAmB,cAAc,IAAI,QAAQ;AACnD,QAAI,qBAAqB,QAAW;AAClC,aAAO;AAAA,IACT;AACA,UAAM,aAAa,GAAG,aAAa,IAAI;AACvC,kBAAc,IAAI,UAAU,UAAU;AACtC,WAAO;AAAA,EACT;AAEA,eAAa,SAAS,SAAS,mBAAmB,MAAsB;AACtE,WAAO,GAAG,QAAQ,IAAI;AACtB,UAAM,WAAW,iBAAiB,IAAI;AACtC,UAAM,mBAAmB,oBAAoB,IAAI,QAAQ;AACzD,QAAI,qBAAqB,QAAW;AAClC,aAAO;AAAA,IACT;AACA,UAAM,aAAa,GAAG,aAAa,OAAO,IAAI;AAC9C,wBAAoB,IAAI,UAAU,UAAU;AAC5C,WAAO;AAAA,EACT;AAEA,SAAO;AAAA,IACL,OAAG,+BAAiB;AAAA,MAClB,GAAG;AAAA,MACH,UAAU,SAAS,SAAS,YAAoB,oBAA4B,MAAwB;AAClG,0BAAkB,GAAG,QAAQ,eAAe;AAC5C,2BAAmB,eAAe;AAClC,eAAO,GAAG,SAAS,YAAY,iBAAiB,GAAG,IAAI;AAAA,MACzD;AAAA,MACA,aAAa,YAAY,oBAAoB,MAAM;AACjD,0BAAkB,GAAG,QAAQ,eAAe;AAC5C,2BAAmB,eAAe;AAClC,eAAO,GAAG,aAAa,YAAY,iBAAiB,GAAG,IAAI;AAAA,MAC7D;AAAA,MACA,OAAO,SAAS,MAAM,kBAA0B,MAAwB;AACtE,wBAAgB,GAAG,QAAQ,aAAa;AACxC,2BAAmB,aAAa;AAChC,eAAO,GAAG,MAAM,eAAe,GAAG,IAAI;AAAA,MACxC;AAAA,MACA,UAAU,kBAAkB,MAAM;AAChC,wBAAgB,GAAG,QAAQ,aAAa;AACxC,2BAAmB,aAAa;AAChC,eAAO,GAAG,UAAU,eAAe,GAAG,IAAI;AAAA,MAC5C;AAAA,MACA,OAAO,YAAY,iBAAiB,UAAU;AAC5C,qBAAa,GAAG,QAAQ,UAAU;AAClC,0BAAkB,GAAG,QAAQ,eAAe;AAC5C,2BAAmB,UAAU;AAC7B,2BAAmB,eAAe;AAClC,eAAO,GAAG,OAAO,YAAY,iBAAiB,QAAQ;AAAA,MACxD;AAAA,MACA,WAAW,YAAY,iBAAiB;AACtC,qBAAa,GAAG,QAAQ,UAAU;AAClC,0BAAkB,GAAG,QAAQ,eAAe;AAC5C,2BAAmB,UAAU;AAC7B,2BAAmB,eAAe;AAClC,eAAO,GAAG,WAAW,YAAY,eAAe;AAAA,MAClD;AAAA,MACA,MAAM,eAAe,UAAU;AAC7B,wBAAgB,GAAG,QAAQ,aAAa;AACxC,2BAAmB,aAAa;AAChC,eAAO,GAAG,MAAM,eAAe,QAAQ;AAAA,MACzC;AAAA,MACA,UAAU,eAAe;AACvB,wBAAgB,GAAG,QAAQ,aAAa;AACxC,2BAAmB,aAAa;AAChC,eAAO,GAAG,UAAU,aAAa;AAAA,MACnC;AAAA,MACA,OAAO,YAAY,SAAS;AAC1B,qBAAa,GAAG,QAAQ,UAAU;AAClC,2BAAmB,UAAU;AAC7B,eAAO,GAAG,OAAO,YAAY,OAAO;AAAA,MACtC;AAAA,MACA,YAAY,QAAQ,MAAM,MAAM;AAC9B,eAAO,GAAG,QAAQ,IAAI;AACtB,2BAAmB,IAAI;AACvB,eAAO,GAAG,YAAY,QAAQ,MAAM,IAAI;AAAA,MAC1C;AAAA,MACA,OAAO,UAAU,UAAU;AACzB,mBAAW,GAAG,QAAQ,QAAQ;AAC9B,2BAAmB,QAAQ;AAC3B,eAAO,GAAG,OAAO,UAAU,QAAQ;AAAA,MACrC;AAAA,MACA,WAAW,UAAU;AACnB,mBAAW,GAAG,QAAQ,QAAQ;AAC9B,2BAAmB,QAAQ;AAC3B,eAAO,GAAG,WAAW,QAAQ;AAAA,MAC/B;AAAA,MACA,WAAW,SAAS,UAAU,aAAqB,MAAgC;AACjF,YAAI,UAAU;AACZ,qBAAW,GAAG,QAAQ,QAAQ;AAC9B,6BAAmB,QAAQ;AAAA,QAC7B;AACA,eAAO,GAAG,UAAU,UAAU,GAAG,IAAI;AAAA,MACvC;AAAA,MACA,cAAc,aAAa,MAAM;AAC/B,YAAI,UAAU;AACZ,qBAAW,GAAG,QAAQ,QAAQ;AAC9B,6BAAmB,QAAQ;AAAA,QAC7B;AACA,eAAO,GAAG,cAAc,UAAU,GAAG,IAAI;AAAA,MAC3C;AAAA,MACA,SAAS,MAAM,SAAS;AACtB,eAAO,GAAG,QAAQ,IAAI;AACtB,cAAM,iBAAiB,SAAS,kBAAkB;AAClD,cAAM,WAAW,iBAAiB,IAAI,KAAK,iBAAiB,aAAa;AACzE,cAAM,cAAc,WAAW,IAAI,QAAQ;AAC3C,YAAI,aAAa;AACf,cAAI,YAAY,SAAS,WAAW;AAClC,kBAAM,YAAY;AAAA,UACpB;AACA,iBAAO,YAAY;AAAA,QACrB;AACA,YAAI;AACF,gBAAM,QAAQ,GAAG,SAAS,MAAM,OAAO;AACvC,qBAAW,IAAI,UAAU,EAAE,MAAM,WAAW,OAAO,MAAM,CAAC;AAC1D,iBAAO;AAAA,QACT,SAAS,GAAG;AACV,qBAAW,IAAI,UAAU,EAAE,MAAM,WAAW,OAAO,EAAW,CAAC;AAC/D,gBAAM;AAAA,QACR;AAAA,MACF;AAAA,MACA,KAAK,MAAM,UAAU;AACnB,eAAO,GAAG,QAAQ,IAAI;AAEtB,cAAM,WAAW,iBAAiB,IAAI,IAAI;AAC1C,cAAM,cAAc,WAAW,IAAI,QAAQ;AAC3C,YAAI,aAAa;AACf,cAAI,YAAY,SAAS,WAAW;AAClC,YAAC,SAAgC,YAAY,KAAK;AAAA,UACpD,WAAW,YAAY,SAAS,WAAW;AACzC,qBAAS,MAAM,YAAY,KAAyB;AAAA,UACtD;AAAA,QACF,OAAO;AACL,aAAG,KAAK,MAAM,CAAC,OAAO,UAAU;AAC9B,gBAAI,OAAO;AACT,yBAAW,IAAI,UAAU,EAAE,MAAM,WAAW,MAAM,CAAC;AAAA,YACrD,OAAO;AACL,yBAAW,IAAI,UAAU,EAAE,MAAM,WAAW,OAAO,MAAM,CAAC;AAAA,YAC5D;AAEA,qBAAS,OAAO,KAAK;AAAA,UACvB,CAAC;AAAA,QACH;AAAA,MACF;AAAA,MACA;AAAA,MACA,SAAS,MAAM,UAAU;AACvB,eAAO,GAAG,QAAQ,IAAI;AACtB,cAAM,WAAW,iBAAiB,IAAI;AACtC,cAAM,mBAAmB,cAAc,IAAI,QAAQ;AACnD,YAAI,qBAAqB,QAAW;AAClC,mBAAS,MAAM,gBAAgB;AAAA,QACjC,OAAO;AACL,aAAG,SAAS,MAAM,CAAC,OAAO,eAAe;AACvC,gBAAI,CAAC,OAAO;AACV,4BAAc,IAAI,UAAU,UAAU;AAAA,YACxC;AACA,qBAAS,OAAO,UAAU;AAAA,UAC5B,CAAC;AAAA,QACH;AAAA,MACF;AAAA,IACF,CAAC;AAAA,IACD,WAAW,MAAM,OAAO,OAAO;AAC7B,YAAM,mBAAmB,GAAG,QAAQ,IAAI;AACxC,UAAI,MAAM;AACR,mCAA2B,GAAG,KAAK,kBAAkB,GAAG,GAAG,CAAC;AAAA,MAC9D;AACA,aAAO,mBAAmB,gBAAgB;AAAA,IAC5C;AAAA,IACA,gBAAgB;AACd,iBAAW,MAAM;AAAA,IACnB;AAAA,IACA,UAAU;AAAA,MACR,GAAG;AAAA,MACH,MAAM,SAAS,MAAM;AACnB,eAAO,GAAG,QAAQ,IAAI;AACtB,cAAM,WAAW,iBAAiB,IAAI;AACtC,cAAM,mBAAmB,cAAc,IAAI,QAAQ;AACnD,YAAI,qBAAqB,QAAW;AAClC,iBAAO;AAAA,QACT;AACA,cAAM,aAAa,MAAM,SAAS,SAAS,IAAI;AAC/C,sBAAc,IAAI,UAAU,UAAU;AACtC,eAAO;AAAA,MACT;AAAA,MACA,SAAS,YAAY,oBAAoB,MAAM;AAC7C,0BAAkB,GAAG,QAAQ,eAAe;AAC5C,2BAAmB,eAAe;AAClC,eAAO,SAAS,SAAS,YAAY,iBAAiB,GAAG,IAAI;AAAA,MAC/D;AAAA,MACA,MAAM,kBAAkB,MAAM;AAC5B,wBAAgB,GAAG,QAAQ,aAAa;AACxC,2BAAmB,aAAa;AAChC,eAAO,SAAS,MAAM,eAAe,GAAG,IAAI;AAAA,MAC9C;AAAA,MACA,OAAO,YAAY,iBAAiB;AAClC,qBAAa,GAAG,QAAQ,UAAU;AAClC,0BAAkB,GAAG,QAAQ,eAAe;AAC5C,2BAAmB,UAAU;AAC7B,2BAAmB,eAAe;AAClC,eAAO,SAAS,OAAO,YAAY,eAAe;AAAA,MACpD;AAAA,MACA,MAAM,eAAe;AACnB,wBAAgB,GAAG,QAAQ,aAAa;AACxC,2BAAmB,aAAa;AAChC,eAAO,SAAS,MAAM,aAAa;AAAA,MACrC;AAAA,MACA,GAAG,YAAY,SAAS;AACtB,qBAAa,GAAG,QAAQ,UAAU;AAClC,2BAAmB,UAAU;AAC7B,eAAO,SAAS,GAAG,YAAY,OAAO;AAAA,MACxC;AAAA,MACA,OAAO,UAAU;AACf,mBAAW,GAAG,QAAQ,QAAQ;AAC9B,2BAAmB,QAAQ;AAC3B,eAAO,SAAS,OAAO,QAAQ;AAAA,MACjC;AAAA,MACA,UAAU,aAAa,MAAM;AAC3B,YAAI,UAAU;AACZ,qBAAW,GAAG,QAAQ,QAAQ;AAC9B,6BAAmB,QAAQ;AAAA,QAC7B;AACA,eAAO,SAAS,UAAU,UAAU,GAAG,IAAI;AAAA,MAC7C;AAAA,MACA,MAAM,KAAK,MAAM;AACf,eAAO,GAAG,QAAQ,IAAI;AAEtB,cAAM,WAAW,iBAAiB,IAAI,IAAI;AAC1C,cAAM,cAAc,WAAW,IAAI,QAAQ;AAC3C,YAAI,aAAa;AACf,cAAI,YAAY,SAAS,WAAW;AAClC,kBAAM,YAAY;AAAA,UACpB;AACA,iBAAO,YAAY;AAAA,QACrB;AACA,YAAI;AACF,gBAAM,QAAQ,MAAM,SAAS,KAAK,IAAI;AACtC,qBAAW,IAAI,UAAU,EAAE,MAAM,WAAW,OAAO,MAAM,CAAC;AAC1D,iBAAO;AAAA,QACT,SAAS,GAAG;AACV,qBAAW,IAAI,UAAU,EAAE,MAAM,WAAW,OAAO,EAAW,CAAC;AAC/D,gBAAM;AAAA,QACR;AAAA,MACF;AAAA,MACA,QAAQ,QAAQ,MAAM,MAAM;AAC1B,eAAO,GAAG,QAAQ,IAAI;AACtB,2BAAmB,IAAI;AACvB,eAAO,SAAS,QAAQ,QAAQ,MAAM,IAAI;AAAA,MAC5C;AAAA,IACF;AAAA,EACF;AACF;",
		"names": []
		}

+1

-1

dist/fs-cached.mjs.map

		{
		"version": 3,
		"sources": ["../src/cached-fs.ts"],
		"sourcesContent": ["import type { IFileSystem, IFileSystemStats, CallbackFnVoid } from '@file-services/types';\nimport { createFileSystem } from '@file-services/utils';\n\nconst identity = (val: string) => val;\nconst toLowerCase = (val: string) => val.toLowerCase();\n\nexport interface ICachedFileSystem extends IFileSystem {\n /*\n \n * @param path the file path to clear from the cache\n /\n invalidate(path: string, deep?: boolean): void;\n /\n invalidates all files\n */\n invalidateAll(): void;\n}\n\ninterface ISuccessCacheResult<T> {\n kind: 'success';\n value: T;\n}\n\ninterface IFailureCacheResult {\n kind: 'failure';\n error: Error;\n}\n\nexport function createCachedFs(fs: IFileSystem): ICachedFileSystem {\n const getCanonicalPath = fs.caseSensitive ? identity : toLowerCase;\n const statsCache = new Map<string, ISuccessCacheResult<IFileSystemStats \| undefined> \| IFailureCacheResult>();\n const realpathCache = new Map<string, string>();\n const realpathNativeCache = new Map<string, string>();\n const { promises, delimiter } = fs;\n\n const suffixTrue = delimiter + 'true';\n const suffixFalse = delimiter + 'false';\n\n const invalidateAbsolute = (absolutePath: string) => {\n const cachePath = getCanonicalPath(absolutePath);\n realpathCache.delete(cachePath);\n realpathNativeCache.delete(cachePath);\n statsCache.delete(cachePath + suffixTrue);\n statsCache.delete(cachePath + suffixFalse);\n };\n const invalidateAbsoluteByPrefix = (absolutePath: string) => {\n const prefix = getCanonicalPath(absolutePath);\n for (const key of realpathCache.keys()) {\n if (key.startsWith(prefix)) {\n realpathCache.delete(key);\n }\n }\n for (const key of realpathNativeCache.keys()) {\n if (key.startsWith(prefix)) {\n realpathNativeCache.delete(key);\n }\n }\n for (const key of statsCache.keys()) {\n if (key.startsWith(prefix)) {\n statsCache.delete(key);\n }\n }\n };\n\n function realpathSync(path: string): string {\n path = fs.resolve(path);\n const cacheKey = getCanonicalPath(path);\n const cachedActualPath = realpathCache.get(cacheKey);\n if (cachedActualPath !== undefined) {\n return cachedActualPath;\n }\n const actualPath = fs.realpathSync(path);\n realpathCache.set(cacheKey, actualPath);\n return actualPath;\n }\n\n realpathSync.native = function realpathSyncNative(path: string): string {\n path = fs.resolve(path);\n const cacheKey = getCanonicalPath(path);\n const cachedActualPath = realpathNativeCache.get(cacheKey);\n if (cachedActualPath !== undefined) {\n return cachedActualPath;\n }\n const actualPath = fs.realpathSync.native(path);\n realpathNativeCache.set(cacheKey, actualPath);\n return actualPath;\n };\n\n return {\n ...createFileSystem({\n ...fs,\n copyFile: function copyFile(sourcePath: string, destinationPath: string, ...args: [CallbackFnVoid]) {\n destinationPath = fs.resolve(destinationPath);\n invalidateAbsolute(destinationPath);\n return fs.copyFile(sourcePath, destinationPath, ...args);\n } as IFileSystem['copyFile'],\n copyFileSync(sourcePath, destinationPath, ...args) {\n destinationPath = fs.resolve(destinationPath);\n invalidateAbsolute(destinationPath);\n return fs.copyFileSync(sourcePath, destinationPath, ...args);\n },\n mkdir: function mkdir(directoryPath: string, ...args: [CallbackFnVoid]) {\n directoryPath = fs.resolve(directoryPath);\n invalidateAbsolute(directoryPath);\n return fs.mkdir(directoryPath, ...args);\n } as IFileSystem['mkdir'],\n mkdirSync(directoryPath, ...args) {\n directoryPath = fs.resolve(directoryPath);\n invalidateAbsolute(directoryPath);\n return fs.mkdirSync(directoryPath, ...args);\n },\n rename(sourcePath, destinationPath, callback) {\n sourcePath = fs.resolve(sourcePath);\n destinationPath = fs.resolve(destinationPath);\n invalidateAbsolute(sourcePath);\n invalidateAbsolute(destinationPath);\n return fs.rename(sourcePath, destinationPath, callback);\n },\n renameSync(sourcePath, destinationPath) {\n sourcePath = fs.resolve(sourcePath);\n destinationPath = fs.resolve(destinationPath);\n invalidateAbsolute(sourcePath);\n invalidateAbsolute(destinationPath);\n return fs.renameSync(sourcePath, destinationPath);\n },\n rmdir(directoryPath, callback) {\n directoryPath = fs.resolve(directoryPath);\n invalidateAbsolute(directoryPath);\n return fs.rmdir(directoryPath, callback);\n },\n rmdirSync(directoryPath) {\n directoryPath = fs.resolve(directoryPath);\n invalidateAbsolute(directoryPath);\n return fs.rmdirSync(directoryPath);\n },\n rmSync(targetPath, options) {\n targetPath = fs.resolve(targetPath);\n invalidateAbsolute(targetPath);\n return fs.rmSync(targetPath, options);\n },\n symlinkSync(target, path, type) {\n path = fs.resolve(path);\n invalidateAbsolute(path);\n return fs.symlinkSync(target, path, type);\n },\n unlink(filePath, callback) {\n filePath = fs.resolve(filePath);\n invalidateAbsolute(filePath);\n return fs.unlink(filePath, callback);\n },\n unlinkSync(filePath) {\n filePath = fs.resolve(filePath);\n invalidateAbsolute(filePath);\n return fs.unlinkSync(filePath);\n },\n writeFile: function writeFile(filePath: string, ...args: [string, CallbackFnVoid]) {\n if (filePath) {\n filePath = fs.resolve(filePath);\n invalidateAbsolute(filePath);\n }\n return fs.writeFile(filePath, ...args);\n } as IFileSystem['writeFile'],\n writeFileSync(filePath, ...args) {\n if (filePath) {\n filePath = fs.resolve(filePath);\n invalidateAbsolute(filePath);\n }\n return fs.writeFileSync(filePath, ...args);\n },\n statSync(path, options) {\n path = fs.resolve(path);\n const throwIfNoEntry = options?.throwIfNoEntry ?? true;\n const cacheKey = getCanonicalPath(path) + (throwIfNoEntry ? suffixTrue : suffixFalse);\n const cachedStats = statsCache.get(cacheKey);\n if (cachedStats) {\n if (cachedStats.kind === 'failure') {\n throw cachedStats.error;\n }\n return cachedStats.value as IFileSystemStats;\n }\n try {\n const stats = fs.statSync(path, options);\n statsCache.set(cacheKey, { kind: 'success', value: stats });\n return stats as IFileSystemStats;\n } catch (e) {\n statsCache.set(cacheKey, { kind: 'failure', error: e as Error });\n throw e;\n }\n },\n stat(path, callback) {\n path = fs.resolve(path);\n // force throwIfNoEntry, as callback version doesn't support it\n const cacheKey = getCanonicalPath(path) + suffixTrue;\n const cachedStats = statsCache.get(cacheKey);\n if (cachedStats) {\n if (cachedStats.kind === 'failure') {\n (callback as (e: Error) => void)(cachedStats.error);\n } else if (cachedStats.kind === 'success') {\n callback(null, cachedStats.value as IFileSystemStats);\n }\n } else {\n fs.stat(path, (error, stats) => {\n if (error) {\n statsCache.set(cacheKey, { kind: 'failure', error });\n } else {\n statsCache.set(cacheKey, { kind: 'success', value: stats });\n }\n\n callback(error, stats);\n });\n }\n },\n realpathSync,\n realpath(path, callback) {\n path = fs.resolve(path);\n const cacheKey = getCanonicalPath(path);\n const cachedActualPath = realpathCache.get(cacheKey);\n if (cachedActualPath !== undefined) {\n callback(null, cachedActualPath);\n } else {\n fs.realpath(path, (error, actualPath) => {\n if (!error) {\n realpathCache.set(cacheKey, actualPath);\n }\n callback(error, actualPath);\n });\n }\n },\n }),\n invalidate(path, deep = false) {\n const pathToInvalidate = fs.resolve(path);\n if (deep) {\n invalidateAbsoluteByPrefix(fs.join(pathToInvalidate, fs.sep));\n }\n return invalidateAbsolute(pathToInvalidate);\n },\n invalidateAll() {\n statsCache.clear();\n },\n promises: {\n ...promises,\n async realpath(path) {\n path = fs.resolve(path);\n const cacheKey = getCanonicalPath(path);\n const cachedActualPath = realpathCache.get(cacheKey);\n if (cachedActualPath !== undefined) {\n return cachedActualPath;\n }\n const actualPath = await promises.realpath(path);\n realpathCache.set(cacheKey, actualPath);\n return actualPath;\n },\n copyFile(sourcePath, destinationPath, ...args) {\n destinationPath = fs.resolve(destinationPath);\n invalidateAbsolute(destinationPath);\n return promises.copyFile(sourcePath, destinationPath, ...args);\n },\n mkdir(directoryPath, ...args) {\n directoryPath = fs.resolve(directoryPath);\n invalidateAbsolute(directoryPath);\n return promises.mkdir(directoryPath, ...args);\n },\n rename(sourcePath, destinationPath) {\n sourcePath = fs.resolve(sourcePath);\n destinationPath = fs.resolve(destinationPath);\n invalidateAbsolute(sourcePath);\n invalidateAbsolute(destinationPath);\n return promises.rename(sourcePath, destinationPath);\n },\n rmdir(directoryPath) {\n directoryPath = fs.resolve(directoryPath);\n invalidateAbsolute(directoryPath);\n return promises.rmdir(directoryPath);\n },\n rm(targetPath, options) {\n targetPath = fs.resolve(targetPath);\n invalidateAbsolute(targetPath);\n return promises.rm(targetPath, options);\n },\n unlink(filePath) {\n filePath = fs.resolve(filePath);\n invalidateAbsolute(filePath);\n return promises.unlink(filePath);\n },\n writeFile(filePath, ...args) {\n if (filePath) {\n filePath = fs.resolve(filePath);\n invalidateAbsolute(filePath);\n }\n return promises.writeFile(filePath, ...args);\n },\n async stat(path) {\n path = fs.resolve(path);\n // force throwIfNoEntry, as this function doesn't support it\n const cacheKey = getCanonicalPath(path) + suffixTrue;\n const cachedStats = statsCache.get(cacheKey);\n if (cachedStats) {\n if (cachedStats.kind === 'failure') {\n throw cachedStats.error;\n }\n return cachedStats.value as IFileSystemStats;\n }\n try {\n const stats = await promises.stat(path);\n statsCache.set(cacheKey, { kind: 'success', value: stats });\n return stats;\n } catch (e) {\n statsCache.set(cacheKey, { kind: 'failure', error: e as Error });\n throw e;\n }\n },\n symlink(target, path, type) {\n path = fs.resolve(path);\n invalidateAbsolute(path);\n return promises.symlink(target, path, type);\n },\n },\n };\n}\n"],
		"sourcesContent": ["import type { IFileSystem, IFileSystemStats, CallbackFnVoid } from \"@file-services/types\";\nimport { createFileSystem } from \"@file-services/utils\";\n\nconst identity = (val: string) => val;\nconst toLowerCase = (val: string) => val.toLowerCase();\n\nexport interface ICachedFileSystem extends IFileSystem {\n /*\n \n * @param path the file path to clear from the cache\n /\n invalidate(path: string, deep?: boolean): void;\n /\n invalidates all files\n */\n invalidateAll(): void;\n}\n\ninterface ISuccessCacheResult<T> {\n kind: \"success\";\n value: T;\n}\n\ninterface IFailureCacheResult {\n kind: \"failure\";\n error: Error;\n}\n\nexport function createCachedFs(fs: IFileSystem): ICachedFileSystem {\n const getCanonicalPath = fs.caseSensitive ? identity : toLowerCase;\n const statsCache = new Map<string, ISuccessCacheResult<IFileSystemStats \| undefined> \| IFailureCacheResult>();\n const realpathCache = new Map<string, string>();\n const realpathNativeCache = new Map<string, string>();\n const { promises, delimiter } = fs;\n\n const suffixTrue = delimiter + \"true\";\n const suffixFalse = delimiter + \"false\";\n\n const invalidateAbsolute = (absolutePath: string) => {\n const cachePath = getCanonicalPath(absolutePath);\n realpathCache.delete(cachePath);\n realpathNativeCache.delete(cachePath);\n statsCache.delete(cachePath + suffixTrue);\n statsCache.delete(cachePath + suffixFalse);\n };\n const invalidateAbsoluteByPrefix = (absolutePath: string) => {\n const prefix = getCanonicalPath(absolutePath);\n for (const key of realpathCache.keys()) {\n if (key.startsWith(prefix)) {\n realpathCache.delete(key);\n }\n }\n for (const key of realpathNativeCache.keys()) {\n if (key.startsWith(prefix)) {\n realpathNativeCache.delete(key);\n }\n }\n for (const key of statsCache.keys()) {\n if (key.startsWith(prefix)) {\n statsCache.delete(key);\n }\n }\n };\n\n function realpathSync(path: string): string {\n path = fs.resolve(path);\n const cacheKey = getCanonicalPath(path);\n const cachedActualPath = realpathCache.get(cacheKey);\n if (cachedActualPath !== undefined) {\n return cachedActualPath;\n }\n const actualPath = fs.realpathSync(path);\n realpathCache.set(cacheKey, actualPath);\n return actualPath;\n }\n\n realpathSync.native = function realpathSyncNative(path: string): string {\n path = fs.resolve(path);\n const cacheKey = getCanonicalPath(path);\n const cachedActualPath = realpathNativeCache.get(cacheKey);\n if (cachedActualPath !== undefined) {\n return cachedActualPath;\n }\n const actualPath = fs.realpathSync.native(path);\n realpathNativeCache.set(cacheKey, actualPath);\n return actualPath;\n };\n\n return {\n ...createFileSystem({\n ...fs,\n copyFile: function copyFile(sourcePath: string, destinationPath: string, ...args: [CallbackFnVoid]) {\n destinationPath = fs.resolve(destinationPath);\n invalidateAbsolute(destinationPath);\n return fs.copyFile(sourcePath, destinationPath, ...args);\n } as IFileSystem[\"copyFile\"],\n copyFileSync(sourcePath, destinationPath, ...args) {\n destinationPath = fs.resolve(destinationPath);\n invalidateAbsolute(destinationPath);\n return fs.copyFileSync(sourcePath, destinationPath, ...args);\n },\n mkdir: function mkdir(directoryPath: string, ...args: [CallbackFnVoid]) {\n directoryPath = fs.resolve(directoryPath);\n invalidateAbsolute(directoryPath);\n return fs.mkdir(directoryPath, ...args);\n } as IFileSystem[\"mkdir\"],\n mkdirSync(directoryPath, ...args) {\n directoryPath = fs.resolve(directoryPath);\n invalidateAbsolute(directoryPath);\n return fs.mkdirSync(directoryPath, ...args);\n },\n rename(sourcePath, destinationPath, callback) {\n sourcePath = fs.resolve(sourcePath);\n destinationPath = fs.resolve(destinationPath);\n invalidateAbsolute(sourcePath);\n invalidateAbsolute(destinationPath);\n return fs.rename(sourcePath, destinationPath, callback);\n },\n renameSync(sourcePath, destinationPath) {\n sourcePath = fs.resolve(sourcePath);\n destinationPath = fs.resolve(destinationPath);\n invalidateAbsolute(sourcePath);\n invalidateAbsolute(destinationPath);\n return fs.renameSync(sourcePath, destinationPath);\n },\n rmdir(directoryPath, callback) {\n directoryPath = fs.resolve(directoryPath);\n invalidateAbsolute(directoryPath);\n return fs.rmdir(directoryPath, callback);\n },\n rmdirSync(directoryPath) {\n directoryPath = fs.resolve(directoryPath);\n invalidateAbsolute(directoryPath);\n return fs.rmdirSync(directoryPath);\n },\n rmSync(targetPath, options) {\n targetPath = fs.resolve(targetPath);\n invalidateAbsolute(targetPath);\n return fs.rmSync(targetPath, options);\n },\n symlinkSync(target, path, type) {\n path = fs.resolve(path);\n invalidateAbsolute(path);\n return fs.symlinkSync(target, path, type);\n },\n unlink(filePath, callback) {\n filePath = fs.resolve(filePath);\n invalidateAbsolute(filePath);\n return fs.unlink(filePath, callback);\n },\n unlinkSync(filePath) {\n filePath = fs.resolve(filePath);\n invalidateAbsolute(filePath);\n return fs.unlinkSync(filePath);\n },\n writeFile: function writeFile(filePath: string, ...args: [string, CallbackFnVoid]) {\n if (filePath) {\n filePath = fs.resolve(filePath);\n invalidateAbsolute(filePath);\n }\n return fs.writeFile(filePath, ...args);\n } as IFileSystem[\"writeFile\"],\n writeFileSync(filePath, ...args) {\n if (filePath) {\n filePath = fs.resolve(filePath);\n invalidateAbsolute(filePath);\n }\n return fs.writeFileSync(filePath, ...args);\n },\n statSync(path, options) {\n path = fs.resolve(path);\n const throwIfNoEntry = options?.throwIfNoEntry ?? true;\n const cacheKey = getCanonicalPath(path) + (throwIfNoEntry ? suffixTrue : suffixFalse);\n const cachedStats = statsCache.get(cacheKey);\n if (cachedStats) {\n if (cachedStats.kind === \"failure\") {\n throw cachedStats.error;\n }\n return cachedStats.value as IFileSystemStats;\n }\n try {\n const stats = fs.statSync(path, options);\n statsCache.set(cacheKey, { kind: \"success\", value: stats });\n return stats as IFileSystemStats;\n } catch (e) {\n statsCache.set(cacheKey, { kind: \"failure\", error: e as Error });\n throw e;\n }\n },\n stat(path, callback) {\n path = fs.resolve(path);\n // force throwIfNoEntry, as callback version doesn't support it\n const cacheKey = getCanonicalPath(path) + suffixTrue;\n const cachedStats = statsCache.get(cacheKey);\n if (cachedStats) {\n if (cachedStats.kind === \"failure\") {\n (callback as (e: Error) => void)(cachedStats.error);\n } else if (cachedStats.kind === \"success\") {\n callback(null, cachedStats.value as IFileSystemStats);\n }\n } else {\n fs.stat(path, (error, stats) => {\n if (error) {\n statsCache.set(cacheKey, { kind: \"failure\", error });\n } else {\n statsCache.set(cacheKey, { kind: \"success\", value: stats });\n }\n\n callback(error, stats);\n });\n }\n },\n realpathSync,\n realpath(path, callback) {\n path = fs.resolve(path);\n const cacheKey = getCanonicalPath(path);\n const cachedActualPath = realpathCache.get(cacheKey);\n if (cachedActualPath !== undefined) {\n callback(null, cachedActualPath);\n } else {\n fs.realpath(path, (error, actualPath) => {\n if (!error) {\n realpathCache.set(cacheKey, actualPath);\n }\n callback(error, actualPath);\n });\n }\n },\n }),\n invalidate(path, deep = false) {\n const pathToInvalidate = fs.resolve(path);\n if (deep) {\n invalidateAbsoluteByPrefix(fs.join(pathToInvalidate, fs.sep));\n }\n return invalidateAbsolute(pathToInvalidate);\n },\n invalidateAll() {\n statsCache.clear();\n },\n promises: {\n ...promises,\n async realpath(path) {\n path = fs.resolve(path);\n const cacheKey = getCanonicalPath(path);\n const cachedActualPath = realpathCache.get(cacheKey);\n if (cachedActualPath !== undefined) {\n return cachedActualPath;\n }\n const actualPath = await promises.realpath(path);\n realpathCache.set(cacheKey, actualPath);\n return actualPath;\n },\n copyFile(sourcePath, destinationPath, ...args) {\n destinationPath = fs.resolve(destinationPath);\n invalidateAbsolute(destinationPath);\n return promises.copyFile(sourcePath, destinationPath, ...args);\n },\n mkdir(directoryPath, ...args) {\n directoryPath = fs.resolve(directoryPath);\n invalidateAbsolute(directoryPath);\n return promises.mkdir(directoryPath, ...args);\n },\n rename(sourcePath, destinationPath) {\n sourcePath = fs.resolve(sourcePath);\n destinationPath = fs.resolve(destinationPath);\n invalidateAbsolute(sourcePath);\n invalidateAbsolute(destinationPath);\n return promises.rename(sourcePath, destinationPath);\n },\n rmdir(directoryPath) {\n directoryPath = fs.resolve(directoryPath);\n invalidateAbsolute(directoryPath);\n return promises.rmdir(directoryPath);\n },\n rm(targetPath, options) {\n targetPath = fs.resolve(targetPath);\n invalidateAbsolute(targetPath);\n return promises.rm(targetPath, options);\n },\n unlink(filePath) {\n filePath = fs.resolve(filePath);\n invalidateAbsolute(filePath);\n return promises.unlink(filePath);\n },\n writeFile(filePath, ...args) {\n if (filePath) {\n filePath = fs.resolve(filePath);\n invalidateAbsolute(filePath);\n }\n return promises.writeFile(filePath, ...args);\n },\n async stat(path) {\n path = fs.resolve(path);\n // force throwIfNoEntry, as this function doesn't support it\n const cacheKey = getCanonicalPath(path) + suffixTrue;\n const cachedStats = statsCache.get(cacheKey);\n if (cachedStats) {\n if (cachedStats.kind === \"failure\") {\n throw cachedStats.error;\n }\n return cachedStats.value as IFileSystemStats;\n }\n try {\n const stats = await promises.stat(path);\n statsCache.set(cacheKey, { kind: \"success\", value: stats });\n return stats;\n } catch (e) {\n statsCache.set(cacheKey, { kind: \"failure\", error: e as Error });\n throw e;\n }\n },\n symlink(target, path, type) {\n path = fs.resolve(path);\n invalidateAbsolute(path);\n return promises.symlink(target, path, type);\n },\n },\n };\n}\n"],
		"mappings": ";AACA,SAAS,wBAAwB;AAEjC,IAAM,WAAW,CAAC,QAAgB;AAClC,IAAM,cAAc,CAAC,QAAgB,IAAI,YAAY;AAwB9C,SAAS,eAAe,IAAoC;AACjE,QAAM,mBAAmB,GAAG,gBAAgB,WAAW;AACvD,QAAM,aAAa,oBAAI,IAAqF;AAC5G,QAAM,gBAAgB,oBAAI,IAAoB;AAC9C,QAAM,sBAAsB,oBAAI,IAAoB;AACpD,QAAM,EAAE,UAAU,UAAU,IAAI;AAEhC,QAAM,aAAa,YAAY;AAC/B,QAAM,cAAc,YAAY;AAEhC,QAAM,qBAAqB,CAAC,iBAAyB;AACnD,UAAM,YAAY,iBAAiB,YAAY;AAC/C,kBAAc,OAAO,SAAS;AAC9B,wBAAoB,OAAO,SAAS;AACpC,eAAW,OAAO,YAAY,UAAU;AACxC,eAAW,OAAO,YAAY,WAAW;AAAA,EAC3C;AACA,QAAM,6BAA6B,CAAC,iBAAyB;AAC3D,UAAM,SAAS,iBAAiB,YAAY;AAC5C,eAAW,OAAO,cAAc,KAAK,GAAG;AACtC,UAAI,IAAI,WAAW,MAAM,GAAG;AAC1B,sBAAc,OAAO,GAAG;AAAA,MAC1B;AAAA,IACF;AACA,eAAW,OAAO,oBAAoB,KAAK,GAAG;AAC5C,UAAI,IAAI,WAAW,MAAM,GAAG;AAC1B,4BAAoB,OAAO,GAAG;AAAA,MAChC;AAAA,IACF;AACA,eAAW,OAAO,WAAW,KAAK,GAAG;AACnC,UAAI,IAAI,WAAW,MAAM,GAAG;AAC1B,mBAAW,OAAO,GAAG;AAAA,MACvB;AAAA,IACF;AAAA,EACF;AAEA,WAAS,aAAa,MAAsB;AAC1C,WAAO,GAAG,QAAQ,IAAI;AACtB,UAAM,WAAW,iBAAiB,IAAI;AACtC,UAAM,mBAAmB,cAAc,IAAI,QAAQ;AACnD,QAAI,qBAAqB,QAAW;AAClC,aAAO;AAAA,IACT;AACA,UAAM,aAAa,GAAG,aAAa,IAAI;AACvC,kBAAc,IAAI,UAAU,UAAU;AACtC,WAAO;AAAA,EACT;AAEA,eAAa,SAAS,SAAS,mBAAmB,MAAsB;AACtE,WAAO,GAAG,QAAQ,IAAI;AACtB,UAAM,WAAW,iBAAiB,IAAI;AACtC,UAAM,mBAAmB,oBAAoB,IAAI,QAAQ;AACzD,QAAI,qBAAqB,QAAW;AAClC,aAAO;AAAA,IACT;AACA,UAAM,aAAa,GAAG,aAAa,OAAO,IAAI;AAC9C,wBAAoB,IAAI,UAAU,UAAU;AAC5C,WAAO;AAAA,EACT;AAEA,SAAO;AAAA,IACL,GAAG,iBAAiB;AAAA,MAClB,GAAG;AAAA,MACH,UAAU,SAAS,SAAS,YAAoB,oBAA4B,MAAwB;AAClG,0BAAkB,GAAG,QAAQ,eAAe;AAC5C,2BAAmB,eAAe;AAClC,eAAO,GAAG,SAAS,YAAY,iBAAiB,GAAG,IAAI;AAAA,MACzD;AAAA,MACA,aAAa,YAAY,oBAAoB,MAAM;AACjD,0BAAkB,GAAG,QAAQ,eAAe;AAC5C,2BAAmB,eAAe;AAClC,eAAO,GAAG,aAAa,YAAY,iBAAiB,GAAG,IAAI;AAAA,MAC7D;AAAA,MACA,OAAO,SAAS,MAAM,kBAA0B,MAAwB;AACtE,wBAAgB,GAAG,QAAQ,aAAa;AACxC,2BAAmB,aAAa;AAChC,eAAO,GAAG,MAAM,eAAe,GAAG,IAAI;AAAA,MACxC;AAAA,MACA,UAAU,kBAAkB,MAAM;AAChC,wBAAgB,GAAG,QAAQ,aAAa;AACxC,2BAAmB,aAAa;AAChC,eAAO,GAAG,UAAU,eAAe,GAAG,IAAI;AAAA,MAC5C;AAAA,MACA,OAAO,YAAY,iBAAiB,UAAU;AAC5C,qBAAa,GAAG,QAAQ,UAAU;AAClC,0BAAkB,GAAG,QAAQ,eAAe;AAC5C,2BAAmB,UAAU;AAC7B,2BAAmB,eAAe;AAClC,eAAO,GAAG,OAAO,YAAY,iBAAiB,QAAQ;AAAA,MACxD;AAAA,MACA,WAAW,YAAY,iBAAiB;AACtC,qBAAa,GAAG,QAAQ,UAAU;AAClC,0BAAkB,GAAG,QAAQ,eAAe;AAC5C,2BAAmB,UAAU;AAC7B,2BAAmB,eAAe;AAClC,eAAO,GAAG,WAAW,YAAY,eAAe;AAAA,MAClD;AAAA,MACA,MAAM,eAAe,UAAU;AAC7B,wBAAgB,GAAG,QAAQ,aAAa;AACxC,2BAAmB,aAAa;AAChC,eAAO,GAAG,MAAM,eAAe,QAAQ;AAAA,MACzC;AAAA,MACA,UAAU,eAAe;AACvB,wBAAgB,GAAG,QAAQ,aAAa;AACxC,2BAAmB,aAAa;AAChC,eAAO,GAAG,UAAU,aAAa;AAAA,MACnC;AAAA,MACA,OAAO,YAAY,SAAS;AAC1B,qBAAa,GAAG,QAAQ,UAAU;AAClC,2BAAmB,UAAU;AAC7B,eAAO,GAAG,OAAO,YAAY,OAAO;AAAA,MACtC;AAAA,MACA,YAAY,QAAQ,MAAM,MAAM;AAC9B,eAAO,GAAG,QAAQ,IAAI;AACtB,2BAAmB,IAAI;AACvB,eAAO,GAAG,YAAY,QAAQ,MAAM,IAAI;AAAA,MAC1C;AAAA,MACA,OAAO,UAAU,UAAU;AACzB,mBAAW,GAAG,QAAQ,QAAQ;AAC9B,2BAAmB,QAAQ;AAC3B,eAAO,GAAG,OAAO,UAAU,QAAQ;AAAA,MACrC;AAAA,MACA,WAAW,UAAU;AACnB,mBAAW,GAAG,QAAQ,QAAQ;AAC9B,2BAAmB,QAAQ;AAC3B,eAAO,GAAG,WAAW,QAAQ;AAAA,MAC/B;AAAA,MACA,WAAW,SAAS,UAAU,aAAqB,MAAgC;AACjF,YAAI,UAAU;AACZ,qBAAW,GAAG,QAAQ,QAAQ;AAC9B,6BAAmB,QAAQ;AAAA,QAC7B;AACA,eAAO,GAAG,UAAU,UAAU,GAAG,IAAI;AAAA,MACvC;AAAA,MACA,cAAc,aAAa,MAAM;AAC/B,YAAI,UAAU;AACZ,qBAAW,GAAG,QAAQ,QAAQ;AAC9B,6BAAmB,QAAQ;AAAA,QAC7B;AACA,eAAO,GAAG,cAAc,UAAU,GAAG,IAAI;AAAA,MAC3C;AAAA,MACA,SAAS,MAAM,SAAS;AACtB,eAAO,GAAG,QAAQ,IAAI;AACtB,cAAM,iBAAiB,SAAS,kBAAkB;AAClD,cAAM,WAAW,iBAAiB,IAAI,KAAK,iBAAiB,aAAa;AACzE,cAAM,cAAc,WAAW,IAAI,QAAQ;AAC3C,YAAI,aAAa;AACf,cAAI,YAAY,SAAS,WAAW;AAClC,kBAAM,YAAY;AAAA,UACpB;AACA,iBAAO,YAAY;AAAA,QACrB;AACA,YAAI;AACF,gBAAM,QAAQ,GAAG,SAAS,MAAM,OAAO;AACvC,qBAAW,IAAI,UAAU,EAAE,MAAM,WAAW,OAAO,MAAM,CAAC;AAC1D,iBAAO;AAAA,QACT,SAAS,GAAG;AACV,qBAAW,IAAI,UAAU,EAAE,MAAM,WAAW,OAAO,EAAW,CAAC;AAC/D,gBAAM;AAAA,QACR;AAAA,MACF;AAAA,MACA,KAAK,MAAM,UAAU;AACnB,eAAO,GAAG,QAAQ,IAAI;AAEtB,cAAM,WAAW,iBAAiB,IAAI,IAAI;AAC1C,cAAM,cAAc,WAAW,IAAI,QAAQ;AAC3C,YAAI,aAAa;AACf,cAAI,YAAY,SAAS,WAAW;AAClC,YAAC,SAAgC,YAAY,KAAK;AAAA,UACpD,WAAW,YAAY,SAAS,WAAW;AACzC,qBAAS,MAAM,YAAY,KAAyB;AAAA,UACtD;AAAA,QACF,OAAO;AACL,aAAG,KAAK,MAAM,CAAC,OAAO,UAAU;AAC9B,gBAAI,OAAO;AACT,yBAAW,IAAI,UAAU,EAAE,MAAM,WAAW,MAAM,CAAC;AAAA,YACrD,OAAO;AACL,yBAAW,IAAI,UAAU,EAAE,MAAM,WAAW,OAAO,MAAM,CAAC;AAAA,YAC5D;AAEA,qBAAS,OAAO,KAAK;AAAA,UACvB,CAAC;AAAA,QACH;AAAA,MACF;AAAA,MACA;AAAA,MACA,SAAS,MAAM,UAAU;AACvB,eAAO,GAAG,QAAQ,IAAI;AACtB,cAAM,WAAW,iBAAiB,IAAI;AACtC,cAAM,mBAAmB,cAAc,IAAI,QAAQ;AACnD,YAAI,qBAAqB,QAAW;AAClC,mBAAS,MAAM,gBAAgB;AAAA,QACjC,OAAO;AACL,aAAG,SAAS,MAAM,CAAC,OAAO,eAAe;AACvC,gBAAI,CAAC,OAAO;AACV,4BAAc,IAAI,UAAU,UAAU;AAAA,YACxC;AACA,qBAAS,OAAO,UAAU;AAAA,UAC5B,CAAC;AAAA,QACH;AAAA,MACF;AAAA,IACF,CAAC;AAAA,IACD,WAAW,MAAM,OAAO,OAAO;AAC7B,YAAM,mBAAmB,GAAG,QAAQ,IAAI;AACxC,UAAI,MAAM;AACR,mCAA2B,GAAG,KAAK,kBAAkB,GAAG,GAAG,CAAC;AAAA,MAC9D;AACA,aAAO,mBAAmB,gBAAgB;AAAA,IAC5C;AAAA,IACA,gBAAgB;AACd,iBAAW,MAAM;AAAA,IACnB;AAAA,IACA,UAAU;AAAA,MACR,GAAG;AAAA,MACH,MAAM,SAAS,MAAM;AACnB,eAAO,GAAG,QAAQ,IAAI;AACtB,cAAM,WAAW,iBAAiB,IAAI;AACtC,cAAM,mBAAmB,cAAc,IAAI,QAAQ;AACnD,YAAI,qBAAqB,QAAW;AAClC,iBAAO;AAAA,QACT;AACA,cAAM,aAAa,MAAM,SAAS,SAAS,IAAI;AAC/C,sBAAc,IAAI,UAAU,UAAU;AACtC,eAAO;AAAA,MACT;AAAA,MACA,SAAS,YAAY,oBAAoB,MAAM;AAC7C,0BAAkB,GAAG,QAAQ,eAAe;AAC5C,2BAAmB,eAAe;AAClC,eAAO,SAAS,SAAS,YAAY,iBAAiB,GAAG,IAAI;AAAA,MAC/D;AAAA,MACA,MAAM,kBAAkB,MAAM;AAC5B,wBAAgB,GAAG,QAAQ,aAAa;AACxC,2BAAmB,aAAa;AAChC,eAAO,SAAS,MAAM,eAAe,GAAG,IAAI;AAAA,MAC9C;AAAA,MACA,OAAO,YAAY,iBAAiB;AAClC,qBAAa,GAAG,QAAQ,UAAU;AAClC,0BAAkB,GAAG,QAAQ,eAAe;AAC5C,2BAAmB,UAAU;AAC7B,2BAAmB,eAAe;AAClC,eAAO,SAAS,OAAO,YAAY,eAAe;AAAA,MACpD;AAAA,MACA,MAAM,eAAe;AACnB,wBAAgB,GAAG,QAAQ,aAAa;AACxC,2BAAmB,aAAa;AAChC,eAAO,SAAS,MAAM,aAAa;AAAA,MACrC;AAAA,MACA,GAAG,YAAY,SAAS;AACtB,qBAAa,GAAG,QAAQ,UAAU;AAClC,2BAAmB,UAAU;AAC7B,eAAO,SAAS,GAAG,YAAY,OAAO;AAAA,MACxC;AAAA,MACA,OAAO,UAAU;AACf,mBAAW,GAAG,QAAQ,QAAQ;AAC9B,2BAAmB,QAAQ;AAC3B,eAAO,SAAS,OAAO,QAAQ;AAAA,MACjC;AAAA,MACA,UAAU,aAAa,MAAM;AAC3B,YAAI,UAAU;AACZ,qBAAW,GAAG,QAAQ,QAAQ;AAC9B,6BAAmB,QAAQ;AAAA,QAC7B;AACA,eAAO,SAAS,UAAU,UAAU,GAAG,IAAI;AAAA,MAC7C;AAAA,MACA,MAAM,KAAK,MAAM;AACf,eAAO,GAAG,QAAQ,IAAI;AAEtB,cAAM,WAAW,iBAAiB,IAAI,IAAI;AAC1C,cAAM,cAAc,WAAW,IAAI,QAAQ;AAC3C,YAAI,aAAa;AACf,cAAI,YAAY,SAAS,WAAW;AAClC,kBAAM,YAAY;AAAA,UACpB;AACA,iBAAO,YAAY;AAAA,QACrB;AACA,YAAI;AACF,gBAAM,QAAQ,MAAM,SAAS,KAAK,IAAI;AACtC,qBAAW,IAAI,UAAU,EAAE,MAAM,WAAW,OAAO,MAAM,CAAC;AAC1D,iBAAO;AAAA,QACT,SAAS,GAAG;AACV,qBAAW,IAAI,UAAU,EAAE,MAAM,WAAW,OAAO,EAAW,CAAC;AAC/D,gBAAM;AAAA,QACR;AAAA,MACF;AAAA,MACA,QAAQ,QAAQ,MAAM,MAAM;AAC1B,eAAO,GAAG,QAAQ,IAAI;AACtB,2BAAmB,IAAI;AACvB,eAAO,SAAS,QAAQ,QAAQ,MAAM,IAAI;AAAA,MAC5C;AAAA,IACF;AAAA,EACF;AACF;",
		"names": []
		}

+1

-1

dist/index.d.ts

		@@ -1,2 +0,2 @@
		export * from './cached-fs';
		export * from "./cached-fs";
		//# sourceMappingURL=index.d.ts.map

+3

-3

package.json

		{
		"name": "@file-services/cached",
		"description": "A file system wrapper that adds cache to any `IFileSystem` implementation.",
		"version": "8.3.3",
		"version": "9.0.0",
		"main": "./dist/fs-cached.cjs",
		@@ -21,4 +21,4 @@ "types": "./dist/index.d.ts",
		"dependencies": {
		"@file-services/types": "^8.3.3",
		"@file-services/utils": "^8.3.3"
		"@file-services/types": "^9.0.0",
		"@file-services/utils": "^9.0.0"
		},
		@@ -25,0 +25,0 @@ "files": [

+6

-6

README.md

		@@ -19,15 +19,15 @@ # @file-services/cached
		```ts
		import { nodeFs } from '@file-services/node';
		import { createCachedFs } from '@file-services/cached';
		import { nodeFs } from "@file-services/node";
		import { createCachedFs } from "@file-services/cached";

		const cachedFs = createCachedFs(nodeFs);
		cachedFs.writeFileSync('/file.js', 'CONTENT');
		cachedFs.writeFileSync("/file.js", "CONTENT");

		// calls fs
		cachedFs.statSync('/file.js');
		cachedFs.statSync("/file.js");
		// cached
		cachedFs.statSync('/file.js');
		cachedFs.statSync("/file.js");

		// clears the cache
		cachedFs.invalidate('/file.js');
		cachedFs.invalidate("/file.js");
		```
		@@ -34,0 +34,0 @@

+19

-19

src/cached-fs.ts

		@@ -1,3 +0,3 @@
		import type { IFileSystem, IFileSystemStats, CallbackFnVoid } from '@file-services/types';
		import { createFileSystem } from '@file-services/utils';
		import type { IFileSystem, IFileSystemStats, CallbackFnVoid } from "@file-services/types";
		import { createFileSystem } from "@file-services/utils";

		@@ -20,3 +20,3 @@ const identity = (val: string) => val;
		interface ISuccessCacheResult<T> {
		kind: 'success';
		kind: "success";
		value: T;
		@@ -26,3 +26,3 @@ }
		interface IFailureCacheResult {
		kind: 'failure';
		kind: "failure";
		error: Error;
		@@ -38,4 +38,4 @@ }

		const suffixTrue = delimiter + 'true';
		const suffixFalse = delimiter + 'false';
		const suffixTrue = delimiter + "true";
		const suffixFalse = delimiter + "false";

		@@ -99,3 +99,3 @@ const invalidateAbsolute = (absolutePath: string) => {
		return fs.copyFile(sourcePath, destinationPath, ...args);
		} as IFileSystem['copyFile'],
		} as IFileSystem["copyFile"],
		copyFileSync(sourcePath, destinationPath, ...args) {
		@@ -110,3 +110,3 @@ destinationPath = fs.resolve(destinationPath);
		return fs.mkdir(directoryPath, ...args);
		} as IFileSystem['mkdir'],
		} as IFileSystem["mkdir"],
		mkdirSync(directoryPath, ...args) {
		@@ -167,3 +167,3 @@ directoryPath = fs.resolve(directoryPath);
		return fs.writeFile(filePath, ...args);
		} as IFileSystem['writeFile'],
		} as IFileSystem["writeFile"],
		writeFileSync(filePath, ...args) {
		@@ -182,3 +182,3 @@ if (filePath) {
		if (cachedStats) {
		if (cachedStats.kind === 'failure') {
		if (cachedStats.kind === "failure") {
		throw cachedStats.error;
		@@ -190,6 +190,6 @@ }
		const stats = fs.statSync(path, options);
		statsCache.set(cacheKey, { kind: 'success', value: stats });
		statsCache.set(cacheKey, { kind: "success", value: stats });
		return stats as IFileSystemStats;
		} catch (e) {
		statsCache.set(cacheKey, { kind: 'failure', error: e as Error });
		statsCache.set(cacheKey, { kind: "failure", error: e as Error });
		throw e;
		@@ -204,5 +204,5 @@ }
		if (cachedStats) {
		if (cachedStats.kind === 'failure') {
		if (cachedStats.kind === "failure") {
		(callback as (e: Error) => void)(cachedStats.error);
		} else if (cachedStats.kind === 'success') {
		} else if (cachedStats.kind === "success") {
		callback(null, cachedStats.value as IFileSystemStats);
		@@ -213,5 +213,5 @@ }
		if (error) {
		statsCache.set(cacheKey, { kind: 'failure', error });
		statsCache.set(cacheKey, { kind: "failure", error });
		} else {
		statsCache.set(cacheKey, { kind: 'success', value: stats });
		statsCache.set(cacheKey, { kind: "success", value: stats });
		}
		@@ -308,3 +308,3 @@
		if (cachedStats) {
		if (cachedStats.kind === 'failure') {
		if (cachedStats.kind === "failure") {
		throw cachedStats.error;
		@@ -316,6 +316,6 @@ }
		const stats = await promises.stat(path);
		statsCache.set(cacheKey, { kind: 'success', value: stats });
		statsCache.set(cacheKey, { kind: "success", value: stats });
		return stats;
		} catch (e) {
		statsCache.set(cacheKey, { kind: 'failure', error: e as Error });
		statsCache.set(cacheKey, { kind: "failure", error: e as Error });
		throw e;
		@@ -322,0 +322,0 @@ }

+1

-1

src/index.ts

		@@ -1,1 +0,1 @@
		export * from './cached-fs';
		export * from "./cached-fs";

@file-services/cached - npm Package Compare versions

New alerts

Fixed alerts

Improved metrics

Dependency changes