utils.ts

export function parallel(items, handler, concurrency) {
    if (!Number.isInteger(concurrency) || concurrency < 1) throw new Error("concurrency must be a positive integer greater than 0");
    if (items.length === 0) return Promise.resolve([]);
    return new Promise((resolve, reject) => {
        const results = [];
        let i = 0;

        const next = (result) => {
            results.push(result);
            if (i < items.length) {
                try {
                    handler(items[i++]).then(next).catch(reject);
                } catch (err) {
                    reject(err);
                }
            } else if (results.length === items.length) resolve(results);
        };

        for (let x = 0; x < Math.min(concurrency, items.length); x++) {
            try {
                handler(items[i++]).then(next).catch(reject);
            } catch (err) {
                reject(err);
                break;
            }
        }
    });
}

export function safeName(name: string) {
    return String(name)
        .replace(/[^A-z0-9_]/g, "-")
        .substring(0, 64);
}