Implement basic array mutation observing in the default adapter.

@@ -6,22 +6,53 @@ Rivets.adapters['.'] =
   counter: 0
   counter: 0
   weakmap: {}
   weakmap: {}
 
 
-  subscribe: (obj, keypath, callback) ->
+  weakReference: (obj) ->
     unless obj[@id]?
     unless obj[@id]?
       id = @counter++
       id = @counter++
 
 
-      Object.defineProperty obj, @id,
-        enumerable: false
-        configurable: false
-        writable: false
-        value: id
+      @weakmap[id] =
+        callbacks: {}
+
+      Object.defineProperty obj, @id, value: id
+
+    @weakmap[obj[@id]]
+
+  stubFunction: (obj, fn) ->
+    original = obj[fn]
+    map = @weakReference obj
+    weakmap = @weakmap
+
+    obj[fn] = ->
+      response = original.apply obj, arguments
+
+      for r, k of map.pointers
+        callback() for callback in weakmap[r]?.callbacks[k] ? []
+
+      response
 
 
-      @weakmap[id] = {}
+  observeMutations: (obj, ref, keypath) ->
+    if Object.prototype.toString.call(obj) is '[object Array]'
+      map = @weakReference obj
 
 
-    map = @weakmap[obj[@id]]
+      unless map.pointers?
+        map.pointers = {}
+        functions = ['push', 'pop', 'shift', 'unshift', 'sort', 'reverse', 'splice']
+        @stubFunction obj, fn for fn in functions
 
 
-    unless map[keypath]?
-      map[keypath] = []
+      map.pointers[ref] ?= []
+
+      unless keypath in map.pointers[ref]
+        map.pointers[ref].push keypath
+
+  unobserveMutations: (obj, ref, keypath) ->
+    if keyapths = @weakReference(obj).pointers?[ref]
+      keypaths.splice keypaths.indexOf(keypath), 1
+
+  subscribe: (obj, keypath, callback) ->
+    callbacks = @weakReference(obj).callbacks
+
+    unless callbacks[keypath]?
+      callbacks[keypath] = []
       value = obj[keypath]
       value = obj[keypath]
 
 
       Object.defineProperty obj, keypath,
       Object.defineProperty obj, keypath,
@@ -29,14 +60,17 @@ Rivets.adapters['.'] =
         set: (newValue) ->
         set: (newValue) ->
           if newValue isnt value
           if newValue isnt value
             value = newValue
             value = newValue
-            callback() for callback in map[keypath]
+            callback() for callback in callbacks[keypath]
+
+    unless callback in callbacks[keypath]
+      callbacks[keypath].push callback
 
 
-    unless callback in map[keypath]
-      map[keypath].push callback
+    @observeMutations obj[keypath], obj[@id], keypath
 
 
   unsubscribe: (obj, keypath, callback) ->
   unsubscribe: (obj, keypath, callback) ->
-    callbacks = @weakmap[obj[@id]][keypath]
+    callbacks = @weakmap[obj[@id]].callbacks[keypath]
     callbacks.splice callbacks.indexOf(callback), 1
     callbacks.splice callbacks.indexOf(callback), 1
+    @observeMutations obj[keypath], obj[@id], keypath
 
 
   read: (obj, keypath) ->
   read: (obj, keypath) ->
     obj[keypath]
     obj[keypath]