red-rings-couchdb/util/view.js

// Generated by CoffeeScript 2.3.1
(function() {
  // View dispatcher
  // ---------------
  var Immutable, count_as_stream, group_as_stream, most, query_as_stream, range_as_stream, view_as_stream;

  view_as_stream = function(db_uri, app, view, key) {
    switch (false) {
      // - Map (JSON object) is used to provide one-time queries. These do not support `changes` streaming.
      // The `key` field (in the `SUBSCRIBE` message) is used to determine what type of query is performed:
      case !Immutable.Map.isMap(key):
        switch (false) {
          // For `group` queries we send the view's `key` in the `value` field of the message.
          // For view queries we need to keep the original `key` field (for routing purposes).
          case !key.has('level'):
            return group_as_stream(db_uri, app, view, key.get('level'), key.get('min'), key.get('max')).tap(function(row) {
              return [row.key, row.value] = [key, row.key];
            });
          // For count queries we set the `_key` field to the key generated by the view (the `value` field contains the view's `value`, i.e. the `count`).
          case !key.has('count'):
            return count_as_stream(db_uri, app, view, key.get('count'), key.get('detail')).tap(function(row) {
              if (row.key != null) {
                return [row.key, row._key] = [key, row.key];
              } else {
                return row.key = key;
              }
            });
          // For range queries we set the `_key` field to the key generated by the view (the `value` field contains the view's `value`).
          case !(key.has('min') || key.has('max')):
            return range_as_stream(db_uri, app, view, key.get('min'), key.get('max')).tap(function(row) {
              return [row.key, row._key] = [key, row.key];
            });
          default:
            return most.empty();
        }
        break;
      default:
        // - string, List, etc., generate regular view queries (and are subject to `changes` streaming, see `./changes-view`).
        return query_as_stream(db_uri, app, view, key);
    }
  };

  module.exports = view_as_stream;

  query_as_stream = require('./query');

  count_as_stream = require('./count');

  range_as_stream = require('./range');

  group_as_stream = require('./group');

  most = require('most');

  Immutable = require('immutable');

}).call(this);