Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions .gitignore
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
node_modules
10 changes: 9 additions & 1 deletion README.md
Original file line number Diff line number Diff line change
@@ -1 +1,9 @@
# api-auth
# api-auth

/api/signup POST Sign up with new user info
/api/signIn POST Sign in while get an access token based on credentials
/api/users GET Get all the users info (admin only)
/api/users/:id GET Get a single user info (admin and authenticated user)
/api/users POST Create a user (admin only)
/api/users/:id DELETE Delete a user (admin only)
/api/users/:id PUT Update a user with new info (admin and authenticated user)
48 changes: 48 additions & 0 deletions app.js
Original file line number Diff line number Diff line change
@@ -0,0 +1,48 @@
var express = require('express');
var path = require('path');
var favicon = require('serve-favicon');
var logger = require('morgan');
var cookieParser = require('cookie-parser');
var bodyParser = require('body-parser');

var index = require('./routes/index');
var users = require('./routes/users');
var api = require('./routes/api');

var app = express();

// view engine setup
app.set('views', path.join(__dirname, 'views'));
app.set('view engine', 'jade');

// uncomment after placing your favicon in /public
//app.use(favicon(path.join(__dirname, 'public', 'favicon.ico')));
app.use(logger('dev'));
app.use(bodyParser.json());
app.use(bodyParser.urlencoded({ extended: false }));
app.use(cookieParser());
app.use(express.static(path.join(__dirname, 'public')));

app.use('/', index);
app.use('/users', users);
app.use('/api', api);

// catch 404 and forward to error handler
app.use(function(req, res, next) {
var err = new Error('Not Found');
err.status = 404;
next(err);
});

// error handler
app.use(function(err, req, res, next) {
// set locals, only providing error in development
res.locals.message = err.message;
res.locals.error = req.app.get('env') === 'development' ? err : {};

// render the error page
res.status(err.status || 500);
res.render('error');
});

module.exports = app;
90 changes: 90 additions & 0 deletions bin/www
Original file line number Diff line number Diff line change
@@ -0,0 +1,90 @@
#!/usr/bin/env node

/**
* Module dependencies.
*/

var app = require('../app');
var debug = require('debug')('api-auth:server');
var http = require('http');

/**
* Get port from environment and store in Express.
*/

var port = normalizePort(process.env.PORT || '3000');
app.set('port', port);

/**
* Create HTTP server.
*/

var server = http.createServer(app);

/**
* Listen on provided port, on all network interfaces.
*/

server.listen(port);
server.on('error', onError);
server.on('listening', onListening);

/**
* Normalize a port into a number, string, or false.
*/

function normalizePort(val) {
var port = parseInt(val, 10);

if (isNaN(port)) {
// named pipe
return val;
}

if (port >= 0) {
// port number
return port;
}

return false;
}

/**
* Event listener for HTTP server "error" event.
*/

function onError(error) {
if (error.syscall !== 'listen') {
throw error;
}

var bind = typeof port === 'string'
? 'Pipe ' + port
: 'Port ' + port;

// handle specific listen errors with friendly messages
switch (error.code) {
case 'EACCES':
console.error(bind + ' requires elevated privileges');
process.exit(1);
break;
case 'EADDRINUSE':
console.error(bind + ' is already in use');
process.exit(1);
break;
default:
throw error;
}
}

/**
* Event listener for HTTP server "listening" event.
*/

function onListening() {
var addr = server.address();
var bind = typeof addr === 'string'
? 'pipe ' + addr
: 'port ' + addr.port;
debug('Listening on ' + bind);
}
9 changes: 9 additions & 0 deletions config/config.json
Original file line number Diff line number Diff line change
@@ -0,0 +1,9 @@
{
"development": {
"username": "parel",
"password": "12345",
"database": "api_auth",
"host": "127.0.0.1",
"dialect": "postgres"
}
}
106 changes: 106 additions & 0 deletions controllers/userController.js
Original file line number Diff line number Diff line change
@@ -0,0 +1,106 @@
'use strict';

var models = require('../models');
var passwordHash = require('password-hash');
var jwt = require('jsonwebtoken');

var methods = {};

methods.getAllUsers = (req,res,next) => {
models.User.findAll()
.then(data => {
res.json(data)
})
}

methods.getOneUser = (req,res,next) => {
models.User.findOne({
where: {
id: req.params.id
}
})
.then(data => {
res.json(data)
})
}

methods.createUser = (req,res,next) => {
models.User.create({
username: req.body.username,
password: passwordHash.generate(req.body.password),
name: req.body.name,
email: req.body.email,
role: req.body.role || 'user'
})
.then(data => {
res.json(data)
})
}

methods.updateUser = (req,res,next) => {
models.User.update({
username: req.body.username,
password: passwordHash.generate(req.body.password) || req.body.password,
name: req.body.name,
email: req.body.email,
role: req.body.role || 'user'
},{
where : {
id : req.params.id
}
})
.then(data => {
res.json(data)
})
}

methods.deleteUser = (req,res,next) => {
models.User.destroy({
where : {
id : req.params.id
}
})
.then(data => {
res.json(data);
})
}

methods.signUp = (req,res,next) => {
models.User.create({
username: req.body.username,
password: passwordHash.generate(req.body.password),
name: req.body.name,
email: req.body.email,
role: 'user'
})
.then(data => {
res.json(data)
})
}

methods.signIn = (req,res,next) => {
models.User.findOne({
where: {
username: req.body.username
}
})
.then(data => {
if (data === null) {
res.send('User not found')
} else {
if (passwordHash.verify(req.body.password, data.password)) {
var token = jwt.sign({
username : data.username,
role : data.role
}, 'secret', {
expiresIn : '3h'
})
res.send(token)
} else {
res.send('Password unmatch')
}
}
})
}

module.exports = methods;
35 changes: 35 additions & 0 deletions helpers/util.js
Original file line number Diff line number Diff line change
@@ -0,0 +1,35 @@
'use strict';

var jwt = require('jsonwebtoken');
var models = require('../models');
var util = {};

util.isValidAdmin = (req,res,next) => {
jwt.verify(req.headers.token, 'secret', (err,decoded) => {
if (decoded) {
if (decoded.role == 'admin') {
next();
} else {
res.send('You are not authorized')
}
} else {
res.send(err)
}
})
}

util.isValidUserOrAdmin = (req,res,next) => {
jwt.verify(req.headers.token, 'secret', (err,decoded) => {
if (decoded) {
if (decoded.role == 'admin' || decoded.role == 'user') {
next();
} else {
res.send('You are not authorized')
}
} else {
res.send(err)
}
})
}

module.exports = util;
40 changes: 40 additions & 0 deletions migrations/20170425081642-create-user.js
Original file line number Diff line number Diff line change
@@ -0,0 +1,40 @@
'use strict';
module.exports = {
up: function(queryInterface, Sequelize) {
return queryInterface.createTable('Users', {
id: {
allowNull: false,
autoIncrement: true,
primaryKey: true,
type: Sequelize.INTEGER
},
username: {
type: Sequelize.STRING
},
password: {
type: Sequelize.STRING
},
name: {
type: Sequelize.STRING
},
email: {
type: Sequelize.STRING
},
role: {
type: Sequelize.STRING
},
createdAt: {
allowNull: false,
type: Sequelize.DATE
},
updatedAt: {
allowNull: false,
defaultValue: new Date().toISOString(),
type: Sequelize.DATE
}
});
},
down: function(queryInterface, Sequelize) {
return queryInterface.dropTable('Users');
}
};
36 changes: 36 additions & 0 deletions models/index.js
Original file line number Diff line number Diff line change
@@ -0,0 +1,36 @@
'use strict';

var fs = require('fs');
var path = require('path');
var Sequelize = require('sequelize');
var basename = path.basename(module.filename);
var env = process.env.NODE_ENV || 'development';
var config = require(__dirname + '/../config/config.json')[env];
var db = {};

if (config.use_env_variable) {
var sequelize = new Sequelize(process.env[config.use_env_variable]);
} else {
var sequelize = new Sequelize(config.database, config.username, config.password, config);
}

fs
.readdirSync(__dirname)
.filter(function(file) {
return (file.indexOf('.') !== 0) && (file !== basename) && (file.slice(-3) === '.js');
})
.forEach(function(file) {
var model = sequelize['import'](path.join(__dirname, file));
db[model.name] = model;
});

Object.keys(db).forEach(function(modelName) {
if (db[modelName].associate) {
db[modelName].associate(db);
}
});

db.sequelize = sequelize;
db.Sequelize = Sequelize;

module.exports = db;
Loading