tachybase_todo/packages/server/src/application.ts

63 lines
1.6 KiB
TypeScript
Raw Normal View History

import Koa from 'koa';
import Database, { DatabaseOptions } from '@nocobase/database';
import Resourcer from '@nocobase/resourcer';
export interface ApplicationOptions {
database: DatabaseOptions;
resourcer?: any;
}
export class Application extends Koa {
public readonly database: Database;
public readonly resourcer: Resourcer;
2020-12-18 19:54:53 +08:00
protected plugins = new Map<string, any>();
constructor(options: ApplicationOptions) {
super();
this.database = new Database(options.database);
this.resourcer = new Resourcer();
// this.runHook('afterInit');
2020-12-18 19:54:53 +08:00
}
registerPlugin(key: string | object, plugin?: any) {
2020-12-18 19:54:53 +08:00
if (typeof key === 'object') {
Object.keys(key).forEach((k) => {
this.registerPlugin(k, key[k]);
2020-12-18 19:54:53 +08:00
});
} else {
const config = {};
if (Array.isArray(plugin)) {
const [entry, options = {}] = plugin;
Object.assign(config, { entry, options });
} else {
Object.assign(config, { entry: plugin, options: {} });
}
this.plugins.set(key, config);
}
}
getPluginInstance(key: string) {
const plugin = this.plugins.get(key);
return plugin && plugin.instance;
2020-12-18 19:54:53 +08:00
}
async loadPlugins() {
for (const plugin of this.plugins.values()) {
plugin.instance = await this.loadPlugin(plugin);
}
2020-12-18 19:54:53 +08:00
}
protected async loadPlugin({ entry, options = {} }: { entry: string | Function, options: any }) {
const main = typeof entry === 'function'
? entry
: require(`${entry}/${__filename.endsWith('.ts') ? 'src' : 'lib'}/server`).default;
2020-12-18 19:54:53 +08:00
return await main.call(this, options);
}
}
export default Application;