Continuando a implementacao

Author: markleymsm

server/app.js

@@ -1,15 +1,16 @@
-let createError = require('http-errors');
-let express = require('express');
-let path = require('path');
-let cookieParser = require('cookie-parser');
-let logger = require('morgan');
-let mongoose = require('./src/db/connection');
-let cors = require('cors');
-
-let indexRouter = require('./routes/index');
-let usersRouter = require('./routes/users');
-
-let app = express();
+const createError = require('http-errors');
+const express = require('express');
+const path = require('path');
+const cookieParser = require('cookie-parser');
+const logger = require('morgan');
+const mongoose = require('./src/db/connection');
+const cors = require('cors');
+const routes = require('./src/routes');
+
+// let indexRouter = require('./routes/index');
+// let usersRouter = require('./routes/users');
+
+const app = express();
 app.use(cors());
 
 // view engine setup
@@ -22,8 +23,10 @@ app.use(express.urlencoded({ extended: false }));
 app.use(cookieParser());
 app.use(express.static(path.join(__dirname, 'public')));
 
-app.use('/', indexRouter);
-app.use('/users', usersRouter);
+// app.use('/', indexRouter);
+// app.use('/users', usersRouter);
+
+routes(app);
 
 // catch 404 and forward to error handler
 app.use(function (req, res, next) {

server/routes/index.js

@@ -0,0 +1,65 @@
+const jwt = require('jwt-simple');
+const User = require('../models/user');
+const cfg = require('../../config');
+
+module.exports = function (app) {
+    return {
+        token: (req, res) => {
+            let user = req.body;
+
+            if (!user.user_name || !user.password) {
+                return res.status(401).send('Unauthorized111');
+            }
+
+            let query = {email: user.user_name, password: user.password};
+
+            let callback = function (err, user) {
+                if (err) {
+                    return res.status(500).json({err: err});
+                }
+
+                if (!user) {
+                    return res.status(401).send('Unauthorized2222');
+                }
+
+                let payload = {id: user.id};
+                let token = jwt.encode(payload, cfg.jwtSecret);
+
+                return res.json({token: token})
+            };
+
+            user = User.findOne(query, callback);
+        },
+
+        me: (req, res) => {
+            res.status(200).json({
+                user: req.user
+            })
+        },
+        register: (req, res) => {
+            let data = {
+                name: req.body.name,
+                email: req.body.email,
+                password: req.body.password,
+                accounts: [{
+                    name: req.body.account_name,
+                    role: 'owner',
+                    enabled: true
+                }]
+            };
+
+            let callback = function (err, user) {
+                if (err) {
+                    return res.status(422).json({err: err});
+                }
+                return res.status(200).json({user: user});
+
+            };
+
+            User.create(data, callback);
+        },
+        edit: (req, res) => {
+            return res.json({page: 'auth@edit'});
+        }
+    }
+}

server/routes/users.js

@@ -0,0 +1,21 @@
+const model = require('../models/list');
+const CrudService = require('../services/crud');
+
+const service = new CrudService(model);
+
+module.exports = function () {
+    return {
+        index: function (req, res) {
+            service.list().then((result) => {
+                return res.json(result);
+            });
+        },
+        add: function (req, res) {
+            service.insert(req.body).then((result) => {
+                return res.json(result);
+            }).catch((err) =>{
+                return res.status(422).json(err);
+            });
+        }
+    }
+};

server/src/controllers/auth.js

@@ -0,0 +1,8 @@
+const mongoose = require('mongoose');
+
+const List = mongoose.Schema({
+    title: {type: String, required: true},
+    quantity: Number
+});
+
+module.exports = mongoose.model('List', List);

server/src/controllers/lists.js

@@ -0,0 +1,10 @@
+const passport = require('../auth/auth');
+
+module.exports = function (app) {
+    const controller = require('../controllers/auth')(app);
+
+    app.post('/oauth/token', controller.token);
+    app.get('/oauth/me', passport.authenticate('jwt', {session: false}), controller.me);
+    app.post('/oauth/register', controller.register);
+    app.put('/oauth/profile-update', passport.authenticate('jwt', {session: false}), controller.edit);
+}

server/src/models/list.js

@@ -0,0 +1,11 @@
+let auth = require('./auth');
+let lists = require('./lists');
+
+module.exports = (app) => {
+    app.get('/', function (req, res) {
+        res.render('index', {title: 'Express'});
+    });
+
+    auth(app);
+    lists(app);
+};

server/src/routes/auth.js

@@ -0,0 +1,6 @@
+module.exports = function (app) {
+    let controller = require('../controllers/lists')();
+
+    app.get('/api/lists', controller.index);
+    app.post('/api/lists', controller.add);
+}

server/src/routes/index.js

@@ -0,0 +1,24 @@
+function CrudService(model) {
+    this.model = model;
+}
+
+CrudService.prototype.list = function () {
+    return new Promise((resolve) => {
+        this.model.find(null, (err, result) => {
+            return resolve({data: result})
+        })
+    });
+};
+
+CrudService.prototype.insert = function (data) {
+    return new Promise((resolve, reject) => {
+        this.model.create(data, (err, result) => {
+            if (err) {
+                return reject({err: err});
+            }
+            return resolve({data: result})
+        })
+    });
+};
+
+module.exports = CrudService;