import { logger } from '../../helpers/logger'
import { AbstractScheduler } from './abstract-scheduler'
-import { retryTransactionWrapper } from '../../helpers/database-utils'
import { SCHEDULER_INTERVALS_MS } from '../../initializers/constants'
import { CONFIG } from '../../initializers/config'
import { PluginModel } from '../../models/server/plugin'
}
protected async internalExecute () {
- return retryTransactionWrapper(this.checkLatestPluginsVersion.bind(this))
+ return this.checkLatestPluginsVersion()
}
private async checkLatestPluginsVersion () {
if (CONFIG.PLUGINS.INDEX.ENABLED === false) return
- logger.info('Checkin latest plugins version.')
+ logger.info('Checking latest plugins version.')
const plugins = await PluginModel.listInstalled()
}
const npmNames = Object.keys(pluginIndex)
- const results = await getLatestPluginsVersion(npmNames)
- for (const result of results) {
- const plugin = pluginIndex[result.npmName]
- if (!result.latestVersion) continue
+ try {
+ const results = await getLatestPluginsVersion(npmNames)
- if (plugin.latestVersion !== result.latestVersion && compareSemVer(plugin.latestVersion, result.latestVersion) < 0) {
- plugin.latestVersion = result.latestVersion
- await plugin.save()
+ for (const result of results) {
+ const plugin = pluginIndex[result.npmName]
+ if (!result.latestVersion) continue
+
+ if (
+ !plugin.latestVersion ||
+ (plugin.latestVersion !== result.latestVersion && compareSemVer(plugin.latestVersion, result.latestVersion) < 0)
+ ) {
+ plugin.latestVersion = result.latestVersion
+ await plugin.save()
+
+ logger.info('Plugin %s has a new latest version %s.', result.npmName, plugin.latestVersion)
+ }
}
+ } catch (err) {
+ logger.error('Cannot get latest plugins version.', { npmNames, err })
}
}
-
}
static get Instance () {