Merge pull request #6 from flamebase/develop

Develop

Author: efraespada

README.md

@@ -60,7 +60,7 @@ var message = {};
 message.author = "john_travolta@ddd.com";
 message.text = "Message 5";
 
-var messageId = new Date().getTime().toString();
+var messageId = new Date().getTime() + "";
 
 FD.ref.messages[messageId] = message;
 
@@ -125,6 +125,12 @@ config.notification = function() {
 
 FD.setSyncConfig(config);
 ```
+Now all reference changes are sent every time you call `FD.syncToDatabase()`. It only sends changes.
+
+For sending full reference:
+```javascript
+FD.syncToDatabase(true);
+```
 - Enable debug logs:
 ```javascript
 FD.debug(true);

index.js

@@ -53,21 +53,30 @@ function FlamebaseDatabase(database, path) {
             object.ref = object.db.getData(path);
             object.syncNotifications();
         } catch(e) {
-            console.log("####################### data error: " + e);
-            console.log("####################### deleting:  " + path);
+            console.log("####################### not found, generating {} ");
+            // object.createEmptyReferenceForPath(e, path);
+
+            /*
             try {
+                // console.log("####################### deleting:  " + path);
                 object.db.delete(path);
             } catch (e) {
 
-            }
+            }*/
             object.ref = {};
         }
     };
 
     /**
      * sync to database
      */
-    this.syncToDatabase = function() {
+    this.syncToDatabase = function(restart) {
+        if (restart !== undefined && restart) {
+            this.lastStringReference = JSON.stringify({});
+            if (this.debugVal) {
+                logger.debug("cleaning last reference on " + path);
+            }
+        }
         object.db.push(path, object.ref);
         object.syncNotifications();
     };
@@ -262,6 +271,44 @@ function FlamebaseDatabase(database, path) {
         return result;
     };
 
+    /*this.createEmptyReferenceForPath = function(e, path) {
+        var aux = null;
+        if (e.toString().indexOf("Can't find dataPath") > -1) {
+
+            var mainRef = object.db.getData("/");
+            var pathParts = path.split("/");
+
+            for (var p = 0; p < pathParts.length; p++) {
+                var pa = pathParts[p];
+
+                if (pa.length === 0) {
+                    continue;
+                }
+
+                if (aux === null) {
+                    if (mainRef[pa] !== undefined) {
+                        aux = mainRef[pa];
+                    } else {
+                        mainRef[pa] = {};
+                        aux = mainRef[pa]
+                    }
+                } else {
+                    if (aux[pa] !== undefined) {
+                        aux = aux[pa];
+                    } else {
+                        aux[pa] = {};
+                        aux = aux[pa]
+                    }
+                }
+            }
+
+            logger.debug("generated: " + JSON.stringifyAligned(mainRef));
+
+            object.ref = mainRef;
+            object.db.push("/", mainRef);
+        }
+    };*/
+
     this.exist = function() {
         return !(this.ref === null || this.ref === undefined)
     };

package.json

@@ -47,5 +47,5 @@
   "scripts": {
     "test": "echo \"Error: no test specified\" && exit 1"
   },
-  "version": "1.0.2"
+  "version": "1.1.0"
 }