X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server.js;h=a7d7e781cf311709e702d22464066b8f4c29c06b;hb=81ca2cd3f4f4ff2808fce512b38d735c9f550218;hp=d3718f8de31b59e99b6e9d98c2523376ab94ef44;hpb=f5a60a5138135a3412dfbcfd6e564f7aa47a55c2;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server.js b/server.js index d3718f8de..a7d7e781c 100644 --- a/server.js +++ b/server.js @@ -1,181 +1,154 @@ -;(function () { - 'use strict' - - // ----------- Constantes ----------- - global.API_VERSION = 'v1' - - // ----------- Node modules ----------- - var express = require('express') - var path = require('path') - var morgan = require('morgan') - var bodyParser = require('body-parser') - var multer = require('multer') - var TrackerServer = require('bittorrent-tracker').Server - var WebSocketServer = require('ws').Server - var app = express() - var http = require('http') - - // ----------- Checker ----------- - var checker = require('./src/checker') - - var miss = checker.checkConfig() - if (miss.length !== 0) { - // Do not use logger module - console.error('Miss some configurations keys.', { miss: miss }) - process.exit(0) - } - - checker.createDirectories() - - // ----------- PeerTube modules ----------- - var config = require('config') - var logger = require('./src/logger') - var routes = require('./routes') - var api = require('./routes/api/' + global.API_VERSION) - var utils = require('./src/utils') - var videos = require('./src/videos') - var webtorrent = require('./src/webTorrentNode') - - var compression - var port = config.get('listen.port') - var uploads = config.get('storage.uploads') - - // ----------- Command line ----------- - - // ----------- App ----------- - app.use(morgan('combined', { stream: logger.stream })) - app.use(bodyParser.json()) - app.use(multer({ dest: uploads })) - app.use(bodyParser.urlencoded({ extended: false })) - - // ----------- Views, routes and static files ----------- - - if (process.env.NODE_ENV === 'production') { - // logger.log('Production : static files in dist/\n') - - // GZip compression - compression = require('compression') - app.use(compression()) - - // A month - var maxAge = 86400000 * 30 - - // TODO - app.get(/^\/(index|(partials\/[a-z\/]+))?$/, function (req, res, next) { - if (req.url === '/') { - req.url = '/index' - } - - req.url += '.html' - next() - }) - - app.use(express.static(path.join(__dirname, '/dist/public'), { maxAge: maxAge })) - app.use(express.static(path.join(__dirname, '/dist/views'), { maxAge: maxAge })) - } else { - // Livereload - app.use(require('connect-livereload')({ - port: 35729 - })) - - require('segfault-handler').registerHandler() - - app.use(express.static(path.join(__dirname, '/public'), { maxAge: 0 })) - - // Jade template from ./views directory - app.set('views', path.join(__dirname, '/views')) - app.set('view engine', 'jade') - - // Views routes - app.use('/', routes) - } - - // ----------- Routes ----------- - var api_route = '/api/' + global.API_VERSION - app.use(api_route + '/videos', api.videos) - app.use(api_route + '/remotevideos', api.remoteVideos) - app.use(api_route + '/pods', api.pods) - - // ----------- Tracker ----------- - - var trackerServer = new TrackerServer({ - http: false, - udp: false, - ws: false, - dht: false - }) - - trackerServer.on('error', function (err) { - logger.error(err) - }) - - trackerServer.on('warning', function (err) { - logger.error(err) - }) - - var server = http.createServer(app) - var wss = new WebSocketServer({server: server, path: '/tracker/socket'}) - wss.on('connection', function (ws) { - trackerServer.onWebSocketConnection(ws) - }) - - // ----------- Errors ----------- +'use strict' + +// ----------- Node modules ----------- +const bodyParser = require('body-parser') +const cors = require('cors') +const express = require('express') +const expressValidator = require('express-validator') +const http = require('http') +const morgan = require('morgan') +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 constants = require('./server/initializers/constants') +const database = require('./server/initializers/database') +const logger = require('./server/helpers/logger') + +database.connect() + +// ----------- Checker ----------- +const checker = require('./server/initializers/checker') + +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 Request = mongoose.model('Request') + +// ----------- Command line ----------- + +// ----------- App ----------- + +// For the logger +app.use(morgan('combined', { stream: logger.stream })) +// For body requests +app.use(bodyParser.json({ limit: '500kb' })) +app.use(bodyParser.urlencoded({ extended: false })) +// Validate some params for the API +app.use(expressValidator({ + customValidators: Object.assign( + {}, + customValidators.misc, + customValidators.pods, + customValidators.users, + customValidators.videos + ) +})) + +// ----------- Views, routes and static files ----------- + +// API routes +const apiRoute = '/api/' + constants.API_VERSION +app.use(apiRoute, routes.api) + +// Static files +app.use('/client', express.static(path.join(__dirname, '/client/dist'), { maxAge: constants.STATIC_MAX_AGE })) +// 404 for static files not found +app.use('/client/*', function (req, res, next) { + res.sendStatus(404) +}) + +const torrentsPhysicalPath = constants.CONFIG.STORAGE.TORRENTS_DIR +app.use(constants.STATIC_PATHS.TORRENTS, cors(), express.static(torrentsPhysicalPath, { maxAge: constants.STATIC_MAX_AGE })) + +// Videos path for webseeding +const videosPhysicalPath = constants.CONFIG.STORAGE.VIDEOS_DIR +app.use(constants.STATIC_PATHS.WEBSEED, cors(), express.static(videosPhysicalPath, { maxAge: constants.STATIC_MAX_AGE })) + +// Thumbnails path for express +const thumbnailsPhysicalPath = constants.CONFIG.STORAGE.THUMBNAILS_DIR +app.use(constants.STATIC_PATHS.THUMBNAILS, express.static(thumbnailsPhysicalPath, { maxAge: constants.STATIC_MAX_AGE })) + +// Client application +app.use('/*', function (req, res, next) { + res.sendFile(path.join(__dirname, 'client/dist/index.html')) +}) + +// ----------- Tracker ----------- + +const trackerServer = new TrackerServer({ + http: false, + udp: false, + ws: false, + dht: false +}) + +trackerServer.on('error', function (err) { + logger.error(err) +}) + +trackerServer.on('warning', function (err) { + logger.error(err) +}) + +const server = http.createServer(app) +const wss = new WebSocketServer({server: server, path: '/tracker/socket'}) +wss.on('connection', function (ws) { + trackerServer.onWebSocketConnection(ws) +}) + +// ----------- Errors ----------- + +// Catch 404 and forward to error handler +app.use(function (req, res, next) { + const err = new Error('Not Found') + err.status = 404 + next(err) +}) + +app.use(function (err, req, res, next) { + logger.error(err) + res.sendStatus(err.status || 500) +}) + +const port = constants.CONFIG.LISTEN.PORT +installer.installApplication(function (err) { + if (err) throw err + + // Run the migration scripts if needed + migrator.migrate(function (err) { + if (err) throw err - // Catch 404 and forward to error handler - app.use(function (req, res, next) { - var err = new Error('Not Found') - err.status = 404 - next(err) - }) + // ----------- Make the server listening ----------- + server.listen(port, function () { + // Activate the pool requests + Request.activate() - // Prod : no stacktraces leaked to user - if (process.env.NODE_ENV === 'production') { - app.use(function (err, req, res, next) { - logger.error('Error : ' + err.message, { error: err }) - res.status(err.status || 500) - res.render('error', { - message: err.message, - error: {} - }) - }) - } else { - app.use(function (err, req, res, next) { - logger.error('Error : ' + err.message, { error: err }) - res.status(err.status || 500) - res.render('error', { - message: err.message, - error: err - }) - }) - } + logger.info('Server listening on port %d', port) + logger.info('Webserver: %s', constants.CONFIG.WEBSERVER.URL) - // ----------- Create the certificates if they don't already exist ----------- - utils.createCertsIfNotExist(function (err) { - if (err) throw err - // Create/activate the webtorrent module - webtorrent.create(function () { - function cleanForExit () { - utils.cleanForExit(webtorrent.app) - } - - function exitGracefullyOnSignal () { - process.exit() - } - - process.on('exit', cleanForExit) - process.on('SIGINT', exitGracefullyOnSignal) - process.on('SIGTERM', exitGracefullyOnSignal) - - // ----------- Make the server listening ----------- - server.listen(port, function () { - videos.seedAll(function () { - logger.info('Seeded all the videos') - logger.info('Server listening on port %d', port) - app.emit('ready') - }) - }) + app.emit('ready') }) }) +}) - module.exports = app -})() +module.exports = app