Initial checkin for presence

Author: auser

lib/firestack.js

@@ -8,6 +8,7 @@ const firebase = require('firebase');
 
 const app = require('firebase/app');
 const storage = require('firebase/storage');
+const db = require('firebase/database');
 
 import {NativeModules, NativeEventEmitter, AsyncStorage} from 'react-native';
 // TODO: Break out modules into component pieces
@@ -23,6 +24,7 @@ import {Authentication} from './modules/authentication'
 import {Database} from './modules/database'
 import {Analytics} from './modules/analytics'
 import {Storage} from './modules/storage'
+import {Presence} from './modules/presence'
 
 let log;
 export class Firestack extends Singleton {
@@ -66,7 +68,7 @@ export class Firestack extends Singleton {
         log.info('Native configureWithOptions success', configuredProperties);
         this.configured = true;
         this.firestackOptions = configuredProperties;
-        return args;
+        return configuredProperties;
       }).catch((err) => {
         log.error('Native error occurred while calling configure', err);
       })
@@ -108,6 +110,12 @@ export class Firestack extends Singleton {
     return this._storage;
   }
 
+  // presence
+  get presence() {
+    if (!this._presence) { this._presence = new Presence(this); }
+    return this._presence;
+  }
+
   // Storage
   //
   // /**

lib/modules/database.js

@@ -234,6 +234,12 @@ class DatabaseRef extends ReferenceBase {
     return this.query.setFilter('startAt', value, key);
   }
 
+  presence(path) {
+    const presence = this.firestack.presence;
+    const ref = path ? this.child(path) : this;
+    return presence.ref(ref, this.dbPath());
+  }
+
   // onDisconnect
   onDisconnect() {
     return new DatabaseOnDisconnect(this);

lib/modules/presence.js

@@ -0,0 +1,71 @@
+import promisify from '../promisify'
+import { Base, ReferenceBase } from './base'
+
+class PresenceRef extends ReferenceBase {
+  constructor(presence, ref) {
+    super(presence.firestack);
+
+    const db = this.firestack.database;
+    this.ref = ref;
+    this._connectedRef = db.ref('.info/connected');
+
+    this._onConnect = [];
+  }
+
+  setOnlineFor(path) {
+    const connectedDeviceRef = this.ref.child(path)
+    this._lastOnlineRef = connectedDeviceRef.child('lastOnline');
+
+    this._connectedRef.on('value', (snapshot) => {
+      const val = snapshot.val();
+      if (val) {
+        // add self to connection list
+        // this.ref.push()
+        connectedDeviceRef.setAt({
+          online: true
+        })
+          .then(() => {
+            connectedDeviceRef.onDisconnect()
+              .setValue({
+                online: false
+              });
+
+            this._lastOnlineRef.onDisconnect()
+              .setValue(this.firestack.ServerValue.TIMESTAMP)
+
+            this._onConnect.forEach(fn => {
+              if (fn && typeof fn === 'function') {
+                fn.bind(this)(connectedDeviceRef);
+              }
+            })
+          })
+      }
+    })
+  }
+
+}
+
+export class Presence extends Base {
+  constructor(firestack, options={}) {
+    super(firestack, options);
+  }
+
+  on(path='presence/connections') {
+    const _ref = this.firestack.database.ref(path);
+    return new PresenceRef(this, _ref);
+  }
+
+  ref(dbRef, path) {
+    return new PresenceRef(this, dbRef, path);
+  }
+
+  _pathKey(...path) {
+    return path.join('-');
+  }
+
+  get namespace() {
+    return 'firestack:presence'
+  }
+}
+
+export default Presence;