@motif/api/lib/Config.js

"use strict"

const debug = require("debug")("motif:config")
const fs = require("fs")
const path = require("path")

const DAO = require("@motif/dao")

class Config {
  get mode() {
    return this._mode
  }

  get port() {
    return this._config.port || 3000
  }

  get createDoc() {
    return this._config.createDoc || false
  }

  get docPath() {
    return this._config.swagger && this._config.swagger.docPath || "/doc"
  }

  get database() {
    return this._config.database || {}
  }

  get(name) {
    return this._config[name]
  }

  _parseConfig( options = {} ) {
    let { config } = options
    if (config) {
      return config
    }

    try {
      if (fs.existsSync(this._appPath + "/config/conf.d/config." + this._mode + ".json")) {
        const content = fs.readFileSync( this._appPath + "/config/conf.d/config." + this._mode + ".json" )
        return JSON.parse(content)
      }
      else if (fs.existsSync(this._appPath + "/data/config/conf.d/config." + this._mode + ".json")) {
        const content = fs.readFileSync( this._appPath + "/data/config/conf.d/config." + this._mode + ".json" )
        return JSON.parse(content)
      }
    }
    catch(e) {
      debug("parse config error", e)
    }

    return {}
  }

  _initialize() {
    return new Promise( async callback => {

      for (var key in this._connections) {
        let options = this._connections[key]
        await DAO.registerConnnection(key, options)
      }

      if (this._connectionOptions) {
        await DAO.registerConnnections(this._connectionOptions)
      }

      callback()
    })
  }

  constructor(options) {
    debug("config", options)

    const { mode } = options
    const appPath = path.resolve(process.env.PWD, ".")

    this._appPath = appPath
    this._mode = mode
    this._config = this._parseConfig( options )
    this._connections = {}
    this._connectionOptions = null
  }

  connection(key) {
    return DAO.connection(key)
  }

  registerConnnection(key, options) {
    this._connections[key] = options
  }

  registerConnnections(connectionOptions) {
    this._connectionOptions = connectionOptions
  }
}

module.exports = Config