X-Git-Url: https://git.auder.net/?a=blobdiff_plain;f=server%2Fbin%2Fwww;h=f11102eb9fb006b9a433db927b7309e8caa74afe;hb=2bb4666e276e837add0958554a11b38f7f4d9357;hp=e287d5039fb76d68eda80ba7e9ebb0de7cef6da4;hpb=625022fdcf750f0aff8fcd699f7e9b89730e1d10;p=vchess.git diff --git a/server/bin/www b/server/bin/www index e287d503..f11102eb 100755 --- a/server/bin/www +++ b/server/bin/www @@ -4,22 +4,35 @@ * Module dependencies. */ -var app = require('../app'); -var debug = require('debug')('vc:server'); -var http = require('http'); +let app = require('../app'); +const debug = require('debug')('vc:server'); +const http = require('http'); /** * Get port from environment and store in Express. */ -var port = normalizePort(process.env.PORT || '3000'); +const port = normalizePort(process.env.PORT || '3000'); app.set('port', port); /** * Create HTTP server. */ -var server = http.createServer(app); +let server = http.createServer(app); + +/* + * CRON tasks + */ + +let cron = require('node-cron'); +const UserModel = require("../models/User"); +const GameModel = require("../models/Game"); +cron.schedule('0 0 0 * * *', function() { + // Remove unlogged users and unstarted games every 24h + UserModel.cleanUsersDb(); + GameModel.cleanGamesDb(); +}); /** * Listen on provided port, on all network interfaces. @@ -42,16 +55,16 @@ require('../sockets')(wss); */ function normalizePort(val) { - var port = parseInt(val, 10); + const parsedPort = parseInt(val, 10); - if (isNaN(port)) { + if (isNaN(parsedPort)) { // named pipe return val; } - if (port >= 0) { + if (parsedPort >= 0) { // port number - return port; + return parsedPort; } return false; @@ -66,7 +79,7 @@ function onError(error) { throw error; } - var bind = typeof port === 'string' + const bind = typeof port === 'string' ? 'Pipe ' + port : 'Port ' + port; @@ -90,8 +103,8 @@ function onError(error) { */ function onListening() { - var addr = server.address(); - var bind = typeof addr === 'string' + const addr = server.address(); + const bind = typeof addr === 'string' ? 'pipe ' + addr : 'port ' + addr.port; debug('Listening on ' + bind);