robin
124 lines
3.5 KiB
JavaScript
124 lines
3.5 KiB
JavaScript
const Koa = require("koa")
|
|
const load = require("./load")
|
|
const path = require('path')
|
|
const xe = require("xe-utils")
|
|
const EventEmitter = require('events');
|
|
const Router = require("koa-router");
|
|
const Parameter = require('parameter');
|
|
const error = require('./errorException');
|
|
const log4js = require("log4js");
|
|
const Smf = require('./smf/smf');
|
|
|
|
module.exports = class Bamboo extends Koa {
|
|
constructor() {
|
|
super();
|
|
this.init()
|
|
}
|
|
|
|
path(args) {
|
|
return this.isPath + '/' + (args || "")
|
|
}
|
|
|
|
isPath(args) {
|
|
return path.resolve('./' + (args || ""))
|
|
}
|
|
|
|
get xe() {
|
|
return xe
|
|
}
|
|
|
|
async init() {
|
|
this.config = {}
|
|
await this.loadConfig()
|
|
this.event = new EventEmitter()
|
|
this.parameter = new Parameter();
|
|
this.error = error;
|
|
this.smf = new Smf()
|
|
log4js.configure(this.config['log']);
|
|
this.logger = log4js.getLogger();
|
|
// await this.loadEvent()
|
|
// await this.loadStatus()
|
|
// await this.loadMiddleware()
|
|
// await this.loadController()
|
|
}
|
|
|
|
/**
|
|
* 加载配置
|
|
*/
|
|
async loadConfig() {
|
|
this.config = {}
|
|
const config = await load(this.isPath(), "config")
|
|
config.forEach(item => {
|
|
this.config[item.file_name] = item.res
|
|
})
|
|
}
|
|
//
|
|
// /**
|
|
// * 加载事件
|
|
// */
|
|
// async loadEvent() {
|
|
// const event = await load(this.isPath(), "event")
|
|
// event.forEach(item => {
|
|
// Object.keys(item.res).forEach(key => {
|
|
// this.event.on(key, item.res[key])
|
|
// })
|
|
// })
|
|
// }
|
|
//
|
|
// /**
|
|
// * 加载状态
|
|
// */
|
|
// async loadStatus() {
|
|
// const status = await load(this.isPath(), "status")
|
|
// const setSmfDataList = []
|
|
// status.forEach(item => {
|
|
// setSmfDataList.push(item.res)
|
|
// })
|
|
// this.smf.setSmfDataList(setSmfDataList)
|
|
// //监听流程变更
|
|
// this.smf.on((e, paras) => {
|
|
// this.event.emit(e.currentState, paras)
|
|
// })
|
|
// }
|
|
//
|
|
// /**
|
|
// * 加载控制器路由
|
|
// */
|
|
// async loadController() {
|
|
// const controller = await load(this.isPath(), "controller")
|
|
// const router = new Router();
|
|
// controller.forEach(item => {
|
|
// item.res.method.forEach(method => {
|
|
// router[method](item.res.path, async (ctx, next) => {
|
|
// const validate = this.parameter.validate(item.res.params, ctx.request.body);
|
|
// if (validate) {
|
|
// console.error(validate);
|
|
// this.error.ParameterException(validate);
|
|
// }
|
|
// else {
|
|
// await item.res.fun(ctx, this.application)
|
|
// await next();
|
|
// }
|
|
// })
|
|
// })
|
|
// })
|
|
// }
|
|
//
|
|
// /**
|
|
// * 加载中间件
|
|
// */
|
|
// async loadMiddleware() {
|
|
// const middleware = await load(this.isPath(), "middleware")
|
|
// let hashList = xe.toArray(middleware)
|
|
// hashList = xe.orderBy(hashList, "fun.sort")
|
|
// hashList = hashList.filter(item => item.res.use)
|
|
// hashList.forEach(item => {
|
|
// this.use(async (ctx, next) => {
|
|
// ctx['logger'] = this.logger
|
|
// return await item.res.fun(ctx, next, this.application)
|
|
// })
|
|
// })
|
|
// }
|
|
|
|
}
|