initial commit

Author: akhilpy

config.js

@@ -0,0 +1,5 @@
+module.exports={
+// secret: used when we create and verify JSON Web Tokens
+					secret:'jsismagic',
+	
+};

database.js

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

database.sql

@@ -0,0 +1,64 @@
+SET @OLD_UNIQUE_CHECKS=@@UNIQUE_CHECKS, UNIQUE_CHECKS=0;
+SET @OLD_FOREIGN_KEY_CHECKS=@@FOREIGN_KEY_CHECKS, FOREIGN_KEY_CHECKS=0;
+SET @OLD_SQL_MODE=@@SQL_MODE, SQL_MODE='TRADITIONAL,ALLOW_INVALID_DATES';
+
+CREATE SCHEMA IF NOT EXISTS `restful_api_demo` DEFAULT CHARACTER SET latin1 ;
+USE `restful_api_demo` ;
+
+-- -----------------------------------------------------
+-- Table `restful_api_demo`.`user_login`
+-- -----------------------------------------------------
+DROP TABLE IF EXISTS `restful_api_demo`.`user_login` ;
+
+CREATE TABLE IF NOT EXISTS `restful_api_demo`.`user_login` (
+  `user_id` INT(70) NOT NULL AUTO_INCREMENT,
+  `user_email` VARCHAR(45) NOT NULL,
+  `user_password` VARCHAR(45) NULL,
+  `user_join_date` TIMESTAMP NULL DEFAULT CURRENT_TIMESTAMP,
+  PRIMARY KEY (`user_id`),
+  UNIQUE INDEX `user_email_UNIQUE` (`user_email` ASC))
+ENGINE = InnoDB;
+
+
+-- -----------------------------------------------------
+-- Table `restful_api_demo`.`user_info`
+-- -----------------------------------------------------
+DROP TABLE IF EXISTS `restful_api_demo`.`user_info` ;
+
+CREATE TABLE IF NOT EXISTS `restful_api_demo`.`user_info` (
+  `user_info_id` INT(70) NOT NULL AUTO_INCREMENT,
+  `user_id_fk` INT(70) NOT NULL,
+  `user_name` VARCHAR(45) NULL,
+  `user_location` VARCHAR(45) NULL,
+  PRIMARY KEY (`user_info_id`),
+  UNIQUE INDEX `user_id_fk_UNIQUE` (`user_id_fk` ASC),
+  CONSTRAINT `user_info_foreign_key`
+    FOREIGN KEY (`user_id_fk`)
+    REFERENCES `restful_api_demo`.`user_login` (`user_id`)
+    ON DELETE NO ACTION
+    ON UPDATE NO ACTION)
+ENGINE = InnoDB;
+
+
+-- -----------------------------------------------------
+-- Table `restful_api_demo`.`user_status`
+-- -----------------------------------------------------
+DROP TABLE IF EXISTS `restful_api_demo`.`user_status` ;
+
+CREATE TABLE IF NOT EXISTS `restful_api_demo`.`user_status` (
+  `user_status_id` INT(70) NOT NULL AUTO_INCREMENT,
+  `user_id_fk` INT(70) NOT NULL,
+  `status_text` TEXT NULL DEFAULT NULL,
+  `status_time` TIMESTAMP NULL DEFAULT CURRENT_TIMESTAMP,
+  PRIMARY KEY (`user_status_id`),
+  UNIQUE INDEX `user_id_fk_UNIQUE` (`user_id_fk` ASC),
+  CONSTRAINT `user_status_foreign_key`
+    FOREIGN KEY (`user_id_fk`)
+    REFERENCES `restful_api_demo`.`user_login` (`user_id`)
+    ON DELETE NO ACTION
+    ON UPDATE NO ACTION)
+ENGINE = InnoDB;
+
+SET SQL_MODE=@OLD_SQL_MODE;
+SET FOREIGN_KEY_CHECKS=@OLD_FOREIGN_KEY_CHECKS;
+SET UNIQUE_CHECKS=@OLD_UNIQUE_CHECKS;

middleware/addNewUser.js

@@ -0,0 +1,59 @@
+
+var mysql   = require("mysql");
+var express = require("express");
+var md5 = require("MD5");
+var connection = require("../database");
+
+
+ var addNewUser = function(req,res, next){
+ 	var date = new Date();
+    var post  = {
+      first_name:req.body.first_name,
+      last_name:req.body.last_name,
+      email:req.body.email,
+      password:md5(req.body.password),
+      dob:req.body.dob,
+      latitude:req.body.latitude,
+      longitude:req.body.longitude,
+      device_type:req.body.device_type,
+      device_token:req.body.device_token,
+     // time_zone:req.body.time_zone
+      
+  };
+  console.log(post);
+  		var query = "SELECT email FROM ?? WHERE ??=?";
+
+		var table = ["user", "email", post.email];
+
+		query = mysql.format(query,table);
+
+		connection.query(query,function(err,rows){
+		if(err) {
+			res.json({"Error" : true, "Message" : "Error executing MySQL query"});
+		}
+		else {
+
+		if(rows.length==0){
+
+			var query = "INSERT INTO  ?? SET  ?";
+			var table = ["user"];
+			query = mysql.format(query,table);
+			connection.query(query, post, function(err,rows){
+				if(err) {
+					res.json({"Error" : true, "Message" : "Error executing MySQL query"});
+				} else {
+					res.json({"Error" : false, "Message" : "Success"});
+				}
+			});
+
+		}
+		else{
+			res.json({"Error" : false, "Message" : "Email Id already registered"});
+		}
+		}
+    });
+	}
+
+   module.exports = addNewUser;
+
+

middleware/findAllUsers.js

@@ -0,0 +1,24 @@
+
+var mysql   = require("mysql");
+var express = require("express");
+var jwt = require('jsonwebtoken'); // used to create, sign, and verify tokens
+var config = require('../config');
+var connection = require("../database");
+
+var findAllUsers = function (req, res) {
+
+	var query = "SELECT * FROM ?? ";
+
+    var table = ["user"];
+
+    query = mysql.format(query,table);
+
+    connection.query(query,function(err,rows){
+        if(err) {
+            res.json({"Error" : true, "Message" : "Error executing MySQL query"});
+        } else {
+            res.json({"Error" : false, "Message" : "Success", "Users" : rows});
+        }
+    });
+};
+module.exports = findAllUsers;

middleware/userLoginCheck.js

@@ -0,0 +1,97 @@
+
+var mysql   = require("mysql");
+var express = require("express");
+var md5 = require("MD5");
+var jwt = require('jsonwebtoken'); // used to create, sign, and verify tokens
+var config = require('../config');
+var connection = require("../database"); // get our config file
+
+
+var userLoginCheck = function (req, res) {
+
+	//var em = req.body.email || req.query.email;
+	var post  = {
+		password:req.body.password,
+		email:req.body.email
+	}
+
+	var query = "SELECT * FROM ?? WHERE ??=? AND ??=?";
+
+	var table = ["user","password",  md5(post.password), "email", post.email];
+
+	query = mysql.format(query,table);
+
+	connection.query(query,function(err,rows){
+		if(err) {
+			res.json({"Error" : true, "Message" : "Error executing MySQL query"});
+		}
+		else {
+
+			if(rows.length==1){
+				var token = jwt.sign(rows, config.secret, {
+					expiresIn: 1440
+				});
+				user_id= rows[0].userid;
+				var data  = {
+					user_id:rows[0].userid,
+					device_type:rows[0].device_type,
+					access_token:token,
+					device_token:rows[0].device_token,
+					ip_address:rows[0].ip_address
+				}
+				var query = "INSERT INTO  ?? SET  ?";
+				var table = ["access_token"];
+				query = mysql.format(query,table);
+				connection.query(query, data, function(err,rows){
+					if(err) {
+						res.json({"Error" : true, "Message" : "Error executing MySQL query"});
+					} else {
+						res.json({
+							success: true,
+							message: 'Token generated',
+							token: token,
+							currUser: user_id
+						});
+           				 } // return info including token
+           				});
+			}
+			else {
+				res.json({"Error" : true, "Message" : "wrong email/password combination"});
+			}
+
+		}
+	});
+}
+
+module.exports = userLoginCheck;
+
+
+
+// 	User.findOne({ email: em }, function (err, user) {
+// 		if (err) {
+// 			res.error(err);
+// 		} else if (!user) {
+// 			// res.json({ success: false, message: 'Authentication failed wrong email' });
+// 			res.sendStatus(401);
+
+// 		} else if (user) {
+// 			// check if password matches
+// 			if (!bcrypt.compareSync(req.body.password, user.password)) {
+// 				// res.json({ success: false, message: 'Wrong password' })
+// 				res.sendStatus(401);
+// 			} else {
+// 				// create token
+// 				var token = jwt.sign(user, config.secret, {
+// 					expiresInMinutes: 1440
+// 				});
+// 				// return info including token
+// 				res.json({
+// 					success: true,
+// 					message: 'Token generated',
+// 					token: token,
+// 					currUser: user._id
+// 				});
+// 			}
+// 		}
+// 	});
+// }

middleware/verifyToken.js

@@ -0,0 +1,34 @@
+
+// get our mongoose model
+var jwt = require('jsonwebtoken'); // used to create, sign, and verify tokens
+var config = require('../config'); // get our config file
+
+/**
+ * This api is use to verify token for each request,
+ * when client requests with a token this API decodes that match with existing token  and send with 
+ * decoded object.
+ * We set currUser i.e. current user to req object so we can access somewhere else.
+ * 
+ */
+ 
+var verifyToken=function (req, res,next) {
+	var token = req.body.token || req.query.token || req.headers['token'];
+	 if (token) {
+		// verify secret and checks exp
+		jwt.verify(token, config.secret, function (err, currUser) {
+			if (err) {
+				res.send(err);
+			} else {
+				// decoded object
+				req.currUser = currUser;
+				next();
+			}
+		});
+	}
+	 else {
+		// send not found error
+		//res.send(401, " ");
+		res.status(401).send("Invalid Access");
+	}
+};
+module.exports=verifyToken;

middleware/welcome.js

@@ -0,0 +1,3 @@
+module.exports=function(req, res) {
+	res.send('Welcome..!! Now  you are now authenticated !');
+};