Builtin Prosody: new settings to choose how long the room's content is archived, and if it should be archived by default.

server/lib/prosody/config.ts

@@ -2,7 +2,7 @@ import * as fs from 'fs'
 import * as path from 'path'
 import { getBaseRouterRoute } from '../helpers'
 import { ProsodyFilePaths } from './config/paths'
-import { ProsodyConfigContent } from './config/content'
+import { ConfigLogExpiration, ProsodyConfigContent } from './config/content'
 import { getProsodyDomain } from './config/domain'
 import { getAPIKey } from '../apikey'
 import type { ProsodyLogLevel } from './config/content'
@@ -70,6 +70,8 @@ interface ProsodyConfig {
   port: string
   baseApiUrl: string
   roomType: 'video' | 'channel'
+  logByDefault: boolean
+  logExpiration: ConfigLogExpiration
 }
 async function getProsodyConfig (options: RegisterServerOptions): Promise<ProsodyConfig> {
   const logger = options.peertubeHelpers.logger
@@ -79,6 +81,9 @@ async function getProsodyConfig (options: RegisterServerOptions): Promise<Prosod
   if (!/^\d+$/.test(port)) {
     throw new Error('Invalid port')
   }
+  const logByDefault = (await options.settingsManager.getSetting('prosody-muc-log-by-default') as boolean) ?? true
+  const logExpirationSetting =
+    (await options.settingsManager.getSetting('prosody-muc-expiration') as string) ?? DEFAULTLOGEXPIRATION
   const enableC2s = (await options.settingsManager.getSetting('prosody-c2s') as boolean) || false
   const prosodyDomain = await getProsodyDomain(options)
   const paths = await getProsodyFilePaths(options)
@@ -111,8 +116,8 @@ async function getProsodyConfig (options: RegisterServerOptions): Promise<Prosod
     config.useC2S(c2sPort)
   }
 
-  // TODO: add a settings so that admin can choose? (on/off and duration)
-  config.useMam('1w') // Remove archived messages after 1 week
+  const logExpiration = readLogExpiration(options, logExpirationSetting)
+  config.useMam(logByDefault, logExpiration)
   // TODO: add a settings to choose?
   config.useDefaultPersistent()
 
@@ -142,7 +147,9 @@ async function getProsodyConfig (options: RegisterServerOptions): Promise<Prosod
     port,
     baseApiUrl,
     host: prosodyDomain,
-    roomType
+    roomType,
+    logByDefault,
+    logExpiration
   }
 }
 
@@ -164,6 +171,57 @@ async function writeProsodyConfig (options: RegisterServerOptions): Promise<Pros
   return config
 }
 
+const DEFAULTLOGEXPIRATION = '1w'
+const DEFAULTLOGEXPIRATIONTYPE = 'period'
+function readLogExpiration (options: RegisterServerOptions, logExpiration: string): ConfigLogExpiration {
+  const logger = options.peertubeHelpers.logger
+  logExpiration = logExpiration?.trim()
+  if (logExpiration === 'never') {
+    return {
+      value: 'never',
+      type: 'never'
+    }
+  }
+  if (/^\d+$/.test(logExpiration)) {
+    if (logExpiration === '0') {
+      logger.error('Invalid prosody-muc-expiration value, cannot be 0.')
+      return {
+        value: DEFAULTLOGEXPIRATION,
+        type: DEFAULTLOGEXPIRATIONTYPE,
+        error: '0 is not an acceptable value.'
+      }
+    }
+    return {
+      value: logExpiration,
+      type: 'seconds',
+      seconds: parseInt(logExpiration)
+    }
+  }
+  const matches = logExpiration.match(/^(\d+)([d|w|m|y])$/)
+  if (matches) {
+    const d = matches[1]
+    if (d === '0') {
+      logger.error(`Invalid prosody-muc-expiration value, cannot be ${logExpiration}.`)
+      return {
+        value: DEFAULTLOGEXPIRATION,
+        type: DEFAULTLOGEXPIRATIONTYPE,
+        error: '0 is not an acceptable value.'
+      }
+    }
+    return {
+      value: logExpiration,
+      type: 'period'
+    }
+  }
+
+  logger.error(`Invalid prosody-muc-expiration value '${logExpiration}'.`)
+  return {
+    value: DEFAULTLOGEXPIRATION,
+    type: DEFAULTLOGEXPIRATIONTYPE,
+    error: `Invalid value '${logExpiration}'.`
+  }
+}
+
 export {
   getProsodyConfig,
   getWorkingDir,

server/lib/prosody/config/content.ts

@@ -4,6 +4,27 @@ type ConfigEntryValue = boolean | number | string | ConfigEntryValue[]
 
 type ConfigEntries = Map<string, ConfigEntryValue>
 
+interface ConfigLogExpirationNever {
+  value: 'never'
+  type: 'never'
+}
+interface ConfigLogExpirationSeconds {
+  value: string
+  seconds: number
+  type: 'seconds'
+}
+interface ConfigLogExpirationPeriod {
+  value: string
+  type: 'period'
+}
+interface ConfigLogExpirationError {
+  value: string
+  error: string
+  type: 'period'
+}
+type ConfigLogExpiration =
+  ConfigLogExpirationNever | ConfigLogExpirationPeriod | ConfigLogExpirationSeconds | ConfigLogExpirationError
+
 function writeValue (value: ConfigEntryValue): string {
   if (typeof value === 'boolean') {
     return value.toString() + ';\n'
@@ -218,16 +239,23 @@ class ProsodyConfigContent {
 
   /**
    * Calling this method makes Prosody use mod_muc_mam to store rooms history.
-   * @param duration: how long the server must store messages. See https://prosody.im/doc/modules/mod_muc_mam
+   * @param logByDefault: if the room content should be archived by default.
+   * @param logExpiration: how long the server must store messages. See https://prosody.im/doc/modules/mod_muc_mam
    */
-  useMam (duration: string): void {
+  useMam (logByDefault: boolean, logExpiration: ConfigLogExpiration): void {
     this.muc.add('modules_enabled', 'muc_mam')
 
-    this.muc.set('muc_log_by_default', true)
+    this.muc.set('muc_log_by_default', !!logByDefault)
     this.muc.set('muc_log_presences', true)
-    this.muc.set('log_all_rooms', true)
-    this.muc.set('muc_log_expires_after', duration)
-    this.muc.set('muc_log_cleanup_interval', 4 * 60 * 60)
+    this.muc.set('log_all_rooms', false)
+    this.muc.set('muc_log_expires_after', logExpiration.value)
+    const defaultCleanupInterval = 4 * 60 * 60
+    if (logExpiration.type === 'seconds' && logExpiration.seconds && logExpiration.seconds < defaultCleanupInterval) {
+      // if the log expiration is less than the default cleanup interval, we have to decrease it.
+      this.muc.set('muc_log_cleanup_interval', logExpiration.seconds)
+    } else {
+      this.muc.set('muc_log_cleanup_interval', defaultCleanupInterval)
+    }
 
     // We can also use mod_muc_moderation
     // NB: for now Prosody has a partial support of this feature with «internal» storage.
@@ -287,5 +315,6 @@ class ProsodyConfigContent {
 
 export {
   ProsodyLogLevel,
-  ProsodyConfigContent
+  ProsodyConfigContent,
+  ConfigLogExpiration
 }