3 // ----------- Node modules -----------
4 const bodyParser = require('body-parser')
5 const cors = require('cors')
6 const express = require('express')
7 const expressValidator = require('express-validator')
8 const http = require('http')
9 const morgan = require('morgan')
10 const path = require('path')
11 const TrackerServer = require('bittorrent-tracker').Server
12 const WebSocketServer = require('ws').Server
14 process.title = 'peertube'
16 // Create our main app
19 // ----------- Database -----------
20 const config = require('config')
21 const constants = require('./server/initializers/constants')
22 const database = require('./server/initializers/database')
23 const logger = require('./server/helpers/logger')
27 // ----------- Checker -----------
28 const checker = require('./server/initializers/checker')
30 const miss = checker.checkConfig()
31 if (miss.length !== 0) {
32 throw new Error('Miss some configurations keys : ' + miss)
35 // ----------- PeerTube modules -----------
36 const customValidators = require('./server/helpers/custom-validators')
37 const installer = require('./server/initializers/installer')
38 const migrator = require('./server/initializers/migrator')
39 const mongoose = require('mongoose')
40 const routes = require('./server/controllers')
41 const Request = mongoose.model('Request')
43 // ----------- Command line -----------
45 // ----------- App -----------
48 app.use(morgan('combined', { stream: logger.stream }))
50 app.use(bodyParser.json({ limit: '500kb' }))
51 app.use(bodyParser.urlencoded({ extended: false }))
52 // Validate some params for the API
53 app.use(expressValidator({
54 customValidators: Object.assign(
56 customValidators.misc,
57 customValidators.pods,
58 customValidators.users,
59 customValidators.videos
63 // ----------- Views, routes and static files -----------
66 const apiRoute = '/api/' + constants.API_VERSION
67 app.use(apiRoute, routes.api)
70 app.use('/client', express.static(path.join(__dirname, '/client/dist'), { maxAge: constants.STATIC_MAX_AGE }))
71 // 404 for static files not found
72 app.use('/client/*', function (req, res, next) {
76 const torrentsPhysicalPath = path.join(__dirname, config.get('storage.torrents'))
77 app.use(constants.STATIC_PATHS.TORRENTS, cors(), express.static(torrentsPhysicalPath, { maxAge: constants.STATIC_MAX_AGE }))
79 // Videos path for webseeding
80 const videosPhysicalPath = path.join(__dirname, config.get('storage.videos'))
81 app.use(constants.STATIC_PATHS.WEBSEED, cors(), express.static(videosPhysicalPath, { maxAge: constants.STATIC_MAX_AGE }))
83 // Thumbnails path for express
84 const thumbnailsPhysicalPath = path.join(__dirname, config.get('storage.thumbnails'))
85 app.use(constants.STATIC_PATHS.THUMBNAILS, express.static(thumbnailsPhysicalPath, { maxAge: constants.STATIC_MAX_AGE }))
88 app.use('/*', function (req, res, next) {
89 res.sendFile(path.join(__dirname, 'client/dist/index.html'))
92 // ----------- Tracker -----------
94 const trackerServer = new TrackerServer({
101 trackerServer.on('error', function (err) {
105 trackerServer.on('warning', function (err) {
109 const server = http.createServer(app)
110 const wss = new WebSocketServer({server: server, path: '/tracker/socket'})
111 wss.on('connection', function (ws) {
112 trackerServer.onWebSocketConnection(ws)
115 // ----------- Errors -----------
117 // Catch 404 and forward to error handler
118 app.use(function (req, res, next) {
119 const err = new Error('Not Found')
124 app.use(function (err, req, res, next) {
126 res.sendStatus(err.status || 500)
129 const port = constants.CONFIG.LISTEN.PORT
130 installer.installApplication(function (err) {
133 // Run the migration scripts if needed
134 migrator.migrate(function (err) {
137 // ----------- Make the server listening -----------
138 server.listen(port, function () {
139 // Activate the pool requests
142 logger.info('Server listening on port %d', port)