X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server.ts;h=a7a723b2400cc622ffbf9fa8c118764cb2a4fc4e;hb=fabe350bcac2d24c8524d4b6bb776dba7e374c8d;hp=2085c67d91ebd6b5ab985c3e0cf70477eb307032;hpb=cfd57d2ca0bb058087f7dc90fcc3e8442b0288e1;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server.ts b/server.ts index 2085c67d9..a7a723b24 100644 --- a/server.ts +++ b/server.ts @@ -45,14 +45,24 @@ try { import { checkConfig, checkActivityPubUrls, checkFFmpegVersion } from './server/initializers/checker-after-init' -checkConfig() +try { + checkConfig() +} catch (err) { + logger.error('Config error.', { err }) + process.exit(-1) +} // Trust our proxy (IP forwarding...) 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() }) @@ -102,8 +112,8 @@ import { wellKnownRouter, lazyStaticRouter, servicesRouter, + objectStorageProxyRouter, pluginsRouter, - webfingerRouter, trackerRouter, createWebsocketTrackerServer, botsRouter, @@ -123,6 +133,7 @@ import { AutoFollowIndexInstances } from './server/lib/schedulers/auto-follow-in import { RemoveDanglingResumableUploadsScheduler } from './server/lib/schedulers/remove-dangling-resumable-uploads-scheduler' import { VideoViewsBufferScheduler } from './server/lib/schedulers/video-views-buffer-scheduler' import { GeoIPUpdateScheduler } from './server/lib/schedulers/geo-ip-update-scheduler' +import { RunnerJobWatchDogScheduler } from './server/lib/schedulers/runner-job-watch-dog-scheduler' import { isHTTPSignatureDigestValid } from './server/helpers/peertube-crypto' import { PeerTubeSocket } from './server/lib/peertube-socket' import { updateStreamingPlaylistsInfohashesIfNeeded } from './server/lib/hls' @@ -225,7 +236,6 @@ app.use('/', pluginsRouter) app.use('/', activityPubRouter) app.use('/', feedsRouter) -app.use('/', webfingerRouter) app.use('/', trackerRouter) app.use('/', botsRouter) @@ -235,6 +245,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 }>() @@ -272,7 +283,7 @@ app.use((err, _req, res: express.Response, _next) => { }) }) -const server = createWebsocketTrackerServer(app) +const { server, trackerServer } = createWebsocketTrackerServer(app) // ----------- Run ----------- @@ -321,7 +332,13 @@ async function startApplication () { VideoChannelSyncLatestScheduler.Instance.enable() VideoViewsBufferScheduler.Instance.enable() GeoIPUpdateScheduler.Instance.enable() - OpenTelemetryMetrics.Instance.registerMetrics() + RunnerJobWatchDogScheduler.Instance.enable() + + OpenTelemetryMetrics.Instance.registerMetrics({ trackerServer }) + + PluginManager.Instance.init(server) + // Before PeerTubeSocket init + PluginManager.Instance.registerWebSocketRouter() PeerTubeSocket.Instance.init(server) VideoViewsManager.Instance.init()