ztimson/map-alliance
ztimson/map-alliance
1
0
Fork 0
Code Issues Pull Requests Actions Packages Releases 1 Activity

Change sync interval based on number of collaborators

Browse Source
This commit is contained in:
Zakary Timson 2019-08-31 16:50:02 -04:00
parent 02861f5c1b
commit 20ae1708a9
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/app/services/sync.service.ts
View File

@ -1,7 +1,7 @@
import {Injectable} from "@angular/core"; import {Injectable} from "@angular/core";
import {AngularFirestore, AngularFirestoreCollection} from "@angular/fire/firestore"; import {AngularFirestore, AngularFirestoreCollection} from "@angular/fire/firestore";
import {BehaviorSubject, Subscription} from "rxjs"; import {BehaviorSubject, Subscription} from "rxjs";
import {Circle, MapData, Marker, Measurement, Polygon, Polyline, Rectangle} from "../models/mapSymbol"; import {Circle, MapData, MapSymbol, Marker, Measurement, Polygon, Polyline, Rectangle} from "../models/mapSymbol";
import * as _ from 'lodash'; import * as _ from 'lodash';
@Injectable({ @Injectable({
@ -13,7 +13,7 @@ export class SyncService {
private collection: AngularFirestoreCollection; private collection: AngularFirestoreCollection;
private mapSub: Subscription; private mapSub: Subscription;
private name: string; private name: string;
private saveRate = 5_000; private saveInterval;
mapSymbols = new BehaviorSubject<MapData>({}); mapSymbols = new BehaviorSubject<MapData>({});
@ -104,12 +104,12 @@ export class SyncService {
this.mapSub = null; this.mapSub = null;
} }
this.code = mapCode; this.code = mapCode;
this.mapSub = this.collection.doc(this.code).valueChanges().subscribe(newMap => { this.mapSub = this.collection.doc(this.code).valueChanges().subscribe((newMap: MapData) => {
this.mapSymbols.next(Object.assign({}, newMap)); this.mapSymbols.next(Object.assign({}, newMap)); // TODO: Add merge operation so pending changes arn't lost
this.changed = false; this.changed = false;
if(this.saveInterval) clearInterval(this.saveInterval);
this.saveInterval = setInterval(() => this.save(), (newMap.locations && newMap.locations.length > 1) ? 2_000 : 30_000)
}); });
setInterval(() => this.save(), this.saveRate);
} }
removeMyLocation() { removeMyLocation() {