Oak-Team
/
oak-cli
13
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 19 Wiki Activity

serverStart时默认启动watchers

This commit is contained in:
Xu Chang 2022-12-09 18:59:35 +08:00
parent abeff203e0
commit e529019f48
3 changed files with 12 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
lib/server/start.d.ts vendored
View File

@ -4,4 +4,4 @@ import { Connector, EntityDict } from 'oak-domain/lib/types';
import { EntityDict as BaseEntityDict } from 'oak-domain/lib/base-app-domain'; import { EntityDict as BaseEntityDict } from 'oak-domain/lib/base-app-domain';
import { AsyncContext, AsyncRowStore } from 'oak-domain/lib/store/AsyncRowStore'; import { AsyncContext, AsyncRowStore } from 'oak-domain/lib/store/AsyncRowStore';
import { SyncContext } from 'oak-domain/lib/store/SyncRowStore'; import { SyncContext } from 'oak-domain/lib/store/SyncRowStore';
export declare function startup<ED extends EntityDict & BaseEntityDict, Cxt extends AsyncContext<ED>, FrontCxt extends SyncContext<ED>>(path: string, contextBuilder: (scene?: string) => (store: AsyncRowStore<ED, Cxt>) => Promise<Cxt>, connector: Connector<ED, Cxt, FrontCxt>): Promise<void>; export declare function startup<ED extends EntityDict & BaseEntityDict, Cxt extends AsyncContext<ED>, FrontCxt extends SyncContext<ED>>(path: string, contextBuilder: (scene?: string) => (store: AsyncRowStore<ED, Cxt>) => Promise<Cxt>, connector: Connector<ED, Cxt, FrontCxt>, omitWatchers?: boolean): Promise<void>;

5
lib/server/start.js
View File

@ -10,7 +10,7 @@ const koa_router_1 = tslib_1.__importDefault(require("koa-router"));
const koa_body_1 = tslib_1.__importDefault(require("koa-body")); const koa_body_1 = tslib_1.__importDefault(require("koa-body"));
const oak_backend_base_1 = require("oak-backend-base"); const oak_backend_base_1 = require("oak-backend-base");
const types_1 = require("oak-domain/lib/types"); const types_1 = require("oak-domain/lib/types");
async function startup(path, contextBuilder, connector) { async function startup(path, contextBuilder, connector, omitWatchers) {
const dbConfig = require(path_1.default.join(path, '/configuration/mysql.json')); const dbConfig = require(path_1.default.join(path, '/configuration/mysql.json'));
const appLoader = new oak_backend_base_1.AppLoader(path, contextBuilder, dbConfig); const appLoader = new oak_backend_base_1.AppLoader(path, contextBuilder, dbConfig);
await appLoader.mount(); await appLoader.mount();
@ -72,5 +72,8 @@ async function startup(path, contextBuilder, connector) {
throw err; throw err;
}); });
koa.listen(serverConfig.port); koa.listen(serverConfig.port);
if (!omitWatchers) {
appLoader.startWatchers();
}
} }
exports.startup = startup; exports.startup = startup;

8
src/server/start.ts
View File

@ -13,7 +13,9 @@ import { SyncContext } from 'oak-domain/lib/store/SyncRowStore';
export async function startup<ED extends EntityDict & BaseEntityDict, Cxt extends AsyncContext<ED>, FrontCxt extends SyncContext<ED>>( export async function startup<ED extends EntityDict & BaseEntityDict, Cxt extends AsyncContext<ED>, FrontCxt extends SyncContext<ED>>(
path: string, path: string,
contextBuilder: (scene?: string) => (store: AsyncRowStore<ED, Cxt>) => Promise<Cxt>, contextBuilder: (scene?: string) => (store: AsyncRowStore<ED, Cxt>) => Promise<Cxt>,
connector: Connector<ED, Cxt, FrontCxt>) { connector: Connector<ED, Cxt, FrontCxt>,
omitWatchers?: boolean
) {
const dbConfig = require(PathLib.join(path, '/configuration/mysql.json')); const dbConfig = require(PathLib.join(path, '/configuration/mysql.json'));
const appLoader = new AppLoader(path, contextBuilder, dbConfig); const appLoader = new AppLoader(path, contextBuilder, dbConfig);
await appLoader.mount(); await appLoader.mount();
@ -78,4 +80,8 @@ export async function startup<ED extends EntityDict & BaseEntityDict, Cxt extend
throw err; throw err;
}); });
koa.listen(serverConfig.port); koa.listen(serverConfig.port);
if (!omitWatchers) {
appLoader.startWatchers();
}
} }