Sucukdeluxe
d7c9f287e4
CI / verify (push) Has been cancelled
Restore the v2.1.19 application baseline and retain only the focused import preflight summary with duplicate, unavailable, destination, job, and size-limit visibility.
65 lines
2.7 KiB
JavaScript
65 lines
2.7 KiB
JavaScript
const { test } = require('node:test');
|
|
const assert = require('node:assert');
|
|
const fs = require('fs');
|
|
const os = require('os');
|
|
const path = require('path');
|
|
|
|
test('internal audit records never contaminate the MDU session link log', async () => {
|
|
let createUploadAuditWriter;
|
|
try {
|
|
({ createUploadAuditWriter } = require('../lib/upload-audit'));
|
|
} catch {}
|
|
assert.equal(typeof createUploadAuditWriter, 'function');
|
|
|
|
const directory = fs.mkdtempSync(path.join(os.tmpdir(), 'mhu-upload-audit-'));
|
|
const sessionLog = path.join(directory, '13-08-2026-mdu-session-14-20-123456.log');
|
|
const writer = createUploadAuditWriter({
|
|
fs,
|
|
path,
|
|
resolveUploadLogTarget: () => ({ path: sessionLog, isFallback: false }),
|
|
rotateLogFile: () => {},
|
|
invalidateUploadLogTarget: () => {},
|
|
reportError: () => {},
|
|
retryDelays: [0]
|
|
});
|
|
|
|
await writer.append('# SOURCE-CLEANUP {"outcome":"deleted"}\r\n', 'source-cleanup');
|
|
await writer.append('# UPLOAD-PLAN {"plannedUploadCount":4}\r\n', 'upload-plan');
|
|
|
|
const auditLog = path.join(directory, 'upload-audit.log');
|
|
assert.equal(fs.existsSync(sessionLog), false);
|
|
assert.equal(fs.readFileSync(auditLog, 'utf8'), '# SOURCE-CLEANUP {"outcome":"deleted"}\r\n# UPLOAD-PLAN {"plannedUploadCount":4}\r\n');
|
|
fs.rmSync(directory, { recursive: true, force: true });
|
|
});
|
|
|
|
test('audit writer reports the actual fallback file after a failed primary write', async () => {
|
|
const { createUploadAuditWriter } = require('../lib/upload-audit');
|
|
const directory = fs.mkdtempSync(path.join(os.tmpdir(), 'mhu-upload-audit-fallback-'));
|
|
const blockedParent = path.join(directory, 'blocked');
|
|
const fallbackDirectory = path.join(directory, 'fallback');
|
|
fs.writeFileSync(blockedParent, 'not a directory');
|
|
let attempts = 0;
|
|
const persistedFallbacks = [];
|
|
const writer = createUploadAuditWriter({
|
|
fs,
|
|
path,
|
|
resolveUploadLogTarget: () => ({
|
|
path: attempts++ === 0
|
|
? path.join(blockedParent, 'fileuploader.log')
|
|
: path.join(fallbackDirectory, 'fileuploader.log'),
|
|
isFallback: attempts > 1
|
|
}),
|
|
rotateLogFile: () => {},
|
|
invalidateUploadLogTarget: () => {},
|
|
persistFallbackLogPath: async targetPath => { persistedFallbacks.push(targetPath); },
|
|
reportError: () => {},
|
|
retryDelays: [0, 0]
|
|
});
|
|
|
|
assert.equal(await writer.append('# UPLOAD-PLAN {}\r\n', 'upload-plan'), true);
|
|
assert.equal(writer.getActivePath(), path.join(fallbackDirectory, 'upload-audit.log'));
|
|
assert.deepEqual(persistedFallbacks, [path.join(fallbackDirectory, 'fileuploader.log')]);
|
|
assert.equal(fs.readFileSync(writer.getActivePath(), 'utf8'), '# UPLOAD-PLAN {}\r\n');
|
|
fs.rmSync(directory, { recursive: true, force: true });
|
|
});
|