var express = require('express');
var app = express();
app.use(express.static("./public"));
app.set('view engine','ejs');
app.set('views','./views');
const mongoose = require('mongoose');
mongoose.connect('mongodb://localhost:27017/myDatabase');
var db = mongoose.connection;
db.on('error', console.error.bind(console, 'connection error:'));
db.once('open', function() {
console.log('Server is open now');
});
const userSchema = new mongoose.Schema({
// name: String,
// age: Number
mess: String,
})
const user = mongoose.model('user',userSchema)
//user.create({mess: "Day la tin nhan dau tien trong server"});
var server = require('http').Server(app);
var io = require('socket.io')(server);
server.listen(3000);
//listen from port 3000
//if pp connect, it will create new socket
//from server listen
var data_from_server;
user.find(function(err,users)
{
if(err)
{
console.log("Can't get data from server ");
return null;
}
else
{
data_from_server = JSON.stringify(users);
}
})
// io.on('Server-sent-all-data',function(){
// // i will give you data
// });
io.on('connection', function(socket){
console.log('Co nguoi ket noi '+socket.id);
//from socket listen
socket.on('disconnect',function(){
console.log(socket.id+' ngat ket noi ');
});
socket.on('Client-sent-data',function(data){
var new_message = new user();
new_message.mess = data;
console.log(socket.id+' gui 1 tin nhan '+data);
new_message.save(function (err)
{if (err) console.log ('Error on save!')});
io.sockets.emit('Server-sent-data',data);
})
socket.emit('Server-sent-all-data',data_from_server)
});
// speak all socket
app.get('/',function(req,res){
res.render("trangchu");
})