import {ImmutableStore, Store, UIEventSource} from "../../Logic/UIEventSource" import type {Map as MlMap} from "maplibre-gl" import {GeoJSONSource, Marker} from "maplibre-gl" import {ShowDataLayerOptions} from "./ShowDataLayerOptions" import {GeoOperations} from "../../Logic/GeoOperations" import LayerConfig from "../../Models/ThemeConfig/LayerConfig" import PointRenderingConfig from "../../Models/ThemeConfig/PointRenderingConfig" import {OsmTags} from "../../Models/OsmFeature" import {FeatureSource, FeatureSourceForLayer} from "../../Logic/FeatureSource/FeatureSource" import {BBox} from "../../Logic/BBox" import {Feature, Point} from "geojson" import LineRenderingConfig from "../../Models/ThemeConfig/LineRenderingConfig" import {Utils} from "../../Utils" import * as range_layer from "../../assets/layers/range/range.json" import {LayerConfigJson} from "../../Models/ThemeConfig/Json/LayerConfigJson" import PerLayerFeatureSourceSplitter from "../../Logic/FeatureSource/PerLayerFeatureSourceSplitter" import FilteredLayer from "../../Models/FilteredLayer" import SimpleFeatureSource from "../../Logic/FeatureSource/Sources/SimpleFeatureSource" class PointRenderingLayer { private readonly _config: PointRenderingConfig private readonly _visibility?: Store private readonly _fetchStore?: (id: string) => Store> private readonly _map: MlMap private readonly _onClick: (feature: Feature) => void private readonly _allMarkers: Map = new Map() private readonly _selectedElement: Store<{ properties: { id?: string } }> private readonly _markedAsSelected: HTMLElement[] = [] private _dirty = false constructor( map: MlMap, features: FeatureSource, config: PointRenderingConfig, visibility?: Store, fetchStore?: (id: string) => Store>, onClick?: (feature: Feature) => void, selectedElement?: Store<{ properties: { id?: string } }> ) { this._visibility = visibility this._config = config this._map = map this._fetchStore = fetchStore this._onClick = onClick this._selectedElement = selectedElement const self = this features.features.addCallbackAndRunD((features) => self.updateFeatures(features)) visibility?.addCallbackAndRunD((visible) => { if (visible === true && self._dirty) { self.updateFeatures(features.features.data) } self.setVisibility(visible) }) selectedElement?.addCallbackAndRun((selected) => { this._markedAsSelected.forEach((el) => el.classList.remove("selected")) this._markedAsSelected.splice(0, this._markedAsSelected.length) if (selected === undefined) { return } PointRenderingConfig.allowed_location_codes.forEach((code) => { const marker = this._allMarkers .get(selected.properties?.id + "-" + code) ?.getElement() if (marker === undefined) { return } marker?.classList?.add("selected") this._markedAsSelected.push(marker) }) }) } private updateFeatures(features: Feature[]) { if (this._visibility?.data === false) { this._dirty = true return } this._dirty = false const cache = this._allMarkers const unseenKeys = new Set(cache.keys()) for (const location of this._config.location) { for (const feature of features) { if (feature?.geometry === undefined) { console.warn( "Got an invalid feature:", features, " while rendering", location, "of", this._config ) } const id = feature.properties.id + "-" + location unseenKeys.delete(id) const loc = GeoOperations.featureToCoordinateWithRenderingType( feature, location ) if (loc === undefined) { continue } if (cache.has(id)) { const cached = cache.get(id) const oldLoc = cached.getLngLat() if (loc[0] !== oldLoc.lng && loc[1] !== oldLoc.lat) { cached.setLngLat(loc) } continue } const marker = this.addPoint(feature, loc) if (this._selectedElement?.data === feature.properties.id) { marker.getElement().classList.add("selected") this._markedAsSelected.push(marker.getElement()) } cache.set(id, marker) } } for (const unseenKey of unseenKeys) { cache.get(unseenKey).remove() cache.delete(unseenKey) } } private setVisibility(visible: boolean) { for (const marker of this._allMarkers.values()) { if (visible) { marker.getElement().classList.remove("hidden") } else { marker.getElement().classList.add("hidden") } } } private addPoint(feature: Feature, loc: [number, number]): Marker { let store: Store> if (this._fetchStore) { store = this._fetchStore(feature.properties.id) } else { store = new ImmutableStore(feature.properties) } const {html, iconAnchor} = this._config.RenderIcon(store, true) html.SetClass("marker") if (this._onClick !== undefined) { html.SetClass("cursor-pointer") } const el = html.ConstructElement() if (this._onClick) { const self = this el.addEventListener("click", function (ev) { ev.preventDefault() self._onClick(feature) console.log("Got click:", feature) // Workaround to signal the MapLibreAdaptor to ignore this click ev["consumed"] = true }) } const marker = new Marker(el).setLngLat(loc).setOffset(iconAnchor).addTo(this._map) store .map((tags) => this._config.pitchAlignment.GetRenderValue(tags).Subs(tags).txt) .addCallbackAndRun((pitchAligment) => marker.setPitchAlignment(pitchAligment)) store .map((tags) => this._config.rotationAlignment.GetRenderValue(tags).Subs(tags).txt) .addCallbackAndRun((pitchAligment) => marker.setRotationAlignment(pitchAligment)) if (feature.geometry.type === "Point") { // When the tags get 'pinged', check that the location didn't change store.addCallbackAndRunD(() => { // Check if the location is still the same const oldLoc = marker.getLngLat() const newloc = (feature.geometry).coordinates if (newloc[0] === oldLoc.lng && newloc[1] === oldLoc.lat) { return } marker.setLngLat({lon: newloc[0], lat: newloc[1]}) }) } return marker } } class LineRenderingLayer { /** * These are dynamic properties * @private */ private static readonly lineConfigKeys = [ "color", "width", "lineCap", "offset", "fill", "fillColor", ] as const private static readonly lineConfigKeysColor = ["color", "fillColor"] as const private static readonly lineConfigKeysNumber = ["width", "offset"] as const private static missingIdTriggered = false private readonly _map: MlMap private readonly _config: LineRenderingConfig private readonly _visibility?: Store private readonly _fetchStore?: (id: string) => Store> private readonly _onClick?: (feature: Feature) => void private readonly _layername: string private readonly _listenerInstalledOn: Set = new Set() private currentSourceData constructor( map: MlMap, features: FeatureSource, layername: string, config: LineRenderingConfig, visibility?: Store, fetchStore?: (id: string) => Store>, onClick?: (feature: Feature) => void ) { this._layername = layername this._map = map this._config = config this._visibility = visibility this._fetchStore = fetchStore this._onClick = onClick const self = this features.features.addCallbackAndRunD(() => self.update(features.features)) } public destruct(): void { this._map.removeLayer(this._layername + "_polygon") } /** * Calculate the feature-state for maplibre * @param properties * @private */ private calculatePropsFor( properties: Record ): Partial> { const config = this._config const calculatedProps: Record = {} for (const key of LineRenderingLayer.lineConfigKeys) { calculatedProps[key] = config[key]?.GetRenderValue(properties)?.Subs(properties).txt } calculatedProps.fillColor = calculatedProps.fillColor ?? calculatedProps.color for (const key of LineRenderingLayer.lineConfigKeysColor) { let v = calculatedProps[key] if (v === undefined) { continue } if (v.length == 9 && v.startsWith("#")) { // This includes opacity calculatedProps[`${key}-opacity`] = parseInt(v.substring(7), 16) / 256 calculatedProps[key] = v.substring(0, 7) } } calculatedProps["fillColor-opacity"] = calculatedProps["fillColor-opacity"] ?? 0.1 for (const key of LineRenderingLayer.lineConfigKeysNumber) { calculatedProps[key] = Number(calculatedProps[key]) } return calculatedProps } private async update(featureSource: Store) { const map = this._map while (!map.isStyleLoaded()) { await Utils.waitFor(100) } // After waiting 'till the map has loaded, the data might have changed already // As such, we only now read the features from the featureSource and compare with the previously set data const features = featureSource.data const src = map.getSource(this._layername) if (this.currentSourceData === features) { // Already up to date return } if (src === undefined) { this.currentSourceData = features map.addSource(this._layername, { type: "geojson", data: { type: "FeatureCollection", features, }, promoteId: "id", }) // @ts-ignore const linelayer = this._layername + "_line" map.addLayer({ source: this._layername, id: linelayer, type: "line", paint: { "line-color": ["feature-state", "color"], "line-opacity": ["feature-state", "color-opacity"], "line-width": ["feature-state", "width"], "line-offset": ["feature-state", "offset"], }, layout: { "line-cap": "round", }, }) map.on("click", linelayer, (e) => { // line-layer-listener e.originalEvent["consumed"] = true this._onClick(e.features[0]) }) const polylayer = this._layername + "_polygon" map.addLayer({ source: this._layername, id: polylayer, type: "fill", filter: ["in", ["geometry-type"], ["literal", ["Polygon", "MultiPolygon"]]], layout: {}, paint: { "fill-color": ["feature-state", "fillColor"], "fill-opacity": ["feature-state", "fillColor-opacity"], }, }) if (this._onClick) { map.on("click", polylayer, (e) => { console.log("Got polylayer click:", e) // polygon-layer-listener if(e.originalEvent["consumed"]){ // This is a polygon beneath a marker, we can ignore it return } e.originalEvent["consumed"] = true console.log("Got features:", e.features, e) this._onClick(e.features[0]) }) } this._visibility?.addCallbackAndRunD((visible) => { try { map.setLayoutProperty(linelayer, "visibility", visible ? "visible" : "none") map.setLayoutProperty(polylayer, "visibility", visible ? "visible" : "none") } catch (e) { console.warn( "Error while setting visiblity of layers ", linelayer, polylayer, e ) } }) } else { this.currentSourceData = features src.setData({ type: "FeatureCollection", features: this.currentSourceData, }) } for (let i = 0; i < features.length; i++) { const feature = features[i] const id = feature.properties.id ?? feature.id if (id === undefined) { if (!LineRenderingLayer.missingIdTriggered) { console.trace( "Got a feature without ID; this causes rendering bugs:", feature, "from" ) LineRenderingLayer.missingIdTriggered = true } continue } if (this._listenerInstalledOn.has(id)) { continue } if (this._fetchStore === undefined) { map.setFeatureState( {source: this._layername, id}, this.calculatePropsFor(feature.properties) ) } else { const tags = this._fetchStore(id) this._listenerInstalledOn.add(id) tags.addCallbackAndRunD((properties) => { map.setFeatureState( {source: this._layername, id}, this.calculatePropsFor(properties) ) }) } } } } export default class ShowDataLayer { private static rangeLayer = new LayerConfig( range_layer, "ShowDataLayer.ts:range.json" ) private readonly _map: Store private readonly _options: ShowDataLayerOptions & { layer: LayerConfig drawMarkers?: true | boolean drawLines?: true | boolean } private onDestroy: (() => void)[] = [] constructor( map: Store, options: ShowDataLayerOptions & { layer: LayerConfig drawMarkers?: true | boolean drawLines?: true | boolean } ) { this._map = map this._options = options const self = this this.onDestroy.push(map.addCallbackAndRunD((map) => self.initDrawFeatures(map))) } public static showMultipleLayers( mlmap: UIEventSource, features: FeatureSource, layers: LayerConfig[], options?: Partial ) { const perLayer: PerLayerFeatureSourceSplitter = new PerLayerFeatureSourceSplitter( layers.filter((l) => l.source !== null).map((l) => new FilteredLayer(l)), features, { constructStore: (features, layer) => new SimpleFeatureSource(layer, features), } ) perLayer.forEach((fs) => { new ShowDataLayer(mlmap, { layer: fs.layer.layerDef, features: fs, ...(options ?? {}), }) }) } public static showRange( map: Store, features: FeatureSource, doShowLayer?: Store ): ShowDataLayer { return new ShowDataLayer(map, { layer: ShowDataLayer.rangeLayer, features, doShowLayer, }) } public destruct() { } private zoomToCurrentFeatures(map: MlMap) { if (this._options.zoomToFeatures) { const features = this._options.features.features.data const bbox = BBox.bboxAroundAll(features.map(BBox.get)) map.resize() map.fitBounds(bbox.toLngLat(), { padding: {top: 10, bottom: 10, left: 10, right: 10}, animate: false }) } } private initDrawFeatures(map: MlMap) { let {features, doShowLayer, fetchStore, selectedElement, selectedLayer} = this._options const onClick = this._options.onClick ?? (this._options.layer.title === undefined ? undefined : ((feature: Feature) => { selectedElement?.setData(feature) selectedLayer?.setData(this._options.layer) })) if (this._options.drawLines !== false) { for (let i = 0; i < this._options.layer.lineRendering.length; i++) { const lineRenderingConfig = this._options.layer.lineRendering[i] const l = new LineRenderingLayer( map, features, this._options.layer.id + "_linerendering_" + i, lineRenderingConfig, doShowLayer, fetchStore, onClick ) this.onDestroy.push(l.destruct) } } if (this._options.drawMarkers !== false) { for (const pointRenderingConfig of this._options.layer.mapRendering) { new PointRenderingLayer( map, features, pointRenderingConfig, doShowLayer, fetchStore, onClick, selectedElement ) } } features.features.addCallbackAndRunD((_) => this.zoomToCurrentFeatures(map)) } }