ini push

Author: nihitx

.gitignore

@@ -0,0 +1 @@
+/node_modules

database_create.sql

@@ -0,0 +1,12 @@
+CREATE TABLE `user` (
+  `ID` bigint(20) unsigned NOT NULL AUTO_INCREMENT,
+  `Owner` bigint(20) unsigned NOT NULL,
+  `firstname` varchar(50) DEFAULT NULL,
+  `lastname` varchar(50) DEFAULT NULL,
+  `email` varchar(50) DEFAULT NULL,
+  `password` varchar(255) DEFAULT NULL,
+  `token` varchar(255) DEFAULT NULL,
+  `INSERT_DT` timestamp DEFAULT CURRENT_TIMESTAMP,
+  `UPDATE_DT` datetime DEFAULT NULL,
+  PRIMARY KEY (`ID`)
+) ENGINE=InnoDB AUTO_INCREMENT=0 DEFAULT CHARSET=latin1;

db.js

@@ -0,0 +1,13 @@
+var mysql = require('mysql');
+
+var connection = mysql.createConnection({
+    host     : '127.0.0.1',
+    user     : 'root',
+    password : 'root',
+    database : 'bitcoin'
+});
+connection.connect(function(err) {
+    if (err) throw err;
+});
+
+module.exports = connection;

index.js

@@ -0,0 +1,48 @@
+var express = require('express');
+var app = express();
+var path = require('path');
+var bodyParser = require('body-parser');
+
+/* Getting all the db querys */
+const {saveUser,findUser, UpdateToken} = require('./models/user');
+/* This middle ware checks if the token given by the user is right */
+const {authenticate} = require('./middleware/authenticate');
+
+// The code below allows the node js to find the public directory with the index.html file
+const publicPath = path.join(__dirname, './public');
+// Node js is using port 3000/ and when you push to cloud it will use process.env.PORT
+const port = process.env.PORT || 3000;
+
+// Bodyparser for using json data
+app.use(bodyParser.json());
+app.use(bodyParser.urlencoded({ extended: false }));
+app.use(express.static(publicPath));
+
+
+/* GET index page */
+app.get('/', function(req, res, next) {
+   res.render('index');
+});
+
+/* This function saves a user to the db
+	It uses promises.
+ */
+app.post('/createUser',(req,res,next)=>{
+    saveUser(req.body).then((result)=>{
+        return res.header('x-auth', result.token).send({email : result.email});
+    }).catch((e)=>{
+        return res.status(400).send(e);
+    });
+});
+
+/* When the user from the front-end wants to use a function,
+ The below code is an example of using the word authenticate to see if the
+ user is actually authenticated
+*/
+app.get('/get/me',authenticate,(req,res,next)=>{
+    res.send(req.user);
+});
+
+app.listen(port, () => {
+  console.log(`Server is up on ${port}`);
+});

middleware/authenticate.js

@@ -0,0 +1,17 @@
+const {getUserByToken} = require('../models/user');
+
+// First we call the model using the above code.
+// We pass in the token from the request header and see if we can get the
+// User or not, if not then we return a 401 and if it works we pass next()
+var authenticate = (req,res,next)=>{
+    var token = req.header('x-auth');
+    getUserByToken(token).then((result)=>{
+        req.user = result;
+        req.token = token;
+        next();
+    }).catch((e)=>{
+        return res.status(401).send();
+    });
+}
+
+module.exports = {authenticate}

models/user.js

@@ -0,0 +1,45 @@
+var db = require('../db');
+var jwt = require('jsonwebtoken');
+var bcrypt = require('bcryptjs');
+
+getAllUser = () => new Promise((resolve, reject) => {
+    db.query('SELECT * from user', function (error, results, fields) {
+        if (error){
+            reject();
+        }else{
+            resolve(results[0]);
+        }
+    });
+});
+
+saveUser = (userinfo) => new Promise((resolve,reject)=>{
+    var salt = bcrypt.genSaltSync(10);
+    var hash = bcrypt.hashSync(userinfo.password, salt);
+
+    userinfo.password = hash;
+    userinfo.token = jwt.sign({Owner : userinfo.Owner},'secretkeyyo');
+
+    db.query('INSERT INTO user SET ?',userinfo,function(error,results,fields){
+        if(error){
+            reject();
+        }else{
+            resolve(userinfo);
+        }
+    })
+});
+
+getUserByToken = (token) => new Promise((resolve, reject) => {
+    var decoded ;
+    try{
+        decoded = jwt.verify(token,'secretkeyyo');
+        resolve(decoded);
+    }catch(e){
+        reject();
+    }
+});
+
+// The code below export the above functios so it can be used in other files.
+module.exports = {
+    saveUser,
+    getUserByToken
+};