external/MeshCentral
1
0
Fork 0
mirror of https://github.com/Ylianst/MeshCentral.git synced 2025-03-09 15:40:18 +00:00
Code Issues Releases Wiki Activity

Use pipeline instead of pipe

Browse source
This commit is contained in:
PTR-inc 2025-02-25 15:40:00 +01:00
parent b5635e89cc
commit 7c22811fee
1 changed files with 3 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

9
db.js
View file

@ -3809,12 +3809,9 @@ module.exports.CreateDB = function (parent, func) {
} }
} }
// Upload to the WebDAV folder // Upload to the WebDAV folder
const { stat } = await import ('fs/promises'); const { pipeline } = require('stream/promises');
const stats = await stat(filename); await pipeline(fs.createReadStream(filename), client.createWriteStream('/' + webdavfolderName + '/' + path.basename(filename)));
let fileStream = fs.createReadStream(filename); console.log('WebDAV upload completed: ' + webdavfolderName + '/' + path.basename(filename)); if (func) { func('WebDAV upload completed: ' + webdavfolderName + '/' + path.basename(filename)); }
fileStream.on('close', function () { console.log('WebDAV upload completed: ' + webdavfolderName + '/' + path.basename(filename)); if (func) { func('WebDAV upload completed: ' + webdavfolderName + '/' + path.basename(filename)); } })
fileStream.on('error', function (err) { console.error(err); if (func) { func('WebDAV upload error: ' + err.message); } })
fileStream.pipe(client.createWriteStream('/' + webdavfolderName + '/' + path.basename(filename), { headers: { "Content-Length": stats.size } }));
} }
catch(err) { catch(err) {
console.error('WebDAV error: ' + err.message); if (func) { func('WebDAV error: ' + err.message);} console.error('WebDAV error: ' + err.message); if (func) { func('WebDAV error: ' + err.message);}