133 lines
4.7 KiB
TypeScript
133 lines
4.7 KiB
TypeScript
import type { Router, RequestHandler, Request, Response, NextFunction } from 'express'
|
|
import type { ProxyOptions } from 'express-http-proxy'
|
|
import type { ChatType } from '../../../shared/lib/types'
|
|
import { getBaseRouterRoute, getBaseStaticRoute } from '../helpers'
|
|
import { asyncMiddleware } from '../middlewares/async'
|
|
import { getProsodyDomain } from '../prosody/config/domain'
|
|
import * as path from 'path'
|
|
const bodyParser = require('body-parser')
|
|
|
|
const fs = require('fs').promises
|
|
const proxy = require('express-http-proxy')
|
|
|
|
let httpBindRoute: RequestHandler
|
|
|
|
async function initWebchatRouter (options: RegisterServerOptions): Promise<Router> {
|
|
const {
|
|
getRouter,
|
|
peertubeHelpers,
|
|
settingsManager
|
|
} = options
|
|
|
|
const converseJSIndex = await fs.readFile(path.resolve(__dirname, '../../conversejs/index.html'))
|
|
|
|
const router: Router = getRouter()
|
|
// eslint-disable-next-line @typescript-eslint/no-misused-promises
|
|
router.get('/room/:videoUUID', asyncMiddleware(
|
|
async (req: Request, res: Response, _next: NextFunction): Promise<void> => {
|
|
res.removeHeader('X-Frame-Options') // this route can be opened in an iframe
|
|
|
|
const settings = await settingsManager.getSettings([
|
|
'chat-type', 'chat-room', 'chat-server',
|
|
'chat-bosh-uri', 'chat-ws-uri'
|
|
])
|
|
const chatType: ChatType = (settings['chat-type'] ?? 'disabled') as ChatType
|
|
|
|
let server: string
|
|
let room: string
|
|
let boshUri: string
|
|
let wsUri: string
|
|
let authenticationUrl: string = ''
|
|
let advancedControls: boolean = false
|
|
if (chatType === 'builtin-prosody') {
|
|
const prosodyDomain = await getProsodyDomain(options)
|
|
server = 'anon.' + prosodyDomain
|
|
room = '{{VIDEO_UUID}}@room.' + prosodyDomain
|
|
boshUri = getBaseRouterRoute(options) + 'webchat/http-bind'
|
|
wsUri = ''
|
|
authenticationUrl = options.peertubeHelpers.config.getWebserverUrl() +
|
|
getBaseRouterRoute(options) +
|
|
'api/auth'
|
|
advancedControls = true
|
|
} else if (chatType === 'builtin-converse') {
|
|
if (!settings['chat-server']) {
|
|
throw new Error('Missing chat-server settings.')
|
|
}
|
|
if (!settings['chat-room']) {
|
|
throw new Error('Missing chat-room settings.')
|
|
}
|
|
if (!settings['chat-bosh-uri'] && !settings['chat-ws-uri']) {
|
|
throw new Error('Missing BOSH or Websocket uri.')
|
|
}
|
|
server = settings['chat-server'] as string
|
|
room = settings['chat-room'] as string
|
|
boshUri = settings['chat-bosh-uri'] as string
|
|
wsUri = settings['chat-ws-uri'] as string
|
|
} else {
|
|
throw new Error('Builtin chat disabled.')
|
|
}
|
|
|
|
const uuid = req.params.videoUUID
|
|
const video = await peertubeHelpers.videos.loadByIdOrUUID(uuid)
|
|
if (!video) {
|
|
throw new Error('Video not found')
|
|
}
|
|
|
|
let page = '' + (converseJSIndex as string)
|
|
const baseStaticUrl = getBaseStaticRoute(options)
|
|
page = page.replace(/{{BASE_STATIC_URL}}/g, baseStaticUrl)
|
|
page = page.replace(/{{JID}}/g, server)
|
|
room = room.replace(/{{VIDEO_UUID}}/g, video.uuid)
|
|
page = page.replace(/{{ROOM}}/g, room)
|
|
page = page.replace(/{{BOSH_SERVICE_URL}}/g, boshUri)
|
|
page = page.replace(/{{WS_SERVICE_URL}}/g, wsUri)
|
|
page = page.replace(/{{AUTHENTICATION_URL}}/g, authenticationUrl)
|
|
page = page.replace(/{{ADVANCEDCONTROLS}}/g, advancedControls ? 'true' : 'false')
|
|
|
|
res.status(200)
|
|
res.type('html')
|
|
res.send(page)
|
|
}
|
|
))
|
|
|
|
changeHttpBindRoute(options, null)
|
|
router.all('/http-bind',
|
|
bodyParser.raw({ type: 'text/xml' }),
|
|
(req: Request, res: Response, next: NextFunction) => {
|
|
httpBindRoute(req, res, next)
|
|
}
|
|
)
|
|
return router
|
|
}
|
|
|
|
function changeHttpBindRoute ({ peertubeHelpers }: RegisterServerOptions, port: string | null): void {
|
|
const logger = peertubeHelpers.logger
|
|
logger.info('Changing http-bind port for ' + (port ?? 'null'))
|
|
if (port !== null && !/^\d+$/.test(port)) {
|
|
logger.error('Port is not valid. Replacing by null')
|
|
port = null
|
|
}
|
|
if (port === null) {
|
|
httpBindRoute = (_req: Request, res: Response, _next: NextFunction) => {
|
|
res.status(404)
|
|
res.send('Not found')
|
|
}
|
|
} else {
|
|
const options: ProxyOptions = {
|
|
https: false,
|
|
proxyReqPathResolver: async (_req: Request): Promise<string> => {
|
|
return '/http-bind' // should not be able to access anything else
|
|
},
|
|
// preserveHostHdr: true,
|
|
parseReqBody: true // Note that setting this to false overrides reqAsBuffer and reqBodyEncoding below.
|
|
// FIXME: should we remove cookies?
|
|
}
|
|
httpBindRoute = proxy('http://localhost:' + port, options)
|
|
}
|
|
}
|
|
|
|
export {
|
|
initWebchatRouter,
|
|
changeHttpBindRoute
|
|
}
|