X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server.js;h=65cf69f7db034f9a5b71e3f1440258afea031049;hb=3bb2c7f99dd495adac8e486e98f135c183642381;hp=f9925eb247c04afbbcecc6fe1ea5616cced3a69f;hpb=9457bf88079a23d28011ff7c65faa56a548b7817;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server.js b/server.js index f9925eb24..65cf69f7d 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('./server/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('./server/initializers/constants') -var customValidators = require('./server/helpers/customValidators') -var database = require('./server/initializers/database') -var logger = require('./server/helpers/logger') -var peertubeCrypto = require('./server/helpers/peertubeCrypto') -var poolRequests = require('./server/lib/poolRequests') -var routes = require('./server/controllers') -var utils = require('./server/helpers/utils') -var videos = require('./server/lib/videos') -var webtorrent = require('./server/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,42 +51,54 @@ 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 -var api_route = '/api/' + constants.API_VERSION -app.use(api_route, routes.api) +const apiRoute = '/api/' + constants.API_VERSION +app.use(apiRoute, routes.api) // Static files -app.use('/app', express.static(path.join(__dirname, '/client'), { 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('/app/*', function (req, res, next) { +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('/videos/embed', function (req, res, next) { + res.sendFile(path.join(__dirname, 'client/dist/standalone/videos/embed.html')) +}) app.use('/*', function (req, res, next) { - res.sendFile(path.join(__dirname, 'client/index.html')) + res.sendFile(path.join(__dirname, 'client/dist/index.html')) }) // ----------- Tracker ----------- -var trackerServer = new TrackerServer({ +const trackerServer = new TrackerServer({ http: false, udp: false, ws: false, @@ -99,8 +113,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) }) @@ -109,7 +123,7 @@ 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) }) @@ -119,41 +133,23 @@ app.use(function (err, req, res, next) { res.sendStatus(err.status || 500) }) -// TODO: move into initializer -require('./server/models/users').createClient('coucou', [ 'password' ], function (err, id) { - if (err) throw err - logger.info('Client id: ' + id) - - require('./server/models/users').createUser('floflo', 'coucou', function () {}) -}) - -// ----------- 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') }) }) })