meta.js

var path = require('path');
var async = require('async');

var Meta = module.exports = function(tree, stuff) {
  var self = this;
  self.tree = tree;
  self.operations = stuff.operations;
  self.operations.init(tree);
  self.controllers = stuff.controllers;
  //   else if (ch.type === 'del') {
  //     // Get the type
  //     var type = key[0];
  //     // If a controller exists for the type
  //     if (self.controllers[type]) {
  //       // Delete the metadata for it
  //       if (self.controllers[type].model) {
  //         var rows = [];
  //         rows.push({type: 'del', key: key});
  //         self.tree.meta.batch(rows);
  //       }
  //       // Call the onDel for the metadata
  //       if (self.controllers[type].onDel) {
  //         self.controllers[type].onDel(key);
  //       }
  //     };
  //   }
};
Meta.prototype.store = function(ch, cb) {
  var self = this;
  var key = ch.key;
  var storeRequests = [];
  // Get the type
  var type = key[0];
  // If a controller exists for the type
  if (self.controllers[type]) {
    // Create a new metadata for it
    // using the controller's model
    if (self.controllers[type].model) {
      var value = new self.controllers[type].model();
      var rows = [];
      rows.push({type: 'put', key: key, value: value});
      storeRequests.push(function(cb) {
        self.tree.meta.batch(rows, cb);
      });
    }
    // else {
    //   cb();
    // }
    // Call the onPut for the metadata
    if (self.controllers[type].onPut) {
      storeRequests.push(function(cb) {
        self.controllers[type].onPut({key: key, value: value, callback: cb});
      });
    }
  };
  async.parallel(storeRequests, cb);
}

// options:  key, callback, field
Meta.prototype.get = function(options) {
  var self = this;
  var key = options.key;
  self.operations.getValue({key: options.key, callback: function(err, value) {
    if (options.field) {
      options.callback(err, value[options.field]);
    }
    else {
      options.callback(err, value);
    }
  }});
};