Showing
2 changed files
with
71 additions
and
26 deletions
| ... | @@ -68,7 +68,6 @@ router.post('/makefolder', function(req, res, next) { | ... | @@ -68,7 +68,6 @@ router.post('/makefolder', function(req, res, next) { |
| 68 | s3.putObject(params, function(err, data) { | 68 | s3.putObject(params, function(err, data) { |
| 69 | if (err) { | 69 | if (err) { |
| 70 | console.log('s3 error'); | 70 | console.log('s3 error'); |
| 71 | - throw err; | ||
| 72 | } else { | 71 | } else { |
| 73 | console.log(data); | 72 | console.log(data); |
| 74 | let sql = 'INSERT INTO folders (folder_name,location,user_id,created) values (?,?,?,?);'; | 73 | let sql = 'INSERT INTO folders (folder_name,location,user_id,created) values (?,?,?,?);'; | ... | ... |
| 1 | var express = require('express'); | 1 | var express = require('express'); |
| 2 | var request = require('request'); | 2 | var request = require('request'); |
| 3 | var async = require('async'); | 3 | var async = require('async'); |
| 4 | +const AWS = require("aws-sdk"); | ||
| 4 | 5 | ||
| 5 | var cryptoM = require('./../../routes/modules/cryptoM.js'); | 6 | var cryptoM = require('./../../routes/modules/cryptoM.js'); |
| 6 | 7 | ||
| 8 | +const BUCKET_NAME = "hong-s3-cloud"; | ||
| 9 | + | ||
| 10 | +const s3 = new AWS.S3({ | ||
| 11 | + accessKeyId: process.env.AWS_ACCESS_KEY_ID, | ||
| 12 | + secretAccessKey: process.env.AWS_SECRET_ACCESS_KEY, | ||
| 13 | + region: "ap-northeast-2" | ||
| 14 | +}); | ||
| 15 | + | ||
| 7 | var router = express.Router(); | 16 | var router = express.Router(); |
| 8 | 17 | ||
| 9 | router.get('/', function(req, res, next) { | 18 | router.get('/', function(req, res, next) { |
| ... | @@ -14,32 +23,69 @@ router.get('/', function(req, res, next) { | ... | @@ -14,32 +23,69 @@ router.get('/', function(req, res, next) { |
| 14 | 23 | ||
| 15 | router.post('/', function(req, res, next) { | 24 | router.post('/', function(req, res, next) { |
| 16 | console.log(req.body); | 25 | console.log(req.body); |
| 17 | - var user_id=req.body.user_id; | 26 | + var user_id = req.body.user_id; |
| 18 | - var user_pw=req.body.user_pw; | 27 | + var user_pw = req.body.user_pw; |
| 19 | - var user_email=req.body.user_email; | 28 | + var user_email = req.body.user_email; |
| 20 | - var user_name=req.body.user_name; | 29 | + var user_name = req.body.user_name; |
| 21 | - var user_phone=req.body.user_phone; | 30 | + var user_phone = req.body.user_phone; |
| 22 | 31 | ||
| 23 | var sqlquery = "SELECT * FROM users WHERE user_id = ?"; | 32 | var sqlquery = "SELECT * FROM users WHERE user_id = ?"; |
| 24 | - connection.query(sqlquery, [user_id], function (err, rows) { | 33 | + connection.query(sqlquery, [user_id], function(err, rows) { |
| 25 | - if (rows.length == 0) { | 34 | + if (rows.length == 0) { |
| 26 | - user_pw=cryptoM.encrypt(user_pw); | 35 | + user_pw = cryptoM.encrypt(user_pw); |
| 27 | - console.log(user_pw); | 36 | + console.log(user_pw); |
| 28 | - var sql = 'INSERT INTO users(user_id,user_pw, user_email, user_phone, user_name) values (?,?,?,?,?)'; | 37 | + var sql = 'INSERT INTO users(user_id,user_pw, user_email, user_phone, user_name) values (?,?,?,?,?)'; |
| 29 | - var values = [user_id, user_pw, user_email, user_phone,user_name]; | 38 | + var values = [user_id, user_pw, user_email, user_phone, user_name]; |
| 30 | - connection.query(sql, values, function (err) { | 39 | + connection.query(sql, values, function(err) { |
| 31 | - if (err) { | 40 | + if (err) { |
| 32 | - console.log("inserting user failed"); | 41 | + console.log("inserting user failed"); |
| 33 | - throw err; | 42 | + throw err; |
| 34 | - } else { | 43 | + } else { |
| 35 | - res.status(200).send('saved'); | 44 | + let params = { |
| 36 | - | 45 | + Bucket: BUCKET_NAME, |
| 37 | - } | 46 | + Key: user_id + '/', |
| 38 | - }); | 47 | + Body: "", |
| 39 | - } else { | 48 | + ACL: "public-read-write" |
| 40 | - res.status(404).send(err); | 49 | + }; |
| 41 | - } | 50 | + s3.putObject(params, function(err, data) { |
| 42 | - }); | 51 | + if (err) { |
| 52 | + console.log('s3 error'); | ||
| 53 | + } else { | ||
| 54 | + let params2 = { | ||
| 55 | + Bucket: BUCKET_NAME, | ||
| 56 | + Key: user_id + '/share/', | ||
| 57 | + Body: "", | ||
| 58 | + ACL: "public-read-write" | ||
| 59 | + }; | ||
| 60 | + s3.putObject(params2, function(err, data) { | ||
| 61 | + if (err) { | ||
| 62 | + console.log('s3 error'); | ||
| 63 | + } else { | ||
| 64 | + let params3 = { | ||
| 65 | + Bucket: BUCKET_NAME, | ||
| 66 | + Key: user_id + '/trashcan/', | ||
| 67 | + Body: "", | ||
| 68 | + ACL: "public-read-write" | ||
| 69 | + }; | ||
| 70 | + s3.putObject(params3, function(err, data) { | ||
| 71 | + if (err) { | ||
| 72 | + console.log('s3 error'); | ||
| 73 | + } else { | ||
| 74 | + res.status(200).send('saved'); | ||
| 75 | + } | ||
| 76 | + }); | ||
| 77 | + } | ||
| 78 | + }); | ||
| 79 | + } | ||
| 80 | + }); | ||
| 81 | + | ||
| 82 | + | ||
| 83 | + } | ||
| 84 | + }); | ||
| 85 | + } else { | ||
| 86 | + res.status(404).send(err); | ||
| 87 | + } | ||
| 88 | + }); | ||
| 43 | }); | 89 | }); |
| 44 | 90 | ||
| 45 | -module.exports = router; | 91 | +module.exports = router; |
| ... | \ No newline at end of file | ... | \ No newline at end of file | ... | ... |
-
Please register or login to post a comment