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-03-04 17:05:05 +08:00
parent 775fcf5693
commit 3c66319b03
1 changed files with 16 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -32,9 +32,15 @@ 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[]>();
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) => {
for (let config = list.shift(); config; config = list.shift()) {
app.addDataSource(config);
}
});
} }
public static getDataSourceClass(type: string) { public static getDataSourceClass(type: string) {
@ -55,6 +61,8 @@ class DataSourceManager extends EventEmitter {
constructor({ app, useMock, initialData }: DataSourceManagerOptions) { constructor({ app, useMock, initialData }: DataSourceManagerOptions) {
super(); super();
DataSourceManager.waitInitSchemaList.set(this, []);
this.app = app; this.app = app;
this.useMock = useMock; this.useMock = useMock;
@ -133,7 +141,12 @@ class DataSourceManager extends EventEmitter {
public async addDataSource(config?: DataSourceSchema) { public async addDataSource(config?: DataSourceSchema) {
if (!config) return; if (!config) return;
const DataSourceClass = DataSourceManager.dataSourceClassMap.get(config.type) || DataSource; const DataSourceClass = DataSourceManager.dataSourceClassMap.get(config.type);
if (!DataSourceClass) {
DataSourceManager.waitInitSchemaList.get(this)?.push(config);
return;
}
const ds = new DataSourceClass({ const ds = new DataSourceClass({
app: this.app, app: this.app,
@ -276,6 +289,7 @@ class DataSourceManager extends EventEmitter {
ds.destroy(); ds.destroy();
}); });
this.dataSourceMap.clear(); this.dataSourceMap.clear();
DataSourceManager.waitInitSchemaList.delete(this);
} }
public onDataChange(id: string, path: string, callback: (newVal: any) => void) { public onDataChange(id: string, path: string, callback: (newVal: any) => void) {
@ -288,5 +302,6 @@ class DataSourceManager extends EventEmitter {
} }
DataSourceManager.register('http', HttpDataSource as any); DataSourceManager.register('http', HttpDataSource as any);
DataSourceManager.register('base', DataSource as any);
export default DataSourceManager; export default DataSourceManager;