import { isTestInstance } from './server/helpers/core-utils' if (isTestInstance()) { require('source-map-support').install() } // ----------- Node modules ----------- import * as bodyParser from 'body-parser' import * as express from 'express' import * as http from 'http' import * as morgan from 'morgan' import * as path from 'path' import * as bitTorrentTracker from 'bittorrent-tracker' import * as cors from 'cors' import { Server as WebSocketServer } from 'ws' const TrackerServer = bitTorrentTracker.Server process.title = 'peertube' // Create our main app const app = express() // ----------- Core checker ----------- import { checkMissedConfig, checkFFmpeg, checkConfig } from './server/initializers/checker' const missed = checkMissedConfig() if (missed.length !== 0) { throw new Error('Your configuration files miss keys: ' + missed) } import { ACCEPT_HEADERS, API_VERSION, CONFIG, STATIC_PATHS } from './server/initializers/constants' checkFFmpeg(CONFIG) const errorMessage = checkConfig() if (errorMessage !== null) { throw new Error(errorMessage) } // ----------- Database ----------- // Do not use barrels because we don't want to load all modules here (we need to initialize database first) import { logger } from './server/helpers/logger' // Initialize database and models import { initDatabaseModels } from './server/initializers/database' import { migrate } from './server/initializers/migrator' migrate() .then(() => initDatabaseModels(false)) .then(() => onDatabaseInitDone()) // ----------- PeerTube modules ----------- import { installApplication } from './server/initializers' import { activitypubHttpJobScheduler, transcodingJobScheduler } from './server/lib/jobs' import { VideosPreviewCache } from './server/lib/cache' import { apiRouter, clientsRouter, staticRouter, servicesRouter, webfingerRouter, activityPubRouter } from './server/controllers' // ----------- Command line ----------- // ----------- App ----------- // Enable CORS for develop if (isTestInstance()) { app.use((req, res, next) => { // These routes have already cors if ( req.path.indexOf(STATIC_PATHS.TORRENTS) === -1 && req.path.indexOf(STATIC_PATHS.WEBSEED) === -1 ) { return (cors({ origin: 'http://localhost:3000', credentials: true }))(req, res, next) } return next() }) } // For the logger app.use(morgan('combined', { stream: { write: logger.info } })) // For body requests app.use(bodyParser.json({ type: [ 'application/json', 'application/*+json' ], limit: '500kb' })) app.use(bodyParser.urlencoded({ extended: false })) // ----------- Tracker ----------- const trackerServer = new TrackerServer({ http: false, udp: false, ws: false, dht: false }) trackerServer.on('error', function (err) { logger.error(err) }) trackerServer.on('warning', function (err) { logger.error(err) }) const server = http.createServer(app) const wss = new WebSocketServer({ server: server, path: '/tracker/socket' }) wss.on('connection', function (ws) { trackerServer.onWebSocketConnection(ws) }) const onHttpRequest = trackerServer.onHttpRequest.bind(trackerServer) app.get('/tracker/announce', (req, res) => onHttpRequest(req, res, { action: 'announce' })) app.get('/tracker/scrape', (req, res) => onHttpRequest(req, res, { action: 'scrape' })) // ----------- Views, routes and static files ----------- // API const apiRoute = '/api/' + API_VERSION app.use(apiRoute, apiRouter) // Services (oembed...) app.use('/services', servicesRouter) app.use('/', webfingerRouter) app.use('/', activityPubRouter) // Client files app.use('/', clientsRouter) // Static files app.use('/', staticRouter) // Always serve index client page (the client is a single page application, let it handle routing) app.use('/*', function (req, res) { if (req.accepts(ACCEPT_HEADERS) === 'html') { return res.sendFile(path.join(__dirname, '../client/dist/index.html')) } return res.status(404).end() }) // ----------- Errors ----------- // Catch 404 and forward to error handler app.use(function (req, res, next) { const err = new Error('Not Found') err['status'] = 404 next(err) }) app.use(function (err, req, res, next) { logger.error(err) res.sendStatus(err.status || 500) }) // ----------- Run ----------- function onDatabaseInitDone () { const port = CONFIG.LISTEN.PORT installApplication() .then(() => { // ----------- Make the server listening ----------- server.listen(port, () => { VideosPreviewCache.Instance.init(CONFIG.CACHE.PREVIEWS.SIZE) activitypubHttpJobScheduler.activate() transcodingJobScheduler.activate() logger.info('Server listening on port %d', port) logger.info('Web server: %s', CONFIG.WEBSERVER.URL) }) }) }