// ----------- Node modules -----------
+import { registerOpentelemetryTracing } from './server/lib/opentelemetry/tracing'
+registerOpentelemetryTracing()
+
import express from 'express'
import morgan, { token } from 'morgan'
import cors from 'cors'
// Trust our proxy (IP forwarding...)
app.set('trust proxy', CONFIG.TRUST_PROXY)
+app.use((_req, res, next) => {
+ res.locals.requestStart = Date.now()
+
+ return next()
+})
+
// Security middleware
import { baseCSP } from './server/middlewares/csp'
import {
activityPubRouter,
apiRouter,
+ miscRouter,
clientsRouter,
feedsRouter,
staticRouter,
+ wellKnownRouter,
lazyStaticRouter,
servicesRouter,
liveRouter,
import { VideosTorrentCache } from '@server/lib/files-cache/videos-torrent-cache'
import { ServerConfigManager } from '@server/lib/server-config-manager'
import { VideoViewsManager } from '@server/lib/views/video-views-manager'
-import { isTestInstance } from './server/helpers/core-utils'
+import { isTestOrDevInstance } from './server/helpers/core-utils'
+import { OpenTelemetryMetrics } from '@server/lib/opentelemetry/metrics'
// ----------- Command line -----------
// ----------- App -----------
// Enable CORS for develop
-if (isTestInstance()) {
+if (isTestOrDevInstance()) {
app.use(cors({
origin: '*',
exposedHeaders: 'Retry-After',
// W3C DNT Tracking Status
app.use(advertiseDoNotTrack)
+// ----------- Open Telemetry -----------
+
+OpenTelemetryMetrics.Instance.init(app)
+
// ----------- Views, routes and static files -----------
// API
// Static files
app.use('/', staticRouter)
+app.use('/', wellKnownRouter)
+app.use('/', miscRouter)
app.use('/', downloadRouter)
app.use('/', lazyStaticRouter)
checkFFmpegVersion()
.catch(err => logger.error('Cannot check ffmpeg version', { err }))
- // Email initialization
+ Redis.Instance.init()
Emailer.Instance.init()
await Promise.all([
RemoveDanglingResumableUploadsScheduler.Instance.enable()
VideoViewsBufferScheduler.Instance.enable()
GeoIPUpdateScheduler.Instance.enable()
+ OpenTelemetryMetrics.Instance.registerMetrics()
- Redis.Instance.init()
PeerTubeSocket.Instance.init(server)
VideoViewsManager.Instance.init()