Compare commits
3 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| d29d0d5121 | |||
| 5b3bbdf02c | |||
| 6b379270a9 |
1
.gitignore
vendored
1
.gitignore
vendored
@@ -10,6 +10,7 @@ uploads
|
||||
public/momentum*js
|
||||
junit.xml
|
||||
/docs/
|
||||
main.mjs
|
||||
|
||||
# Logs
|
||||
*.log
|
||||
|
||||
6927
package-lock.json
generated
Normal file
6927
package-lock.json
generated
Normal file
File diff suppressed because it is too large
Load Diff
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"name": "@ztimson/utils",
|
||||
"version": "0.29.4",
|
||||
"version": "0.29.7",
|
||||
"description": "Utility library",
|
||||
"author": "Zak Timson",
|
||||
"license": "MIT",
|
||||
|
||||
24
src/files.ts
24
src/files.ts
@@ -83,6 +83,7 @@ export function timestampFilename(name?: string, date: Date | number | string =
|
||||
|
||||
/**
|
||||
* Upload file to URL with progress callback using PromiseProgress
|
||||
* Works in both browser (with progress) and Node.js (fallback without progress)
|
||||
*
|
||||
* @param {{url: string, files: File[], headers?: {[p: string]: string}, withCredentials?: boolean}} options
|
||||
* @return {PromiseProgress<T>} Promise of request with `onProgress` callback
|
||||
@@ -93,10 +94,12 @@ export function uploadWithProgress<T>(options: {
|
||||
headers?: {[key: string]: string};
|
||||
withCredentials?: boolean;
|
||||
}): PromiseProgress<T> {
|
||||
// Browser environment - use XMLHttpRequest for progress
|
||||
if (typeof XMLHttpRequest !== 'undefined') {
|
||||
return new PromiseProgress<T>((res, rej, prog) => {
|
||||
const xhr = new XMLHttpRequest();
|
||||
const formData = new FormData();
|
||||
options.files.forEach(f => formData.append('file', f));
|
||||
options.files.forEach(f => formData.append('files', f));
|
||||
|
||||
xhr.withCredentials = !!options.withCredentials;
|
||||
xhr.upload.addEventListener('progress', (event) => event.lengthComputable ? prog(event.loaded / event.total) : null);
|
||||
@@ -108,4 +111,23 @@ export function uploadWithProgress<T>(options: {
|
||||
Object.entries(options.headers || {}).forEach(([key, value]) => xhr.setRequestHeader(key, value));
|
||||
xhr.send(formData);
|
||||
});
|
||||
}
|
||||
|
||||
// Node.js environment - fallback to fetch without progress
|
||||
return new PromiseProgress<T>(async (res, rej) => {
|
||||
try {
|
||||
const formData = new FormData();
|
||||
options.files.forEach(f => formData.append('files', f));
|
||||
const response = await fetch(options.url, {method: 'POST', headers: options.headers || {}, body: formData});
|
||||
if(!response.ok) {
|
||||
const error = await response.text();
|
||||
rej(JSONAttemptParse(error));
|
||||
} else {
|
||||
const result = await response.text();
|
||||
res(<T>JSONAttemptParse(result));
|
||||
}
|
||||
} catch (error) {
|
||||
rej(error);
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
@@ -76,8 +76,18 @@ export class PathEvent {
|
||||
/** Whether this path contains glob patterns */
|
||||
hasGlob!: boolean;
|
||||
|
||||
/** Internal cache for PathEvent instances to avoid redundant parsing */
|
||||
private static pathEventCache: Map<string, PathEvent> = new Map();
|
||||
/** Internal cache for parsed path data (plain objects, not instances) */
|
||||
private static pathEventCache: Map<string, {
|
||||
module: string;
|
||||
fullPath: string;
|
||||
dir: string;
|
||||
path: string;
|
||||
name: string;
|
||||
methods: Method[];
|
||||
hasGlob: boolean;
|
||||
}> = new Map();
|
||||
/** Max size for path cache before LRU eviction */
|
||||
private static readonly MAX_PATH_CACHE_SIZE = 1000;
|
||||
/** Cache for compiled permissions (path + required permissions → result) */
|
||||
private static permissionCache: Map<string, PathEvent> = new Map();
|
||||
/** Max size for permission cache before LRU eviction */
|
||||
@@ -111,8 +121,20 @@ export class PathEvent {
|
||||
return;
|
||||
}
|
||||
|
||||
// Check cache and reconstruct from plain object
|
||||
if(PathEvent.pathEventCache.has(e)) {
|
||||
Object.assign(this, PathEvent.pathEventCache.get(e)!);
|
||||
const cached = PathEvent.pathEventCache.get(e)!;
|
||||
// Move to end (LRU - most recently used)
|
||||
PathEvent.pathEventCache.delete(e);
|
||||
PathEvent.pathEventCache.set(e, cached);
|
||||
|
||||
this.module = cached.module;
|
||||
this.fullPath = cached.fullPath;
|
||||
this.dir = cached.dir;
|
||||
this.path = cached.path;
|
||||
this.name = cached.name;
|
||||
this.methods = new ASet(cached.methods);
|
||||
this.hasGlob = cached.hasGlob;
|
||||
return;
|
||||
}
|
||||
|
||||
@@ -128,19 +150,49 @@ export class PathEvent {
|
||||
this.name = '';
|
||||
this.methods = new ASet<Method>(p === '*' ? ['*'] : <any>method.split(''));
|
||||
this.hasGlob = true;
|
||||
PathEvent.pathEventCache.set(e, this);
|
||||
|
||||
// LRU eviction
|
||||
if(PathEvent.pathEventCache.size >= PathEvent.MAX_PATH_CACHE_SIZE) {
|
||||
const firstKey = PathEvent.pathEventCache.keys().next().value;
|
||||
if(firstKey) PathEvent.pathEventCache.delete(firstKey);
|
||||
}
|
||||
|
||||
PathEvent.pathEventCache.set(e, {
|
||||
module: this.module,
|
||||
fullPath: this.fullPath,
|
||||
dir: this.dir,
|
||||
path: this.path,
|
||||
name: this.name,
|
||||
methods: [...this.methods],
|
||||
hasGlob: this.hasGlob
|
||||
});
|
||||
return;
|
||||
}
|
||||
|
||||
let temp = p.split('/').filter(p => !!p);
|
||||
this.module = temp.splice(0, 1)[0] || '';
|
||||
this.path = temp.join('/');
|
||||
this.dir = temp.length > 2 ? temp.slice(0, -1).join('/') : '';
|
||||
this.dir = temp.length > 1 ? temp.slice(0, -1).join('/') : '';
|
||||
this.fullPath = `${this.module}${this.module && this.path ? '/' : ''}${this.path}`;
|
||||
this.name = temp.pop() || '';
|
||||
this.hasGlob = this.fullPath.includes('*');
|
||||
this.methods = new ASet(<any>method.split(''));
|
||||
PathEvent.pathEventCache.set(e, this);
|
||||
|
||||
// LRU eviction
|
||||
if(PathEvent.pathEventCache.size >= PathEvent.MAX_PATH_CACHE_SIZE) {
|
||||
const firstKey = PathEvent.pathEventCache.keys().next().value;
|
||||
if(firstKey) PathEvent.pathEventCache.delete(firstKey);
|
||||
}
|
||||
|
||||
PathEvent.pathEventCache.set(e, {
|
||||
module: this.module,
|
||||
fullPath: this.fullPath,
|
||||
dir: this.dir,
|
||||
path: this.path,
|
||||
name: this.name,
|
||||
methods: [...this.methods],
|
||||
hasGlob: this.hasGlob
|
||||
});
|
||||
}
|
||||
|
||||
/**
|
||||
|
||||
Reference in New Issue
Block a user