release: v3.3.48

lib/upload-manager.js

@@ -310,18 +310,30 @@ class UploadManager extends EventEmitter {
     this._batchResults = results;
     this._additionalPromises = []; // Track jobs added mid-batch via addJobs()
 
-    for (const task of tasks) {
+    const DEDUP_CHUNK = 200;
-      const fileName = path.basename(task.file);
+    for (let i = 0; i < tasks.length; i += DEDUP_CHUNK) {
-      if (!results.has(task.file)) {
+      const end = Math.min(i + DEDUP_CHUNK, tasks.length);
-        let size = 0;
+      for (let j = i; j < end; j++) {
-        try { size = fs.statSync(task.file).size; } catch {}
+        const task = tasks[j];
-        results.set(task.file, { name: fileName, size, results: [] });
+        if (!results.has(task.file)) {
+          const fileName = path.basename(task.file);
+          let size = 0;
+          try { size = fs.statSync(task.file).size; } catch {}
+          results.set(task.file, { name: fileName, size, results: [] });
+        }
       }
+      if (end < tasks.length) await new Promise(setImmediate);
     }
 
     this._startStatsTimer();
 
-    const promises = tasks.map((task) => this._runJob(task, results, signal));
+    const SPAWN_CHUNK = 100;
+    const promises = [];
+    for (let i = 0; i < tasks.length; i += SPAWN_CHUNK) {
+      const end = Math.min(i + SPAWN_CHUNK, tasks.length);
+      for (let j = i; j < end; j++) promises.push(this._runJob(tasks[j], results, signal));
+      if (end < tasks.length) await new Promise(setImmediate);
+    }
     await Promise.allSettled(promises);
     // Wait for any jobs added mid-batch via addJobs()
     while (this._additionalPromises.length > 0) {

main.js

@@ -216,23 +216,10 @@ function rotLog(msg, ts) {
   try {
     const iso = new Date(ts || Date.now()).toISOString();
     const line = `[${iso}] ${msg}\n`;
-    // Write synchronously. Rotation events are rare (a handful per batch) so
+    _rotLogBuffer.push(line);
-    // the batching optimization from debugLog doesn't buy us anything, and
+    if (!_rotLogFlushTimer) {
-    // syncing guarantees the user can refresh the file and see fresh entries
+      _rotLogFlushTimer = setTimeout(() => { _rotLogFlushTimer = null; _flushRotLog(); }, 500);
-    // without waiting on a flush timer.
-    const candidates = [
-      getRotLogPath(),
-      path.join(app.getPath('desktop') || app.getPath('userData'), 'account-rotation.log'),
-      path.join(app.getPath('userData'), 'account-rotation.log')
-    ];
-    for (const target of candidates) {
-      try {
-        fs.mkdirSync(path.dirname(target), { recursive: true });
-        fs.appendFileSync(target, line, 'utf-8');
-        break;
-      } catch {}
     }
-    // Mirror into the main debug log for single-file-grep convenience.
     _debugLogBuffer.push(`[${iso}] [ROT] ${msg}\n`);
     if (!_debugLogFlushTimer) {
       _debugLogFlushTimer = setTimeout(() => { _debugLogFlushTimer = null; _flushDebugLog(); }, 500);

package.json

@@ -1,6 +1,6 @@
 {
   "name": "multi-hoster-uploader",
-  "version": "3.3.47",
+  "version": "3.3.48",
   "description": "Upload files to doodstream, voe, vidmoly, byse simultaneously",
   "main": "main.js",
   "scripts": {