chiefy/vaulted

'use strict';
var
  _ = require('lodash'),
  debuglog = require('util').debuglog('vaulted');


/**
 * @module internal
 * @desc Provides internal helpers for working with the Vault.
 * @private
 */

var internal = module.exports;

function checkStatus(vault, token, status) {
  if (!status.initialized) {
    debuglog('either vault not initialized');
    return vault;
  }
  vault.setInitialized();

  return vault.getSealedStatus().bind(vault)
    .then(function () {
      return vault.getMounts({
        token: token
      });
    })
    .then(function () {
      return vault.getAuthMounts({
        token: token
      });
    })
    .then(function () {
      debuglog('internal state loaded');
      return vault;
    }).
  catch(function onError(err) {
    debuglog('failed to retrieve state: %s', err.message);
    return vault;
  });
}

/**
 * @private
 * @method loadState
 * @desc Load retrieve the current state of the vault and sets internal properties accordingly
 *
 * @param {Vaulted} vault an instance of Vaulted.
 * @resolve {Vaulted} Resolves with current instance of Vaulted
 * @reject {Error} An error indicating what went wrong
 * @return {Promise}
 */
internal.loadState = function loadState(vault, token) {
  return vault.getInitStatus().bind(vault)
    .then(_.partial(checkStatus, vault, token));
};

/**
 * @private
 * @method syncMounts
 * @desc Sync the existing mounts with mounted/exposed APIs.
 *
 * @param {Vaulted} vault an instance of Vaulted.
 */
internal.syncMounts = function syncMounts(vault) {
  var match;

  _.forEach(vault.mounts, function (mount, name) {
    match = _.find(_.keys(vault.api.endpoints), _.matches(name));
    if (!match) {
      vault.api.mountEndpoints(vault.config, mount.type, name);
    }
  });

  _.forEach(vault.auths, function (auth, name) {
    match = _.find(_.keys(vault.api.endpoints), _.matches('auth/' + name));
    if (!match) {
      vault.api.mountEndpoints(vault.config, auth.type, name);
    }
  });

};