* Fixed cache expiry

+ Prefix PathEvents

package.json

@@ -1,6 +1,6 @@
 {
 	"name": "@ztimson/utils",
-	"version": "0.24.4",
+	"version": "0.24.12",
 	"description": "Utility library",
 	"author": "Zak Timson",
 	"license": "MIT",

src/aset.ts

@@ -29,6 +29,14 @@ export class ASet<T> extends Array {
 		return this;
 	}
 
+	/**
+	 * Remove all elements
+	 */
+	clear() {
+		this.splice(0, this.length);
+		return this;
+	}
+
 	/**
 	 * Delete elements from set
 	 * @param items Elements that will be deleted

src/cache.ts

@@ -7,16 +7,20 @@ export type CacheOptions = {
 	storage?: Storage;
 	/** Key cache will be stored under */
 	storageKey?: string;
+	/** Keep or delete cached items once expired, defaults to delete */
+	expiryPolicy?: 'delete' | 'keep';
 }
 
+export type CachedValue<T> = T & {_expired?: boolean};
+
 /**
  * Map of data which tracks whether it is a complete collection & offers optional expiry of cached values
  */
 export class Cache<K extends string | number | symbol, T> {
-	private store = <Record<K, T>>{};
+	private store: Record<K, T> = <any>{};
 
 	/** Support index lookups */
-	[key: string | number | symbol]: T | any;
+	[key: string | number | symbol]: CachedValue<T> | any;
 	/** Whether cache is complete */
 	complete = false;
 
@@ -38,7 +42,7 @@ export class Cache<K extends string | number | symbol, T> {
 		return new Proxy(this, {
 			get: (target: this, prop: string | symbol) => {
 				if(prop in target) return (target as any)[prop];
-				return deepCopy(target.store[prop as K]);
+				return this.get(prop as K, true);
 			},
 			set: (target: this, prop: string | symbol, value: any) => {
 				if(prop in target) (target as any)[prop] = value;
@@ -53,12 +57,18 @@ export class Cache<K extends string | number | symbol, T> {
 		return <K>value[this.key];
 	}
 
+	private save() {
+		if(this.options.storageKey && this.options.storage)
+			this.options.storage.setItem(this.options.storageKey, JSON.stringify(this.store));
+	}
+
 	/**
 	 * Get all cached items
 	 * @return {T[]} Array of items
 	 */
-	all(): T[] {
-		return deepCopy(Object.values(this.store));
+	all(expired?: boolean): CachedValue<T>[] {
+		return deepCopy<any>(Object.values(this.store)
+			.filter((v: any) => expired || !v._expired));
 	}
 
 	/**
@@ -90,7 +100,8 @@ export class Cache<K extends string | number | symbol, T> {
 	 * Remove all keys from cache
 	 */
 	clear() {
-		this.store = <Record<K, T>>{};
+		this.complete = false;
+		this.store = <any>{};
 	}
 
 	/**
@@ -99,16 +110,26 @@ 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));
+		this.save();
 	}
 
 	/**
 	 * Return cache as an array of key-value pairs
 	 * @return {[K, T][]} Key-value pairs array
 	 */
-	entries(): [K, T][] {
-		return <[K, T][]>Object.entries(this.store);
+	entries(expired?: boolean): [K, CachedValue<T>][] {
+		return deepCopy<any>(Object.entries(this.store)
+			.filter((v: any) => expired || !v?._expired));
+	}
+
+	/**
+	 * Manually expire a cached item
+	 * @param {K} key Key to expire
+	 */
+	expire(key: K) {
+		this.complete = false;
+		if(this.options.expiryPolicy == 'keep') (<any>this.store[key])._expired = true;
+		else this.delete(key);
 	}
 
 	/**
@@ -116,24 +137,31 @@ export class Cache<K extends string | number | symbol, T> {
 	 * @param {K} key Key to lookup
 	 * @return {T} Cached item
 	 */
-	get(key: K): T {
-		return deepCopy(this.store[key]);
+	get(key: K, expired?: boolean): T | null {
+		const cached = deepCopy<any>(this.store[key] ?? null);
+		if(expired || !cached?._expired) return cached;
+		return null;
 	}
 
 	/**
 	 * Get a list of cached keys
 	 * @return {K[]} Array of keys
 	 */
-	keys(): K[] {
-		return <K[]>Object.keys(this.store);
+	keys(expired?: boolean): K[] {
+		return <K[]>Object.keys(this.store)
+			.filter(k => expired || !(<any>this.store)[k]._expired);
 	}
 
 	/**
 	 * Get map of cached items
 	 * @return {Record<K, T>}
 	 */
-	map(): Record<K, T> {
-		return deepCopy(this.store);
+	map(expired?: boolean): Record<K, CachedValue<T>> {
+		const copy: any = deepCopy(this.store);
+		if(!expired) Object.keys(copy).forEach(k => {
+			if(copy[k]._expired) delete copy[k]
+		});
+		return copy;
 	}
 
 	/**
@@ -144,12 +172,12 @@ export class Cache<K extends string | number | symbol, T> {
 	 * @return {this}
 	 */
 	set(key: K, value: T, ttl = this.options.ttl): this {
+		if(this.options.expiryPolicy == 'keep') delete (<any>value)._expired;
 		this.store[key] = value;
-		if(this.options.storageKey && this.options.storage)
-			this.options.storage.setItem(this.options.storageKey, JSON.stringify(this.store));
+		this.save();
 		if(ttl) setTimeout(() => {
-			this.complete = false;
-			this.delete(key);
+			this.expire(key);
+			this.save();
 		}, ttl * 1000);
 		return this;
 	}

src/path-events.ts

@@ -90,9 +90,9 @@ export class PathEvent {
 	get delete(): boolean { return !this.methods.has('n') && (this.methods.has('*') || this.methods.has('d')) }
 	set delete(v: boolean) { v ? this.methods.delete('n').delete('*').add('d') : this.methods.delete('d'); }
 
-	constructor(Event: string | PathEvent) {
-		if(typeof Event == 'object') return Object.assign(this, Event);
-		let [p, scope, method] = Event.replaceAll(/\/{2,}/g, '/').split(':');
+	constructor(e: string | PathEvent) {
+		if(typeof e == 'object') return Object.assign(this, e);
+		let [p, scope, method] = e.replaceAll(/\/{2,}/g, '/').split(':');
 		if(!method) method = scope || '*';
 		if(p == '*' || !p && method == '*') {
 			p = '';
@@ -100,14 +100,14 @@ export class PathEvent {
 		}
 		let temp = p.split('/').filter(p => !!p);
 		this.module = temp.splice(0, 1)[0]?.toLowerCase() || '';
-		this.fullPath = p;
 		this.path = temp.join('/');
+		this.fullPath = `${this.module}${this.module && this.path ? '/' : ''}${this.path}`;
 		this.name = temp.pop() || '';
 		this.methods = new ASet(<any>method.split(''));
 	}
 
 	/**
-	 * Combine multiple  events into one parsed object. Longest path takes precedent, but all subsequent methods are
+	 * 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
@@ -199,14 +199,14 @@ export class PathEvent {
 	}
 
 	/**
-	 * Create  event string from its components
+	 * 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('/');
+		let p = makeArray(path).filter(p => !!p).join('/');
 		p = p?.trim().replaceAll(/\/{2,}/g, '/').replaceAll(/(^\/|\/$)/g, '');
 		if(methods?.length) p += `:${makeArray(methods).map(m => m.toLowerCase()).join('')}`;
 		return p;
@@ -223,7 +223,7 @@ export class PathEvent {
 	}
 
 	/**
-	 * Create  event string from its components
+	 * Create event string from its components
 	 *
 	 * @return {string} String representation of Event
 	 */
@@ -235,11 +235,12 @@ export class PathEvent {
 export type PathListener = (event: PathEvent, ...args: any[]) => any;
 export type PathUnsubscribe = () => void;
 
+export type Event = string | PathEvent;
 export interface IPathEventEmitter {
-	emit(event: string, ...args: any[]): void;
+	emit(event: Event, ...args: any[]): void;
 	off(listener: PathListener): void;
-	on(event: string, listener: PathListener): PathUnsubscribe;
-	once(event: string, listener?: PathListener): Promise<any>;
+	on(event: Event | Event[], listener: PathListener): PathUnsubscribe;
+	once(event: Event | Event[], listener?: PathListener): Promise<any>;
 	relayEvents(emitter: PathEventEmitter): void;
 }
 
@@ -249,8 +250,10 @@ export interface IPathEventEmitter {
 export class PathEventEmitter implements IPathEventEmitter{
 	private listeners: [PathEvent, PathListener][] = [];
 
-	emit(event: string | PathEvent, ...args: any[]) {
-		const parsed = new PathEvent(event);
+	constructor(public readonly prefix: string = '') { }
+
+	emit(event: Event, ...args: any[]) {
+		const parsed = new PathEvent(`${this.prefix}/${typeof event == 'string' ? event : event.toString()}`);
 		this.listeners.filter(l => PathEvent.has(l[0], event))
 			.forEach(async l => l[1](parsed, ...args));
 	};
@@ -259,12 +262,15 @@ export class PathEventEmitter implements IPathEventEmitter{
 		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]));
+	on(event: Event | Event[], listener: PathListener): PathUnsubscribe {
+		makeArray(event).forEach(e => this.listeners.push([
+			new PathEvent(`${this.prefix}/${typeof e == 'string' ? event : event.toString()}`),
+			listener
+		]));
 		return () => this.off(listener);
 	}
 
-	once(event: string | string[], listener?: PathListener): Promise<any> {
+	once(event: Event | Event[], listener?: PathListener): Promise<any> {
 		return new Promise(res => {
 			const unsubscribe = this.on(event, (event: PathEvent, ...args: any[]) => {
 				res(args.length < 2 ? args[0] : args);

src/types.ts

@@ -18,3 +18,10 @@
 export function typeKeys<T extends object>() {
 	return Object.keys(<T>{}) as Array<keyof T>;
 }
+
+/**
+ * Mark all properties as writable
+ */
+export type Writable<T> = {
+	-readonly [P in keyof T]: T[P]
+};

tests/path-events.spec.ts

@@ -0,0 +1,43 @@
+import {PathEvent} from '../src';
+
+describe('Path Events', () => {
+	describe('malformed', () => {
+		test('starting slash', async () =>
+			expect(new PathEvent('/module').toString()).toEqual('module:*'));
+		test('trailing slash', async () =>
+			expect(new PathEvent('module/').toString()).toEqual('module:*'));
+		test('double slash', async () =>
+			expect(new PathEvent('module////path').toString()).toEqual('module/path:*'));
+	});
+
+	describe('methods', () => {
+		test('custom', async () => {
+			expect(new PathEvent('module:t').methods.includes('t')).toBeTruthy();
+			expect(new PathEvent('module:t').methods.includes('z')).toBeFalsy();
+		});
+		test('create', async () =>
+			expect(new PathEvent('module:crud').create).toBeTruthy());
+		test('read', async () =>
+			expect(new PathEvent('module:crud').read).toBeTruthy());
+		test('update', async () =>
+			expect(new PathEvent('module:crud').update).toBeTruthy());
+		test('delete', async () =>
+			expect(new PathEvent('module:crud').delete).toBeTruthy());
+		test('none', async () => {
+			const event = new PathEvent('module:n');
+			expect(event.none).toBeTruthy();
+			expect(event.create).toBeFalsy();
+			expect(event.read).toBeFalsy();
+			expect(event.update).toBeFalsy();
+			expect(event.delete).toBeFalsy()
+		});
+		test('wildcard', async () => {
+			const event = new PathEvent('module:*');
+			expect(event.none).toBeFalsy();
+			expect(event.create).toBeTruthy();
+			expect(event.read).toBeTruthy();
+			expect(event.update).toBeTruthy();
+			expect(event.delete).toBeTruthy()
+		});
+	});
+});