feat(processing): smistamento ricorsivo cartelle + gestione unrouted per ZIP e folder
This commit is contained in:
@@ -4,6 +4,7 @@ const path = require('path');
|
||||
const { pipeline } = require('stream/promises');
|
||||
const { getDestinationDecision, isCadFile } = require('./router');
|
||||
const { buildDestinationIndex } = require('./destinationIndex');
|
||||
const { getUnroutedTarget } = require('./unrouted');
|
||||
|
||||
async function processZip(zipPath, config) {
|
||||
const stream = fs.createReadStream(zipPath).pipe(unzipper.Parse({ forceStream: true }));
|
||||
@@ -12,6 +13,7 @@ async function processZip(zipPath, config) {
|
||||
scanned: 0,
|
||||
copied: 0,
|
||||
skipped: 0,
|
||||
unrouted: 0,
|
||||
details: [],
|
||||
};
|
||||
|
||||
@@ -35,9 +37,16 @@ async function processZip(zipPath, config) {
|
||||
const destDir = decision.destination;
|
||||
|
||||
if (!destDir) {
|
||||
result.skipped += 1;
|
||||
result.details.push({ file: baseName, reason: decision.reason || 'Nessuna regola trovata' });
|
||||
entry.autodrain();
|
||||
const unroutedTarget = await getUnroutedTarget(baseName);
|
||||
await pipeline(entry, fs.createWriteStream(unroutedTarget.destinationPath));
|
||||
|
||||
result.copied += 1;
|
||||
result.unrouted += 1;
|
||||
result.details.push({
|
||||
file: baseName,
|
||||
destination: unroutedTarget.destinationDir,
|
||||
reason: decision.reason || 'Nessuna regola trovata',
|
||||
});
|
||||
continue;
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user