peertube-plugin-livechat/server/lib/rss/init.ts

88 lines
3.1 KiB
TypeScript
Raw Normal View History

2023-07-05 16:33:30 +00:00
import type { RegisterServerOptions, Video } from '@peertube/peertube-types'
import type { CustomTag } from '@peertube/feed/lib/typings'
import { videoHasWebchat } from '../../../shared/lib/video'
import { fillVideoCustomFields } from '../custom-fields'
import { getProsodyDomain } from '../prosody/config/domain'
import { getPublicChatUri } from '../uri/webchat'
async function initRSS (options: RegisterServerOptions): Promise<void> {
const logger = options.peertubeHelpers.logger
const registerHook = options.registerHook
logger.info('Registring RSS hooks...')
registerHook({
target: 'filter:feed.podcast.video.create-custom-tags.result',
handler: async (
result: CustomTag[], { video, liveItem }: { video: Video, liveItem: boolean }
): Promise<CustomTag[]> => {
if (!liveItem) {
// Note: the Podcast RSS feed specification does not handle chats for non-live.
// So we just return here.
return result
}
// FIXME: calling getSettings for each RSS entry is not optimal.
// Settings should be cached somewhere on the plugin level.
// (i already have some plans to do something for this)
const settings = await options.settingsManager.getSettings([
'chat-per-live-video',
'chat-all-lives',
'chat-all-non-lives',
'chat-videos-list',
'prosody-room-type',
'federation-dont-publish-remotely',
'prosody-room-allow-s2s',
'prosody-s2s-port'
])
if (settings['federation-dont-publish-remotely']) {
// Chat must not be published to the outer world.
return result
}
await fillVideoCustomFields(options, video)
const hasChat = await videoHasWebchat({
'chat-per-live-video': !!settings['chat-per-live-video'],
'chat-all-lives': !!settings['chat-all-lives'],
'chat-all-non-lives': !!settings['chat-all-non-lives'],
'chat-videos-list': settings['chat-videos-list'] as string
}, video)
if (!hasChat) {
logger.debug(`Video uuid=${video.uuid} has not livechat, no need to add podcast:chat tag.`)
return result
}
const prosodyDomain = await getProsodyDomain(options)
const podcastChat: any = {
name: 'podcast:chat',
attributes: {
server: prosodyDomain,
protocol: 'xmpp',
// space: will be added only if external XMPP connections are available
embedUrl: getPublicChatUri(options, video)
}
}
// In order to connect to the chat using standard xmpp, it requires these settings:
// - prosody-room-allow-s2s
// - prosody-s2s-port
if (settings['prosody-room-allow-s2s'] && settings['prosody-s2s-port']) {
let roomJID: string
if (settings['prosody-room-type'] === 'channel') {
roomJID = `channel.${video.channel.id}@room.${prosodyDomain}`
} else {
roomJID = `${video.uuid}@room.${prosodyDomain}`
}
podcastChat.attributes.space = roomJID
}
return result.concat([podcastChat])
}
})
}
export {
initRSS
}