1 import { chunk } from 'lodash'
2 import { compareSemVer } from '@shared/core-utils'
3 import { logger } from '../../helpers/logger'
4 import { CONFIG } from '../../initializers/config'
5 import { SCHEDULER_INTERVALS_MS } from '../../initializers/constants'
6 import { PluginModel } from '../../models/server/plugin'
7 import { Notifier } from '../notifier'
8 import { getLatestPluginsVersion } from '../plugins/plugin-index'
9 import { AbstractScheduler } from './abstract-scheduler'
11 export class PluginsCheckScheduler extends AbstractScheduler {
13 private static instance: AbstractScheduler
15 protected schedulerIntervalMs = SCHEDULER_INTERVALS_MS.CHECK_PLUGINS
17 private constructor () {
21 protected async internalExecute () {
22 return this.checkLatestPluginsVersion()
25 private async checkLatestPluginsVersion () {
26 if (CONFIG.PLUGINS.INDEX.ENABLED === false) return
28 logger.info('Checking latest plugins version.')
30 const plugins = await PluginModel.listInstalled()
32 // Process 10 plugins in 1 HTTP request
33 const chunks = chunk(plugins, 10)
34 for (const chunk of chunks) {
35 // Find plugins according to their npm name
36 const pluginIndex: { [npmName: string]: PluginModel } = {}
37 for (const plugin of chunk) {
38 pluginIndex[PluginModel.buildNpmName(plugin.name, plugin.type)] = plugin
41 const npmNames = Object.keys(pluginIndex)
44 const results = await getLatestPluginsVersion(npmNames)
46 for (const result of results) {
47 const plugin = pluginIndex[result.npmName]
48 if (!result.latestVersion) continue
51 !plugin.latestVersion ||
52 (plugin.latestVersion !== result.latestVersion && compareSemVer(plugin.latestVersion, result.latestVersion) < 0)
54 plugin.latestVersion = result.latestVersion
57 // Notify if there is an higher plugin version available
58 if (compareSemVer(plugin.version, result.latestVersion) < 0) {
59 Notifier.Instance.notifyOfNewPluginVersion(plugin)
62 logger.info('Plugin %s has a new latest version %s.', result.npmName, plugin.latestVersion)
66 logger.error('Cannot get latest plugins version.', { npmNames, err })
71 static get Instance () {
72 return this.instance || (this.instance = new this())