red-rings-couchdb/attachments.js

// Generated by CoffeeScript 2.3.1
(function() {
  // Creates a thru stream (that should be applied to the output of the backend).
  var URL, attachments, dc, ec, proxy;

  ec = encodeURIComponent;

  dc = decodeURIComponent;

  // In the parameter we need:
  // - .url — base url (used to build URIs provided to external users)
  // - .target — a function that takes and id and returns a set of request options (esp. `.url` which must be a `new URL` object)
  // - .secret
  // - .hash (defaults to `sha256`)
  // - .timeout (defaults to one hour)
  attachments = function(our_proxy) {
    var download_uri, handler, target, thru, upload_uri;
    target = our_proxy.target;
    our_proxy.target = function(pathname) {
      var $;
      if (!($ = pathname.match(/^\/([^\/]+)\/(.+)$/))) {
        return null;
      }
      return typeof target === "function" ? target(pathname, dc($[1]), $[2]) : void 0;
    };
    ({handler, download_uri, upload_uri} = proxy(our_proxy));
    thru = function(stream) {
      return stream.map(function(msg) {
        var ec_id, id, rev;
        rev = msg.getIn(['value', 'rev']);
        attachments = msg.getIn(['doc', '_attachments']);
        if (!((rev != null) && (attachments != null))) {
          return msg;
        }
        id = msg.get('id');
        ec_id = ec(id);
        return msg.withMutations(function(msg) {
          attachments.forEach(function(rec, name) {
            var path;
            path = `/${ec_id}/${ec(name)}`;
            if (rec.has('stub')) {
              msg = msg.setIn(['doc', '_attachments', name, 'download_uri'], download_uri(path, rev));
            }
            msg = msg.setIn(['doc', '_attachments', name, 'upload_uri'], upload_uri(path, rev));
          });
          return msg;
        });
      });
    };
    return {handler, thru};
  };

  // The `handler` can be used either as a `createServer` request-listener, or as middleware (using Express conventions).
  // The `thru` can be used as a most.js `.thru` processor on (e.g.) the output of the backe
  module.exports = attachments;

  proxy = require('./util/attachments-proxy');

  ({URL} = require('url'));

}).call(this);