all storage removed except localstorage

src/jio.storage/cryptstorage.js

-/*jslint indent: 2, maxlen: 80, sloppy: true, nomen: true */
-/*global jIO: true, sjcl: true, $: true, setTimeout: true */
-jIO.addStorageType('crypt', function (spec, my) {
-  spec = spec || {};
-  var that = my.basicStorage(spec, my),
-    priv = {},
-    is_valid_storage = (spec.storage ? true : false),
-    super_serialized = that.serialized;
-
-  priv.username = spec.username || '';
-  priv.password = spec.password || '';
-  priv.sub_storage_spec = spec.storage || {
-    type: 'base'
-  };
-  priv.sub_storage_string = JSON.stringify(priv.sub_storage_string);
-
-  that.serialized = function () {
-    var o = super_serialized();
-    o.username = priv.username;
-    o.password = priv.password; // TODO : unsecured !!!
-    o.storage = priv.sub_storage_string;
-    return o;
-  };
-
-  that.validateState = function () {
-    if (priv.username && is_valid_storage) {
-      return '';
-    }
-    return 'Need at least two parameters: "username" and "storage".';
-  };
-
-  // TODO : IT IS NOT SECURE AT ALL!
-  // WE MUST REWORK CRYPTED STORAGE!
-  priv.encrypt_param_object = {
-    "iv": "kaprWwY/Ucr7pumXoTHbpA",
-    "v": 1,
-    "iter": 1000,
-    "ks": 256,
-    "ts": 128,
-    "mode": "ccm",
-    "adata": "",
-    "cipher": "aes",
-    "salt": "K4bmZG9d704"
-  };
-  priv.decrypt_param_object = {
-    "iv": "kaprWwY/Ucr7pumXoTHbpA",
-    "ks": 256,
-    "ts": 128,
-    "salt": "K4bmZG9d704"
-  };
-  priv.encrypt = function (data, callback) {
-    // end with a callback in order to improve encrypt to an
-    // asynchronous encryption.
-    var tmp = sjcl.encrypt(priv.username + ':' + priv.password, data,
-      priv.encrypt_param_object);
-    callback(JSON.parse(tmp).ct);
-  };
-  priv.decrypt = function (data, callback) {
-    var tmp, param = $.extend(true, {}, priv.decrypt_param_object);
-    param.ct = data || '';
-    param = JSON.stringify(param);
-    try {
-      tmp = sjcl.decrypt(priv.username + ':' + priv.password, param);
-    } catch (e) {
-      callback({
-        status: 403,
-        statusText: 'Forbidden',
-        error: 'forbidden',
-        message: 'Unable to decrypt.',
-        reason: 'unable to decrypt'
-      });
-      return;
-    }
-    callback(undefined, tmp);
-  };
-
-  priv.newAsyncModule = function () {
-    var async = {};
-    async.call = function (obj, function_name, arglist) {
-      obj._wait = obj._wait || {};
-      if (obj._wait[function_name]) {
-        obj._wait[function_name] -= 1;
-        return function () {};
-      }
-      // ok if undef or 0
-      arglist = arglist || [];
-      setTimeout(function () {
-        obj[function_name].apply(obj[function_name], arglist);
-      });
-    };
-    async.neverCall = function (obj, function_name) {
-      obj._wait = obj._wait || {};
-      obj._wait[function_name] = -1;
-    };
-    async.wait = function (obj, function_name, times) {
-      obj._wait = obj._wait || {};
-      obj._wait[function_name] = times;
-    };
-    async.end = function () {
-      async.call = function () {};
-    };
-    return async;
-  };
-
-  that.post = function (command) {
-    that.put(command);
-  };
-
-  /**
-   * Saves a document.
-   * @method put
-   */
-  that.put = function (command) {
-    var new_file_name, new_file_content, am = priv.newAsyncModule(),
-      o = {};
-    o.encryptFilePath = function () {
-      priv.encrypt(command.getDocId(), function (res) {
-        new_file_name = res;
-        am.call(o, 'save');
-      });
-    };
-    o.encryptFileContent = function () {
-      priv.encrypt(command.getDocContent(), function (res) {
-        new_file_content = res;
-        am.call(o, 'save');
-      });
-    };
-    o.save = function () {
-      var success = function (val) {
-        val.id = command.getDocId();
-        that.success(val);
-      },
-        error = function (err) {
-          that.error(err);
-        },
-        cloned_doc = command.cloneDoc();
-
-      cloned_doc._id = new_file_name;
-      cloned_doc.content = new_file_content;
-      that.addJob('put', priv.sub_storage_spec, cloned_doc,
-        command.cloneOption(), success, error);
-    };
-    am.wait(o, 'save', 1);
-    am.call(o, 'encryptFilePath');
-    am.call(o, 'encryptFileContent');
-  }; // end put
-
-  /**
-   * Loads a document.
-   * @method get
-   */
-  that.get = function (command) {
-    var new_file_name, am = priv.newAsyncModule(),
-      o = {};
-    o.encryptFilePath = function () {
-      priv.encrypt(command.getDocId(), function (res) {
-        new_file_name = res;
-        am.call(o, 'get');
-      });
-    };
-    o.get = function () {
-      that.addJob('get', priv.sub_storage_spec, new_file_name,
-        command.cloneOption(), o.success, o.error);
-    };
-    o.success = function (val) {
-      val._id = command.getDocId();
-      if (command.getOption('metadata_only')) {
-        that.success(val);
-      } else {
-        priv.decrypt(val.content, function (err, res) {
-          if (err) {
-            that.error(err);
-          } else {
-            val.content = res;
-            that.success(val);
-          }
-        });
-      }
-    };
-    o.error = function (error) {
-      that.error(error);
-    };
-    am.call(o, 'encryptFilePath');
-  }; // end get
-
-  /**
-   * Gets a document list.
-   * @method allDocs
-   */
-  that.allDocs = function (command) {
-    var result_array = [],
-      am = priv.newAsyncModule(),
-      o = {};
-    o.allDocs = function () {
-      that.addJob('allDocs', priv.sub_storage_spec, null,
-        command.cloneOption(), o.onSuccess, o.error);
-    };
-    o.onSuccess = function (val) {
-      if (val.total_rows === 0) {
-        return am.call(o, 'success');
-      }
-      result_array = val.rows;
-      var i, decrypt = function (c) {
-        priv.decrypt(result_array[c].id, function (err, res) {
-          if (err) {
-            am.call(o, 'error', [err]);
-          } else {
-            result_array[c].id = res;
-            result_array[c].key = res;
-            am.call(o, 'success');
-          }
-        });
-        if (!command.getOption('metadata_only')) {
-          priv.decrypt(
-            result_array[c].value.content,
-
-            function (err, res) {
-              if (err) {
-                am.call(o, 'error', [err]);
-              } else {
-                result_array[c].value.content = res;
-                am.call(o, 'success');
-              }
-            }
-          );
-        }
-      };
-      if (command.getOption('metadata_only')) {
-        am.wait(o, 'success', val.total_rows - 1);
-      } else {
-        am.wait(o, 'success', val.total_rows * 2 - 1);
-      }
-      for (i = 0; i < result_array.length; i += 1) {
-        decrypt(i);
-      }
-    };
-    o.error = function (error) {
-      am.end();
-      that.error(error);
-    };
-    o.success = function () {
-      am.end();
-      that.success({
-        total_rows: result_array.length,
-        rows: result_array
-      });
-    };
-    am.call(o, 'allDocs');
-  }; // end allDocs
-
-  /**
-   * Removes a document.
-   * @method remove
-   */
-  that.remove = function (command) {
-    var new_file_name, o = {};
-    o.encryptDocId = function () {
-      priv.encrypt(command.getDocId(), function (res) {
-        new_file_name = res;
-        o.removeDocument();
-      });
-    };
-    o.removeDocument = function () {
-      var cloned_doc = command.cloneDoc();
-      cloned_doc._id = new_file_name;
-      that.addJob('remove', priv.sub_storage_spec, cloned_doc,
-        command.cloneOption(), o.success, that.error);
-    };
-    o.success = function (val) {
-      val.id = command.getDocId();
-      that.success(val);
-    };
-    o.encryptDocId();
-  }; // end remove
-
-  return that;
-});

src/jio.storage/replicatestorage.js

-/*jslint indent: 2, maxlen: 80, sloppy: true, nomen: true */
-/*global jIO: true */
-jIO.addStorageType('replicate', function (spec, my) {
-
-  var that, cloned_option, priv = {},
-    super_serialized = that.serialized;
-
-  spec = spec || {};
-  that = my.basicStorage(spec, my);
-
-  priv.return_value_array = [];
-  priv.storagelist = spec.storagelist || [];
-  priv.nb_storage = priv.storagelist.length;
-
-  that.serialized = function () {
-    var o = super_serialized();
-    o.storagelist = priv.storagelist;
-    return o;
-  };
-
-  that.validateState = function () {
-    if (priv.storagelist.length === 0) {
-      return 'Need at least one parameter: "storagelist" ' +
-        'containing at least one storage.';
-    }
-    return '';
-  };
-
-  priv.isTheLast = function (error_array) {
-    return (error_array.length === priv.nb_storage);
-  };
-
-  priv.doJob = function (command, errormessage, nodocid) {
-    var done = false,
-      error_array = [],
-      i,
-      error = function (err) {
-        if (!done) {
-          error_array.push(err);
-          if (priv.isTheLast(error_array)) {
-            that.error({
-              status: 207,
-              statusText: 'Multi-Status',
-              error: 'multi_status',
-              message: 'All ' + errormessage + (!nodocid ? ' "' +
-                command.getDocId() + '"' : ' ') + ' requests have failed.',
-              reason: 'requests fail',
-              array: error_array
-            });
-          }
-        }
-      },
-      success = function (val) {
-        if (!done) {
-          done = true;
-          that.success(val);
-        }
-      };
-    for (i = 0; i < priv.nb_storage; i += 1) {
-      cloned_option = command.cloneOption();
-      that.addJob(command.getLabel(), priv.storagelist[i],
-        command.cloneDoc(), cloned_option, success, error);
-    }
-  };
-
-  that.post = function (command) {
-    priv.doJob(command, 'post');
-    that.end();
-  };
-
-  /**
-   * Save a document in several storages.
-   * @method put
-   */
-  that.put = function (command) {
-    priv.doJob(command, 'put');
-    that.end();
-  };
-
-  /**
-   * Load a document from several storages, and send the first retreived
-   * document.
-   * @method get
-   */
-  that.get = function (command) {
-    priv.doJob(command, 'get');
-    that.end();
-  };
-
-  /**
-   * Get a document list from several storages, and returns the first
-   * retreived document list.
-   * @method allDocs
-   */
-  that.allDocs = function (command) {
-    priv.doJob(command, 'allDocs', true);
-    that.end();
-  };
-
-  /**
-   * Remove a document from several storages.
-   * @method remove
-   */
-  that.remove = function (command) {
-    priv.doJob(command, 'remove');
-    that.end();
-  };
-
-  return that;
-});