[Develop and manual Test] API endpoint (post) /api/v1/fileUpload

[eos/zephyr.git] / server / api / v1 / fileUpload / index.js

diff --git a/server/api/v1/fileUpload/index.js b/server/api/v1/fileUpload/index.js
index 2cbe7df..344fc76 100644 (file)
--- a/server/api/v1/fileUpload/index.js
+++ b/server/api/v1/fileUpload/index.js
@@ -4,28 +4,82 @@ var express    = require('express');
 var router     = express.Router()
 var path       = require('path')
 var formidable = require('formidable')
-var DB = require(__dirname + '/../../../../server/class/DB');
+var db = require(__dirname + '/../../../../server/class/DB').instance;
+var uuid = require('node-uuid');
+var fs = require('fs');
 
 router.post('/', function(req, res) {
-    DB()
-    .then(function(db) {
-        var form = new formidable.IncomingForm();
-        form.uploadDir = __dirname + '/../../../../user-specific-files/workspace'; 
-
-        form.parse(req, function(err, fields, files) {
-            var parentDirectory = fields['parentDirectory'];
-            var keys = Object.keys(files);
-            keys.forEach(function(f) {
-                db.createFile(files[f].name, parentDirectory)
-                .then(function(path) {
-                    files[f].path = form.uploadDir + '/' + path;
-                    console.log(files[f].path);
-                });
+    var form = new formidable.IncomingForm();
+    var filesInfo = [];
+
+    form.uploadDir = __dirname + '/../../../../user-specific-files/tmp';
+    
+    form.on('fileBegin', function(parentDirectory, file) {
+    });
+ 
+    form.on('error', function(err) {
+        console.errro(err);
+        var i = {
+            status: 'error',
+            message: err
+        }
+        res.send(i);
+    });
+
+
+    form.parse(req, function(err, fields, files) {
+        var workspace;
+        var parentDirectory = fields['parentDirectory'];
+        if(process.env['NODE_ENV'] === 'debug') {
+            workspace = __dirname + '/../../../../user-specific-files/workspace.debug/'; 
+        } else {
+            workspace = __dirname + '/../../../../user-specific-files/workspace/'; 
+        }
+        var promises = [];
+        Object.keys(files).forEach(function(key) {
+            var file = files[key];
+            var fileName = file.name;
+            var tmpPath = file.path;
+            var info = {
+                status: null,
+                parentDirectory: parentDirectory,
+                fileName: fileName,
+                tmpPath: tmpPath,
+                fileId: null
+            };
+            
+            filesInfo.push(info);
+            promises.push(db.createFile(fileName, parentDirectory)); // file作成に成功したらresolve, 失敗したらreject
+        });
+
+        Promise.all(promises)
+        .catch(function(err) {
+            filesInfo.forEach(function(fileInfo) {
+                fs.unlinkSync(fileInfo.tmpPath);
             });
-            res.send("done");
+
+            var info = {
+                status: 'error',
+                messag: err.message
+            };
+
+            res.send(info);
+        })
+        .then(function(fileIds) {
+            fileIds.forEach(function(fileId, i) { 
+                filesInfo[i].status = 'success';
+                filesInfo[i].fileId = fileId;
+                fs.renameSync(filesInfo[i].tmpPath, workspace + fileId);
+                delete tmpPaths[i];
+            })
+            res.send(responsesInfo);
         });
     });
+
+    form.on('end', function() {
+        
+    });
+
 });
 
 module.exports = router;
-