var socket = require( 'socket.io' );
var express = require( 'express' );
var http = require( 'http' );

var app = express();
var server = http.createServer( app );

var io = socket.listen( server );

io.sockets.on( 'connection', function( client ) {
	console.log( "New client !" );
	
	client.on( 'message', function( data ) {
		console.log( 'Message received ' + data.name + ":" + data.message+": "+data.send_by );
		
		//client.broadcast.emit( 'message', { name: data.name, message: data.message } );
		io.sockets.emit( 'message', { chat_id:data.chat_id,to_id:data.to_id,send_by:data.send_by,current_time:data.current_time,name: data.name, message: data.message,image:data.image } );
	});

	client.on( 'notifyUser', function( data ) {
		console.log( 'Message notifyUser ' + data.name + ":" + data.send_by+": "+data.to_id );
		//client.broadcast.emit( 'message', { name: data.name, message: data.message } );
		io.sockets.emit( 'notifyUser', { name:data.name,send_by:data.send_by,to_id:data.to_id} );
	});
	client.on( 'see_product', function( data ) {
		
		//client.broadcast.emit( 'message', { name: data.name, message: data.message } );
		io.sockets.emit( 'see_product', { name:data.name,sendby:data.sendby} );
	});
	     

});


server.listen( 5000 );