106 lines
2.3 KiB
JavaScript
106 lines
2.3 KiB
JavaScript
const AWS = require('aws-sdk')
|
|
const fs = require('fs')
|
|
const path = require('path')
|
|
|
|
class Aws {
|
|
constructor () {
|
|
AWS.config.update({
|
|
accessKeyId: process.env.AWS_ACCESS_KEY_ID,
|
|
secretAccessKey: process.env.AWS_SECRET_ACCESS_KEY
|
|
})
|
|
}
|
|
|
|
_send (params, callback) {
|
|
fs.readFile(params.path, (err, data) => {
|
|
if (err) {
|
|
callback(err, null)
|
|
return false
|
|
}
|
|
const base64data = Buffer.from(data, 'binary')
|
|
const dest = path.join(process.env.AWS_BASEFOLDER, params.filename)
|
|
const s3 = new AWS.S3()
|
|
|
|
s3.putObject({
|
|
Bucket: process.env.AWS_BUCKET,
|
|
Key: dest,
|
|
Body: base64data,
|
|
ACL: 'public-read'
|
|
}, (err, res) => {
|
|
if (err) {
|
|
callback(err, res)
|
|
} else {
|
|
callback(null, {
|
|
file: process.env.AWS_URL + dest
|
|
})
|
|
fs.unlink(params.path, () => { })
|
|
}
|
|
})
|
|
})
|
|
}
|
|
|
|
_compress (params, callback) {
|
|
const newFile = params.path + '.' + params.filename.split('.')[1]
|
|
|
|
fs.copyFile(params.path, newFile, (err, res) => {
|
|
if (err) {
|
|
callback(err, null)
|
|
return false
|
|
}
|
|
|
|
this._send({
|
|
path: newFile,
|
|
// path: file[0].path,
|
|
filename: params.filename
|
|
}, (err, res) => {
|
|
callback(err, res)
|
|
// fs.unlink(file[0].path, () => { })
|
|
})
|
|
})
|
|
}
|
|
|
|
/**
|
|
* Upload file on s3
|
|
* @param {Object} params {path: String, filename: String}
|
|
* @param {Function} callback
|
|
*/
|
|
upload (params, callback) {
|
|
fs.readFile(params.path, (err, data) => {
|
|
if (err) {
|
|
callback(err, null)
|
|
return false
|
|
}
|
|
|
|
this._compress(params, callback)
|
|
})
|
|
}
|
|
|
|
deleteObjects (files, callback) {
|
|
const s3 = new AWS.S3()
|
|
const basePath = process.env.AWS_URL + process.env.AWS_BASEFOLDER
|
|
let items = []
|
|
|
|
files.forEach((file) => {
|
|
if (file) {
|
|
items.push({
|
|
Key: file.replace(basePath, '')
|
|
})
|
|
}
|
|
})
|
|
|
|
if (items.length > 0) {
|
|
s3.deleteObjects({
|
|
Bucket: process.env.AWS_BUCKET,
|
|
Delete: { // required
|
|
Objects: items
|
|
}
|
|
}, callback)
|
|
} else {
|
|
callback(null, {
|
|
code: 200,
|
|
res: 'No file deleted'
|
|
})
|
|
}
|
|
}
|
|
}
|
|
|
|
module.exports = Aws
|