Carlos banks

api/server.js

@@ -0,0 +1,11 @@
+const express = require('express');
+const helmet = require('helmet');
+const usersRouter = require('./users/usersRouter');
+
+const server = express();
+
+server.use(express.json());
+server.use(helmet());
+server.use('/api', usersRouter);
+
+module.exports = server;

api/users/usersModel.js

@@ -0,0 +1,19 @@
+const db = require('../../data/dbConfig');
+
+module.exports = {
+    find,
+    findBy,
+    insert
+}
+
+function find() {
+    return db('users').select('id', 'username', 'department');
+}
+
+function findBy(user) {
+    return db('users').where(user).first();
+}
+
+function insert(user) {
+    return db('users').insert(user).then(([id]) => findBy({ id }).first());
+} 

api/users/usersRouter.js

@@ -0,0 +1,55 @@
+const router = require('express').Router();
+
+const Users = require('./usersModel.js');
+const bcrypt = require('bcryptjs');
+const genToken = require('../../utils/generateToken.js');
+const restricted = require('../../utils/restricted.js');
+
+// REGISTER A USER
+router.post('/register', async (req, res) => {
+    const user = req.body;
+    if (!user.username && !user.password && !user.department) 
+        return res.status(401).json({ message: "Provide a username, password, and a department." });
+    user.password = bcrypt.hashSync(user.password);
+
+    try {
+        const _user = await Users.insert(user);
+        res.status(201).json(_user);
+
+    } catch(error) {
+        res.status(400).json({ message: "This user already exists.", error });
+    }
+});
+
+// USER LOGIN
+router.post('/login', async (req, res) => {
+    const { username, password } = req.body;
+    try {
+        const _user = await Users.findBy({ username });
+        if (_user && bcrypt.compareSync(password, _user.password)) {
+            const user = {
+                id: _user.id,
+                username: _user.username,
+                department: _user.department,
+                token: genToken(_user)
+            }
+            res.status(200).json(user);
+        } else {
+            res.status(401).json({ message: "Try again!" });
+        }
+    } catch(error) {
+        res.status(401).json({ message: "Try again!" });
+    }
+});
+
+// GET USERS
+router.get('/users', restricted, async (req, res) => {
+    try {
+        const users = await Users.find();
+        res.status(200).json(users);
+    } catch(error) {
+        res.status(500).json({ message: "Error retrieving users" })
+    }
+});
+
+module.exports = router; 

data/dbConfig.js

@@ -0,0 +1,3 @@
+const environment = process.env.ENVIRONMENT || 'development';
+const config = require('../knexfile.js')[environment];
+module.exports = require('knex')(config); 

data/migrations/20200319201349_user-table.js

@@ -0,0 +1,20 @@
+exports.up = function(knex) {
+    return (
+        knex.schema
+            .createTable('users', tbl => {
+                tbl.increments()
+                tbl.text('username')
+                    .notNullable()
+                    .unique();
+                tbl.string('password').notNullable();
+                tbl.text('department').notNullable();
+            })
+    );
+};
+
+exports.down = function(knex) {
+  return (
+      knex.schema
+        .dropTableIfExists('users')
+  );
+};

index.js

@@ -0,0 +1,7 @@
+require('dotenv').config();
+const server = require('./api/server.js');
+const PORT = process.env.PORT || 3000;
+
+server.listen(PORT, () => {
+    console.log(`Sever Listening On Port ${PORT}`);
+});

knexfile.js

@@ -0,0 +1,14 @@
+module.exports = {
+
+  development: {
+    client: 'sqlite3',
+    connection: {
+      filename: './data/users.db3'
+    },
+    migrations: {
+      directory: './data/migrations'
+    },
+    useNullAsDefault: true
+  }
+
+};