]> git.immae.eu Git - github/Chocobozzz/PeerTube.git/blame - server.js
Forgot to add cxx to env
[github/Chocobozzz/PeerTube.git] / server.js
CommitLineData
8c308c2b
C
1;(function () {
2 'use strict'
3
f5a60a51
C
4 // ----------- Constantes -----------
5 global.API_VERSION = 'v1'
6
8c308c2b
C
7 // ----------- Node modules -----------
8 var express = require('express')
34ca3b52 9 var expressValidator = require('express-validator')
8c308c2b
C
10 var path = require('path')
11 var morgan = require('morgan')
12 var bodyParser = require('body-parser')
13 var multer = require('multer')
14 var TrackerServer = require('bittorrent-tracker').Server
15 var WebSocketServer = require('ws').Server
16 var app = express()
17 var http = require('http')
18
19 // ----------- Checker -----------
20 var checker = require('./src/checker')
21
22 var miss = checker.checkConfig()
23 if (miss.length !== 0) {
24 // Do not use logger module
25 console.error('Miss some configurations keys.', { miss: miss })
26 process.exit(0)
27 }
28
29 checker.createDirectories()
30
d148f3b9 31 // ----------- PeerTube modules -----------
8c308c2b
C
32 var config = require('config')
33 var logger = require('./src/logger')
34 var routes = require('./routes')
8c308c2b
C
35 var utils = require('./src/utils')
36 var videos = require('./src/videos')
37 var webtorrent = require('./src/webTorrentNode')
38
8c308c2b
C
39 var port = config.get('listen.port')
40 var uploads = config.get('storage.uploads')
41
42 // ----------- Command line -----------
43
44 // ----------- App -----------
45 app.use(morgan('combined', { stream: logger.stream }))
46 app.use(bodyParser.json())
47 app.use(multer({ dest: uploads }))
48 app.use(bodyParser.urlencoded({ extended: false }))
34ca3b52 49 app.use(expressValidator())
8c308c2b
C
50
51 // ----------- Views, routes and static files -----------
52
e85782f7
C
53 // Livereload
54 app.use(require('connect-livereload')({
55 port: 35729
56 }))
8c308c2b 57
e85782f7 58 require('segfault-handler').registerHandler()
8c308c2b 59
e85782f7 60 app.use(express.static(path.join(__dirname, '/public'), { maxAge: 0 }))
8c308c2b 61
e85782f7
C
62 // Jade template from ./views directory
63 app.set('views', path.join(__dirname, '/views'))
64 app.set('view engine', 'jade')
8c308c2b 65
e85782f7 66 // API
f5a60a51 67 var api_route = '/api/' + global.API_VERSION
e85782f7
C
68 app.use(api_route, routes.api)
69
70 // Views routes
71 app.use('/', routes.views)
8c308c2b
C
72
73 // ----------- Tracker -----------
74
75 var trackerServer = new TrackerServer({
76 http: false,
77 udp: false,
78 ws: false,
79 dht: false
80 })
81
82 trackerServer.on('error', function (err) {
83 logger.error(err)
84 })
85
86 trackerServer.on('warning', function (err) {
87 logger.error(err)
88 })
89
90 var server = http.createServer(app)
91 var wss = new WebSocketServer({server: server, path: '/tracker/socket'})
92 wss.on('connection', function (ws) {
93 trackerServer.onWebSocketConnection(ws)
94 })
95
96 // ----------- Errors -----------
97
98 // Catch 404 and forward to error handler
99 app.use(function (req, res, next) {
100 var err = new Error('Not Found')
101 err.status = 404
102 next(err)
103 })
104
105 // Prod : no stacktraces leaked to user
106 if (process.env.NODE_ENV === 'production') {
107 app.use(function (err, req, res, next) {
108 logger.error('Error : ' + err.message, { error: err })
109 res.status(err.status || 500)
110 res.render('error', {
111 message: err.message,
112 error: {}
113 })
114 })
115 } else {
116 app.use(function (err, req, res, next) {
117 logger.error('Error : ' + err.message, { error: err })
118 res.status(err.status || 500)
119 res.render('error', {
120 message: err.message,
121 error: err
122 })
123 })
124 }
125
126 // ----------- Create the certificates if they don't already exist -----------
127 utils.createCertsIfNotExist(function (err) {
128 if (err) throw err
129 // Create/activate the webtorrent module
130 webtorrent.create(function () {
0ae2e7f7
C
131 function cleanForExit () {
132 utils.cleanForExit(webtorrent.app)
133 }
134
135 function exitGracefullyOnSignal () {
136 process.exit()
137 }
138
139 process.on('exit', cleanForExit)
140 process.on('SIGINT', exitGracefullyOnSignal)
141 process.on('SIGTERM', exitGracefullyOnSignal)
142
8c308c2b
C
143 // ----------- Make the server listening -----------
144 server.listen(port, function () {
145 videos.seedAll(function () {
146 logger.info('Seeded all the videos')
147 logger.info('Server listening on port %d', port)
148 app.emit('ready')
149 })
150 })
151 })
152 })
153
154 module.exports = app
155})()