Cache localstorage fix

package.json

@@ -1,6 +1,6 @@
 {
 	"name": "@ztimson/utils",
-	"version": "0.18.1",
+	"version": "0.20.7",
 	"description": "Utility library",
 	"author": "Zak Timson",
 	"license": "MIT",
@@ -38,8 +38,5 @@
 	},
 	"files": [
 		"dist"
-	],
-	"dependencies": {
-		"var-persist": "^1.0.1"
-	}
+	]
 }

src/cache.ts

@@ -1,3 +1,12 @@
+export type CacheOptions = {
+	/** Delete keys automatically after x amount of seconds */
+	ttl?: number;
+	/** Storage to persist cache */
+	storage?: Storage;
+	/** Key cache will be stored under */
+	storageKey?: string;
+}
+
 /**
  * Map of data which tracks whether it is a complete collection & offers optional expiry of cached values
  */
@@ -13,9 +22,18 @@ export class Cache<K extends string | number | symbol, T> {
 	 * Create new cache
 	 *
 	 * @param {keyof T} key Default property to use as primary key
-	 * @param {number} ttl Default expiry in milliseconds
+	 * @param options
 	 */
-	constructor(public readonly key?: keyof T, public ttl?: number) {
+	constructor(public readonly key?: keyof T, public readonly options: CacheOptions = {}) {
+		if(options.storageKey && !options.storage && typeof(Storage) !== 'undefined')
+			options.storage = localStorage;
+		if(options.storageKey && options.storage) {
+			const stored = options.storage.getItem(options.storageKey);
+			if(stored) {
+				try { Object.assign(this.store, JSON.parse(stored)); }
+				catch { }
+			}
+		}
 		return new Proxy(this, {
 			get: (target: this, prop: string | symbol) => {
 				if (prop in target) return (target as any)[prop];
@@ -69,6 +87,13 @@ export class Cache<K extends string | number | symbol, T> {
 		return this;
 	}
 
+	/**
+	 * Remove all keys from cache
+	 */
+	clear() {
+		this.store = <Record<K, T>>{};
+	}
+
 	/**
 	 * Delete an item from the cache
 	 *
@@ -76,6 +101,8 @@ export class Cache<K extends string | number | symbol, T> {
 	 */
 	delete(key: K) {
 		delete this.store[key];
+		if(this.options.storageKey && this.options.storage)
+			this.options.storage.setItem(this.options.storageKey, JSON.stringify(this.store));
 	}
 
 	/**
@@ -118,15 +145,17 @@ export class Cache<K extends string | number | symbol, T> {
 	 *
 	 * @param {K} key Key item will be cached under
 	 * @param {T} value Item to cache
-	 * @param {number | undefined} ttl Override default expiry
+	 * @param {number | undefined} ttl Override default expiry in seconds
 	 * @return {this}
 	 */
-	set(key: K, value: T, ttl = this.ttl): this {
+	set(key: K, value: T, ttl = this.options.ttl): this {
 		this.store[key] = value;
+		if(this.options.storageKey && this.options.storage)
+			this.options.storage.setItem(this.options.storageKey, JSON.stringify(this.store));
 		if(ttl) setTimeout(() => {
 			this.complete = false;
 			this.delete(key);
-		}, ttl);
+		}, ttl * 1000);
 		return this;
 	}
 

src/emitter.ts

@@ -1,33 +1,33 @@
-export type Listener = (...args: any[]) => any;
-export type TypedEvents = {[k in string | symbol]: Listener} & {'*': (event: string, ...args: any[]) => any};
+export type TypedListener = (...args: any[]) => any;
+export type TypedEvents = {[k in string | symbol]: TypedListener} & {'*': (event: string, ...args: any[]) => any};
 
 export type NamespaceEvents<Namespace extends string, Events extends TypedEvents> = {
 	[K in keyof Events as `${Namespace}:${Extract<K, string>}`]: Events[K];
 };
 
 export class TypedEmitter<T extends TypedEvents = TypedEvents> {
-	private static listeners: {[key: string]: Listener[]} = {};
+	private static listeners: {[key: string]: TypedListener[]} = {};
 
-	private listeners: { [key in keyof T]?: Listener[] } = {};
+	private listeners: { [key in keyof T]?: TypedListener[] } = {};
 
 	static emit(event: any, ...args: any[]) {
 		(this.listeners['*'] || []).forEach(l => l(event, ...args));
 		(this.listeners[event.toString()] || []).forEach(l => l(...args));
 	};
 
-	static off(event: any, listener: Listener) {
+	static off(event: any, listener: TypedListener) {
 		const e = event.toString();
 		this.listeners[e] = (this.listeners[e] || []).filter(l => l === listener);
 	}
 
-	static on(event: any, listener: Listener) {
+	static on(event: any, listener: TypedListener) {
 		const e = event.toString();
 		if(!this.listeners[e]) this.listeners[e] = [];
 		this.listeners[e]?.push(listener);
 		return () => this.off(event, listener);
 	}
 
-	static once(event: any, listener?: Listener): Promise<any> {
+	static once(event: any, listener?: TypedListener): Promise<any> {
 		return new Promise(res => {
 			const unsubscribe = this.on(event, <any>((...args: any) => {
 				res(args.length == 1 ? args[0] : args);

src/http.ts

@@ -75,47 +75,52 @@ export class Http {
 
 		// Send request
 		return new PromiseProgress((res, rej, prog) => {
-			fetch(url, {
-				headers,
-				method: opts.method || (opts.body ? 'POST' : 'GET'),
-				body: opts.body
-			}).then(async (resp: any) => {
-				for(let fn of [...Object.values(Http.interceptors), ...Object.values(this.interceptors)]) {
-					await new Promise<void>(res => fn(resp, () => res()));
-				}
-
-				const contentLength = resp.headers.get('Content-Length');
-				const total = contentLength ? parseInt(contentLength, 10) : 0;
-				let loaded = 0;
-
-				const reader = resp.body?.getReader();
-				const stream = new ReadableStream({
-					start(controller) {
-						function push() {
-							reader?.read().then((event: any) => {
-								if(event.done) return controller.close();
-								loaded += event.value.byteLength;
-								prog(loaded / total);
-								controller.enqueue(event.value);
-								push();
-							}).catch((error: any) => controller.error(error));
-						}
-						push();
+			try {
+				fetch(url, {
+					headers,
+					method: opts.method || (opts.body ? 'POST' : 'GET'),
+					body: opts.body
+				}).then(async (resp: any) => {
+					for(let fn of [...Object.values(Http.interceptors), ...Object.values(this.interceptors)]) {
+						await new Promise<void>(res => fn(resp, () => res()));
 					}
-				});
 
-				resp.data = new Response(stream);
-				if(opts.decode == null || opts.decode) {
-					const content = resp.headers.get('Content-Type')?.toLowerCase();
-					if(content?.includes('form')) resp.data = <T>await resp.data.formData();
-					else if(content?.includes('json')) resp.data = <T>await resp.data.json();
-					else if(content?.includes('text')) resp.data = <T>await resp.data.text();
-					else if(content?.includes('application')) resp.data = <T>await resp.data.blob();
-				}
+					const contentLength = resp.headers.get('Content-Length');
+					const total = contentLength ? parseInt(contentLength, 10) : 0;
+					let loaded = 0;
 
-				if(resp.ok) res(resp);
-				else rej(resp);
-			})
+					const reader = resp.body?.getReader();
+					const stream = new ReadableStream({
+						start(controller) {
+							function push() {
+								reader?.read().then((event: any) => {
+									if(event.done) return controller.close();
+									loaded += event.value.byteLength;
+									prog(loaded / total);
+									controller.enqueue(event.value);
+									push();
+								}).catch((error: any) => controller.error(error));
+							}
+
+							push();
+						}
+					});
+
+					resp.data = new Response(stream);
+					if(opts.decode == null || opts.decode) {
+						const content = resp.headers.get('Content-Type')?.toLowerCase();
+						if(content?.includes('form')) resp.data = <T>await resp.data.formData();
+						else if(content?.includes('json')) resp.data = <T>await resp.data.json();
+						else if(content?.includes('text')) resp.data = <T>await resp.data.text();
+						else if(content?.includes('application')) resp.data = <T>await resp.data.blob();
+					}
+
+					if(resp.ok) res(resp);
+					else rej(resp);
+				}).catch(err => rej(err));
+			} catch(err) {
+				rej(err);
+			}
 		});
 	}
 }

src/index.ts

@@ -11,8 +11,8 @@ export * from './logger';
 export * from './math';
 export * from './misc';
 export * from './objects';
+export * from './path-events';
 export * from './promise-progress';
 export * from './string';
 export * from './time';
 export * from './types';
-export * from 'var-persist';

src/misc.ts

@@ -1,3 +1,4 @@
+import {PathEvent} from './path-events.ts';
 import {md5} from './string';
 
 /**
@@ -18,6 +19,9 @@ export function gravatar(email: string, def='mp') {
  * @param {string} value String which should be escaped
  * @return {string} New escaped sequence
  */
-function escapeRegex(value: string) {
+export function escapeRegex(value: string) {
 	return value.replace(/[.*+?^${}()|\[\]\\]/g, '\\$&');
 }
+
+export type Listener = (event: PathEvent, ...args: any[]) => any;
+export type Unsubscribe = () => void;

src/path-events.ts

@@ -0,0 +1,256 @@
+import {makeArray} from './array.ts';
+import {ASet} from './aset.ts';
+
+/**
+ * Available methods:
+ * * - All/Wildcard
+ * n - None
+ * c - Create
+ * r - Read
+ * u - Update
+ * d - Delete
+ * x - Execute
+ */
+export type Method = '*' | 'n' | 'c' | 'r' | 'u' | 'd' | 'x';
+
+/**
+ * Shorthand for creating Event from a string
+ *
+ * @example
+ * ```ts
+ * const event: Event = PE`users/system:*`;
+ * ```
+ *
+ * @param {TemplateStringsArray} str String that will be parsed into Event
+ * @param {string} args
+ * @return {PathEvent} Event object
+ */
+export function PE(str: TemplateStringsArray, ...args: string[]) {
+	const combined = [];
+	for(let i = 0; i < str.length || i < args.length; i++) {
+		if(str[i]) combined.push(str[i]);
+		if(args[i]) combined.push(args[i]);
+	}
+	return new PathEvent(combined.join(''));
+}
+
+/**
+ * Shorthand for creating Event strings, ensures paths are correct
+ *
+ * @param {TemplateStringsArray} str
+ * @param {string} args
+ * @return {string}
+ * @constructor
+ */
+export function PES(str: TemplateStringsArray, ...args: any[]) {
+	let combined = [];
+	for(let i = 0; i < str.length || i < args.length; i++) {
+		if(str[i]) combined.push(str[i]);
+		if(args[i]) combined.push(args[i]);
+	}
+	const [paths, methods] = combined.join('').split(':');
+	return PathEvent.toString(paths, <any>methods?.split(''));
+}
+
+/**
+ * A  event broken down into its core components for easy processing
+ * Event Structure: `module/path/name:property:method`
+ * Example: `users/system:crud` or `storage/some/path/file.txt:r`
+ */
+export class PathEvent {
+	/** First directory in path */
+	module!: string;
+	/** Entire path, including the module & name */
+	fullPath!: string;
+	/** Path including the name, excluding the module */
+	path!: string;
+	/** Last sagment of path */
+	name!: string;
+	/** List of methods */
+	methods!: Method[];
+	/** All/Wildcard specified */
+	all!: boolean;
+	/** None specified */
+	none!: boolean;
+	/** Create method specified */
+	create!: boolean;
+	/** Read method specified */
+	read!: boolean;
+	/** Update method specified */
+	update!: boolean;
+	/** Delete method specified */
+	delete!: boolean;
+
+	constructor(Event: string | PathEvent) {
+		if(typeof Event == 'object') return Object.assign(this, Event);
+		let [p, scope, method] = Event.split(':');
+		if(!method) method = scope || '*';
+		if(p == '*' || !p && method == '*') {
+			p = '';
+			method = '*';
+		}
+		let temp = p.split('/').filter(p => !!p);
+		this.module = temp.splice(0, 1)[0]?.toLowerCase() || '';
+		this.fullPath = p;
+		this.path = temp.join('/');
+		this.name = temp.pop() || '';
+		this.methods = <Method[]>method.split('');
+		this.all = method?.includes('*');
+		this.none = method?.includes('n');
+		this.create = !method?.includes('n') && (method?.includes('*') || method?.includes('w') || method?.includes('c'));
+		this.read = !method?.includes('n') && (method?.includes('*') || method?.includes('r'));
+		this.update = !method?.includes('n') && (method?.includes('*') || method?.includes('w') || method?.includes('u'));
+		this.delete = !method?.includes('n') && (method?.includes('*') || method?.includes('w') || method?.includes('d'));
+	}
+
+	/**
+	 * Combine multiple  events into one parsed object. Longest path takes precedent, but all subsequent methods are
+	 * combined until a "none" is reached
+	 *
+	 * @param {string | PathEvent} paths Events as strings or pre-parsed
+	 * @return {PathEvent} Final combined permission
+	 */
+	static combine(paths: (string | PathEvent)[]): PathEvent {
+		let hitNone = false;
+		const combined = paths.map(p => new PathEvent(p))
+			.toSorted((p1, p2) => {
+				const l1 = p1.fullPath.length, l2 = p2.fullPath.length;
+				return l1 < l2 ? 1 : (l1 > l2 ? -1 : 0);
+			}).reduce((acc, p) => {
+				if(p.none) hitNone = true;
+				if(!acc) return p;
+				if(hitNone) return acc;
+				if(p.all) acc.all = true;
+				if(p.all || p.create) acc.create = true;
+				if(p.all || p.read) acc.read = true;
+				if(p.all || p.update) acc.update = true;
+				if(p.all || p.delete) acc.delete = true;
+				acc.methods = [...acc.methods, ...p.methods];
+				return acc;
+			}, <any>null);
+		if(combined.all) combined.methods = ['*'];
+		if(combined.none) combined.methods = ['n'];
+		combined.methods = new ASet(combined.methods); // Make unique
+		combined.raw = PES`${combined.fullPath}:${combined.methods}`;
+		return combined;
+	}
+
+	/**
+	 * Squash 2 sets of paths & return true if any overlap is found
+	 *
+	 * @param {string | PathEvent | (string | PathEvent)[]} target Array of Events as strings or pre-parsed
+	 * @param has Target must have at least one of these path
+	 * @return {boolean} Whether there is any overlap
+	 */
+	static has(target: string | PathEvent | (string | PathEvent)[], ...has: (string | PathEvent)[]): boolean {
+		const parsedRequired = makeArray(has).map(pe => new PathEvent(pe));
+		const parsedTarget = makeArray(target).map(pe => new PathEvent(pe));
+		return !!parsedRequired.find(r => {
+			if(!r.fullPath && r.all) return true;
+			const filtered = parsedTarget.filter(p => r.fullPath.startsWith(p.fullPath));
+			if(!filtered.length) return false;
+			const combined = PathEvent.combine(filtered);
+			return !combined.none && (combined.all || new ASet(combined.methods).intersection(new ASet(r.methods)).length);
+		});
+	}
+
+	/**
+	 * Squash 2 sets of paths & return true if the target has all paths
+	 *
+	 * @param {string | PathEvent | (string | PathEvent)[]} target Array of Events as strings or pre-parsed
+	 * @param has Target must have all these paths
+	 * @return {boolean} Whether there is any overlap
+	 */
+	static hasAll(target: string | PathEvent | (string | PathEvent)[], ...has: (string | PathEvent)[]): boolean {
+		return has.filter(h => PathEvent.has(target, h)).length == has.length;
+	}
+
+	/**
+	 * Same as `has` but raises an error if there is no overlap
+	 *
+	 * @param {string | string[]} target Array of Events as strings or pre-parsed
+	 * @param has Target must have at least one of these path
+	 */
+	static hasFatal(target: string | PathEvent | (string | PathEvent)[], ...has: (string | PathEvent)[]): void {
+		if(!PathEvent.has(target, ...has)) throw new Error(`Requires one of: ${makeArray(has).join(', ')}`);
+	}
+
+	/**
+	 * Same as `hasAll` but raises an error if the target is missing any paths
+	 *
+	 * @param {string | string[]} target Array of Events as strings or pre-parsed
+	 * @param has Target must have all these paths
+	 */
+	static hasAllFatal(target: string | PathEvent | (string | PathEvent)[], ...has: (string | PathEvent)[]): void {
+		if(!PathEvent.hasAll(target, ...has)) throw new Error(`Requires all: ${makeArray(has).join(', ')}`);
+	}
+
+	/**
+	 * Create  event string from its components
+	 *
+	 * @param {string | string[]} path Event path
+	 * @param {Method} methods Event method
+	 * @return {string} String representation of Event
+	 */
+	static toString(path: string | string[], methods: Method | Method[]): string {
+		let p = makeArray(path).filter(p => p != null).join('/');
+		if(methods?.length) p += `:${makeArray(methods).map(m => m.toLowerCase()).join('')}`;
+		return p?.trim().replaceAll(/\/{2,}/g, '/').replaceAll(/(^\/|\/$)/g, '');
+	}
+
+	/**
+	 * Create  event string from its components
+	 *
+	 * @return {string} String representation of Event
+	 */
+	toString() {
+		return PathEvent.toString(this.fullPath, this.methods);
+	}
+}
+
+export type PathListener = (event: PathEvent, ...args: any[]) => any;
+export type PathUnsubscribe = () => void;
+
+export interface IPathEventEmitter {
+	emit(event: string, ...args: any[]): void;
+	off(listener: PathListener): void;
+	on(event: string, listener: PathListener): PathUnsubscribe;
+	once(event: string, listener?: PathListener): Promise<any>;
+	relayEvents(emitter: PathEventEmitter): void;
+}
+
+/**
+ * Event emitter that uses paths allowing listeners to listen to different combinations of modules, paths & methods
+ */
+export class PathEventEmitter implements IPathEventEmitter{
+	private listeners: [PathEvent, PathListener][] = [];
+
+	emit(event: string | PathEvent, ...args: any[]) {
+		const parsed = new PathEvent(event);
+		this.listeners.filter(l => PathEvent.has(l[0], event))
+			.forEach(async l => l[1](parsed, ...args));
+	};
+
+	off(listener: PathListener) {
+		this.listeners = this.listeners.filter(l => l[1] != listener);
+	}
+
+	on(event: string | string[], listener: PathListener): PathUnsubscribe {
+		makeArray(event).forEach(e => this.listeners.push([new PathEvent(e), listener]));
+		return () => this.off(listener);
+	}
+
+	once(event: string | string[], listener?: PathListener): Promise<any> {
+		return new Promise(res => {
+			const unsubscribe = this.on(event, (event: PathEvent, ...args: any[]) => {
+				res(args.length < 2 ? args[0] : args);
+				if(listener) listener(event, ...args);
+				unsubscribe();
+			});
+		});
+	}
+
+	relayEvents(emitter: IPathEventEmitter) {
+		emitter.on('*', (event, ...args) => this.emit(event, ...args));
+	}
+}