1 import * as express from 'express'
2 import { logger } from '@server/helpers/logger'
7 VIDEO_PLAYLIST_PRIVACIES,
9 } from '@server/initializers/constants'
10 import { onExternalUserAuthenticated } from '@server/lib/auth'
11 import { PluginModel } from '@server/models/server/plugin'
12 import { RegisterServerOptions } from '@server/typings/plugins'
13 import { PluginPlaylistPrivacyManager } from '@shared/models/plugins/plugin-playlist-privacy-manager.model'
14 import { PluginSettingsManager } from '@shared/models/plugins/plugin-settings-manager.model'
15 import { PluginStorageManager } from '@shared/models/plugins/plugin-storage-manager.model'
16 import { PluginVideoCategoryManager } from '@shared/models/plugins/plugin-video-category-manager.model'
17 import { PluginVideoLanguageManager } from '@shared/models/plugins/plugin-video-language-manager.model'
18 import { PluginVideoLicenceManager } from '@shared/models/plugins/plugin-video-licence-manager.model'
19 import { PluginVideoPrivacyManager } from '@shared/models/plugins/plugin-video-privacy-manager.model'
21 RegisterServerAuthExternalOptions,
22 RegisterServerAuthExternalResult,
23 RegisterServerAuthPassOptions,
24 RegisterServerExternalAuthenticatedResult
25 } from '@shared/models/plugins/register-server-auth.model'
26 import { RegisterServerHookOptions } from '@shared/models/plugins/register-server-hook.model'
27 import { RegisterServerSettingOptions } from '@shared/models/plugins/register-server-setting.model'
28 import { serverHookObject } from '@shared/models/plugins/server-hook.model'
29 import { buildPluginHelpers } from './plugin-helpers'
31 type AlterableVideoConstant = 'language' | 'licence' | 'category' | 'privacy' | 'playlistPrivacy'
32 type VideoConstant = { [key in number | string]: string }
34 type UpdatedVideoConstant = {
35 [name in AlterableVideoConstant]: {
36 added: { key: number | string, label: string }[]
37 deleted: { key: number | string, label: string }[]
41 export class RegisterHelpersStore {
42 private readonly updatedVideoConstants: UpdatedVideoConstant = {
43 playlistPrivacy: { added: [], deleted: [] },
44 privacy: { added: [], deleted: [] },
45 language: { added: [], deleted: [] },
46 licence: { added: [], deleted: [] },
47 category: { added: [], deleted: [] }
50 private readonly settings: RegisterServerSettingOptions[] = []
52 private readonly idAndPassAuths: RegisterServerAuthPassOptions[] = []
53 private readonly externalAuths: RegisterServerAuthExternalOptions[] = []
55 private readonly onSettingsChangeCallbacks: ((settings: any) => void)[] = []
57 private readonly router: express.Router
60 private readonly npmName: string,
61 private readonly plugin: PluginModel,
62 private readonly onHookAdded: (options: RegisterServerHookOptions) => void
64 this.router = express.Router()
67 buildRegisterHelpers (): RegisterServerOptions {
68 const registerHook = this.buildRegisterHook()
69 const registerSetting = this.buildRegisterSetting()
71 const getRouter = this.buildGetRouter()
73 const settingsManager = this.buildSettingsManager()
74 const storageManager = this.buildStorageManager()
76 const videoLanguageManager = this.buildVideoLanguageManager()
78 const videoLicenceManager = this.buildVideoLicenceManager()
79 const videoCategoryManager = this.buildVideoCategoryManager()
81 const videoPrivacyManager = this.buildVideoPrivacyManager()
82 const playlistPrivacyManager = this.buildPlaylistPrivacyManager()
84 const registerIdAndPassAuth = this.buildRegisterIdAndPassAuth()
85 const registerExternalAuth = this.buildRegisterExternalAuth()
87 const peertubeHelpers = buildPluginHelpers(this.npmName)
103 playlistPrivacyManager,
105 registerIdAndPassAuth,
106 registerExternalAuth,
112 reinitVideoConstants (npmName: string) {
114 language: VIDEO_LANGUAGES,
115 licence: VIDEO_LICENCES,
116 category: VIDEO_CATEGORIES,
117 privacy: VIDEO_PRIVACIES,
118 playlistPrivacy: VIDEO_PLAYLIST_PRIVACIES
120 const types: AlterableVideoConstant[] = [ 'language', 'licence', 'category', 'privacy', 'playlistPrivacy' ]
122 for (const type of types) {
123 const updatedConstants = this.updatedVideoConstants[type][npmName]
124 if (!updatedConstants) continue
126 for (const added of updatedConstants.added) {
127 delete hash[type][added.key]
130 for (const deleted of updatedConstants.deleted) {
131 hash[type][deleted.key] = deleted.label
134 delete this.updatedVideoConstants[type][npmName]
146 getIdAndPassAuths () {
147 return this.idAndPassAuths
150 getExternalAuths () {
151 return this.externalAuths
154 getOnSettingsChangedCallbacks () {
155 return this.onSettingsChangeCallbacks
158 private buildGetRouter () {
159 return () => this.router
162 private buildRegisterSetting () {
163 return (options: RegisterServerSettingOptions) => {
164 this.settings.push(options)
168 private buildRegisterHook () {
169 return (options: RegisterServerHookOptions) => {
170 if (serverHookObject[options.target] !== true) {
171 logger.warn('Unknown hook %s of plugin %s. Skipping.', options.target, this.npmName)
175 return this.onHookAdded(options)
179 private buildRegisterIdAndPassAuth () {
180 return (options: RegisterServerAuthPassOptions) => {
181 if (!options.authName || typeof options.getWeight !== 'function' || typeof options.login !== 'function') {
182 logger.error('Cannot register auth plugin %s: authName of getWeight or login are not valid.', this.npmName)
186 this.idAndPassAuths.push(options)
190 private buildRegisterExternalAuth () {
193 return (options: RegisterServerAuthExternalOptions) => {
194 if (!options.authName || typeof options.authDisplayName !== 'function' || typeof options.onAuthRequest !== 'function') {
195 logger.error('Cannot register auth plugin %s: authName of getWeight or login are not valid.', this.npmName)
199 this.externalAuths.push(options)
202 userAuthenticated (result: RegisterServerExternalAuthenticatedResult): void {
203 onExternalUserAuthenticated({
204 npmName: self.npmName,
205 authName: options.authName,
208 logger.error('Cannot execute onExternalUserAuthenticated.', { npmName: self.npmName, authName: options.authName, err })
211 } as RegisterServerAuthExternalResult
215 private buildSettingsManager (): PluginSettingsManager {
217 getSetting: (name: string) => PluginModel.getSetting(this.plugin.name, this.plugin.type, name),
219 getSettings: (names: string[]) => PluginModel.getSettings(this.plugin.name, this.plugin.type, names),
221 setSetting: (name: string, value: string) => PluginModel.setSetting(this.plugin.name, this.plugin.type, name, value),
223 onSettingsChange: (cb: (settings: any) => void) => this.onSettingsChangeCallbacks.push(cb)
227 private buildStorageManager (): PluginStorageManager {
229 getData: (key: string) => PluginModel.getData(this.plugin.name, this.plugin.type, key),
231 storeData: (key: string, data: any) => PluginModel.storeData(this.plugin.name, this.plugin.type, key, data)
235 private buildVideoLanguageManager (): PluginVideoLanguageManager {
237 addLanguage: (key: string, label: string) => {
238 return this.addConstant({ npmName: this.npmName, type: 'language', obj: VIDEO_LANGUAGES, key, label })
241 deleteLanguage: (key: string) => {
242 return this.deleteConstant({ npmName: this.npmName, type: 'language', obj: VIDEO_LANGUAGES, key })
247 private buildVideoCategoryManager (): PluginVideoCategoryManager {
249 addCategory: (key: number, label: string) => {
250 return this.addConstant({ npmName: this.npmName, type: 'category', obj: VIDEO_CATEGORIES, key, label })
253 deleteCategory: (key: number) => {
254 return this.deleteConstant({ npmName: this.npmName, type: 'category', obj: VIDEO_CATEGORIES, key })
259 private buildVideoPrivacyManager (): PluginVideoPrivacyManager {
261 deletePrivacy: (key: number) => {
262 return this.deleteConstant({ npmName: this.npmName, type: 'privacy', obj: VIDEO_PRIVACIES, key })
267 private buildPlaylistPrivacyManager (): PluginPlaylistPrivacyManager {
269 deletePlaylistPrivacy: (key: number) => {
270 return this.deleteConstant({ npmName: this.npmName, type: 'playlistPrivacy', obj: VIDEO_PLAYLIST_PRIVACIES, key })
275 private buildVideoLicenceManager (): PluginVideoLicenceManager {
277 addLicence: (key: number, label: string) => {
278 return this.addConstant({ npmName: this.npmName, type: 'licence', obj: VIDEO_LICENCES, key, label })
281 deleteLicence: (key: number) => {
282 return this.deleteConstant({ npmName: this.npmName, type: 'licence', obj: VIDEO_LICENCES, key })
287 private addConstant<T extends string | number> (parameters: {
289 type: AlterableVideoConstant
294 const { npmName, type, obj, key, label } = parameters
297 logger.warn('Cannot add %s %s by plugin %s: key already exists.', type, npmName, key)
301 if (!this.updatedVideoConstants[type][npmName]) {
302 this.updatedVideoConstants[type][npmName] = {
308 this.updatedVideoConstants[type][npmName].added.push({ key, label })
314 private deleteConstant<T extends string | number> (parameters: {
316 type: AlterableVideoConstant
320 const { npmName, type, obj, key } = parameters
323 logger.warn('Cannot delete %s %s by plugin %s: key does not exist.', type, npmName, key)
327 if (!this.updatedVideoConstants[type][npmName]) {
328 this.updatedVideoConstants[type][npmName] = {
334 this.updatedVideoConstants[type][npmName].deleted.push({ key, label: obj[key] })