初步完成适配器代码编写

Author: ubuntuvim

addon/adapters/wildember.js

@@ -0,0 +1,94 @@
+import Ember from 'ember';
+import DS from 'ember-data';
+// import firebase from 'firebase';
+import WildemberAdapter from '../adapters/wildember';
+import WildemberSerializer from '../serializers/wildember';
+import forEach from 'lodash/collection/forEach';
+
+export function initialize(/* application */) {
+    // Monkeypatch the store until ED gives us a good way to listen to push events
+    if (!DS.Store.prototype._emberfirePatched) {
+      DS.Store.reopen({
+        _emberfirePatched: true,
+
+        push() {
+          var result = this._super.apply(this, arguments);
+          var records = result;
+
+          if (!Ember.isArray(result)) {
+            records = [result];
+          }
+
+          forEach(records, (record) => {
+            var modelName = record.constructor.modelName;
+            var adapter = this.adapterFor(modelName);
+            if (adapter.recordWasPushed) {
+              adapter.recordWasPushed(this, modelName, record);
+            }
+          });
+
+          return result;
+        },
+
+        recordWillUnload(record) {
+          var adapter = this.adapterFor(record.constructor.modelName);
+          if (adapter.recordWillUnload) {
+            adapter.recordWillUnload(this, record);
+          }
+        },
+
+        recordWillDelete(record) {
+          var adapter = this.adapterFor(record.constructor.modelName);
+          if (adapter.recordWillDelete) {
+            adapter.recordWillDelete(this, record);
+          }
+        }
+      });
+    }
+
+    if (!DS.Model.prototype._emberfirePatched) {
+      DS.Model.reopen({
+        _emberfirePatched: true,
+
+        unloadRecord() {
+          this.store.recordWillUnload(this);
+          return this._super();
+        },
+
+        deleteRecord() {
+          this.store.recordWillDelete(this);
+          this._super();
+        },
+
+        ref() {
+          var adapter = this.store.adapterFor(this.constructor.modelName);
+          if (adapter._getAbsoluteRef) {
+            return adapter._getAbsoluteRef(this);
+          }
+        }
+      });
+    }
+
+    if (!DS.AdapterPopulatedRecordArray.prototype._emberfirePatched) {
+      DS.AdapterPopulatedRecordArray.reopen({
+        _emberfirePatched: true,
+
+        willDestroy() {
+          if (this.__firebaseCleanup) {
+            this.__firebaseCleanup();
+          }
+          return this._super();
+        }
+      });
+    }
+
+    DS.WildemberAdapter = WildemberAdapter;
+    DS.WildemberSerializer = WildemberSerializer;
+
+}
+
+export default {
+  name: 'application',
+  before: 'ember-data',
+  initialize
+};

addon/initializers/application.js

@@ -0,0 +1,50 @@
+import Ember from 'ember';
+
+export default Ember.Mixin.create({
+
+  init() {
+    this._super.apply(this, arguments);
+    // unresolved requests, used in testing
+    this._reasons = 0;
+
+    if (Ember.testing) {
+      this._registerWaiter();
+    }
+  },
+
+
+  _incrementWaiters() {
+    this._reasons++;
+  },
+
+
+  _decrementWaiters() {
+    this._reasons--;
+  },
+
+
+  /**
+   * The waiter calls this to determine if testing should wait. Override in
+   * the implementing class if needed.
+   *
+   * @return {Boolean}
+   * @private
+   */
+  _shouldWait() {
+    return this._reasons === 0;
+  },
+
+
+  /**
+   * Wire up a waiter for this instance.
+   *
+   * @private
+   */
+  _registerWaiter: function() {
+    this._waiter = () => {
+      return this._shouldWait();
+    };
+    Ember.Test.registerWaiter(this._waiter);
+  },
+
+});