Chat can be enabled in video properties.

server/@types/peertube.d.ts

@@ -61,6 +61,7 @@ enum VideoState {
 }
 
 interface MVideoThumbnail { // FIXME: this interface is not complete.
+  id?: number
   uuid: string
   name: string
   category: number
@@ -81,6 +82,7 @@ interface MVideoThumbnail { // FIXME: this interface is not complete.
   downloadEnabled: boolean
   state: VideoState
   channelId: number
+  pluginData?: any
 }
 
 // Keep the order

server/lib/custom-fields.ts

@@ -0,0 +1,63 @@
+async function initCustomFields (options: RegisterServerOptions): Promise<void> {
+  const registerHook = options.registerHook
+  const storageManager = options.storageManager
+  const logger = options.peertubeHelpers.logger
+
+  registerHook({
+    target: 'action:api.video.updated',
+    handler: async (params: any) => {
+      logger.debug('Saving a video, checking for custom fields')
+
+      const body: any = params.body
+      const video: MVideoThumbnail | undefined = params.video
+      if (!video || !video.id) {
+        return
+      }
+      if (!body.pluginData) return
+      const value = body.pluginData['livechat-active']
+      // NB: on Peertube 3.2.1, value is "true", "false", or "null", as strings.
+      if (value === true || value === 'true') {
+        logger.info(`Saving livechat-active=true for video ${video.id}`)
+        await storageManager.storeData(`livechat-active-${video.id}`, true)
+      } else if (value === false || value === 'false' || value === 'null') {
+        logger.info(`Saving livechat-active=false for video ${video.id}`)
+        await storageManager.storeData(`livechat-active-${video.id}`, false)
+      } else {
+        logger.error('Unknown value ' + JSON.stringify(value) + ' for livechat-active field.')
+      }
+    }
+  })
+
+  registerHook({
+    target: 'filter:api.video.get.result',
+    handler: async (video: MVideoThumbnail): Promise<MVideoThumbnail> => {
+      logger.debug('Getting a video, searching for custom fields')
+      await fillVideoCustomFields(options, video)
+      return video
+    }
+  })
+}
+
+async function fillVideoCustomFields (options: RegisterServerOptions, video: MVideoThumbnail): Promise<void> {
+  if (!video) return video
+  if (!video.pluginData) video.pluginData = {}
+  if (!video.id) return
+  const storageManager = options.storageManager
+  const logger = options.peertubeHelpers.logger
+
+  if (video.isLive) {
+    const result: any = await storageManager.getData(`livechat-active-${video.id}`)
+    logger.debug(`Video ${video.id} has livechat-active=` + JSON.stringify(result))
+    // NB: I got weird stuff here. Maybe Peertube 3.2.1 bug?
+    if (result === true || result === 'true') {
+      video.pluginData['livechat-active'] = true
+    } else if (result === false || result === 'false' || result === 'null') {
+      video.pluginData['livechat-active'] = false
+    }
+  }
+}
+
+export {
+  initCustomFields,
+  fillVideoCustomFields
+}

server/lib/diagnostic/video.ts

@@ -7,6 +7,7 @@ export async function diagVideo (test: string, { settingsManager }: RegisterServ
     'chat-auto-display',
     'chat-open-blank',
     'chat-only-locals',
+    'chat-per-live-video',
     'chat-all-lives',
     'chat-all-non-lives',
     'chat-videos-list'
@@ -26,6 +27,10 @@ export async function diagVideo (test: string, { settingsManager }: RegisterServ
   }
 
   let atLeastOne: boolean = false
+  if (videoSettings['chat-per-live-video']) {
+    result.messages.push('Chat can be enabled on live videos.')
+    atLeastOne = true
+  }
   if (videoSettings['chat-all-lives']) {
     result.messages.push('Chat is enabled for all lives.')
     atLeastOne = true

server/lib/routers/api.ts

@@ -7,6 +7,7 @@ import { getUserNickname } from '../helpers'
 import { Affiliations, getVideoAffiliations } from '../prosody/config/affiliations'
 import { getProsodyDomain } from '../prosody/config/domain'
 import type { ChatType } from '../../../shared/lib/types'
+import { fillVideoCustomFields } from '../custom-fields'
 
 // See here for description: https://modules.prosody.im/mod_muc_http_defaults.html
 interface RoomDefaults {
@@ -45,10 +46,15 @@ async function initApiRouter (options: RegisterServerOptions): Promise<Router> {
         res.sendStatus(403)
         return
       }
+
+      // Adding the custom fields:
+      await fillVideoCustomFields(options, video)
+
       // check settings (chat enabled for this video?)
       const settings = await options.settingsManager.getSettings([
         'chat-type',
         'chat-only-locals',
+        'chat-per-live-video',
         'chat-all-lives',
         'chat-all-non-lives',
         'chat-videos-list'
@@ -59,9 +65,10 @@ async function initApiRouter (options: RegisterServerOptions): Promise<Router> {
         return
       }
       if (!videoHasWebchat({
-        'chat-only-locals': settings['chat-only-locals'] as boolean,
-        'chat-all-lives': settings['chat-all-lives'] as boolean,
-        'chat-all-non-lives': settings['chat-all-non-lives'] as boolean,
+        'chat-only-locals': !!settings['chat-only-locals'],
+        '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)) {
         logger.warn(`Video ${jid} has not chat activated`)
@@ -122,11 +129,7 @@ async function initApiRouter (options: RegisterServerOptions): Promise<Router> {
   router.get('/user/check_password', asyncMiddleware(
     async (req: Request, res: Response, _next: NextFunction) => {
       const settings = await options.settingsManager.getSettings([
-        'chat-type',
-        'chat-only-locals',
-        'chat-all-lives',
-        'chat-all-non-lives',
-        'chat-videos-list'
+        'chat-type'
       ])
       if (settings['chat-type'] !== ('builtin-prosody' as ChatType)) {
         logger.warn('Prosody chat is not active')
@@ -153,11 +156,7 @@ async function initApiRouter (options: RegisterServerOptions): Promise<Router> {
   router.get('/user/user_exists', asyncMiddleware(
     async (req: Request, res: Response, _next: NextFunction) => {
       const settings = await options.settingsManager.getSettings([
-        'chat-type',
-        'chat-only-locals',
-        'chat-all-lives',
-        'chat-all-non-lives',
-        'chat-videos-list'
+        'chat-type'
       ])
       if (settings['chat-type'] !== ('builtin-prosody' as ChatType)) {
         logger.warn('Prosody chat is not active')

server/lib/settings.ts

@@ -195,13 +195,31 @@ function initSettings (options: RegisterServerOptions): void {
 <span class="peertube-plugin-livechat-warning">
   The plugin is not compatible with video federation yet.
   The webchat will only be accessible for people watching videos on your server.
+</span>`
+  })
+  registerSetting({
+    name: 'chat-per-live-video',
+    label: 'Users can activate the chat for their lives',
+    type: 'input-checkbox',
+    default: true,
+    descriptionHTML: 'If checked, all live videos will have a checkbox in there properties for enabling the webchat.',
+    private: false
+  })
+  registerSetting({
+    name: 'chat-per-live-video-warning',
+    type: 'html',
+    private: true,
+    descriptionHTML: `
+<span class="peertube-plugin-livechat-warning">
+  You have enabled the setting «Users can activate the chat for their lives».
+  It is redundant with the «Activate chat for all lives» setting.
 </span>`
   })
   registerSetting({
     name: 'chat-all-lives',
     label: 'Activate chat for all lives',
     type: 'input-checkbox',
-    default: true,
+    default: false,
     descriptionHTML: 'If checked, the chat will be enabled for all lives.',
     private: false
   })

server/main.ts

@@ -1,5 +1,6 @@
 import { migrateSettings } from './lib/migration/settings'
 import { initSettings } from './lib/settings'
+import { initCustomFields } from './lib/custom-fields'
 import { initRouters } from './lib/routers/index'
 import { ensureProsodyRunning, ensureProsodyNotRunning } from './lib/prosody/ctl'
 import decache from 'decache'
@@ -19,6 +20,7 @@ async function register (options: RegisterServerOptions): Promise<any> {
   await migrateSettings(options)
 
   await initSettings(options)
+  await initCustomFields(options)
   await initRouters(options)
 
   await ensureProsodyRunning(options)