Skip to content
Snippets Groups Projects
Commit 4a6898b7 authored by Yogmatee Roochun's avatar Yogmatee Roochun
Browse files

rename file after minio and db upload

parent 4a93b55c
No related branches found
No related tags found
2 merge requests!60Dev,!43Shared data model
......@@ -56,9 +56,8 @@ async function processFile(path) {
const files = await getFilesData(extractedFilePath, manifestFilename)
const [filesArr, promisesArr] = await checkFiles(files, tmpPath, user)
await createFiles(filesArr)
await Promise.all(promisesArr).catch(error => {
logger.error(error)
})
await Promise.all(promisesArr)
await renameFile(path)
logger.info('Uploading to Minio and the database has been completed.')
} catch (err) {
logger.error('Error', err.message)
......@@ -209,13 +208,9 @@ function checkFiles(files, tmpPath, user) {
`${uuid}${extension}`,
filename,
extension,
files,
file,
fileSizeInBytes,
mimeType,
fileType,
fileLabel,
user,
),
)
}
......@@ -227,13 +222,9 @@ function uploadFile(
filename,
originalFileName,
extension,
files,
filePath,
item_size,
mimeType,
fileType,
fileLabel,
user,
) {
return new Promise((resolve, reject) => {
minioClient.uploadFile(
......@@ -249,17 +240,7 @@ function uploadFile(
} else {
logger.debug(`${originalFileName} file uploaded to minio`)
fs.unlinkSync(filePath)
const uploadedFile = {
url: `/download/${filename}`,
size: item_size,
filename: originalFileName,
label: fileLabel,
type: fileType,
mimeType,
updatedBy: user.userId,
}
files.push(uploadedFile)
// resolve(files)
resolve(filePath)
}
},
)
......@@ -275,3 +256,12 @@ async function createFiles(filesArr) {
logger.info(filedb)
}
}
async function renameFile(path) {
return new Promise((resolve, reject) => {
fs.rename(path, `${path}_${Date.now()}`, err => {
if (err) reject(err)
})
resolve(path)
})
}
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment