X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server.js;h=16e27e852cba100efa20ee9614f82a53599a100a;hb=693b1aba4675f7e3d850e0f6d07dbfc7bdff9b8c;hp=3b899689c5544b494d579299513d0e22fa6afefc;hpb=3bcb78b3aff565996ee0e2aa96bce7f1bdd6d66a;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server.js b/server.js index 3b899689c..16e27e852 100644 --- a/server.js +++ b/server.js @@ -1,167 +1,160 @@ -;(function () { - 'use strict' - - // ----------- Node modules ----------- - var bodyParser = require('body-parser') - var express = require('express') - var expressValidator = require('express-validator') - var http = require('http') - var morgan = require('morgan') - var multer = require('multer') - var path = require('path') - var TrackerServer = require('bittorrent-tracker').Server - var WebSocketServer = require('ws').Server - - // Create our main app - var app = express() - - // ----------- 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.createDirectoriesIfNotExist() - - // ----------- Constants ----------- - var utils = require('./src/utils') - - global.API_VERSION = 'v1' - global.FRIEND_BASE_SCORE = utils.isTestInstance() ? 20 : 100 - - // ----------- PeerTube modules ----------- - var config = require('config') - var logger = require('./src/logger') - var routes = require('./routes') - var videos = require('./src/videos') - var webtorrent = require('./src/webTorrentNode') - - // Get configurations - var port = config.get('listen.port') - var uploads = config.get('storage.uploads') - - // ----------- Command line ----------- - - // ----------- App ----------- - - // For the logger - app.use(morgan('combined', { stream: logger.stream })) - // For body requests - app.use(bodyParser.json()) - // For POST file requests - app.use(multer({ dest: uploads })) - app.use(bodyParser.urlencoded({ extended: false })) - // Validate some params for the API - app.use(expressValidator()) - - // ----------- Views, routes and static files ----------- - - // Livereload - app.use(require('connect-livereload')({ - port: 35729 - })) - - // Catch sefaults - require('segfault-handler').registerHandler() - - // Static files - 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') - - // API routes - var api_route = '/api/' + global.API_VERSION - app.use(api_route, routes.api) - - // Views routes - app.use('/', routes.views) - - // ----------- 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) +app.use('/', routes.client) + +// Static client files +// TODO: move in client +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 })) + +// Video previews path for express +const previewsPhysicalPath = constants.CONFIG.STORAGE.PREVIEWS_DIR +app.use(constants.STATIC_PATHS.PREVIEWS, express.static(previewsPhysicalPath, { maxAge: constants.STATIC_MAX_AGE })) + +// Always serve index client page +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