From 65fcc3119c334b75dd13bcfdebf186afdc580a8f Mon Sep 17 00:00:00 2001
From: Chocobozzz <florian.bigard@gmail.com>
Date: Mon, 15 May 2017 22:22:03 +0200
Subject: First typescript iteration

---
 server.ts | 142 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 142 insertions(+)
 create mode 100644 server.ts

(limited to 'server.ts')

diff --git a/server.ts b/server.ts
new file mode 100644
index 000000000..119c0c61d
--- /dev/null
+++ b/server.ts
@@ -0,0 +1,142 @@
+// ----------- Node modules -----------
+import bodyParser = require('body-parser')
+import express = require('express')
+const expressValidator = require('express-validator')
+import http = require('http')
+import morgan = require('morgan')
+import path = require('path')
+import bittorrentTracker = require('bittorrent-tracker')
+import { Server as WebSocketServer } from 'ws'
+
+const TrackerServer = bittorrentTracker.Server
+
+process.title = 'peertube'
+
+// Create our main app
+const app = express()
+
+// ----------- Database -----------
+// Do not use barels because we don't want to load all modules here (we need to initialize database first)
+import { logger } from './server/helpers/logger'
+import { API_VERSION, CONFIG } from './server/initializers/constants'
+// Initialize database and models
+const db = require('./server/initializers/database')
+db.init(onDatabaseInitDone)
+
+// ----------- Checker -----------
+import { checkMissedConfig, checkFFmpeg, checkConfig } from './server/initializers/checker'
+
+const missed = checkMissedConfig()
+if (missed.length !== 0) {
+  throw new Error('Miss some configurations keys : ' + missed)
+}
+checkFFmpeg(function (err) {
+  if (err) {
+    throw err
+  }
+})
+
+const errorMessage = checkConfig()
+if (errorMessage !== null) {
+  throw new Error(errorMessage)
+}
+
+// ----------- PeerTube modules -----------
+import { migrate, installApplication } from './server/initializers'
+import { JobScheduler, activateSchedulers } from './server/lib'
+import * as customValidators from './server/helpers/custom-validators'
+import { apiRouter, clientsRouter, staticRouter } from './server/controllers'
+
+// ----------- Command line -----------
+
+// ----------- App -----------
+
+// For the logger
+// app.use(morgan('combined', { stream: logger.stream }))
+// For body requests
+app.use(bodyParser.json({ limit: '500kb' }))
+app.use(bodyParser.urlencoded({ extended: false }))
+// Validate some params for the API
+app.use(expressValidator({
+  customValidators: customValidators
+}))
+
+// ----------- Views, routes and static files -----------
+
+// API
+const apiRoute = '/api/' + API_VERSION
+app.use(apiRoute, apiRouter)
+
+// 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, next) {
+  res.sendFile(path.join(__dirname, './client/dist/index.html'))
+})
+
+// ----------- 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)
+})
+
+// ----------- 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
+    // Run the migration scripts if needed
+  migrate(function (err) {
+    if (err) throw err
+
+    installApplication(function (err) {
+      if (err) throw err
+
+      // ----------- Make the server listening -----------
+      server.listen(port, function () {
+        // Activate the communication with friends
+        activateSchedulers()
+
+        // Activate job scheduler
+        JobScheduler.Instance.activate()
+
+        logger.info('Server listening on port %d', port)
+        logger.info('Webserver: %s', CONFIG.WEBSERVER.URL)
+      })
+    })
+  })
+}
-- 
cgit v1.2.3