+import { chunk } from 'lodash'
+import { compareSemVer } from '@shared/core-utils'
import { logger } from '../../helpers/logger'
-import { AbstractScheduler } from './abstract-scheduler'
-import { SCHEDULER_INTERVALS_MS } from '../../initializers/constants'
import { CONFIG } from '../../initializers/config'
+import { SCHEDULER_INTERVALS_MS } from '../../initializers/constants'
import { PluginModel } from '../../models/server/plugin'
-import { chunk } from 'lodash'
+import { Notifier } from '../notifier'
import { getLatestPluginsVersion } from '../plugins/plugin-index'
-import { compareSemVer } from '../../../shared/core-utils/miscs/miscs'
+import { AbstractScheduler } from './abstract-scheduler'
export class PluginsCheckScheduler extends AbstractScheduler {
private static instance: AbstractScheduler
- protected schedulerIntervalMs = SCHEDULER_INTERVALS_MS.checkPlugins
+ protected schedulerIntervalMs = SCHEDULER_INTERVALS_MS.CHECK_PLUGINS
private constructor () {
super()
const results = await getLatestPluginsVersion(npmNames)
for (const result of results) {
- const plugin = pluginIndex[ result.npmName ]
+ const plugin = pluginIndex[result.npmName]
if (!result.latestVersion) continue
if (
plugin.latestVersion = result.latestVersion
await plugin.save()
- logger.info('Plugin %s has a new latest version %s.', PluginModel.buildNpmName(plugin.name, plugin.type), plugin.latestVersion)
+ // Notify if there is an higher plugin version available
+ if (compareSemVer(plugin.version, result.latestVersion) < 0) {
+ Notifier.Instance.notifyOfNewPluginVersion(plugin)
+ }
+
+ logger.info('Plugin %s has a new latest version %s.', result.npmName, plugin.latestVersion)
}
}
} catch (err) {