4 // ----------- Node modules -----------
5 var bodyParser = require('body-parser')
6 var express = require('express')
7 var expressValidator = require('express-validator')
8 var http = require('http')
9 var morgan = require('morgan')
10 var path = require('path')
11 var TrackerServer = require('bittorrent-tracker').Server
12 var WebSocketServer = require('ws').Server
14 // Create our main app
17 // ----------- Checker -----------
18 var checker = require('./initializers/checker')
20 var miss = checker.checkConfig()
21 if (miss.length !== 0) {
22 // Do not use logger module
23 console.error('Miss some configurations keys.', { miss: miss })
27 checker.createDirectoriesIfNotExist()
29 // ----------- PeerTube modules -----------
30 var config = require('config')
31 var constants = require('./initializers/constants')
32 var customValidators = require('./helpers/customValidators')
33 var database = require('./initializers/database')
34 var logger = require('./helpers/logger')
35 var peertubeCrypto = require('./helpers/peertubeCrypto')
36 var poolRequests = require('./lib/poolRequests')
37 var routes = require('./controllers')
38 var utils = require('./helpers/utils')
39 var videos = require('./lib/videos')
40 var webtorrent = require('./lib/webtorrent')
43 var port = config.get('listen.port')
45 // ----------- Database -----------
48 // ----------- Command line -----------
50 // ----------- App -----------
53 app.use(morgan('combined', { stream: logger.stream }))
55 app.use(bodyParser.json())
56 app.use(bodyParser.urlencoded({ extended: false }))
57 // Validate some params for the API
58 app.use(expressValidator({
59 customValidators: customValidators
62 // ----------- Views, routes and static files -----------
65 app.use(require('connect-livereload')({
70 require('segfault-handler').registerHandler()
73 app.use(express.static(path.join(__dirname, '/public'), { maxAge: 0 }))
75 // Jade template from ./views directory
76 app.set('views', path.join(__dirname, '/views'))
77 app.set('view engine', 'jade')
80 var api_route = '/api/' + constants.API_VERSION
81 app.use(api_route, routes.api)
84 app.use('/', routes.views)
86 // ----------- Tracker -----------
88 var trackerServer = new TrackerServer({
95 trackerServer.on('error', function (err) {
99 trackerServer.on('warning', function (err) {
103 var server = http.createServer(app)
104 var wss = new WebSocketServer({server: server, path: '/tracker/socket'})
105 wss.on('connection', function (ws) {
106 trackerServer.onWebSocketConnection(ws)
109 // ----------- Errors -----------
111 // Catch 404 and forward to error handler
112 app.use(function (req, res, next) {
113 var err = new Error('Not Found')
118 // Prod : no stacktraces leaked to user
119 if (process.env.NODE_ENV === 'production') {
120 app.use(function (err, req, res, next) {
122 res.status(err.status || 500)
123 res.render('error', {
124 message: err.message,
129 app.use(function (err, req, res, next) {
131 res.status(err.status || 500)
132 res.render('error', {
133 message: err.message,
139 // ----------- Create the certificates if they don't already exist -----------
140 peertubeCrypto.createCertsIfNotExist(function (err) {
142 // Create/activate the webtorrent module
143 webtorrent.create(function () {
144 function cleanForExit () {
145 utils.cleanForExit(webtorrent.app)
148 function exitGracefullyOnSignal () {
152 process.on('exit', cleanForExit)
153 process.on('SIGINT', exitGracefullyOnSignal)
154 process.on('SIGTERM', exitGracefullyOnSignal)
156 // ----------- Make the server listening -----------
157 server.listen(port, function () {
158 // Activate the pool requests
159 poolRequests.activate()
161 videos.seedAllExisting(function () {
162 logger.info('Seeded all the videos')
163 logger.info('Server listening on port %d', port)