app.js

var express = require('express'), app = express();

// загружаем модули для работы с mongodb
var mongoose = require('mongoose');

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

const fileUpload = require('express-fileupload');

// Подключаем модуль и ставим на прослушивание 8080-порта - 80й обычно занят под http-сервер
var io = require('socket.io').listen(8080); 

//--------------------------------------------------------
// Ядро системы
var config = require('./config');
var phpf = require('./core/php');       // Реализация php-функций
var access = require('./core/access');  // MongoDB - сессии, управление правами
var db = require('./core/dbmongoose');  // Обёртка для БД
var utils = require('./core/utils');    // Дополнительные функции
//--------------------------------------------------------
//--------------------------------------------------------
// Модули
var Users = require('./modules/users.js'); // модуль - Пользователи
var Messages = require('./modules/messages.js'); // модуль - Сообщения
//--------------------------------------------------------

// последня метка времени для обновления сообщения
var timestampToUpdate = (new Date).getTime();


app.use(bodyParser.json()); // for parsing application/json
app.use(bodyParser.urlencoded({ extended: true })); // for parsing application/x-www-form-urlencoded

// default options
app.use(fileUpload({
  limits: { fileSize:  config.fileSize },
}));


db.connect(function(error){
    if(error) throw error;
});

// Path to our public directory
var pub = __dirname + '/public';

app.use("/", express.static(pub));

// Add headers
app.use(function (req, res, next) {

    // Website you wish to allow to connect
    res.setHeader('Access-Control-Allow-Origin', '*');

    // Request methods you wish to allow
    res.setHeader('Access-Control-Allow-Methods', 'GET, POST, OPTIONS, PUT, PATCH, DELETE');

    // Request headers you wish to allow
    res.setHeader('Access-Control-Allow-Headers', 'X-Requested-With,content-type');

    // Set to true if you need the website to include cookies in the requests sent
    // to the API (e.g. in case you use sessions)
    res.setHeader('Access-Control-Allow-Credentials', true);
	
    res.setHeader('Content-Type', 'text/plain');
    res.setHeader('Cache-Control', 'no-cache');

    // Pass to next layer of middleware
    next();
});

//--------------------------------------------------------------------------------------------------------------------------------

// Отключаем вывод полного лога - пригодится в production'е
//io.set('log level', 1);

// Навешиваем обработчик на подключение нового клиента
io.sockets.on('connection', function (socket) {
	


    var id = 'U' + (socket.id).toString().substr(1,4);
				

    console.log(JSON.stringify({'event': 'connected', 'ID': id, 'datetime': (new Date).getTime()}));
		
			
	// Посылаем клиенту сообщение о том, что он успешно подключился и его имя
	socket.json.send({'event': 'connected', 'ID': id, 'datetime': (new Date).getTime()});
			
			
	// Посылаем всем остальным пользователям, что подключился новый клиент и его имя
	socket.broadcast.json.send({'event': 'userJoined', 'ID': id, 'datetime': (new Date).getTime()});
    
    
    // начать повторы с интервалом 2 сек
    var timerId = setInterval(function() {
        
         Messages.getNewList(timestampToUpdate, config.max_lim, function(messages) {
             
             // рассылка новых сообщений
             for(var i in messages) {
                 
                 console.log(messages[i]);
                    
                  // Отсылаем сообщение остальным участникам чата
                  socket.broadcast.json.send({'event': 'messageReceived', 'login': messages[i].login, 'text': messages[i].text, 'datetime': messages[i].datetime});
                  
                                                   // обновляем метку времени
                  timestampToUpdate = (new Date).getTime();
                 
             } // end for
             

             
         }); 
    
    }, 3000);


	
	// Навешиваем обработчик на входящее сообщение
	socket.on('message', function (msg) {
        
        var data = JSON.parse(decodeURIComponent(msg));

        
		access.check(data, null, function(req) { 
        
            console.log(JSON.stringify(req));
		
			Messages.addItem(req, function(gtime, form_text, form_login) {
                

               // console.log(JSON.stringify({'event': 'messageSent', 'login': form_login, 'text': form_text, 'datetime': gtime}));
               
                // обновляем метку времени
                timestampToUpdate = (new Date).getTime();
				
				// Уведомляем клиента, что его сообщение успешно дошло до сервера
				socket.json.send({'event': 'messageSent', 'login': form_login, 'text': form_text, 'datetime': gtime});
				
				// Отсылаем сообщение остальным участникам чата
				socket.broadcast.json.send({'event': 'messageReceived', 'login': form_login, 'text': form_text, 'datetime': gtime})
				
			});
		}, data.sid);
		
	});
	
	// При отключении клиента - уведомляем остальных
	socket.on('disconnect', function() {
		io.sockets.json.send({'event': 'userSplit', 'ID': id, 'datetime': (new Date).getTime()});
    });
				

	
});  // end connection

//---------------------------------------------------------------------------------------------------------------------------------

//---------------------------------------------------------------------------------------------------------------------------------
//----- Сообщения ----

// список с медленным skip
app.get('/messages/:skip/:lim', function(req, res) { 
	     Messages.list(req, res); 
 });
 
 // список старше последней даты сообщения
 app.get('/feed-messages/:dt/:lim', function(req, res) {
     Messages.feed(req, res);  //-> анонимный доступ
 });
 
// список младше последней даты сообщения
 app.get('/new-messages/:dt/:lim', function(req, res) {
     Messages.newList(req, res);  //-> анонимный доступ
 });
 
 // список со всеми сообщениями
app.get('/all-messages', function(req, res){
    // access.check(req, res, function(req, res) { 
	     Messages.all(req, res);
  //   }); 
 });
 
// добавить сообщение
app.post('/add-message', function(req, res){ 
     access.check(req, res, function(req, res) { 
	     Messages.add(req, res);
     }); 
});

// вернуть сообщение по id
app.get('/message/:id', function(req, res){
     access.checkAdmin(req, res, function(req, res) { 
	     Messages.item(req, res);  //-> доступ администратора
     }); 
});

// удалить сообщение
app.get('/remove-message/:id', function(req, res){     
// временно убираем
     access.checkAdmin(req, res, function(req, res) { 
	     Messages.remove(req, res);  //-> доступ администратора
     }); 
});
//---------------------------------------------------------------------------------------------------------------------------------
//---------------------------------------------------------------------------------------------------------------------------------
//----- Пользователи ----

app.post('/signup', function(req, res){ 
    Users.signup(req, res);  //-> анонимный доступ
});

app.post('/login', function(req, res) {
    Users.login(req, res);  //-> анонимный доступ
});

app.get('/exit', function(req, res){
	Users.exit(req, res);
});


app.get('/clean-sessions', function(req, res){
     access.checkAdmin(req, res, function(req, res) { 
	     Users.cleanSessions(req, res);  //-> доступ администратора
     }); 
});

app.get('/sessions', function(req, res){
     access.checkAdmin(req, res, function(req, res) { 
	     Users.sessions(req, res);  //-> доступ администратора
     }); 
});


app.get('/users',function(req, res) {
     access.checkAdmin(req, res, function(req, res) { 
	     Users.list(req, res);  //-> доступ администратора
     }); 
});

app.get('/all-users', function(req, res){
    access.checkAdmin(req, res, function(req, res) { 
	     Users.all(req, res);  //-> доступ администратора
    }); 
});

app.get('/user/:login', function(req, res){
     access.check(req, res, function(req, res) { 
	     Users.item(req, res);
     }); 
});

app.get('/remove-user/:login', function(req, res){
     access.checkAdmin(req, res, function(req, res) { 
	     Users.remove(req, res);  //-> доступ администратора
     }); 
});

app.post('/save-settings', function(req, res){
     access.check(req, res, function(req, res) { 
	     Users.settings(req, res);
     }); 	
});

app.listen(8000);
console.log('Listening on port 8000');