Subversion Repositories SmartDukaan

var express = require('express');

var app = express();

var cors = require('cors');

var bodyParser = require('body-parser');

var fs = require("fs");

var multer  = require('multer');

var cookieParser = require('cookie-parser')

cassandra = require('cassandra-driver');

var client = new cassandra.Client({ contactPoints: ['localhost'], keyspace: 'profitmandi'});

// Create application/x-www-form-urlencoded parser

var urlencodedParser = bodyParser.urlencoded({ extended: false })

var whitelist = ['http://localdtr', 'http://api.profittill.com','http://staging.profittill.com','http://localhost:8100','http://mobilehotindia.com'];

var corsOptions = {

  origin: function(origin, callback){

    var originIsWhitelisted = whitelist.indexOf(origin) !== -1;

    callback(null, originIsWhitelisted);

  }

};

app.use(express.static('public'));

app.use(multer({ dest: '/tmp/'}));

app.use(cookieParser());

app.use(cors(corsOptions));

app.get('/index.html', function (req, res) {

   res.sendFile( __dirname + "/" + "index.html" );

})

app.get('/process_get', function (req, res) {

   // Prepare output in JSON format

   response = {

       first_name:req.query.first_name,

       last_name:req.query.last_name

   };

   //console.log(response);

   res.end(JSON.stringify(response));

})

app.post('/identify', urlencodedParser, function (req, res) {

   // Prepare output in JSON format

   response = {

       	id:req.body.id,

       	email:req.body.email,

		name:req.body.name,

		mobilenumber:req.body.mobilenumber,

		referral_code:req.body.referral_code

   };

	var query = "INSERT INTO users(id,email,name,mobilenumber,referral_code) values(?,?,?,?,?)";

	var params = [response.id,response.email,response.name,response.mobilenumber,response.referral_code];

	console.log(params);

	client.execute(query, params,{prepare: true}, function(err, result) {

		if(err){

			console.log(err);

			var result = {success:false,message:err};

			res.end(JSON.stringify(result));

		}else{

			var result = {success:true,message:'User Registered'};

			res.end(JSON.stringify(result));

			console.log('User Registered');

		}

	});

})

app.post('/track', urlencodedParser, function (req, res) {

   	// Prepare output in JSON format

   	response = {

   		user_id:req.body.user_id,

       	category:req.body.category,

       	action:req.body.action,

		label:req.body.label,

		properties:req.body.properties

   	};

	var d = new Date();

	var date = d.toYMD();

   	var query = "INSERT INTO user_activities(user_id,date) VALUES("+response.user_id+",'"+date+"')";

	console.log(query);

	client.execute(query, null,{}, function(err, result) {

		if(err){

			console.log('User activity could not tracked. '+err);

		}		

	});

	if(response.properties && response.properties.length > 0)	{

		var query = "INSERT INTO events(user_id,category,action,label,properties,time) values("+response.user_id+",'"+response.category+"','"+response.action+"','"+response.label+"',"+response.properties+",'"+new Date().toISOString()+"')";

	}else{

		var query = "INSERT INTO events(user_id,category,action,label,time) values("+response.user_id+",'"+response.category+"','"+response.action+"','"+response.label+"','"+new Date().toISOString()+"')";

	}

	console.log(query);

	client.execute(query, null,{}, function(err, result) {

		if(err){

			var result = {success:false,message:'Event could not tracked'};

			res.end(JSON.stringify(result));

			console.log('Event could not tracked. '+err);

		}else{

			var result = {success:true,message:'Event tracked'};

			res.end(JSON.stringify(result));

			//console.log('Event tracked');

		}		

	});

})

// This responds with "Hello World" on the homepage

app.get('/', function (req, res) {

   //console.log("Got a GET request for the homepage");

   res.send('Hello GET');

})

// This responds a POST request for the homepage

app.post('/', function (req, res) {

   //console.log("Got a POST request for the homepage");

   console.log("Cookies: ", req.cookies)

   res.send('Hello POST');

})

// This responds a GET request for the /list_users page.

app.get('/list_users', function (req, res) {

	var d = new Date();

	var date = d.toYMD();

	var query = "SELECT user_id FROM user_activities WHERE date ='"+date+"'";

	client.execute(query, {},{prepare: true}, function(err, result) {

		if(err){

			console.log(err);

			res.send(err);

		}else{

			var activeusers = [];

			for(var i in result.rows) {

				activeusers.push(result.rows[i].user_id);

			}

			if(activeusers && activeusers.length>0) {

				var query = "SELECT * FROM users WHERE id IN ("+activeusers.join(',')+")";

			} else{

				var query = "SELECT * FROM users LIMIT 50"; 

			}

			var params = [];	

			if(typeof req.query.id != 'undefined'){

				var query = "SELECT * FROM users WHERE id = ?";

				params = [req.query.id];

			}

			//console.log(query);

			//console.log(params);

			client.execute(query, params,{prepare: true}, function(err, result) {

				if(err){

					console.log(err);

					res.send(err);

				}

				//console.log(JSON.stringify(result.rows));

				res.send(JSON.stringify(result.rows));

			});

		}

	});

})

// This responds a GET request for the /list_events page.

app.get('/list_events', function (req, res) {

	var d = new Date();

	var date = d.toYMD();

	var query = "SELECT user_id FROM user_activities WHERE date ='"+date+"'";

	client.execute(query, {},{prepare: true}, function(err, result) {

		if(err){

			console.log(err);

			res.send(err);

		}else{

			var activeusers = [];

			for(var i in result.rows) {

				activeusers.push(result.rows[i].user_id);

			}

			if(activeusers && activeusers.length>0) {

				var query = "SELECT * FROM events WHERE user_id IN ("+activeusers.join(',')+") ORDER BY time DESC LIMIT 50";

			} else {

				var query = "SELECT * FROM events LIMIT 50";

			}

			var params = [];	

			if(typeof req.query.user_id != 'undefined'){

				var query = "SELECT * FROM events WHERE user_id = ? ORDER BY time DESC";

				params = [req.query.user_id];

			}

			console.log(query);

			//console.log(params);

			client.execute(query, params,{prepare: true}, function(err, result) {

				if(err){

					console.log(err);

					res.send(err);

				}

				//console.log('got user profile with email ' + result.rows[0].email);

				//console.log(JSON.stringify(result.rows));

				res.send(JSON.stringify(result.rows));

			});

		}

	});

})

// This responds a GET request for abcd, abxcd, ab123cd, and so on

app.post('/update_profile', urlencodedParser, function(req, res) {   

   // Prepare output in JSON format

   	response = {

       	id:req.body.id,

       	profile:req.body.profile		

   	};

	var query = "UPDATE users SET profile = "+response.profile+" WHERE id = "+response.id;

	// var params = [response.profile,response.id];

	console.log(query);

	client.execute(query, null,{}, function(err, result) {

		if(err){

			console.log(err);

			var result = {success:false,message:'User not updated. Try again later.'};

			res.end(JSON.stringify(result));

		}else{

			var result = {success:true,message:'User Updated'};

			res.end(JSON.stringify(result));

			//console.log('User Updated');

		}

	});

})

var server = app.listen(8081, function () {

  var host = server.address().address

  var port = server.address().port

  console.log("Example app listening at http://%s:%s", host, port)

})

function generateUUID(){

    var d = new Date().getTime();

    var uuid = 'xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx'.replace(/[xy]/g, function(c) {

        var r = (d + Math.random()*16)%16 | 0;

        d = Math.floor(d/16);

        return (c=='x' ? r : (r&0x3|0x8)).toString(16);

    });

    return uuid;

};

Date.prototype.toYMD = Date_toYMD;

function Date_toYMD() {

	var year, month, day;

	year = String(this.getFullYear());

	month = String(this.getMonth() + 1);

	if (month.length == 1) {

	    month = "0" + month;

	}

	day = String(this.getDate());

	if (day.length == 1) {

	    day = "0" + day;

	}

	return year + "-" + month + "-" + day;

}