server.js

   1 'use strict'
   2
   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
  13
  14 process.title = 'peertube'
  15
  16 // Create our main app
  17 const app = express()
  18
  19 // ----------- Database -----------
  20 const constants = require('./server/initializers/constants')
  21 const database = require('./server/initializers/database')
  22 const logger = require('./server/helpers/logger')
  23
  24 database.connect()
  25
  26 // ----------- Checker -----------
  27 const checker = require('./server/initializers/checker')
  28
  29 const miss = checker.checkConfig()
  30 if (miss.length !== 0) {
  31   throw new Error('Miss some configurations keys : ' + miss)
  32 }
  33
  34 // ----------- PeerTube modules -----------
  35 const customValidators = require('./server/helpers/custom-validators')
  36 const installer = require('./server/initializers/installer')
  37 const migrator = require('./server/initializers/migrator')
  38 const mongoose = require('mongoose')
  39 const routes = require('./server/controllers')
  40 const Request = mongoose.model('Request')
  41
  42 // ----------- Command line -----------
  43
  44 // ----------- App -----------
  45
  46 // For the logger
  47 app.use(morgan('combined', { stream: logger.stream }))
  48 // For body requests
  49 app.use(bodyParser.json({ limit: '500kb' }))
  50 app.use(bodyParser.urlencoded({ extended: false }))
  51 // Validate some params for the API
  52 app.use(expressValidator({
  53   customValidators: Object.assign(
  54     {},
  55     customValidators.misc,
  56     customValidators.pods,
  57     customValidators.users,
  58     customValidators.videos
  59   )
  60 }))
  61
  62 // ----------- Views, routes and static files -----------
  63
  64 // API routes
  65 const apiRoute = '/api/' + constants.API_VERSION
  66 app.use(apiRoute, routes.api)
  67
  68 // Static files
  69 app.use('/client', express.static(path.join(__dirname, '/client/dist'), { maxAge: constants.STATIC_MAX_AGE }))
  70 // 404 for static files not found
  71 app.use('/client/*', function (req, res, next) {
  72   res.sendStatus(404)
  73 })
  74
  75 const torrentsPhysicalPath = path.join(__dirname, constants.CONFIG.STORAGE.TORRENTS_DIR)
  76 app.use(constants.STATIC_PATHS.TORRENTS, cors(), express.static(torrentsPhysicalPath, { maxAge: constants.STATIC_MAX_AGE }))
  77
  78 // Videos path for webseeding
  79 const videosPhysicalPath = path.join(__dirname, constants.CONFIG.STORAGE.VIDEOS_DIR)
  80 app.use(constants.STATIC_PATHS.WEBSEED, cors(), express.static(videosPhysicalPath, { maxAge: constants.STATIC_MAX_AGE }))
  81
  82 // Thumbnails path for express
  83 const thumbnailsPhysicalPath = path.join(__dirname, constants.CONFIG.STORAGE.THUMBNAILS_DIR)
  84 app.use(constants.STATIC_PATHS.THUMBNAILS, express.static(thumbnailsPhysicalPath, { maxAge: constants.STATIC_MAX_AGE }))
  85
  86 // Client application
  87 app.use('/*', function (req, res, next) {
  88   res.sendFile(path.join(__dirname, 'client/dist/index.html'))
  89 })
  90
  91 // ----------- Tracker -----------
  92
  93 const trackerServer = new TrackerServer({
  94   http: false,
  95   udp: false,
  96   ws: false,
  97   dht: false
  98 })
  99
 100 trackerServer.on('error', function (err) {
 101   logger.error(err)
 102 })
 103
 104 trackerServer.on('warning', function (err) {
 105   logger.error(err)
 106 })
 107
 108 const server = http.createServer(app)
 109 const wss = new WebSocketServer({server: server, path: '/tracker/socket'})
 110 wss.on('connection', function (ws) {
 111   trackerServer.onWebSocketConnection(ws)
 112 })
 113
 114 // ----------- Errors -----------
 115
 116 // Catch 404 and forward to error handler
 117 app.use(function (req, res, next) {
 118   const err = new Error('Not Found')
 119   err.status = 404
 120   next(err)
 121 })
 122
 123 app.use(function (err, req, res, next) {
 124   logger.error(err)
 125   res.sendStatus(err.status || 500)
 126 })
 127
 128 const port = constants.CONFIG.LISTEN.PORT
 129 installer.installApplication(function (err) {
 130   if (err) throw err
 131
 132   // Run the migration scripts if needed
 133   migrator.migrate(function (err) {
 134     if (err) throw err
 135
 136     // ----------- Make the server listening -----------
 137     server.listen(port, function () {
 138       // Activate the pool requests
 139       Request.activate()
 140
 141       logger.info('Server listening on port %d', port)
 142       app.emit('ready')
 143     })
 144   })
 145 })
 146
 147 module.exports = app