X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server.js;h=d38c5830f3f0ac565fbfdbe4b5554c98dc7c2bad;hb=e4c556196d7b31111f17596840d2e1d60caa7dcb;hp=11402ea78095387617a8c53edb1016faea37aa4d;hpb=0b69752270f1ceea06a29872b3db23660a55d6d3;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server.js b/server.js index 11402ea78..d38c5830f 100644 --- a/server.js +++ b/server.js @@ -1,174 +1,154 @@ -;(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 customValidators = require('./src/customValidators') - var logger = require('./src/logger') - var poolRequests = require('./src/poolRequests') - 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({ - customValidators: customValidators - })) - - // ----------- 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 ----------- - - // Catch 404 and forward to error handler - app.use(function (req, res, next) { - var 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('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 - }) - }) - } - - // ----------- 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 () { - // Activate the pool requests - poolRequests.activate() - - videos.seedAll(function () { - logger.info('Seeded all the videos') - logger.info('Server listening on port %d', port) - app.emit('ready') - }) +'use strict' + +// ----------- Node modules ----------- +const bodyParser = require('body-parser') +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 + +// 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') + +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) +} + +// ----------- PeerTube modules ----------- +const customValidators = require('./server/helpers/custom-validators') +const installer = require('./server/initializers/installer') +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 ----------- + +// ----------- App ----------- + +// For the logger +app.use(morgan('combined', { stream: logger.stream })) +// For body requests +app.use(bodyParser.json()) +app.use(bodyParser.urlencoded({ extended: false })) +// Validate some params for the API +app.use(expressValidator({ + customValidators: Object.assign({}, customValidators.misc, customValidators.users, customValidators.videos) +})) + +// ----------- Views, routes and static files ----------- + +// Catch sefaults +require('segfault-handler').registerHandler() + +// 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: 0 })) +// 404 for static files not found +app.use('/client/*', function (req, res, next) { + res.sendStatus(404) +}) + +// Thumbnails path for express +const thumbnailsPhysicalPath = path.join(__dirname, config.get('storage.thumbnails')) +app.use(constants.THUMBNAILS_STATIC_PATH, express.static(thumbnailsPhysicalPath, { maxAge: 0 })) + +// 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) +}) + +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) + + // ----------- Make the server listening ----------- + server.listen(port, function () { + // Activate the pool requests + Request.activate() + + Video.seedAllExisting(function (err) { + if (err) throw err + + logger.info('Seeded all the videos') + logger.info('Server listening on port %d', port) + app.emit('ready') }) }) }) +}) - module.exports = app -})() +module.exports = app