Oak-Team
/
oak-backend-base
13
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 18 Wiki Activity

针对runtimeContext结构变化的一些适配

This commit is contained in:
Xu Chang 2022-09-14 20:19:50 +08:00
parent 351a577f8a
commit 897a22c177
10 changed files with 10 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
lib/AppLoader.d.ts vendored
View File

@ -5,7 +5,7 @@ export declare class AppLoader<ED extends EntityDict & BaseEntityDict, Cxt exten
private dbStore; private dbStore;
private aspectDict; private aspectDict;
private contextBuilder; private contextBuilder;
constructor(path: string, contextBuilder: (scene?: string) => (store: RowStore<ED, Cxt>) => Cxt, dbConfig: MySQLConfiguration); constructor(path: string, contextBuilder: (scene?: string) => (store: RowStore<ED, Cxt>) => Promise<Cxt>, dbConfig: MySQLConfiguration);
mount(initialize?: true): Promise<void>; mount(initialize?: true): Promise<void>;
unmount(): Promise<void>; unmount(): Promise<void>;
execAspect(name: string, context: Cxt, params?: any): Promise<any>; execAspect(name: string, context: Cxt, params?: any): Promise<any>;

2
lib/AppLoader.js
View File

@ -53,7 +53,7 @@ class AppLoader extends types_1.AppLoader {
async initialize(dropIfExists) { async initialize(dropIfExists) {
await this.dbStore.initialize(dropIfExists); await this.dbStore.initialize(dropIfExists);
const { data } = require(`${this.path}/lib/data/index`); const { data } = require(`${this.path}/lib/data/index`);
const context = this.contextBuilder()(this.dbStore); const context = await this.contextBuilder()(this.dbStore);
await context.begin(); await context.begin();
for (const entity in data) { for (const entity in data) {
let rows = data[entity]; let rows = data[entity];

2
lib/DbStore.d.ts vendored
View File

@ -4,7 +4,7 @@ import { EntityDict as BaseEntityDict } from 'oak-domain/lib/base-app-domain';
import { MySQLConfiguration } from 'oak-db/lib/MySQL/types/Configuration'; import { MySQLConfiguration } from 'oak-db/lib/MySQL/types/Configuration';
export declare class DbStore<ED extends EntityDict & BaseEntityDict, Cxt extends Context<ED>> extends MysqlStore<ED, Cxt> { export declare class DbStore<ED extends EntityDict & BaseEntityDict, Cxt extends Context<ED>> extends MysqlStore<ED, Cxt> {
private executor; private executor;
constructor(storageSchema: StorageSchema<ED>, contextBuilder: (scene?: string) => (store: RowStore<ED, Cxt>) => Cxt, mysqlConfiguration: MySQLConfiguration); constructor(storageSchema: StorageSchema<ED>, contextBuilder: (scene?: string) => (store: RowStore<ED, Cxt>) => Promise<Cxt>, mysqlConfiguration: MySQLConfiguration);
protected cascadeUpdate<T extends keyof ED>(entity: T, operation: ED[T]['Create'] | ED[T]['Update'] | ED[T]['Remove'], context: Cxt, option: MysqlOperateOption): Promise<import("oak-domain/lib/types").OperationResult<ED>>; protected cascadeUpdate<T extends keyof ED>(entity: T, operation: ED[T]['Create'] | ED[T]['Update'] | ED[T]['Remove'], context: Cxt, option: MysqlOperateOption): Promise<import("oak-domain/lib/types").OperationResult<ED>>;
protected cascadeSelect<T extends keyof ED, S extends ED[T]["Selection"]>(entity: T, selection: S, context: Cxt, option: MySqlSelectOption): Promise<SelectRowShape<ED[T]['Schema'], S['data']>[]>; protected cascadeSelect<T extends keyof ED, S extends ED[T]["Selection"]>(entity: T, selection: S, context: Cxt, option: MySqlSelectOption): Promise<SelectRowShape<ED[T]['Schema'], S['data']>[]>;
operate<T extends keyof ED>(entity: T, operation: ED[T]['Operation'], context: Cxt, option: MysqlOperateOption): Promise<import("oak-domain/lib/types").OperationResult<ED>>; operate<T extends keyof ED>(entity: T, operation: ED[T]['Operation'], context: Cxt, option: MysqlOperateOption): Promise<import("oak-domain/lib/types").OperationResult<ED>>;

2
lib/DbStore.js
View File

@ -7,7 +7,7 @@ class DbStore extends oak_db_1.MysqlStore {
executor; executor;
constructor(storageSchema, contextBuilder, mysqlConfiguration) { constructor(storageSchema, contextBuilder, mysqlConfiguration) {
super(storageSchema, mysqlConfiguration); super(storageSchema, mysqlConfiguration);
this.executor = new TriggerExecutor_1.TriggerExecutor(async (scene) => contextBuilder(scene)(this)); this.executor = new TriggerExecutor_1.TriggerExecutor((scene) => contextBuilder(scene)(this));
} }
async cascadeUpdate(entity, operation, context, option) { async cascadeUpdate(entity, operation, context, option) {
if (!option.blockTrigger) { if (!option.blockTrigger) {

1
lib/index.d.ts vendored
View File

@ -1,2 +1 @@
export { Context as BackendContext } from './BackendContext';
export { AppLoader } from './AppLoader'; export { AppLoader } from './AppLoader';

4
lib/index.js
View File

@ -1,7 +1,5 @@
"use strict"; "use strict";
Object.defineProperty(exports, "__esModule", { value: true }); Object.defineProperty(exports, "__esModule", { value: true });
exports.AppLoader = exports.BackendContext = void 0; exports.AppLoader = void 0;
var BackendContext_1 = require("./BackendContext");
Object.defineProperty(exports, "BackendContext", { enumerable: true, get: function () { return BackendContext_1.Context; } });
var AppLoader_1 = require("./AppLoader"); var AppLoader_1 = require("./AppLoader");
Object.defineProperty(exports, "AppLoader", { enumerable: true, get: function () { return AppLoader_1.AppLoader; } }); Object.defineProperty(exports, "AppLoader", { enumerable: true, get: function () { return AppLoader_1.AppLoader; } });

1
package.json
View File

@ -22,7 +22,6 @@
"mysql2": "^2.3.3", "mysql2": "^2.3.3",
"oak-db": "file:../oak-db", "oak-db": "file:../oak-db",
"oak-domain": "file:../oak-domain", "oak-domain": "file:../oak-domain",
"oak-general-business": "file:../oak-general-business",
"oak-common-aspect": "file:../oak-common-aspect", "oak-common-aspect": "file:../oak-common-aspect",
"uuid": "^8.3.2" "uuid": "^8.3.2"
}, },

6
src/AppLoader.ts
View File

@ -41,8 +41,8 @@ function initTriggers<ED extends EntityDict & BaseEntityDict, Cxt extends Contex
export class AppLoader<ED extends EntityDict & BaseEntityDict, Cxt extends Context<ED>> extends GeneralAppLoader<ED, Cxt> { export class AppLoader<ED extends EntityDict & BaseEntityDict, Cxt extends Context<ED>> extends GeneralAppLoader<ED, Cxt> {
private dbStore: DbStore<ED, Cxt>; private dbStore: DbStore<ED, Cxt>;
private aspectDict: Record<string, Aspect<ED, Cxt>>; private aspectDict: Record<string, Aspect<ED, Cxt>>;
private contextBuilder: (scene?: string) => (store: RowStore<ED, Cxt>) => Cxt; private contextBuilder: (scene?: string) => (store: RowStore<ED, Cxt>) => Promise<Cxt>;
constructor(path: string, contextBuilder: (scene?: string) => (store: RowStore<ED, Cxt>) => Cxt, dbConfig: MySQLConfiguration) { constructor(path: string, contextBuilder: (scene?: string) => (store: RowStore<ED, Cxt>) => Promise<Cxt>, dbConfig: MySQLConfiguration) {
super(path); super(path);
const { storageSchema } = require(`${path}/lib/oak-app-domain/Storage`); const { storageSchema } = require(`${path}/lib/oak-app-domain/Storage`);
this.aspectDict = Object.assign({}, generalAspectDict, require(`${path}/lib/aspects/index`).aspectDict); this.aspectDict = Object.assign({}, generalAspectDict, require(`${path}/lib/aspects/index`).aspectDict);
@ -74,7 +74,7 @@ export class AppLoader<ED extends EntityDict & BaseEntityDict, Cxt extends Conte
await this.dbStore.initialize(dropIfExists); await this.dbStore.initialize(dropIfExists);
const { data } = require(`${this.path}/lib/data/index`); const { data } = require(`${this.path}/lib/data/index`);
const context = this.contextBuilder()(this.dbStore); const context = await this.contextBuilder()(this.dbStore);
await context.begin(); await context.begin();
for (const entity in data) { for (const entity in data) {
let rows = data[entity]; let rows = data[entity];

4
src/DbStore.ts
View File

@ -8,9 +8,9 @@ import { MySQLConfiguration, } from 'oak-db/lib/MySQL/types/Configuration';
export class DbStore<ED extends EntityDict & BaseEntityDict, Cxt extends Context<ED>> extends MysqlStore<ED, Cxt> { export class DbStore<ED extends EntityDict & BaseEntityDict, Cxt extends Context<ED>> extends MysqlStore<ED, Cxt> {
private executor: TriggerExecutor<ED, Cxt>; private executor: TriggerExecutor<ED, Cxt>;
constructor(storageSchema: StorageSchema<ED>, contextBuilder: (scene?: string) => (store: RowStore<ED, Cxt>) => Cxt, mysqlConfiguration: MySQLConfiguration) { constructor(storageSchema: StorageSchema<ED>, contextBuilder: (scene?: string) => (store: RowStore<ED, Cxt>) => Promise<Cxt>, mysqlConfiguration: MySQLConfiguration) {
super(storageSchema, mysqlConfiguration); super(storageSchema, mysqlConfiguration);
this.executor = new TriggerExecutor(async (scene) => contextBuilder(scene)(this)); this.executor = new TriggerExecutor((scene) => contextBuilder(scene)(this));
} }

1
src/index.ts
View File

@ -1,2 +1 @@
export { Context as BackendContext } from './BackendContext';
export { AppLoader } from './AppLoader'; export { AppLoader } from './AppLoader';