server.js

   1 'use strict'
   2
   3 // ----------- Node modules -----------
   4 const bodyParser = require('body-parser')
   5 const express = require('express')
   6 const expressValidator = require('express-validator')
   7 const http = require('http')
   8 const morgan = require('morgan')
   9 const path = require('path')
  10 const TrackerServer = require('bittorrent-tracker').Server
  11 const WebSocketServer = require('ws').Server
  12
  13 process.title = 'peertube'
  14
  15 // Create our main app
  16 const app = express()
  17
  18 // ----------- Database -----------
  19 const constants = require('./server/initializers/constants')
  20 const logger = require('./server/helpers/logger')
  21 // Initialize database and models
  22 const db = require('./server/initializers/database')
  23
  24 // ----------- Checker -----------
  25 const checker = require('./server/initializers/checker')
  26
  27 const missed = checker.checkMissedConfig()
  28 if (missed.length !== 0) {
  29   throw new Error('Miss some configurations keys : ' + missed)
  30 }
  31
  32 const errorMessage = checker.checkConfig()
  33 if (errorMessage !== null) {
  34   throw new Error(errorMessage)
  35 }
  36
  37 // ----------- PeerTube modules -----------
  38 const customValidators = require('./server/helpers/custom-validators')
  39 const installer = require('./server/initializers/installer')
  40 const migrator = require('./server/initializers/migrator')
  41 const routes = require('./server/controllers')
  42
  43 // ----------- Command line -----------
  44
  45 // ----------- App -----------
  46
  47 // For the logger
  48 app.use(morgan('combined', { stream: logger.stream }))
  49 // For body requests
  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(
  55     {},
  56     customValidators.misc,
  57     customValidators.pods,
  58     customValidators.users,
  59     customValidators.videos
  60   )
  61 }))
  62
  63 // ----------- Views, routes and static files -----------
  64
  65 // API
  66 const apiRoute = '/api/' + constants.API_VERSION
  67 app.use(apiRoute, routes.api)
  68
  69 // Client files
  70 app.use('/', routes.client)
  71
  72 // Static files
  73 app.use('/', routes.static)
  74
  75 // Always serve index client page (the client is a single page application, let it handle routing)
  76 app.use('/*', function (req, res, next) {
  77   res.sendFile(path.join(__dirname, './client/dist/index.html'))
  78 })
  79
  80 // ----------- Tracker -----------
  81
  82 const trackerServer = new TrackerServer({
  83   http: false,
  84   udp: false,
  85   ws: false,
  86   dht: false
  87 })
  88
  89 trackerServer.on('error', function (err) {
  90   logger.error(err)
  91 })
  92
  93 trackerServer.on('warning', function (err) {
  94   logger.error(err)
  95 })
  96
  97 const server = http.createServer(app)
  98 const wss = new WebSocketServer({server: server, path: '/tracker/socket'})
  99 wss.on('connection', function (ws) {
 100   trackerServer.onWebSocketConnection(ws)
 101 })
 102
 103 // ----------- Errors -----------
 104
 105 // Catch 404 and forward to error handler
 106 app.use(function (req, res, next) {
 107   const err = new Error('Not Found')
 108   err.status = 404
 109   next(err)
 110 })
 111
 112 app.use(function (err, req, res, next) {
 113   logger.error(err)
 114   res.sendStatus(err.status || 500)
 115 })
 116
 117 // ----------- Run -----------
 118
 119 const port = constants.CONFIG.LISTEN.PORT
 120 installer.installApplication(function (err) {
 121   if (err) throw err
 122
 123   // Run the migration scripts if needed
 124   migrator.migrate(function (err) {
 125     if (err) throw err
 126
 127     // ----------- Make the server listening -----------
 128     server.listen(port, function () {
 129       // Activate the pool requests
 130       db.Request.activate()
 131
 132       logger.info('Server listening on port %d', port)
 133       logger.info('Webserver: %s', constants.CONFIG.WEBSERVER.URL)
 134
 135       app.emit('ready')
 136     })
 137   })
 138 })
 139
 140 module.exports = app