3 // ----------- Node modules -----------
4 var bodyParser = require('body-parser')
5 var express = require('express')
6 var expressValidator = require('express-validator')
7 var http = require('http')
8 var morgan = require('morgan')
9 var path = require('path')
10 var TrackerServer = require('bittorrent-tracker').Server
11 var WebSocketServer = require('ws').Server
13 // Create our main app
16 // ----------- Checker -----------
17 var checker = require('./server/initializers/checker')
19 var miss = checker.checkConfig()
20 if (miss.length !== 0) {
21 throw new Error('Miss some configurations keys : ' + miss)
24 checker.createDirectoriesIfNotExist()
26 // ----------- PeerTube modules -----------
27 var config = require('config')
28 var constants = require('./server/initializers/constants')
29 var customValidators = require('./server/helpers/customValidators')
30 var database = require('./server/initializers/database')
31 var logger = require('./server/helpers/logger')
32 var peertubeCrypto = require('./server/helpers/peertubeCrypto')
33 var poolRequests = require('./server/lib/poolRequests')
34 var routes = require('./server/controllers')
35 var utils = require('./server/helpers/utils')
36 var videos = require('./server/lib/videos')
37 var webtorrent = require('./server/lib/webtorrent')
40 var port = config.get('listen.port')
42 // ----------- Database -----------
45 // ----------- Command line -----------
47 // ----------- App -----------
50 app.use(morgan('combined', { stream: logger.stream }))
52 app.use(bodyParser.json())
53 app.use(bodyParser.urlencoded({ extended: false }))
54 // Validate some params for the API
55 app.use(expressValidator({
56 customValidators: customValidators
59 // ----------- Views, routes and static files -----------
62 app.use(require('connect-livereload')({
67 require('segfault-handler').registerHandler()
70 app.use(express.static(path.join(__dirname, '/client'), { maxAge: 0 }))
73 var api_route = '/api/' + constants.API_VERSION
74 app.use(api_route, routes.api)
77 app.use('/*', function (req, res, next) {
78 res.sendFile(path.join(__dirname, 'client/index.html'))
81 // ----------- Tracker -----------
83 var trackerServer = new TrackerServer({
90 trackerServer.on('error', function (err) {
94 trackerServer.on('warning', function (err) {
98 var server = http.createServer(app)
99 var wss = new WebSocketServer({server: server, path: '/tracker/socket'})
100 wss.on('connection', function (ws) {
101 trackerServer.onWebSocketConnection(ws)
104 // ----------- Errors -----------
106 // Catch 404 and forward to error handler
107 app.use(function (req, res, next) {
108 var err = new Error('Not Found')
113 app.use(function (err, req, res, next) {
115 res.sendStatus(err.status || 500)
118 // ----------- Create the certificates if they don't already exist -----------
119 peertubeCrypto.createCertsIfNotExist(function (err) {
121 // Create/activate the webtorrent module
122 webtorrent.create(function () {
123 function cleanForExit () {
124 utils.cleanForExit(webtorrent.app)
127 function exitGracefullyOnSignal () {
131 process.on('exit', cleanForExit)
132 process.on('SIGINT', exitGracefullyOnSignal)
133 process.on('SIGTERM', exitGracefullyOnSignal)
135 // ----------- Make the server listening -----------
136 server.listen(port, function () {
137 // Activate the pool requests
138 poolRequests.activate()
140 videos.seedAllExisting(function () {
141 logger.info('Seeded all the videos')
142 logger.info('Server listening on port %d', port)