X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server.ts;h=7bab18b0cdcdc4370341e2449a222b4e71f7aa58;hb=d2f8170d403422ce86be2257f873c5a2c84fe94d;hp=417387a4fc14c440865afb792454c64b5d28af86;hpb=63fa260a81a8930c157b73c897fe8696a8cc90d4;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server.ts b/server.ts index 417387a4f..7bab18b0c 100644 --- a/server.ts +++ b/server.ts @@ -56,8 +56,13 @@ try { app.set('trust proxy', CONFIG.TRUST_PROXY) app.use((_req, res, next) => { + // OpenTelemetry res.locals.requestStart = Date.now() + if (CONFIG.SECURITY.POWERED_BY_HEADER.ENABLED === true) { + res.setHeader('x-powered-by', 'PeerTube') + } + return next() }) @@ -107,8 +112,8 @@ import { wellKnownRouter, lazyStaticRouter, servicesRouter, + objectStorageProxyRouter, pluginsRouter, - webfingerRouter, trackerRouter, createWebsocketTrackerServer, botsRouter, @@ -230,7 +235,6 @@ app.use('/', pluginsRouter) app.use('/', activityPubRouter) app.use('/', feedsRouter) -app.use('/', webfingerRouter) app.use('/', trackerRouter) app.use('/', botsRouter) @@ -240,6 +244,7 @@ app.use('/', wellKnownRouter) app.use('/', miscRouter) app.use('/', downloadRouter) app.use('/', lazyStaticRouter) +app.use('/', objectStorageProxyRouter) // Client files, last valid routes! const cliOptions = cli.opts<{ client: boolean, plugins: boolean }>() @@ -277,7 +282,7 @@ app.use((err, _req, res: express.Response, _next) => { }) }) -const server = createWebsocketTrackerServer(app) +const { server, trackerServer } = createWebsocketTrackerServer(app) // ----------- Run ----------- @@ -326,7 +331,12 @@ async function startApplication () { VideoChannelSyncLatestScheduler.Instance.enable() VideoViewsBufferScheduler.Instance.enable() GeoIPUpdateScheduler.Instance.enable() - OpenTelemetryMetrics.Instance.registerMetrics() + + OpenTelemetryMetrics.Instance.registerMetrics({ trackerServer }) + + PluginManager.Instance.init(server) + // Before PeerTubeSocket init + PluginManager.Instance.registerWebSocketRouter() PeerTubeSocket.Instance.init(server) VideoViewsManager.Instance.init()