fix identation

src/index.js

@@ -5,98 +5,98 @@ const Simulator = require('./simulator.js')
 const simulator = new Simulator(events);
 
 const { Observable, fromEvent, interval, Subject } = require('rxjs');
-const { throttle, throttleTime, map, distinctUntilChanged, filter, average, reduce, count, scan} =  require('rxjs/operators');
+const { throttle, throttleTime, map, distinctUntilChanged, filter, average, reduce, count, scan } = require('rxjs/operators');
 
 var loki = require('lokijs')
 //var db = new loki('loki.json', {autosave: true, autoload: true})
 
 var db = new loki('phoenix.db', {
-	autoload: true,
-	autoloadCallback : databaseInitialize,
-	autosave: true, 
-	autosaveInterval: 2000 // save every four seconds for our example
+  autoload: true,
+  autoloadCallback: databaseInitialize,
+  autosave: true,
+  autosaveInterval: 2000 // save every four seconds for our example
 })
 //db.loadDatabase()
 
 function databaseInitialize() {
-    let children = db.getCollection('children')
-    if (!children) {
-        children = db.addCollection('children')
-        db.saveDatabase()
-    }
-    let tracked = db.getCollection('tracked')
-    if (!tracked) {
-        tracked = db.addCollection('tracked')
-        db.saveDatabase()
-    }
-    run()
+  let children = db.getCollection('children')
+  if (!children) {
+    children = db.addCollection('children')
+    db.saveDatabase()
+  }
+  let tracked = db.getCollection('tracked')
+  if (!tracked) {
+    tracked = db.addCollection('tracked')
+    db.saveDatabase()
+  }
+  run()
 }
 
 function run() {
-    let children = db.getCollection('children')
-    let tracked = db.getCollection('tracked')
+  let children = db.getCollection('children')
+  let tracked = db.getCollection('tracked')
 
-    process.on('exit', function () {
-        db.close()
-    });
+  process.on('exit', function () {
+    db.close()
+  });
 
-    let dbChanges = fromEvent(events, "updateDB")
+  let dbChanges = fromEvent(events, "updateDB")
 
-    dbChanges.pipe(throttle(val => interval(400))).subscribe(() => {
-        console.dir("saving database...")
-        db.saveDatabase()
-    })
+  dbChanges.pipe(throttle(val => interval(400))).subscribe(() => {
+    console.dir("saving database...")
+    db.saveDatabase()
+  })
 
-    function trackEvent(eventName, filterConditions) {
-        let eventKey = eventName + "-from0x123";
+  function trackEvent(eventName, filterConditions) {
+    let eventKey = eventName + "-from0x123";
 
-        let lastEvent = tracked.find({"eventName": eventName})[0]
-        if (!lastEvent || lastEvent.length <= 0) {
-            tracked.insert({"eventName": eventName, id: 0})
-            lastEvent = tracked.find({"eventName": eventName})[0]
-        }
-
-        console.dir("last id was " + lastEvent.id)
-
-        let sub = new Subject();
-
-        for (let previous of children.find({ 'eventKey': eventKey })) {
-            console.dir("checking previous event: " + previous.id)
-            sub.next(previous)
-        }
-
-        let contractObserver = fromEvent(events, eventName)
-        contractObserver.pipe(filter((x) => x.id > lastEvent.id)).pipe(filter(filterConditions)).subscribe((e) => {
-            console.dir("------- syncing event");
-            e.eventKey = eventKey
-            console.dir(e);
-            if (children.find({ 'id': e.id }).length > 0) {
-                console.dir("event already synced: " + e.id)
-            } else {
-                children.insert(e)
-                tracked.updateWhere(((x) => x.eventName === eventName), ((x) => x.id = e.id))
-                events.emit("updateDB")
-                sub.next(e)
-            }
-            console.dir("-------");
-        })
-
-        return sub;
+    let lastEvent = tracked.find({ "eventName": eventName })[0]
+    if (!lastEvent || lastEvent.length <= 0) {
+      tracked.insert({ "eventName": eventName, id: 0 })
+      lastEvent = tracked.find({ "eventName": eventName })[0]
     }
 
-    let myscan = scan((acc, curr) => {
-        acc.push(curr);
-        if (acc.length > 4) {
-            acc.shift();
-        }
-        return acc;
-    }, [])
+    console.dir("last id was " + lastEvent.id)
 
-    let mymap = map(arr => arr.reduce((acc, current) => acc + current, 0) / arr.length)
+    let sub = new Subject();
 
-    trackEvent('contractEvent', ((x) => x.from === "0x123")).pipe(map(x => x.rating), myscan, mymap).subscribe((v) => {
-        console.dir("current value is " + v)
+    for (let previous of children.find({ 'eventKey': eventKey })) {
+      console.dir("checking previous event: " + previous.id)
+      sub.next(previous)
+    }
+
+    let contractObserver = fromEvent(events, eventName)
+    contractObserver.pipe(filter((x) => x.id > lastEvent.id)).pipe(filter(filterConditions)).subscribe((e) => {
+      console.dir("------- syncing event");
+      e.eventKey = eventKey
+      console.dir(e);
+      if (children.find({ 'id': e.id }).length > 0) {
+        console.dir("event already synced: " + e.id)
+      } else {
+        children.insert(e)
+        tracked.updateWhere(((x) => x.eventName === eventName), ((x) => x.id = e.id))
+        events.emit("updateDB")
+        sub.next(e)
+      }
+      console.dir("-------");
     })
 
-    simulator.emitEvents()
+    return sub;
+  }
+
+  let myscan = scan((acc, curr) => {
+    acc.push(curr);
+    if (acc.length > 4) {
+      acc.shift();
+    }
+    return acc;
+  }, [])
+
+  let mymap = map(arr => arr.reduce((acc, current) => acc + current, 0) / arr.length)
+
+  trackEvent('contractEvent', ((x) => x.from === "0x123")).pipe(map(x => x.rating), myscan, mymap).subscribe((v) => {
+    console.dir("current value is " + v)
+  })
+
+  simulator.emitEvents()
 }