youbase/lib/documentstore.js

var Documentstore, Envelope, bs, defer, ecc, _;

_ = require('lodash');

bs = require('bs58check');

ecc = require('ecc-tools');

defer = require('when');

Envelope = require('ecc-envelope');

Documentstore = (function() {
  function Documentstore(_store) {
    this._store = _store;
    if (!(this instanceof Documentstore)) {
      return new Documentstore(this._store);
    }
  }

  Documentstore.prototype.put = function(envelope, encoding) {
    return defer(envelope).then((function(_this) {
      return function(envelope) {
        envelope = Envelope({
          decode: envelope,
          as: encoding
        });
        return envelope.open().then(function(data) {
          var key;
          if (data) {
            key = data.from;
            return envelope.encode(_this._store.encoding).then(function(value) {
              return _this._store.put(key, value);
            }).then(function() {
              return key;
            });
          } else {
            return false;
          }
        });
      };
    })(this));
  };

  Documentstore.prototype.get = function(key, encoding) {
    return defer(key).then((function(_this) {
      return function(key) {
        if (typeof key === 'string') {
          key = bs.decode(key);
        }
        return _this._store.get(key);
      };
    })(this)).then((function(_this) {
      return function(data) {
        return Envelope({
          decode: data,
          as: _this._store.encoding
        }).encode(encoding);
      };
    })(this));
  };

  return Documentstore;

})();

module.exports = Documentstore;