Fix observor getting logic

Author: alshakero

dist/fast-json-patch.js

@@ -741,10 +741,10 @@ exports.JsonPatchError = helpers_2.PatchError;
 exports.deepClone = helpers_2._deepClone;
 exports.escapePathComponent = helpers_2.escapePathComponent;
 exports.unescapePathComponent = helpers_2.unescapePathComponent;
-var beforeDict = [];
+var beforeDict = new WeakMap();
 var Mirror = (function () {
     function Mirror(obj) {
-        this.observers = [];
+        this.observers = new Map();
         this.obj = obj;
     }
     return Mirror;
@@ -757,26 +757,13 @@ var ObserverInfo = (function () {
     return ObserverInfo;
 }());
 function getMirror(obj) {
-    for (var i = 0, length = beforeDict.length; i < length; i++) {
-        if (beforeDict[i].obj === obj) {
-            return beforeDict[i];
-        }
-    }
+    return beforeDict.get(obj);
 }
 function getObserverFromMirror(mirror, callback) {
-    for (var j = 0, length = mirror.observers.length; j < length; j++) {
-        if (mirror.observers[j].callback === callback) {
-            return mirror.observers[j].observer;
-        }
-    }
+    return mirror.observers.get(callback);
 }
 function removeObserverFromMirror(mirror, observer) {
-    for (var j = 0, length = mirror.observers.length; j < length; j++) {
-        if (mirror.observers[j].observer === observer) {
-            mirror.observers.splice(j, 1);
-            return;
-        }
-    }
+    mirror.observers.delete(observer.callback);
 }
 /**
  * Detach an observer from an object
@@ -790,15 +777,15 @@ exports.unobserve = unobserve;
  */
 function observe(obj, callback) {
     var patches = [];
-    var root = obj;
     var observer;
     var mirror = getMirror(obj);
     if (!mirror) {
         mirror = new Mirror(obj);
-        beforeDict.push(mirror);
+        beforeDict.set(obj, mirror);
     }
     else {
-        observer = getObserverFromMirror(mirror, callback);
+        var observerInfo = getObserverFromMirror(mirror, callback);
+        observer = observerInfo && observerInfo.observer;
     }
     if (observer) {
         return observer;
@@ -853,21 +840,15 @@ function observe(obj, callback) {
             }
         }
     };
-    mirror.observers.push(new ObserverInfo(callback, observer));
+    mirror.observers.set(callback, new ObserverInfo(callback, observer));
     return observer;
 }
 exports.observe = observe;
 /**
  * Generate an array of patches from an observer
  */
 function generate(observer) {
-    var mirror;
-    for (var i = 0, length = beforeDict.length; i < length; i++) {
-        if (beforeDict[i].obj === observer.object) {
-            mirror = beforeDict[i];
-            break;
-        }
-    }
+    var mirror = beforeDict.get(observer.object);
     _generate(mirror.value, observer.object, observer.patches, "");
     if (observer.patches.length) {
         core_1.applyPatch(mirror.value, observer.patches);
@@ -910,14 +891,10 @@ function _generate(mirror, obj, patches, path) {
                 }
             }
         }
-        else if (Array.isArray(mirror) === Array.isArray(obj)) {
+        else {
             patches.push({ op: "remove", path: path + "/" + helpers_1.escapePathComponent(key) });
             deleted = true; // property has been deleted
         }
-        else {
-            patches.push({ op: "replace", path: path, value: obj });
-            changed = true;
-        }
     }
     if (!deleted && newKeys.length == oldKeys.length) {
         return;