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

fix(data-source): 没有异步加载数据源的情况下，数据源init方法没有执行

Browse Source
This commit is contained in:
roymondchen 2025-05-26 20:04:40 +08:00
parent 1cee0bf4aa
commit c7b2734090
1 changed files with 41 additions and 33 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -96,39 +96,13 @@ class DataSourceManager extends EventEmitter {
this.addDataSource(config); this.addDataSource(config);
}); });
if (this.isAllDataSourceRegistered()) {
this.callDsInit();
} else {
this.on('registered-all', () => { this.on('registered-all', () => {
const dataSourceList = Array.from(this.dataSourceMap); this.callDsInit();
if (typeof Promise.allSettled === 'function') {
Promise.allSettled<Record<string, any>>(dataSourceList.map(([, ds]) => this.init(ds))).then((values) => {
const data: DataSourceManagerData = {};
const errors: Record<string, Error> = {};
values.forEach((value, index) => {
const dsId = dataSourceList[index][0];
if (value.status === 'fulfilled') {
if (this.data[dsId]) {
data[dsId] = this.data[dsId];
} else {
delete data[dsId];
}
} else if (value.status === 'rejected') {
delete data[dsId];
errors[dsId] = value.reason;
}
});
this.emit('init', data, errors);
});
} else {
Promise.all<Record<string, any>>(dataSourceList.map(([, ds]) => this.init(ds)))
.then(() => {
this.emit('init', this.data);
})
.catch(() => {
this.emit('init', this.data);
}); });
} }
});
} }
public async init(ds: DataSource) { public async init(ds: DataSource) {
@ -350,6 +324,40 @@ class DataSourceManager extends EventEmitter {
public offDataChange(id: string, path: string, callback: (newVal: any) => void) { public offDataChange(id: string, path: string, callback: (newVal: any) => void) {
return this.get(id)?.offDataChange(path, callback); return this.get(id)?.offDataChange(path, callback);
} }
private callDsInit() {
const dataSourceList = Array.from(this.dataSourceMap);
if (typeof Promise.allSettled === 'function') {
Promise.allSettled<Record<string, any>>(dataSourceList.map(([, ds]) => this.init(ds))).then((values) => {
const data: DataSourceManagerData = {};
const errors: Record<string, Error> = {};
values.forEach((value, index) => {
const dsId = dataSourceList[index][0];
if (value.status === 'fulfilled') {
if (this.data[dsId]) {
data[dsId] = this.data[dsId];
} else {
delete data[dsId];
}
} else if (value.status === 'rejected') {
delete data[dsId];
errors[dsId] = value.reason;
}
});
this.emit('init', data, errors);
});
} else {
Promise.all<Record<string, any>>(dataSourceList.map(([, ds]) => this.init(ds)))
.then(() => {
this.emit('init', this.data);
})
.catch(() => {
this.emit('init', this.data);
});
}
}
} }
export default DataSourceManager; export default DataSourceManager;