red-rings-couchdb/util/changes-view.js

// Generated by CoffeeScript 2.3.1
(function() {
  // Most.js source for a `map` function in a view
  // ---------

  // Maps results from a changes stream into a view

  // The view is evaluated locally (since CouchDB does not support `changes` on views).

  // The `db_changes` stream is generated by e.g. `all_changes`.
  var changes_view, create;

  changes_view = function(map_function, db_changes) {
    return db_changes.chain(function({doc}) {
      return create(function(add, end, error) {
        var e, emit, fn;
        // Emulate a row as reported without `include_docs`, similarly to what `view_as_stream` does.
        emit = function(key, value) {
          return add({
            id: doc._id,
            key,
            value
          });
        };
        fn = map_function(emit);
        try {
          fn(doc);
        } catch (error1) {
          e = error1;
          error(e);
        }
        end();
      });
    });
  };

  ({create} = require('@most/create'));

  module.exports = changes_view;

}).call(this);