telegram-mtproto/lib/store.js

'use strict';

Object.defineProperty(exports, "__esModule", {
  value: true
});
exports.PureStorage = exports.AsyncStorage = exports.dcList = exports.TimeOffset = exports.ValueStoreMap = exports.ValueStore = undefined;

var _bluebird = require('bluebird');

var _bluebird2 = _interopRequireDefault(_bluebird);

var _ramda = require('ramda');

function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }

const ValueStore = exports.ValueStore = () => {
  let val = null;

  return {
    get: () => (0, _ramda.clone)(val),
    set: newVal => val = newVal
  };
};

const ValueStoreMap = exports.ValueStoreMap = () => {
  const val = new Map();

  return {
    get: key => (0, _ramda.clone)(val.get(key)),
    set: (key, newVal) => val.set(key, newVal)
  };
};

const TimeOffset = exports.TimeOffset = ValueStore();
const dcList = exports.dcList = ValueStoreMap();

const flatProps = (0, _ramda.pipe)((0, _ramda.flip)(_ramda.props), _ramda.unapply);

const AsyncStorage = exports.AsyncStorage = () => {
  let store = {};

  const flatGet = flatProps(store);
  const set = obj => store = Object.assign({}, store, obj);
  const remove = keys => store = (0, _ramda.omit)(keys, store);
  const clr = () => store = {};
  return {
    get: (...keys) => _bluebird2.default.resolve(flatGet(...keys)),
    set: obj => _bluebird2.default.resolve(set(obj)),
    remove: (...keys) => _bluebird2.default.resolve(remove(keys)),
    clear: () => _bluebird2.default.resolve(clr()),
    noPrefix: () => ({})
  };
};

const PureStorage = exports.PureStorage = AsyncStorage(); /*{
                                                          get     : (...keys) => new Promise(rs => ConfigStorage.get(keys, rs)),
                                                          set     : obj => new Promise(rs => ConfigStorage.set(obj, rs)),
                                                          remove  : (...keys) => new Promise(rs => ConfigStorage.remove(...keys, rs)),
                                                          noPrefix: () => ConfigStorage.noPrefix(),
                                                          clear   : () => new Promise(rs => ConfigStorage.clear(rs))
                                                          }*/
//# sourceMappingURL=store.js.map