rodivert/api
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Fixed bug in AWS lib

Browse source
This commit is contained in:
dbroqua 2019-03-12 23:13:47 +01:00
parent 823e6f0de3
commit a850629661
1 changed files with 6 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
libs/aws.js
View file

@ -1,19 +1,16 @@
const AWS = require('aws-sdk') const AWS = require('aws-sdk')
const fs = require('fs') const fs = require('fs')
const path = require('path') const path = require('path')
const imagemin = require('imagemin')
const imageminJpegtran = require('imagemin-jpegtran')
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)
@ -35,12 +32,13 @@ class Aws {
callback(null, { callback(null, {
file: process.env.AWS_URL + dest file: process.env.AWS_URL + dest
}) })
fs.unlink(params.path, () => { })
} }
}) })
}) })
} }
_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) => {
@ -65,7 +63,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)
@ -76,7 +74,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 = []