certd/packages/api/src/plugin/abstract-plugin.js

import fs from 'fs'
import logger from '../utils/util.log.js'
import dayjs from 'dayjs'
import Sleep from '../utils/util.sleep.js'

export class AbstractPlugin {
  constructor ({ accessProviders }) {
    this.logger = logger
    this.accessProviders = accessProviders
  }

  appendTimeSuffix (name) {
    if (name == null) {
      name = 'certd'
    }
    return name + '-' + dayjs().format('YYYYMMDD-HHmmss')
  }

  async executeFromContextFile (options = {}) {
    const { contextPath } = options
    const contextJson = fs.readFileSync(contextPath)
    const context = JSON.parse(contextJson)
    options.context = context
    await this.doExecute(options)
    fs.writeFileSync(JSON.stringify(context))
  }

  async doExecute (options) {
    try {
      return await this.execute(options)
    } catch (e) {
      logger.error('插件执行出错：', e)
      throw e
    }
  }

  /**
   * 执行
   * @param options
   * @returns {Promise<void>}
   */
  async execute (options) {
    console.error('请实现此方法,context:', options.context)
  }

  async doRollback (options) {
    try {
      return await this.rollback(options)
    } catch (e) {
      logger.error('插件rollback出错：', e)
      throw e
    }
  }

  /**
   * 回退，用于单元测试
   * @param options
   */
  async rollback (options) {
    console.error('请实现此方法,rollback:', options.context)
  }

  getAccessProvider (accessProvider, accessProviders = this.accessProviders) {
    if (typeof accessProvider === 'string' && accessProviders) {
      accessProvider = accessProviders[accessProvider]
    }
    return accessProvider
  }

  async sleep (time) {
    await Sleep(time)
  }
}