upload images to s3

Author: julianduque

.gitignore

@@ -1,2 +1,3 @@
 uploads
 saved
+credentials

image-upload.js

@@ -3,8 +3,17 @@
 const path = require('path')
 const isImage = require('is-image')
 const uuid = require('uuid')
+const mime = require('mime-types')
+const S3 = require('aws-sdk/clients/s3')
 const { send } = require('micro')
-const { upload, move } = require('micro-upload')
+const { upload } = require('micro-upload')
+
+const s3 = new S3({
+  region: 'us-west-2',
+  params: { Bucket: 'medellinjs-microservicios' },
+  accessKeyId: process.env.AWS_ACCESS_KEY,
+  secretAccessKey: process.env.AWS_SECRET_KEY
+})
 
 //
 // This microservice will be served as /upload
@@ -28,8 +37,22 @@ module.exports = upload(async (req, res) => {
   let ext = path.extname(file.name)
   let name = uuid.v4() + ext
 
-  // src: file object, dst: path
-  await move(file, path.join(__dirname, 'uploads', name))
+  const result = await s3move(name, file.data)
 
-  send(res, 200, { name: name, src: `/uploads/${name}` })
+  send(res, 200, { name: name, src: result.Location })
 })
+
+function s3move (name, data) {
+  return new Promise((resolve, reject) => {
+    s3.upload({
+      Key: `uploads/${name}`,
+      Body: data,
+      ACL: 'public-read',
+      ContentType: mime.lookup(name)
+    }, (err, data) => {
+      if (err) return reject(err)
+
+      resolve(data)
+    })
+  })
+}

package.json

@@ -13,6 +13,7 @@
   },
   "homepage": "https://github.com/julianduque/microservices-demo#readme",
   "dependencies": {
+    "aws-sdk": "^2.43.0",
     "instagram_js_filter": "^1.4.0",
     "is-image": "^1.0.1",
     "micro": "^7.3.2",