kavehhn
2d87cc4834
ADD: Bucket and Upload System ADD: New errors ADD: Virtuals for categories ADD: Features system ADD: File management system
55 lines
1.5 KiB
JavaScript
55 lines
1.5 KiB
JavaScript
const minioClient = require('./minio')
|
|
const fs = require('fs')
|
|
|
|
|
|
// Upload File to s3 bucket
|
|
exports.uploadObject = async (file, bucketName) => {
|
|
const fileStream = fs.createReadStream(file.path)
|
|
|
|
const uploadedFile = await minioClient.putObject(bucketName, `${file.filename}-${file.originalName}`, fileStream)
|
|
|
|
uploadedFile.fileURL = 'https://' + process.env.AWS_ENDPOINT + '/' + bucketName + '/' + file.filename + '-' + file.originalName
|
|
|
|
uploadedFile.fileName = file.filename + '-' + file.originalName
|
|
|
|
uploadedFile.fileEndpoint = process.env.AWS_ENDPOINT
|
|
|
|
return uploadedFile
|
|
}
|
|
|
|
exports.listOfObjects = (bucketName) => {
|
|
return new Promise((resolve, reject) => {
|
|
let objects = []
|
|
|
|
const stream = minioClient.listObjectsV2(bucketName, '', true)
|
|
|
|
stream.on('data', (obj) => {
|
|
objects.push(obj)
|
|
})
|
|
|
|
stream.on('error', (err) => {
|
|
reject(err)
|
|
})
|
|
|
|
stream.on('end', () => {
|
|
resolve(objects)
|
|
})
|
|
})
|
|
}
|
|
|
|
exports.signedUrl = (bucketName, fileName) => {
|
|
return minioClient.presignedUrl('GET', bucketName, fileName, 60 * 60)
|
|
}
|
|
|
|
exports.deleteObject = (fileName, bucketName) => {
|
|
return minioClient.removeObject(bucketName, fileName)
|
|
}
|
|
|
|
exports.copyObject = (targetBucket, fileName, sourceBucketAndFile) => {
|
|
return minioClient.copyObject(targetBucket, fileName, sourceBucketAndFile)
|
|
}
|
|
|
|
exports.removeObject = (bucketName, fileName) => {
|
|
return minioClient.removeObject(bucketName, fileName)
|
|
}
|