JLNTV_IPD/tmagic-editor
4
0
Fork 0
mirror of https://github.com/Tencent/tmagic-editor.git synced 2025-04-06 03:57:56 +08:00
Code Issues Projects Releases Wiki Activity

fix(data-source): 数据源初始化时机比注册早回出现死循环

Browse Source
This commit is contained in:
roymondchen 2025-04-02 17:17:30 +08:00
parent 9b546645f3
commit 840c2c3c7d
1 changed files with 17 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
packages/data-source/src/DataSourceManager.ts
View File

@ -32,11 +32,12 @@ import { compiledNodeField, compliedConditions, compliedIteratorItem, createIter
class DataSourceManager extends EventEmitter { class DataSourceManager extends EventEmitter {
private static dataSourceClassMap = new Map<string, typeof DataSource>(); private static dataSourceClassMap = new Map<string, typeof DataSource>();
private static ObservedDataClass: ObservedDataClass = SimpleObservedData; private static ObservedDataClass: ObservedDataClass = SimpleObservedData;
private static waitInitSchemaList = new Map<DataSourceManager, DataSourceSchema[]>(); private static waitInitSchemaList = new Map<DataSourceManager, Record<string, DataSourceSchema[]>>();
public static register<T extends typeof DataSource = typeof DataSource>(type: string, dataSource: T) { public static register<T extends typeof DataSource = typeof DataSource>(type: string, dataSource: T) {
DataSourceManager.dataSourceClassMap.set(type, dataSource); DataSourceManager.dataSourceClassMap.set(type, dataSource);
DataSourceManager.waitInitSchemaList?.forEach((list, app) => { DataSourceManager.waitInitSchemaList?.forEach((listMap, app) => {
const list = listMap[type] || [];
for (let config = list.shift(); config; config = list.shift()) { for (let config = list.shift(); config; config = list.shift()) {
app.addDataSource(config); app.addDataSource(config);
} }
@ -61,7 +62,7 @@ class DataSourceManager extends EventEmitter {
constructor({ app, useMock, initialData }: DataSourceManagerOptions) { constructor({ app, useMock, initialData }: DataSourceManagerOptions) {
super(); super();
DataSourceManager.waitInitSchemaList.set(this, []); DataSourceManager.waitInitSchemaList.set(this, {});
this.app = app; this.app = app;
this.useMock = useMock; this.useMock = useMock;
@ -144,7 +145,19 @@ class DataSourceManager extends EventEmitter {
const DataSourceClass = DataSourceManager.dataSourceClassMap.get(config.type); const DataSourceClass = DataSourceManager.dataSourceClassMap.get(config.type);
if (!DataSourceClass) { if (!DataSourceClass) {
DataSourceManager.waitInitSchemaList.get(this)?.push(config); let listMap = DataSourceManager.waitInitSchemaList.get(this);
if (!listMap) {
listMap = {};
DataSourceManager.waitInitSchemaList.set(this, listMap);
}
if (listMap[config.type]) {
listMap[config.type].push(config);
} else {
listMap[config.type] = [config];
}
return; return;
} }