jjkiers/cloudron-box
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

backuptask: fix usage of upload API

Browse Source
This commit is contained in:
Girish Ramakrishnan
2026-01-21 08:58:30 +01:00
parent 42cefd56eb
commit 72c494e9dc
2 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/test/storage-provider-test.js
+5 -5
View File
@@ -66,7 +66,7 @@ describe('Storage', function () {
const sourceStream = fs.createReadStream(sourceFile);
const destFile = path.join(gBackupConfig.backupDir, gBackupConfig.prefix, '/uploadtest/test.txt');
const uploader = await filesystem.upload(gBackupConfig, {}, 'uploadtest/test.txt');
await stream.pipeline(sourceStream, uploader.stream);
await stream.pipeline(sourceStream, uploader.createStream());
await uploader.finish();
expect(fs.existsSync(destFile));
expect(fs.statSync(sourceFile).size).to.be(fs.statSync(destFile).size);
@@ -77,7 +77,7 @@ describe('Storage', function () {
const sourceStream = fs.createReadStream(sourceFile);
const destFile = path.join(gBackupConfig.backupDir, gBackupConfig.prefix, '/uploadtest/empty');
const uploader = await filesystem.upload(gBackupConfig, {}, destFile);
await stream.pipeline(sourceStream, uploader.stream);
await stream.pipeline(sourceStream, uploader.createStream());
await uploader.finish();
expect(fs.existsSync(destFile));
expect(fs.statSync(sourceFile).size).to.be(fs.statSync(destFile).size);
@@ -89,7 +89,7 @@ describe('Storage', function () {
const destFile = path.join(gBackupConfig.backupDir, gBackupConfig.prefix, '/uploadtest/test.txt');
const oldStat = fs.statSync(destFile);
const uploader = await filesystem.upload(gBackupConfig, {}, 'uploadtest/test.txt');
await stream.pipeline(sourceStream, uploader.stream);
await stream.pipeline(sourceStream, uploader.createStream());
await uploader.finish();
expect(fs.existsSync(destFile)).to.be(true);
expect(fs.statSync(sourceFile).size).to.be(fs.statSync(destFile).size);
@@ -246,7 +246,7 @@ describe('Storage', function () {
const sourceStream = fs.createReadStream(sourceFile);
const destKey = 'uploadtest/test.txt';
const uploader = await s3.upload(backupConfig, {}, destKey);
await stream.pipeline(sourceStream, uploader.stream);
await stream.pipeline(sourceStream, uploader.createStream());
await uploader.finish();
expect(fs.existsSync(path.join(bucketPath, destKey))).to.be(true);
expect(fs.statSync(path.join(bucketPath, destKey)).size).to.be(fs.statSync(sourceFile).size);
@@ -383,7 +383,7 @@ describe('Storage', function () {
const sourceStream = fs.createReadStream(sourceFile);
const destKey = 'uploadtest/test.txt';
const uploader = await gcs.upload(backupConfig, {}, destKey);
await stream.pipeline(sourceStream, uploader.stream);
await stream.pipeline(sourceStream, uploader.createStream());
await uploader.finish();
expect(fs.existsSync(path.join(bucketPath, destKey))).to.be(true);
expect(fs.statSync(path.join(bucketPath, destKey)).size).to.be(fs.statSync(sourceFile).size);