X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server.js;h=a7d7e781cf311709e702d22464066b8f4c29c06b;hb=81ca2cd3f4f4ff2808fce512b38d735c9f550218;hp=c971982b37a253297c4a9589128a2f2a60fd718e;hpb=ac2f99eb75ea0295dc08e47b91f4b4d54829d004;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server.js b/server.js index c971982b3..a7d7e781c 100644 --- a/server.js +++ b/server.js @@ -1,46 +1,48 @@ '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 path = require('path') -var TrackerServer = require('bittorrent-tracker').Server -var WebSocketServer = require('ws').Server +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 -var app = express() +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 ----------- -var checker = require('./initializers/checker') +const checker = require('./server/initializers/checker') -var 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) } -checker.createDirectoriesIfNotExist() +const errorMessage = checker.checkConfig() +if (errorMessage !== null) { + throw new Error(errorMessage) +} // ----------- PeerTube modules ----------- -var config = require('config') -var constants = require('./initializers/constants') -var customValidators = require('./helpers/customValidators') -var database = require('./initializers/database') -var logger = require('./helpers/logger') -var peertubeCrypto = require('./helpers/peertubeCrypto') -var poolRequests = require('./lib/poolRequests') -var routes = require('./controllers') -var utils = require('./helpers/utils') -var videos = require('./lib/videos') -var webtorrent = require('./lib/webtorrent') - -// Get configurations -var port = config.get('listen.port') - -// ----------- Database ----------- -database.connect() +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 ----------- @@ -49,40 +51,51 @@ database.connect() // 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 ----------- -// Livereload -app.use(require('connect-livereload')({ - port: 35729 -})) - -// Catch sefaults -require('segfault-handler').registerHandler() +// API routes +const apiRoute = '/api/' + constants.API_VERSION +app.use(apiRoute, routes.api) // Static files -app.use(express.static(path.join(__dirname, '/public'), { maxAge: 0 })) +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) +}) -// Jade template from ./views directory -app.set('views', path.join(__dirname, '/views')) -app.set('view engine', 'jade') +const torrentsPhysicalPath = constants.CONFIG.STORAGE.TORRENTS_DIR +app.use(constants.STATIC_PATHS.TORRENTS, cors(), express.static(torrentsPhysicalPath, { maxAge: constants.STATIC_MAX_AGE })) -// API routes -var api_route = '/api/' + constants.API_VERSION -app.use(api_route, routes.api) +// 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 })) -// Views routes -app.use('/', routes.views) +// Client application +app.use('/*', function (req, res, next) { + res.sendFile(path.join(__dirname, 'client/dist/index.html')) +}) // ----------- Tracker ----------- -var trackerServer = new TrackerServer({ +const trackerServer = new TrackerServer({ http: false, udp: false, ws: false, @@ -97,8 +110,8 @@ trackerServer.on('warning', function (err) { logger.error(err) }) -var server = http.createServer(app) -var wss = new WebSocketServer({server: server, path: '/tracker/socket'}) +const server = http.createServer(app) +const wss = new WebSocketServer({server: server, path: '/tracker/socket'}) wss.on('connection', function (ws) { trackerServer.onWebSocketConnection(ws) }) @@ -107,59 +120,33 @@ wss.on('connection', function (ws) { // Catch 404 and forward to error handler app.use(function (req, res, next) { - var err = new Error('Not Found') + const err = new Error('Not Found') err.status = 404 next(err) }) -// Prod : no stacktraces leaked to user -if (process.env.NODE_ENV === 'production') { - app.use(function (err, req, res, next) { - logger.error(err) - res.status(err.status || 500) - res.render('error', { - message: err.message, - error: {} - }) - }) -} else { - app.use(function (err, req, res, next) { - logger.error(err) - res.status(err.status || 500) - res.render('error', { - message: err.message, - error: err - }) - }) -} +app.use(function (err, req, res, next) { + logger.error(err) + res.sendStatus(err.status || 500) +}) -// ----------- Create the certificates if they don't already exist ----------- -peertubeCrypto.createCertsIfNotExist(function (err) { +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 - poolRequests.activate() + Request.activate() + + logger.info('Server listening on port %d', port) + logger.info('Webserver: %s', constants.CONFIG.WEBSERVER.URL) - videos.seedAllExisting(function () { - logger.info('Seeded all the videos') - logger.info('Server listening on port %d', port) - app.emit('ready') - }) + app.emit('ready') }) }) })