import { Injectable, Inject } from '@angular/core'; import { Router } from '@angular/router'; import { Store, Action } from '@ngrx/store'; import { Effect, Actions,ofType } from '@ngrx/effects'; import { Observable , of } from 'rxjs'; import { withLatestFrom, switchMap, map, catchError, mergeMap, delay} from 'rxjs/operators'; import {GeoJSON,WKT} from 'ol/format'; import {Feature} from 'ol'; import { getCenter, Extent, createEmpty, extend} from 'ol/extent'; import {Point} from 'ol/geom' import * as mapActions from '../actions/map.actions'; import * as mapReducers from '../reducers/map.reducer'; import {commonReducers} from '@farmmaps/common'; import {commonActions} from '@farmmaps/common'; import { IListItem, IItem } from '@farmmaps/common'; import { FolderService, ItemService } from '@farmmaps/common'; import { tassign } from 'tassign'; @Injectable() export class MapEffects { private _geojsonFormat: GeoJSON; private _wktFormat: WKT; private toPointFeature(updateEvent:commonActions.DeviceUpdateEvent): Feature { var f = this._wktFormat.readFeature(updateEvent.attributes["geometry"],{ dataProjection: 'EPSG:4326', featureProjection: 'EPSG:3857' }); f.setId(updateEvent.itemCode); var centroid = getCenter(f.getGeometry().getExtent()); f.setGeometry(new Point(centroid)); return f; } @Effect() init$: Observable = this.actions$.pipe( ofType(mapActions.INIT), withLatestFrom(this.store$.select(commonReducers.selectGetRootItems)), switchMap(([action, rootItems]) => { for (let rootItem of rootItems) { if (rootItem.itemType == "UPLOADS_FOLDER") return of(new mapActions.SetParent(rootItem.code)); } return []; } )); @Effect() initBaseLayers$: Observable = this.actions$.pipe( ofType(mapActions.INIT), withLatestFrom(this.store$.select(mapReducers.selectGetProjection)), map(([action, projection]) => new mapActions.LoadBaseLayers(projection))); @Effect() loadBaseLayers$: Observable = this.actions$.pipe( ofType(mapActions.LOADBASELAYERS), switchMap((action: mapActions.LoadBaseLayers) => { return this.itemService$.getItemList("vnd.farmmaps.itemtype.layer", { "isBaseLayer": true }).pipe( map((items: IItem[]) => new mapActions.LoadBaseLayersSuccess(items)), catchError(error => of(new commonActions.Fail(error)))); })); @Effect() initRootItems$: Observable = this.actions$.pipe( ofType(commonActions.INITROOTSUCCESS), map((action) => new mapActions.Init() )); @Effect() startSearch$: Observable = this.actions$.pipe( ofType(mapActions.STARTSEARCH), switchMap((action: mapActions.StartSearch) => { console.debug("Start search"); var startDate = action.queryState.startDate; var endDate = action.queryState.endDate; var newAction:Observable; if (action.queryState.itemCode || action.queryState.parentCode || action.queryState.itemType || action.queryState.query || action.queryState.tags) { newAction= this.itemService$.getFeatures(action.queryState.bbox, "EPSG:3857", action.queryState.query, action.queryState.tags, startDate, endDate, action.queryState.itemType, action.queryState.parentCode).pipe( switchMap((features: any) => { for (let f of features.features) { if (f.properties && f.properties["code"]) { f.id = f.properties["code"]; } } return of(new mapActions.StartSearchSuccess(this._geojsonFormat.readFeatures(features), action.queryState)); } ), catchError(error => of(new commonActions.Fail(error)))); } else { newAction= of(new commonActions.Escape(true,false)); } return newAction; })); @Effect() startSearchSucces$: Observable = this.actions$.pipe( ofType(mapActions.STARTSEARCHSUCCESS), mergeMap((action: mapActions.StartSearchSuccess) => { if (action.query.bboxFilter) { return [new commonActions.SetMenuVisible(false)]; } else { var extent = createEmpty(); if (extent) { for (let f of action.features) { extend(extent, (f as Feature).getGeometry().getExtent()); } } //return []; return [new mapActions.SetExtent(extent),new commonActions.SetMenuVisible(false)]; } })); @Effect() selectItem$: Observable = this.actions$.pipe( ofType(mapActions.SELECTITEM), withLatestFrom(this.store$.select(mapReducers.selectGetSelectedItem)), switchMap(([action, selectedItem]) => { let a = action as mapActions.SelectItem; let itemCode = selectedItem ? selectedItem.code : ""; if (a.itemCode != itemCode) { return this.itemService$.getItem(a.itemCode).pipe( map((item: IItem) => new mapActions.SelectItemSuccess(item)), catchError(error => of(new commonActions.Fail(error)))) } else { return []; } } )); @Effect() selectItemSuccess$: Observable = this.actions$.pipe( ofType(mapActions.SELECTITEMSUCCESS), switchMap((action:mapActions.SelectItemSuccess) => { return this.itemService$.getFeature(action.item.code, "EPSG:3857").pipe( map((feature: any) => { let f = this._geojsonFormat.readFeature(feature); f.setId(action.item.code); return new mapActions.AddFeatureSuccess(f ); }), catchError(error => of(new commonActions.Fail(error)))); } )); @Effect() uploadedItemClick$: Observable = this.actions$.pipe( ofType(commonActions.UPLOADEDFILECLICK), switchMap((action: commonActions.UploadedFileClick) => of(new mapActions.DoQuery(tassign(mapReducers.initialState.query, {itemCode:action.itemCode}))) )); //@Effect() //itemAdded$: Observable = this.actions$.pipe( // ofType(commonActions.ITEMADDEDEVENT), // withLatestFrom(this.store$.select(mapReducers.selectGetParentCode)), // mergeMap(([action, parentCode]) => { // let itemAddedAction = action as commonActions.ItemAddedEvent; // if (parentCode && itemAddedAction.attributes["parentCode"] == parentCode) { // return this.itemService$.getFeature(itemAddedAction.itemCode,"EPSG:3857").pipe( // map((feature: Feature) => new mapActions.AddFeatureSuccess(this.toPointFeature(feature))), // catchError(error => of(new commonActions.Fail(error)))) // } else // return [ // ]; // })); @Effect() featureUpdate$: Observable = this.actions$.pipe( ofType(commonActions.DEVICEUPDATEEVENT), withLatestFrom(this.store$.select(mapReducers.selectGetFeatures)), mergeMap(([action, features]) => { let deviceUpdateEventAction = action as commonActions.DeviceUpdateEvent; var feature: Feature = null; for (let f of features) { if (f.getId() == deviceUpdateEventAction.itemCode) { feature = f; break; } } if (feature) { return of(new mapActions.UpdateFeatureSuccess(this.toPointFeature(deviceUpdateEventAction))); } else { return []; } })); @Effect() itemUpdate$: Observable = this.actions$.pipe( ofType(commonActions.ITEMCHANGEDEVENT), withLatestFrom(this.store$.select(mapReducers.selectGetSelectedItem)), mergeMap(([action, selectedItem]) => { let itemChangedAction = action as commonActions.ItemChangedEvent; if (selectedItem && selectedItem.code == itemChangedAction.itemCode) { return this.itemService$.getItem(itemChangedAction.itemCode).pipe( map((item: IItem) => new mapActions.SelectItemSuccess(item)), catchError(error => of(new commonActions.Fail(error)))); } else { return []; } })); @Effect() setQueryState$: Observable = this.actions$.pipe( ofType(mapActions.SETQUERYSTATE), switchMap((action: mapActions.SetQueryState) => { var newAction:Action; if (action.queryState.itemCode && action.queryState.itemCode != "") { newAction= new mapActions.SelectItem(action.queryState.itemCode); } else { newAction= new mapActions.StartSearch(action.queryState); } return of(newAction); })); @Effect() setState$: Observable = this.actions$.pipe( ofType(mapActions.SETSTATE), switchMap((action: mapActions.SetState) => { var newAction:Action; if (action.queryState.itemCode && action.queryState.itemCode != "") { newAction= new mapActions.SelectItem(action.queryState.itemCode); } else { newAction= new mapActions.StartSearch(action.queryState); } return of(newAction); })); constructor(private actions$: Actions, private store$: Store, private folderService$: FolderService, private itemService$: ItemService) { this._geojsonFormat = new GeoJSON(); this._wktFormat = new WKT(); } }