Upload latest files to correct location (#3693)
This commit is contained in:
parent
fa85a83a2a
commit
deb1c9407e
|
|
@ -53,14 +53,14 @@ async function upload(dir, scpOptions, prefix) {
|
|||
}
|
||||
}
|
||||
|
||||
async function uploadFiles(files, scpOptions) {
|
||||
async function uploadFiles(files, scpOptions, prefix) {
|
||||
let client;
|
||||
try {
|
||||
client = await getClient(scpOptions);
|
||||
for (let file of files) {
|
||||
await client.uploadFile(
|
||||
file,
|
||||
path.join(scpOptions.destinationPath, path.basename(file))
|
||||
path.join(scpOptions.destinationPath, prefix, path.basename(file))
|
||||
);
|
||||
}
|
||||
} catch (e) {
|
||||
|
|
@ -73,13 +73,13 @@ async function uploadFiles(files, scpOptions) {
|
|||
}
|
||||
}
|
||||
|
||||
async function uploadLatestFiles(dir, scpOptions) {
|
||||
async function uploadLatestFiles(dir, scpOptions, prefix) {
|
||||
function ignoreDirs(file, stats) {
|
||||
return stats.isDirectory();
|
||||
}
|
||||
const files = await readdir(dir, [ignoreDirs]);
|
||||
|
||||
return uploadFiles(files, scpOptions);
|
||||
return uploadFiles(files, scpOptions, prefix);
|
||||
}
|
||||
|
||||
module.exports = {
|
||||
|
|
@ -111,7 +111,9 @@ module.exports = {
|
|||
);
|
||||
if (this.options.copyLatestFilesToBase) {
|
||||
const rootPath = path.resolve(baseDir, '..');
|
||||
await uploadLatestFiles(rootPath, this.scpOptions);
|
||||
const prefix = this.storageManager.getStoragePrefix();
|
||||
const firstPart = prefix.split('/')[0];
|
||||
await uploadLatestFiles(rootPath, this.scpOptions, firstPart);
|
||||
}
|
||||
log.info('Finished upload using scp');
|
||||
if (this.scpOptions.removeLocalResult) {
|
||||
|
|
|
|||
Loading…
Reference in New Issue