47 lines
No EOL
1.5 KiB
TypeScript
47 lines
No EOL
1.5 KiB
TypeScript
import FeatureSource from "./FeatureSource";
|
|
import {UIEventSource} from "../UIEventSource";
|
|
|
|
export default class FeatureSourceMerger implements FeatureSource {
|
|
|
|
public features: UIEventSource<{ feature: any; freshness: Date }[]> = new UIEventSource<{feature: any; freshness: Date}[]>([]);
|
|
private readonly _sources: FeatureSource[];
|
|
|
|
constructor(sources: FeatureSource[]) {
|
|
this._sources = sources;
|
|
const self = this;
|
|
for (let i = 0; i < sources.length; i++){
|
|
let source = sources[i];
|
|
source.features.addCallback(() => {
|
|
self.Update();
|
|
});
|
|
}
|
|
this.Update();
|
|
}
|
|
|
|
private Update() {
|
|
let all = {}; // Mapping 'id' -> {feature, freshness}
|
|
for (const source of this._sources) {
|
|
if(source?.features?.data === undefined){
|
|
continue;
|
|
}
|
|
for (const f of source.features.data) {
|
|
const id = f.feature.properties.id+f.feature.geometry.type+f.feature._matching_layer_id;
|
|
const oldV = all[id];
|
|
if(oldV === undefined){
|
|
all[id] = f;
|
|
}else{
|
|
if(oldV.freshness < f.freshness){
|
|
all[id]=f;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
const newList = [];
|
|
for (const id in all) {
|
|
newList.push(all[id]);
|
|
}
|
|
this.features.setData(newList);
|
|
}
|
|
|
|
|
|
} |