meteor-collection.html

<!--
A wrapper to meteor Mongo.Collection object.
-->

<script>
  Polymer({
    is: 'meteor-collection',

    /**
     * Fired when a document has been inserted. detail contains the id of the new document.
     *
     * @event insert
     */

    /**
     * Fired when a documents has been removed.
     *
     * @event removed
     */

    /**
     * Fired when a documents has been updated.
     *
     * @event updated
     */

    /**
     * Fired when an error occurs while inserting or removing document. detail contains the error object
     *
     * @event error
     */

    properties: {
      /**
       * Name of the mongo collection.
       */
      name: {
        type: String,
        value: null,
        observer: '_nameChanged'
      },
      /**
       * The collection instance.
       */
      _ref: {
        type: Object,
        value: null,
        notify: true,
      }
    },
    /**
     * React to collection name changes.
     */
    _nameChanged: function() {
      if (this.name) {
        if (window['__meteor_elements_'+this.name]) {
          this._ref = window['__meteor_elements_'+this.name];
        } else {
          this._ref = new Mongo.Collection(this.name);
          window['__meteor_elements_'+this.name] = this._ref;
        }
      } else {
        this._ref = null;
      }

      this._setupChildQueries();
    },
    /**
     * Setup the collection reference to childs elements.
     */
    _setupChildQueries: function() {
      var childs = Polymer.dom(this).childNodes;
      for(var i=0; i<childs.length; i++) {
        if (typeof childs[i]._setupCollection === 'function') {
          childs[i]._setupCollection(this._ref);
        }
      }
    },
    /**
     * Insert a document to collection.
     *
     * @method insert
     */
    insert: function(doc) {
      if (this._ref)
        this._ref.insert(doc, function(err, id) {
          if (err)
            this.fire('error', { error: err });
          else
            this.fire('insert', { id: id });
        }.bind(this));
    },
    /**
     * Remove documents in collection.
     *
     * @method remove
     */
    remove: function(selector) {
      if (this._ref)
        this._ref.remove(selector, function(err) {
          if (err)
            this.fire('error', { error: err });
          else
            this.fire('removed');
        }.bind(this));
    },
    /**
     * Modify one or more documents in the collection.
     *
     * @method update
     */
    update: function(selector, modifier, options) {
      options = options || {};
      if (this._ref)
      this._ref.update(selector, modifier, options, function(err) {
        if (err)
          this.fire('error', { error: err });
        else
          this.fire('updated');
      }.bind(this));
    },
    ready: function() {
    }
  });
</script>