client/src/app/+admin/plugins/shared/plugin-api.service.ts

   1 import { catchError, map, switchMap } from 'rxjs/operators'
   2 import { HttpClient, HttpParams } from '@angular/common/http'
   3 import { Injectable } from '@angular/core'
   4 import { environment } from '../../../../environments/environment'
   5 import { RestExtractor, RestService } from '../../../shared'
   6 import { I18n } from '@ngx-translate/i18n-polyfill'
   7 import { PluginType } from '@shared/models/plugins/plugin.type'
   8 import { ComponentPagination } from '@app/shared/rest/component-pagination.model'
   9 import { peertubeTranslate, ResultList } from '@shared/models'
  10 import { PeerTubePlugin } from '@shared/models/plugins/peertube-plugin.model'
  11 import { ManagePlugin } from '@shared/models/plugins/manage-plugin.model'
  12 import { InstallOrUpdatePlugin } from '@shared/models/plugins/install-plugin.model'
  13 import { PeerTubePluginIndex } from '@shared/models/plugins/peertube-plugin-index.model'
  14 import { RegisteredServerSettings, RegisterServerSettingOptions } from '@shared/models/plugins/register-server-setting.model'
  15 import { PluginService } from '@app/core/plugins/plugin.service'
  16 import { Observable } from 'rxjs'
  17
  18 @Injectable()
  19 export class PluginApiService {
  20   private static BASE_PLUGIN_URL = environment.apiUrl + '/api/v1/plugins'
  21
  22   constructor (
  23     private authHttp: HttpClient,
  24     private restExtractor: RestExtractor,
  25     private restService: RestService,
  26     private i18n: I18n,
  27     private pluginService: PluginService
  28   ) { }
  29
  30   getPluginTypeOptions () {
  31     return [
  32       {
  33         label: this.i18n('Plugins'),
  34         value: PluginType.PLUGIN
  35       },
  36       {
  37         label: this.i18n('Themes'),
  38         value: PluginType.THEME
  39       }
  40     ]
  41   }
  42
  43   getPluginTypeLabel (type: PluginType) {
  44     if (type === PluginType.PLUGIN) {
  45       return this.i18n('plugin')
  46     }
  47
  48     return this.i18n('theme')
  49   }
  50
  51   getPlugins (
  52     pluginType: PluginType,
  53     componentPagination: ComponentPagination,
  54     sort: string
  55   ) {
  56     const pagination = this.restService.componentPaginationToRestPagination(componentPagination)
  57
  58     let params = new HttpParams()
  59     params = this.restService.addRestGetParams(params, pagination, sort)
  60     params = params.append('pluginType', pluginType.toString())
  61
  62     return this.authHttp.get<ResultList<PeerTubePlugin>>(PluginApiService.BASE_PLUGIN_URL, { params })
  63                .pipe(catchError(res => this.restExtractor.handleError(res)))
  64   }
  65
  66   searchAvailablePlugins (
  67     pluginType: PluginType,
  68     componentPagination: ComponentPagination,
  69     sort: string,
  70     search?: string
  71   ) {
  72     const pagination = this.restService.componentPaginationToRestPagination(componentPagination)
  73
  74     let params = new HttpParams()
  75     params = this.restService.addRestGetParams(params, pagination, sort)
  76     params = params.append('pluginType', pluginType.toString())
  77
  78     if (search) params = params.append('search', search)
  79
  80     return this.authHttp.get<ResultList<PeerTubePluginIndex>>(PluginApiService.BASE_PLUGIN_URL + '/available', { params })
  81                .pipe(catchError(res => this.restExtractor.handleError(res)))
  82   }
  83
  84   getPlugin (npmName: string) {
  85     const path = PluginApiService.BASE_PLUGIN_URL + '/' + npmName
  86
  87     return this.authHttp.get<PeerTubePlugin>(path)
  88                .pipe(catchError(res => this.restExtractor.handleError(res)))
  89   }
  90
  91   getPluginRegisteredSettings (pluginName: string, pluginType: PluginType) {
  92     const npmName = this.pluginService.nameToNpmName(pluginName, pluginType)
  93     const path = PluginApiService.BASE_PLUGIN_URL + '/' + npmName + '/registered-settings'
  94
  95     return this.authHttp.get<RegisteredServerSettings>(path)
  96                .pipe(
  97                  switchMap(res => this.translateSettingsLabel(npmName, res)),
  98                  catchError(res => this.restExtractor.handleError(res))
  99                )
 100   }
 101
 102   updatePluginSettings (pluginName: string, pluginType: PluginType, settings: any) {
 103     const npmName = this.pluginService.nameToNpmName(pluginName, pluginType)
 104     const path = PluginApiService.BASE_PLUGIN_URL + '/' + npmName + '/settings'
 105
 106     return this.authHttp.put(path, { settings })
 107                .pipe(catchError(res => this.restExtractor.handleError(res)))
 108   }
 109
 110   uninstall (pluginName: string, pluginType: PluginType) {
 111     const body: ManagePlugin = {
 112       npmName: this.pluginService.nameToNpmName(pluginName, pluginType)
 113     }
 114
 115     return this.authHttp.post(PluginApiService.BASE_PLUGIN_URL + '/uninstall', body)
 116                .pipe(catchError(res => this.restExtractor.handleError(res)))
 117   }
 118
 119   update (pluginName: string, pluginType: PluginType) {
 120     const body: ManagePlugin = {
 121       npmName: this.pluginService.nameToNpmName(pluginName, pluginType)
 122     }
 123
 124     return this.authHttp.post(PluginApiService.BASE_PLUGIN_URL + '/update', body)
 125                .pipe(catchError(res => this.restExtractor.handleError(res)))
 126   }
 127
 128   install (npmName: string) {
 129     const body: InstallOrUpdatePlugin = {
 130       npmName
 131     }
 132
 133     return this.authHttp.post(PluginApiService.BASE_PLUGIN_URL + '/install', body)
 134                .pipe(catchError(res => this.restExtractor.handleError(res)))
 135   }
 136
 137   private translateSettingsLabel (npmName: string, res: RegisteredServerSettings): Observable<RegisteredServerSettings> {
 138     return this.pluginService.translationsObservable
 139       .pipe(
 140         map(allTranslations => allTranslations[npmName]),
 141         map(translations => {
 142           const registeredSettings = res.registeredSettings
 143                                         .map(r => {
 144                                           return Object.assign({}, r, { label: peertubeTranslate(r.label, translations) })
 145                                         })
 146
 147           return { registeredSettings }
 148         })
 149       )
 150   }
 151 }