]>
Commit | Line | Data |
---|---|---|
db4b15f2 C |
1 | import { sanitizeUrl } from '@server/helpers/core-utils' |
2 | import { ResultList } from '../../../shared/models' | |
3 | import { PeertubePluginIndexList } from '../../../shared/models/plugins/peertube-plugin-index-list.model' | |
4 | import { PeerTubePluginIndex } from '../../../shared/models/plugins/peertube-plugin-index.model' | |
6702a1b2 C |
5 | import { |
6 | PeertubePluginLatestVersionRequest, | |
7 | PeertubePluginLatestVersionResponse | |
8 | } from '../../../shared/models/plugins/peertube-plugin-latest-version.model' | |
6702a1b2 | 9 | import { logger } from '../../helpers/logger' |
db4b15f2 C |
10 | import { doJSONRequest } from '../../helpers/requests' |
11 | import { CONFIG } from '../../initializers/config' | |
66170ca8 | 12 | import { PEERTUBE_VERSION } from '../../initializers/constants' |
db4b15f2 C |
13 | import { PluginModel } from '../../models/server/plugin' |
14 | import { PluginManager } from './plugin-manager' | |
6702a1b2 C |
15 | |
16 | async function listAvailablePluginsFromIndex (options: PeertubePluginIndexList) { | |
17 | const { start = 0, count = 20, search, sort = 'npmName', pluginType } = options | |
18 | ||
db4b15f2 | 19 | const searchParams: PeertubePluginIndexList & Record<string, string | number> = { |
6702a1b2 C |
20 | start, |
21 | count, | |
22 | sort, | |
23 | pluginType, | |
24 | search, | |
09071200 | 25 | currentPeerTubeEngine: options.currentPeerTubeEngine || PEERTUBE_VERSION |
6702a1b2 C |
26 | } |
27 | ||
28 | const uri = CONFIG.PLUGINS.INDEX.URL + '/api/v1/plugins' | |
29 | ||
e0ce715a | 30 | try { |
db4b15f2 | 31 | const { body } = await doJSONRequest<any>(uri, { searchParams }) |
6702a1b2 | 32 | |
e0ce715a | 33 | logger.debug('Got result from PeerTube index.', { body }) |
6702a1b2 | 34 | |
a1587156 | 35 | addInstanceInformation(body) |
6702a1b2 | 36 | |
e0ce715a C |
37 | return body as ResultList<PeerTubePluginIndex> |
38 | } catch (err) { | |
39 | logger.error('Cannot list available plugins from index %s.', uri, { err }) | |
40 | return undefined | |
41 | } | |
6702a1b2 C |
42 | } |
43 | ||
a1587156 | 44 | function addInstanceInformation (result: ResultList<PeerTubePluginIndex>) { |
6702a1b2 C |
45 | for (const d of result.data) { |
46 | d.installed = PluginManager.Instance.isRegistered(d.npmName) | |
47 | d.name = PluginModel.normalizePluginName(d.npmName) | |
48 | } | |
49 | ||
50 | return result | |
51 | } | |
52 | ||
53 | async function getLatestPluginsVersion (npmNames: string[]): Promise<PeertubePluginLatestVersionResponse> { | |
54 | const bodyRequest: PeertubePluginLatestVersionRequest = { | |
55 | npmNames, | |
66170ca8 | 56 | currentPeerTubeEngine: PEERTUBE_VERSION |
6702a1b2 C |
57 | } |
58 | ||
5fb2e288 | 59 | const uri = sanitizeUrl(CONFIG.PLUGINS.INDEX.URL) + '/api/v1/plugins/latest-version' |
6702a1b2 | 60 | |
db4b15f2 C |
61 | const options = { |
62 | json: bodyRequest, | |
63 | method: 'POST' as 'POST' | |
64 | } | |
65 | const { body } = await doJSONRequest<PeertubePluginLatestVersionResponse>(uri, options) | |
6702a1b2 C |
66 | |
67 | return body | |
68 | } | |
69 | ||
8280d0c2 C |
70 | async function getLatestPluginVersion (npmName: string) { |
71 | const results = await getLatestPluginsVersion([ npmName ]) | |
72 | ||
73 | if (Array.isArray(results) === false || results.length !== 1) { | |
74 | logger.warn('Cannot get latest supported plugin version of %s.', npmName) | |
75 | return undefined | |
76 | } | |
77 | ||
78 | return results[0].latestVersion | |
79 | } | |
80 | ||
6702a1b2 C |
81 | export { |
82 | listAvailablePluginsFromIndex, | |
8280d0c2 | 83 | getLatestPluginVersion, |
6702a1b2 C |
84 | getLatestPluginsVersion |
85 | } |