Fixed bug
This commit is contained in:
parent
cd11c01c9b
commit
43a5234ab3
1 changed files with 7 additions and 7 deletions
14
libs/aws.js
14
libs/aws.js
|
@ -6,14 +6,14 @@ const imageminJpegtran = require('imagemin-jpegtran')
|
||||||
const imageminPngquant = require('imagemin-pngquant')
|
const imageminPngquant = require('imagemin-pngquant')
|
||||||
|
|
||||||
class Aws {
|
class Aws {
|
||||||
constructor() {
|
constructor () {
|
||||||
AWS.config.update({
|
AWS.config.update({
|
||||||
accessKeyId: process.env.AWS_ACCESS_KEY_ID,
|
accessKeyId: process.env.AWS_ACCESS_KEY_ID,
|
||||||
secretAccessKey: process.env.AWS_SECRET_ACCESS_KEY
|
secretAccessKey: process.env.AWS_SECRET_ACCESS_KEY
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
_send(params, callback) {
|
_send (params, callback) {
|
||||||
fs.readFile(params.path, (err, data) => {
|
fs.readFile(params.path, (err, data) => {
|
||||||
if (err) {
|
if (err) {
|
||||||
callback(err, null)
|
callback(err, null)
|
||||||
|
@ -40,7 +40,7 @@ class Aws {
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
_compress(params, callback) {
|
_compress (params, callback) {
|
||||||
const newFile = params.path + '.' + params.filename.split('.')[1]
|
const newFile = params.path + '.' + params.filename.split('.')[1]
|
||||||
|
|
||||||
fs.copyFile(params.path, newFile, (err, res) => {
|
fs.copyFile(params.path, newFile, (err, res) => {
|
||||||
|
@ -50,7 +50,6 @@ class Aws {
|
||||||
}
|
}
|
||||||
|
|
||||||
try {
|
try {
|
||||||
|
|
||||||
(async () => {
|
(async () => {
|
||||||
const file = await imagemin([newFile], '/tmp', {
|
const file = await imagemin([newFile], '/tmp', {
|
||||||
plugins: [
|
plugins: [
|
||||||
|
@ -69,8 +68,9 @@ class Aws {
|
||||||
fs.unlink(file[0].path, () => { })
|
fs.unlink(file[0].path, () => { })
|
||||||
})
|
})
|
||||||
})()
|
})()
|
||||||
|
} catch (e) {
|
||||||
|
callback(e)
|
||||||
}
|
}
|
||||||
catch (callback)
|
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -79,7 +79,7 @@ class Aws {
|
||||||
* @param {Object} params {path: String, filename: String}
|
* @param {Object} params {path: String, filename: String}
|
||||||
* @param {Function} callback
|
* @param {Function} callback
|
||||||
*/
|
*/
|
||||||
upload(params, callback) {
|
upload (params, callback) {
|
||||||
fs.readFile(params.path, (err, data) => {
|
fs.readFile(params.path, (err, data) => {
|
||||||
if (err) {
|
if (err) {
|
||||||
callback(err, null)
|
callback(err, null)
|
||||||
|
@ -90,7 +90,7 @@ class Aws {
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
deleteObjects(files, callback) {
|
deleteObjects (files, callback) {
|
||||||
const s3 = new AWS.S3()
|
const s3 = new AWS.S3()
|
||||||
const basePath = process.env.AWS_URL + process.env.AWS_BASEFOLDER
|
const basePath = process.env.AWS_URL + process.env.AWS_BASEFOLDER
|
||||||
let items = []
|
let items = []
|
||||||
|
|
Loading…
Reference in a new issue