wikijs/server/jobs/sync-storage.js

const _ = require('lodash')

/* global WIKI */

module.exports = async (targetKey) => {
  WIKI.logger.info(`Syncing with storage target ${targetKey}...`)

  try {
    const target = _.find(WIKI.models.storage.targets, ['key', targetKey])
    if (target) {
      await target.fn.sync()
      WIKI.logger.info(`Syncing with storage target ${targetKey}: [ COMPLETED ]`)

      await WIKI.models.storage.query().patch({
        state: {
          status: 'operational',
          message: '',
          lastAttempt: new Date().toISOString()
        }
      }).where('key', targetKey)
    } else {
      throw new Error('Invalid storage target. Unable to perform sync.')
    }
  } catch (err) {
    WIKI.logger.error(`Syncing with storage target ${targetKey}: [ FAILED ]`)
    WIKI.logger.error(err.message)
    await WIKI.models.storage.query().patch({
      state: {
        status: 'error',
        message: err.message,
        lastAttempt: new Date().toISOString()
      }
    }).where('key', targetKey)
  }
}