X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server.js;h=6eb0220004b3a2f5238c3ae0333282415752162a;hb=79530164b6c8f96a6ccf6d33b591d565f1575e67;hp=b2eeeff70edcd6494f3cd23e30ad5a8a3e6cfeaf;hpb=5f698b82c7055df763f3830882ac5bad1397db23;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server.js b/server.js index b2eeeff70..6eb022000 100644 --- a/server.js +++ b/server.js @@ -10,11 +10,12 @@ const path = require('path') const TrackerServer = require('bittorrent-tracker').Server const WebSocketServer = require('ws').Server +process.title = 'peertube' + // Create our main app const app = express() // ----------- Database ----------- -const config = require('config') const constants = require('./server/initializers/constants') const database = require('./server/initializers/database') const logger = require('./server/helpers/logger') @@ -24,23 +25,23 @@ database.connect() // ----------- Checker ----------- const checker = require('./server/initializers/checker') -const miss = checker.checkConfig() -if (miss.length !== 0) { - throw new Error('Miss some configurations keys : ' + miss) +const missed = checker.checkMissedConfig() +if (missed.length !== 0) { + throw new Error('Miss some configurations keys : ' + missed) +} + +const errorMessage = checker.checkConfig() +if (errorMessage !== null) { + throw new Error(errorMessage) } // ----------- PeerTube modules ----------- const customValidators = require('./server/helpers/custom-validators') const installer = require('./server/initializers/installer') +const migrator = require('./server/initializers/migrator') const mongoose = require('mongoose') const routes = require('./server/controllers') -const utils = require('./server/helpers/utils') -const webtorrent = require('./server/lib/webtorrent') const Request = mongoose.model('Request') -const Video = mongoose.model('Video') - -// Get configurations -const port = config.get('listen.port') // ----------- Command line ----------- @@ -49,36 +50,34 @@ const port = config.get('listen.port') // For the logger app.use(morgan('combined', { stream: logger.stream })) // For body requests -app.use(bodyParser.json()) +app.use(bodyParser.json({ limit: '500kb' })) app.use(bodyParser.urlencoded({ extended: false })) // Validate some params for the API app.use(expressValidator({ - customValidators: customValidators + customValidators: Object.assign( + {}, + customValidators.misc, + customValidators.pods, + customValidators.users, + customValidators.videos + ) })) // ----------- Views, routes and static files ----------- -// Catch sefaults -require('segfault-handler').registerHandler() - -// API routes +// API const apiRoute = '/api/' + constants.API_VERSION app.use(apiRoute, routes.api) -// Static files -app.use('/client', express.static(path.join(__dirname, '/client/dist'), { maxAge: 0 })) -// 404 for static files not found -app.use('/client/*', function (req, res, next) { - res.sendStatus(404) -}) +// Client files +app.use('/', routes.client) -// Thumbnails path for express -const thumbnailsPhysicalPath = path.join(__dirname, config.get('storage.thumbnails')) -app.use(constants.THUMBNAILS_STATIC_PATH, express.static(thumbnailsPhysicalPath, { maxAge: 0 })) +// Static files +app.use('/', routes.static) -// Client application +// Always serve index client page (the client is a single page application, let it handle routing) app.use('/*', function (req, res, next) { - res.sendFile(path.join(__dirname, 'client/dist/index.html')) + res.sendFile(path.join(__dirname, './client/dist/index.html')) }) // ----------- Tracker ----------- @@ -118,35 +117,25 @@ app.use(function (err, req, res, next) { res.sendStatus(err.status || 500) }) +// ----------- Run ----------- + +const port = constants.CONFIG.LISTEN.PORT installer.installApplication(function (err) { if (err) throw err - // Create/activate the webtorrent module - webtorrent.create(function () { - function cleanForExit () { - utils.cleanForExit(webtorrent.app) - } - - function exitGracefullyOnSignal () { - process.exit(-1) - } - - process.on('exit', cleanForExit) - process.on('SIGINT', exitGracefullyOnSignal) - process.on('SIGTERM', exitGracefullyOnSignal) + // Run the migration scripts if needed + migrator.migrate(function (err) { + if (err) throw err // ----------- Make the server listening ----------- server.listen(port, function () { // Activate the pool requests Request.activate() - Video.seedAllExisting(function (err) { - if (err) throw err + logger.info('Server listening on port %d', port) + logger.info('Webserver: %s', constants.CONFIG.WEBSERVER.URL) - logger.info('Seeded all the videos') - logger.info('Server listening on port %d', port) - app.emit('ready') - }) + app.emit('ready') }) }) })