upload

Author: MillerRen

Diff for: .eslintrc.js

@@ -18,6 +18,7 @@ module.exports = {
   },
   globals: {
     localStorage: true,
-    location: true
+    location: true,
+    FormData: true
   }
 }

Diff for: server/api/file/file.controller.js

@@ -0,0 +1,60 @@
+'use strict';
+
+var _ = require('lodash');
+var File = require('./file.model');
+
+// Get list of files
+exports.index = function(req, res) {
+  File.find({'metadata.user':req.user._id})
+  .sort('-uploadDate')
+  .skip(req.range.first)
+  .limit(req.range.last-req.range.first+1)
+  .exec(function (err, files) {
+    if(err) { return handleError(res, err); }
+    return res.status(200).json(files);
+  });
+};
+
+// Get a single file
+exports.show = function(req, res) {
+  File.findById(req.params.id, function (err, file) {
+    if(err) { return handleError(res, err); }
+    if(!file) { return res.status(404).send('Not Found'); }
+    return res.json(file);
+  });
+};
+
+// Creates a new file in the DB.
+exports.create = function(req, res, next) {
+  console.log(req.file)
+  File.findById(req.file.id, function (err, file) {
+    if (err) {
+      return handleError(err)
+    }
+    res.json(file)
+  })
+};
+
+// Updates an existing file in the DB.
+exports.update = function(req, res) {
+  res.send('')
+};
+
+// Deletes a file from the DB.
+exports.destroy = function(req, res) {
+  gfs.remove({_id:req.params.id}, function (err, file) {
+    if(err) { return handleError(res, err); }
+    return res.send('');
+  });
+};
+
+exports.count = function(req, res, next) {
+  File.count({}, function(err, count){console.log('file count:', count)
+    res.range({first:req.range.first,last:req.range.last,length:count});
+    next();
+  })
+};
+
+function handleError(res, err) {
+  return res.status(500).send(err);
+}

Diff for: server/api/file/file.model.js

@@ -0,0 +1,24 @@
+'use strict';
+
+var mongoose = require('mongoose'),
+    Schema = mongoose.Schema;
+
+// var FileSchema = new Schema({
+//   filename: String,
+//   fieldname: String,
+//   originalname: String,
+//   encoding: String,
+//   mimetype: String,
+//   type: String,
+//   size: Number,
+//   destination: String,
+//   path: String,
+//   active: Boolean
+// });
+
+var FileSchema = new Schema({}, {strict: false});
+var FileModel = mongoose.model('File', FileSchema, 'fs.files');
+
+FileModel.ensureIndexes({'metadata.user':1});
+
+module.exports = FileModel;

Diff for: server/api/file/file.spec.js

@@ -0,0 +1,20 @@
+'use strict';
+
+var should = require('should');
+var app = require('../../app');
+var request = require('supertest');
+
+describe('GET /api/files', function() {
+
+  it('should respond with JSON array', function(done) {
+    request(app)
+      .get('/api/files')
+      .expect(200)
+      .expect('Content-Type', /json/)
+      .end(function(err, res) {
+        if (err) return done(err);
+        res.body.should.be.instanceof(Array);
+        done();
+      });
+  });
+});

Diff for: server/api/file/index.js

@@ -0,0 +1,31 @@
+'use strict';
+
+var express = require('express');
+var config = require('../../config/environment');
+
+var mongoose = require('mongoose');
+var Grid = require('gridfs-stream');
+var multer = require('multer');
+var gfs = Grid(mongoose.connection.db, mongoose.mongo);
+var storage = require('multer-gridfs-storage')({
+      gfs:gfs,
+      metadata: function(req, file, cb){
+          cb(null, {user:req.user._id});
+      }
+  });
+var upload = multer({ storage: storage });
+
+var auth = require('../../auth/auth.service');
+
+var controller = require('./file.controller');
+
+var router = express.Router();
+
+router.get('/', auth.isAuthenticated(), controller.count, controller.index);
+router.get('/:id', auth.isAuthenticated(), controller.show);
+router.post('/', auth.isAuthenticated(), upload.single('file'), controller.create);
+router.put('/:id', auth.isAuthenticated(), controller.update);
+router.patch('/:id', auth.isAuthenticated(), controller.update);
+router.delete('/:id', auth.isAuthenticated(), controller.destroy);
+
+module.exports = router;

Diff for: server/app.js

@@ -21,11 +21,11 @@ if(config.seedDB) { require('./config/seed'); }
 // Setup server
 var app = express();
 var server = require('http').createServer(app);
-var socketio = require('socket.io')(server, {
-  serveClient: (config.env === 'production') ? false : true,
-  path: '/socket.io-client'
-});
-require('./config/socketio')(socketio);
+// var socketio = require('socket.io')(server, {
+//   serveClient: (config.env === 'production') ? false : true,
+//   path: '/socket.io-client'
+// });
+// require('./config/socketio')(socketio);
 require('./config/express')(app);
 require('./config/rbac')(app);
 require('./routes')(app);

Diff for: server/package.json

@@ -13,11 +13,15 @@
     "errorhandler": "^1.4.0",
     "express": "^4.12.4",
     "express-session": "^1.11.3",
+    "gridfs-stream": "^1.1.1",
     "lodash": "^3.10.1",
     "method-override": "~1.0.0",
     "mongoose": "^4.1.1",
     "mongoose-pagination": "^1.0.0",
     "morgan": "~1.0.0",
+    "multer": "^1.2.0",
+    "multer-gridfs": "^0.0.1",
+    "multer-gridfs-storage": "^1.0.0",
     "passport": "^0.2.2",
     "passport-facebook": "latest",
     "passport-google-oauth": "latest",
@@ -28,8 +32,7 @@
     "socket.io": "^1.3.6",
     "socket.io-client": "^1.3.5"
   },
-  "devDependencies": {
-  },
+  "devDependencies": {},
   "engines": {
     "node": ">=0.10.0"
   },

Diff for: server/routes.js

@@ -9,7 +9,7 @@ var errors = require('./components/errors');
 module.exports = function(app) {
 
   // Insert routes below
-  app.use('/api/things', require('./api/thing'));
+  app.use('/api/files', require('./api/file'));
   app.use('/api/users', require('./api/user'));
 
   app.use('/auth', require('./auth'));

Diff for: src/components/Uploader/index.vue

@@ -1,12 +1,23 @@
 <template>
 <div class="component-uploader">
-  <input type="file" name="" id="">
+  <input type="file" name="file" @change="onChange($event)">
 </div>
 </template>
 <script>
 export default {
   data () {
     return {
+      url: '/api/files'
+    }
+  },
+  methods: {
+    onChange (e) {
+      var fd = new FormData()
+      fd.append('file', e.target.files[0])
+      this.$http.post(this.url, fd)
+      .then(() => {})
+      .catch(() => {})
+      console.log('on change', e)
     }
   }
 }