Skip to content

jio
jio
Commit d42fadc0 authored by Marco Mariani's avatar Marco Mariani
Browse files
Options

Merge remote-tracking branch 'origin/master' into keys-jiodate-async

parents 98cf075d cadb268e
Hide whitespace changes
Inline Side-by-side
Showing with 1000 additions and 468 deletions
complex_queries.js
View file @ d42fadc0
...@@ -20,7 +20,7 @@ ...@@ -20,7 +20,7 @@
} }
window.complex_queries = {}; window.complex_queries = {};
module(window.complex_queries, RSVP); module(window.complex_queries, RSVP);
}(['exports'], function (to_export, RSVP) { }(['exports', 'rsvp'], function (to_export, RSVP) {
"use strict"; "use strict";
/** /**
......
examples/example-queries.html
View file @ d42fadc0
...@@ -15,12 +15,12 @@ ...@@ -15,12 +15,12 @@
<body> <body>
<table> <table>
<tr> <tr>
<td>Query (String):<br /><textarea id="str">1:abc AND 2:def</textarea></td> <td>Query (String):<br /><textarea id="str">title:abc AND format:def</textarea></td>
<td>Query (Object):<br /><textarea id="obj">{&quot;type&quot;:&quot;complex&quot;,&quot;operator&quot;:&quot;AND&quot;,&quot;query_list&quot;:[{&quot;type&quot;:&quot;simple&quot;,&quot;operator&quot;:&quot;=&quot;,&quot;key&quot;:&quot;1&quot;,&quot;value&quot;:&quot;abc&quot;},{&quot;type&quot;:&quot;simple&quot;,&quot;operator&quot;:&quot;=&quot;,&quot;key&quot;:&quot;2&quot;,&quot;value&quot;:&quot;def&quot;}]}</textarea></td> <td>Query (Object):<br /><textarea id="obj">{&quot;type&quot;:&quot;complex&quot;,&quot;operator&quot;:&quot;AND&quot;,&quot;query_list&quot;:[{&quot;type&quot;:&quot;simple&quot;,&quot;operator&quot;:&quot;=&quot;,&quot;key&quot;:&quot;title&quot;,&quot;value&quot;:&quot;abc&quot;},{&quot;type&quot;:&quot;simple&quot;,&quot;operator&quot;:&quot;=&quot;,&quot;key&quot;:&quot;format&quot;,&quot;value&quot;:&quot;def&quot;}]}</textarea></td>
</tr> </tr>
<tr> <tr>
<td>Item list (to filter, from 'Query (Object)'):<br /><textarea id="list">[{&quot;1&quot;:&quot;abc&quot;,&quot;2&quot;:&quot;def&quot;},{&quot;1&quot;:&quot;def&quot;,&quot;2&quot;:&quot;abc&quot;}]</textarea></td> <td>Item list (to filter, from 'Query (Object)'):<br /><textarea id="list">[{&quot;title&quot;:&quot;abc&quot;,&quot;format&quot;:&quot;def&quot;},{&quot;title&quot;:&quot;def&quot;,&quot;format&quot;:&quot;abc&quot;}]</textarea></td>
<td>Result list:<br /><textarea id="result">[{&quot;1&quot;:&quot;abc&quot;,&quot;2&quot;:&quot;def&quot;}]</textarea></td> <td>Result list:<br /><textarea id="result"></textarea></td>
</tr> </tr>
<tr> <tr>
<td><label for="wildcard">Wildcard char: </label></td> <td><label for="wildcard">Wildcard char: </label></td>
...@@ -28,11 +28,11 @@ ...@@ -28,11 +28,11 @@
</tr> </tr>
<tr> <tr>
<td><label for="sort_on">Sort on: </label></td> <td><label for="sort_on">Sort on: </label></td>
<td><input type="text" id="sort_on" name="sort_on" value="[[&quot;1&quot;,&quot;ascending&quot;],[&quot;2&quot;,&quot;descending&quot;]]" /></td> <td><input type="text" id="sort_on" name="sort_on" value="[[&quot;title&quot;,&quot;ascending&quot;],[&quot;format&quot;,&quot;descending&quot;]]" /></td>
</tr> </tr>
<tr> <tr>
<td><label for="select_list">Select_list: </label></td> <td><label for="select_list">Select_list: </label></td>
<td><input type="text" id="select_list" name="select_list" value="[&quot;1&quot;,&quot;2&quot;]" /></td> <td><input type="text" id="select_list" name="select_list" value="[&quot;title&quot;,&quot;format&quot;]" /></td>
</tr> </tr>
<tr> <tr>
<td><label for="limit">Limit: </label></td> <td><label for="limit">Limit: </label></td>
...@@ -42,24 +42,39 @@ ...@@ -42,24 +42,39 @@
<button onclick="searchTextToJson()">Search text to JSON</button> <button onclick="searchTextToJson()">Search text to JSON</button>
<button onclick="jsonToSearchText()">JSON to Search text</button> <button onclick="jsonToSearchText()">JSON to Search text</button>
<button onclick="query()">Query</button> <button onclick="query()">Query</button>
<script type="text/javascript" src="../lib/md5/md5.js"></script> <script type="text/javascript" src="../lib/rsvp/rsvp-custom.js"></script>
<script type="text/javascript" src="../lib/jsSha2/sha2.js"></script> <script type="text/javascript" src="../complex_queries.js"></script>
<script type="text/javascript" src="../lib/sjcl/sjcl.min.js"></script>
<script type="text/javascript" src="../jio.min.js"></script>
<script type="text/javascript" src="../complex_queries.min.js"></script>
<script type="text/javascript" <script type="text/javascript"
src="http://code.jquery.com/jquery-1.8.2.min.js"></script> src="http://code.jquery.com/jquery-1.8.2.min.js"></script>
<script type="text/javascript"> <script type="text/javascript">
<!-- <!--
var searchTextToJson = function () { function searchTextToJson() {
$("#obj").attr("value", JSON.stringify(complex_queries.Query.parseStringToObject($("#str").attr("value")))); $("#obj").attr(
}; "value",
var jsonToSearchText = function () { JSON.stringify(
$("#str").attr("value", complex_queries.QueryFactory.create(JSON.parse($("#obj").attr("value"))).toString()); complex_queries.QueryFactory.create(
}; $("#str").attr("value")
var query = function () { ).serialized()
)
);
}
function jsonToSearchText() {
$("#str").attr(
"value",
complex_queries.QueryFactory.create(
JSON.parse(
$("#obj").attr("value")
)
).toString()
);
}
function query() {
var list = JSON.parse($("#list").attr("value")); var list = JSON.parse($("#list").attr("value"));
$("#str").attr("value", complex_queries.QueryFactory.create(JSON.parse($("#obj").attr("value"))).exec( complex_queries.QueryFactory.create(
JSON.parse(
$("#obj").attr("value")
)
).exec(
list, list,
{ {
"wildcard_character": $('#wildcard').attr('value'), "wildcard_character": $('#wildcard').attr('value'),
...@@ -67,9 +82,10 @@ var query = function () { ...@@ -67,9 +82,10 @@ var query = function () {
"limit": JSON.parse($("#limit").attr("value")), "limit": JSON.parse($("#limit").attr("value")),
"select_list": JSON.parse($("#select_list").attr("value")) "select_list": JSON.parse($("#select_list").attr("value"))
} }
)); ).then(function (list) {
$("#result").attr("value", JSON.stringify(list)); $("#result").attr("value", JSON.stringify(list));
}; });
}
// --> // -->
</script> </script>
</body> </body>
......
examples/example.html
View file @ d42fadc0
...@@ -17,6 +17,7 @@ var log = function (o) { ...@@ -17,6 +17,7 @@ var log = function (o) {
<div id="log"> <div id="log">
</div> </div>
<script src="../src/sha256.amd.js"></script> <script src="../src/sha256.amd.js"></script>
<script src="../lib/rsvp/rsvp-custom.js"></script>
<script src="../jio.js"></script> <script src="../jio.js"></script>
<script src="../complex_queries.js"></script> <script src="../complex_queries.js"></script>
<script src="../src/jio.storage/localstorage.js"></script> <script src="../src/jio.storage/localstorage.js"></script>
...@@ -34,6 +35,11 @@ jio_instance = jIO.createJIO({ ...@@ -34,6 +35,11 @@ jio_instance = jIO.createJIO({
}); });
// Careful! These are asynchronous methods! // Careful! These are asynchronous methods!
// And they use promises with a custom version of RSVP.js
// For more information, see
// RSVP https://github.com/tildeio/rsvp.js#rsvpjs--
// Promises A+ http://promisesaplus.com/
// CommonJS http://wiki.commonjs.org/wiki/Promises
log('-> post "video" document metadata to localStorage'); log('-> post "video" document metadata to localStorage');
jio_instance.post({ jio_instance.post({
...@@ -86,11 +92,11 @@ jio_instance.post({ ...@@ -86,11 +92,11 @@ jio_instance.post({
}).then(function (response) { }).then(function (response) {
return jIO.util.blobAsBinaryString(response.data); return jIO.util.readBlobAsBinaryString(response.data);
}).then(function (binary_string) { }).then(function (event) {
log('Video content is: ' + binary_string); log('Video content is: ' + event.target.result);
log('-> remove "video" document from localStorage'); log('-> remove "video" document from localStorage');
return jio_instance.remove({"_id":'video'}); return jio_instance.remove({"_id":'video'});
......
src/jio.storage/indexstorage.js
View file @ d42fadc0
...@@ -197,6 +197,24 @@ ...@@ -197,6 +197,24 @@
*/ */
that._database = spec.database || []; that._database = spec.database || [];
/**
* True if it has been modified
*
* @property modified
* @type Boolean
* @default false
*/
that.modified = false;
/**
* Updates the modified date
*
* @method touch
*/
that.touch = function () {
that.modified = true;
};
/** /**
* Adds a metadata object in the database, replace if already exist * Adds a metadata object in the database, replace if already exist
* *
...@@ -232,10 +250,11 @@ ...@@ -232,10 +250,11 @@
that._database.push(needed_meta); that._database.push(needed_meta);
that._location[meta._id] = that._database.length - 1; that._location[meta._id] = that._database.length - 1;
} }
that.modified = true;
return true; return true;
} }
if (typeof that._location[meta._id] === "number") { if (typeof that._location[meta._id] === "number") {
that.remove(meta); return that.remove(meta);
} }
return false; return false;
}; };
...@@ -245,6 +264,7 @@ ...@@ -245,6 +264,7 @@
* *
* @method remove * @method remove
* @param {Object} meta The metadata to remove * @param {Object} meta The metadata to remove
* @return {Boolean} true if removed else false
*/ */
that.remove = function (meta) { that.remove = function (meta) {
if (typeof meta._id !== "string") { if (typeof meta._id !== "string") {
...@@ -252,11 +272,13 @@ ...@@ -252,11 +272,13 @@
} }
if (typeof that._location[meta._id] !== "number") { if (typeof that._location[meta._id] !== "number") {
// throw new ReferenceError("Not Found"); // throw new ReferenceError("Not Found");
return; return false;
} }
that._database[that._location[meta._id]] = null; that._database[that._location[meta._id]] = null;
that._free.push(that._location[meta._id]); that._free.push(that._location[meta._id]);
delete that._location[meta._id]; delete that._location[meta._id];
that.modified = true;
return true;
}; };
/** /**
...@@ -354,6 +376,8 @@ ...@@ -354,6 +376,8 @@
that._database.splice(i, 1); that._database.splice(i, 1);
} }
} }
that.modified = true;
return true;
}; };
/** /**
...@@ -454,11 +478,13 @@ ...@@ -454,11 +478,13 @@
IndexStorage.prototype.getIndexDatabase = function (command, index) { IndexStorage.prototype.getIndexDatabase = function (command, index) {
index = this._indices[index]; index = this._indices[index];
function makeNewIndex() { function makeNewIndex() {
return new JSONIndex({ var json_index = new JSONIndex({
"_id": index.id, "_id": index.id,
"_attachment": index.attachment || "body", "_attachment": index.attachment || "body",
"indexing": index.index "indexing": index.index
}); });
json_index.touch();
return json_index;
} }
return command.storage( return command.storage(
index.sub_storage || this._sub_storage index.sub_storage || this._sub_storage
...@@ -497,6 +523,9 @@ ...@@ -497,6 +523,9 @@
IndexStorage.prototype.storeIndexDatabase = function (command, database, IndexStorage.prototype.storeIndexDatabase = function (command, database,
index) { index) {
var that = this; var that = this;
if (!database.modified) {
return RSVP.resolve({"result": "success"});
}
index = this._indices[index]; index = this._indices[index];
function putAttachment() { function putAttachment() {
return command.storage( return command.storage(
......
src/jio.storage/localstorage.js
View file @ d42fadc0
...@@ -364,7 +364,7 @@ ...@@ -364,7 +364,7 @@
*/ */
LocalStorage.prototype.removeAttachment = function (command, param) { LocalStorage.prototype.removeAttachment = function (command, param) {
var doc = this._storage.getItem(this._localpath + "/" + param._id); var doc = this._storage.getItem(this._localpath + "/" + param._id);
if (typeof doc !== 'object') { if (typeof doc !== 'object' || doc === null) {
return command.error( return command.error(
"not_found", "not_found",
"missing document", "missing document",
...@@ -539,7 +539,7 @@ ...@@ -539,7 +539,7 @@
} }
// check document type // check document type
if (typeof doc !== 'object') { if (typeof doc !== 'object' || doc === null) {
// wrong document // wrong document
if (!repair) { if (!repair) {
return {"error": true, "answers": [ return {"error": true, "answers": [
......
src/jio.storage/splitstorage.js
View file @ d42fadc0
...@@ -5,7 +5,7 @@ ...@@ -5,7 +5,7 @@
*/ */
/*jslint indent:2, maxlen: 80, nomen: true */ /*jslint indent:2, maxlen: 80, nomen: true */
/*global jIO, define */ /*global jIO, define, Blob */
/** /**
* Provides a split storage for JIO. This storage splits data * Provides a split storage for JIO. This storage splits data
...@@ -329,9 +329,9 @@ ...@@ -329,9 +329,9 @@
if (err) { if (err) {
err.message = "Unable to " + method + " document"; err.message = "Unable to " + method + " document";
delete err.index; delete err.index;
return that.error(err); return command.error(err);
} }
that.success({"id": doc_underscores._id}); command.success({"id": doc_underscores._id});
}); });
}; };
...@@ -368,10 +368,10 @@ ...@@ -368,10 +368,10 @@
var i, attachment_list = [], data = param._blob; var i, attachment_list = [], data = param._blob;
for (i = 0; i < priv.storage_list.length; i += 1) { for (i = 0; i < priv.storage_list.length; i += 1) {
attachment_list[i] = jIO.util.deepClone(param); attachment_list[i] = jIO.util.deepClone(param);
attachment_list[i]._data = data.slice( attachment_list[i]._blob = data.slice(
(data.length / priv.storage_list.length) * i, data.size * i / priv.storage_list.length,
(data.length / priv.storage_list.length) * (i + 1), data.size * (i + 1) / priv.storage_list.length,
"application/octet-stream" data.type
); );
} }
priv.send( priv.send(
...@@ -447,7 +447,7 @@ ...@@ -447,7 +447,7 @@
} }
} }
} }
that.success({"data": doc}); command.success({"data": doc});
}); });
}; };
...@@ -462,17 +462,15 @@ ...@@ -462,17 +462,15 @@
err, err,
response response
) { ) {
var i, doc;
if (err) { if (err) {
err.message = "Unable to get attachment"; err.message = "Unable to get attachment";
delete err.index; delete err.index;
return command.error(err); return command.error(err);
} }
doc = '';
for (i = 0; i < response.length; i += 1) { command.success({"data": new Blob(response.map(function (answer) {
doc += response[i].data; return answer.data;
} }), {"type": response[0].data.type})});
that.success({"data": doc}); // XXX get mimetype
}); });
}; };
......
src/queries/begin.js
View file @ d42fadc0
...@@ -20,7 +20,7 @@ ...@@ -20,7 +20,7 @@
} }
window.complex_queries = {}; window.complex_queries = {};
module(window.complex_queries, RSVP); module(window.complex_queries, RSVP);
}(['exports'], function (to_export, RSVP) { }(['exports', 'rsvp'], function (to_export, RSVP) {
"use strict"; "use strict";
/** /**
......
test/html5.js
View file @ d42fadc0
...@@ -263,6 +263,43 @@ ...@@ -263,6 +263,43 @@
(/\bPhantomJS\b/i).test(navigator.userAgent)) { (/\bPhantomJS\b/i).test(navigator.userAgent)) {
window.Blob = Blob; window.Blob = Blob;
window.FileReader = FileReader; window.FileReader = FileReader;
//console.warn("Blob and FileReader have been replaced!");
}
if (!Function.prototype.bind) {
//////////////////////////////////////////////////////////////////////
// https://github.com/TristanCavelier/notesntools/blob/master/javascript/\
// bind.js
/**
* Creates a new function that, when called, has its `this` keyword set to
* the provided value, with a given sequence of arguments preceding any
* provided when the new function is called. See Mozilla Developer Network:
* Function.prototype.bind
*
* In PhantomJS, their is a bug with `Function.prototype.bind`. You can
* reproduce this bug by testing this code:
*
* function a(str) { console.log(this, str); }
* var b = a.bind({"a": "b"}, "test");
* b();
*
* @param {Object} thisArg The value to be passed as the `this` parameter to
* the target function when the bound function is called. The value is
* ignored if the bound function is constructed using the `new` operator.
*
* @param {Any} [arg]* Arguments to prepend to arguments provided to the
* bound function when invoking the target function.
*
* @return {Function} The bound function.
*/
Function.prototype.bind = function (thisArg) {
var fun = this, args = [].slice.call(arguments, 1);
return function () {
args.push.apply(args, arguments);
return fun.apply(thisArg, args);
};
};
//console.warn("Function.prototype.bind has been replaced!");
} }
}()); }());
test/jio.storage/splitstorage.tests.js
View file @ d42fadc0
/*jslint indent: 2, maxlen: 80, nomen: true */ /*jslint indent: 2, maxlen: 80, nomen: true */
/*global define, jIO, jio_tests, test, ok, deepEqual, sinon, module */ /*global define, jIO, test_util, RSVP, test, ok, deepEqual, module, stop,
start, hex_sha256 */
// define([module_name], [dependencies], module); // define([module_name], [dependencies], module);
(function (dependencies, module) { (function (dependencies, module) {
...@@ -7,519 +8,957 @@ ...@@ -7,519 +8,957 @@
if (typeof define === 'function' && define.amd) { if (typeof define === 'function' && define.amd) {
return define(dependencies, module); return define(dependencies, module);
} }
module(jIO, jio_tests); module(jIO, test_util, RSVP);
}(['jio', 'jio_tests', 'localstorage', 'splitstorage'], function (jIO, util) { }([
'jio',
'test_util',
'rsvp',
'localstorage',
'splitstorage'
], function (jIO, util, RSVP) {
"use strict"; "use strict";
function generateTools() { var tool = {
return { "readBlobAsBinaryString": jIO.util.readBlobAsBinaryString
clock: sinon.useFakeTimers(), };
spy: util.ospy,
tick: util.otick function reverse(promise) {
}; return new RSVP.Promise(function (resolve, reject, notify) {
promise.then(reject, resolve, notify);
}, function () {
promise.cancel();
});
}
/**
* sequence(thens): Promise
*
* Executes a sequence of *then* callbacks. It acts like
* `smth().then(callback).then(callback)...`. The first callback is called
* with no parameter.
*
* Elements of `thens` array can be a function or an array contaning at most
* three *then* callbacks: *onFulfilled*, *onRejected*, *onNotified*.
*
* When `cancel()` is executed, each then promises are cancelled at the same
* time.
*
* @param {Array} thens An array of *then* callbacks
* @return {Promise} A new promise
*/
function sequence(thens) {
var promises = [];
return new RSVP.Promise(function (resolve, reject, notify) {
var i;
promises[0] = new RSVP.Promise(function (resolve) {
resolve();
});
for (i = 0; i < thens.length; i += 1) {
if (Array.isArray(thens[i])) {
promises[i + 1] = promises[i].
then(thens[i][0], thens[i][1], thens[i][2]);
} else {
promises[i + 1] = promises[i].then(thens[i]);
}
}
promises[i].then(resolve, reject, notify);
}, function () {
var i;
for (i = 0; i < promises.length; i += 1) {
promises[i].cancel();
}
});
}
function unexpectedError(error) {
if (error instanceof Error) {
deepEqual([
error.name + ": " + error.message,
error
], "UNEXPECTED ERROR", "Unexpected error");
} else {
deepEqual(error, "UNEXPECTED ERROR", "Unexpected error");
}
} }
module("SplitStorage + LocalStorage"); module("SplitStorage + LocalStorage");
test("Post", function () { test("Post", function () {
var o = generateTools(); var shared = {}, jio, jio_local_list = [];
o.jio = jIO.newJio({
shared.workspace = {};
shared.local_storage_description1 = {
"type": "local",
"username": "splitstorage",
"application_name": "post1",
"mode": "memory"
};
shared.local_storage_description2 = {
"type": "local",
"username": "splitstorage",
"application_name": "post2",
"mode": "memory"
};
jio = jIO.createJIO({
"type": "split", "type": "split",
"storage_list": [{ "storage_list": [
"type": "local", shared.local_storage_description1,
"username": "splitstorage", shared.local_storage_description2
"application_name": "post1" ]
}, { }, {"workspace": shared.workspace});
"type": "local", jio_local_list[0] = jIO.createJIO(shared.local_storage_description1, {
"username": "splitstorage", "workspace": shared.workspace
"application_name": "post2" });
}] jio_local_list[1] = jIO.createJIO(shared.local_storage_description2, {
"workspace": shared.workspace
}); });
jio_local_list.run = function (method, argument) {
var i, promises = [];
for (i = 0; i < this.length; i += 1) {
promises[i] = this[i][method].apply(this[i], argument);
}
return RSVP.all(promises);
};
jio_local_list.get = function () {
return this.run("get", arguments);
};
stop();
// post without id // post without id
o.spy(o, "jobstatus", "done", "Post document without id"); jio.post({
o.jio.post({
"_underscored_meta": "uvalue", "_underscored_meta": "uvalue",
"meta": "data" "meta": "data"
}, function (err, response) { }).then(function (answer) {
o.f(err, response); shared.uuid = answer.id;
o.uuid = (err || response).id; answer.id = "<uuid>";
ok(util.isUuid(o.uuid), "Uuid should look like " + ok(util.isUuid(shared.uuid), "Uuid should look like " +
"xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx : " + o.uuid); "xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx : " + shared.uuid);
}); deepEqual(answer, {
o.tick(o); "id": "<uuid>",
"method": "post",
// check uploaded documents "result": "success",
deepEqual(util.jsonlocalstorage.getItem( "status": 201,
'jio/localstorage/splitstorage/post1/' + o.uuid "statusText": "Created"
), { }, "Post document without id");
"_id": o.uuid,
"_underscored_meta": "uvalue", // check uploaded documents
"data": "{\"meta\"" return jio_local_list.get({"_id": shared.uuid});
}, "Check uploaded document in sub storage 1");
}).then(function (answers) {
deepEqual(util.jsonlocalstorage.getItem( var i;
'jio/localstorage/splitstorage/post2/' + o.uuid for (i = 0; i < answers.length; i += 1) {
), { deepEqual(answers[i].data, {
"_id": o.uuid, "_id": shared.uuid,
"_underscored_meta": "uvalue", "_underscored_meta": "uvalue",
"data": ":\"data\"}" "data": i === 0 ? "{\"meta\"" : ":\"data\"}"
}, "Check uploaded document in sub storage 2"); }, "Check uploaded document in sub storage " + (i + 1));
}
// post with id
o.spy(o, "value", {"ok": true, "id": "one"}, "Post document with id");
o.jio.post({
"_id": "one",
"_underscored_meta": "uvalue",
"meta": "data",
"hello": "world"
}, o.f);
o.tick(o);
// check uploaded documents
deepEqual(util.jsonlocalstorage.getItem(
'jio/localstorage/splitstorage/post1/one'
), {
"_id": "one",
"_underscored_meta": "uvalue",
"data": "{\"meta\":\"data\","
}, "Check uploaded document in sub storage 1");
deepEqual(util.jsonlocalstorage.getItem( // post with id
'jio/localstorage/splitstorage/post2/one' return jio.post({
), { "_id": "one",
"_id": "one", "_underscored_meta": "uvalue",
"_underscored_meta": "uvalue", "meta": "data",
"data": "\"hello\":\"world\"}" "hello": "world"
}, "Check uploaded document in sub storage 2"); });
// post with id }).then(function (answer) {
o.spy(o, "status", 409, "Post document with same id");
o.jio.post({ deepEqual(answer, {
"_id": "one", "id": "one",
"_underscored_meta": "uvalue", "method": "post",
"meta": "data", "result": "success",
"hello": "world" "status": 201,
}, o.f); "statusText": "Created"
o.tick(o); }, "Post document with id");
// check uploaded documents
return jio_local_list.get({"_id": "one"});
}).then(function (answers) {
deepEqual(answers[0].data, {
"_id": "one",
"_underscored_meta": "uvalue",
"data": "{\"meta\":\"data\","
}, "Check uploaded document in sub storage 1");
deepEqual(answers[1].data, {
"_id": "one",
"_underscored_meta": "uvalue",
"data": "\"hello\":\"world\"}"
}, "Check uploaded document in sub storage 2");
// post with id
return reverse(jio.post({
"_id": "one",
"_underscored_meta": "uvalue",
"meta": "data",
"hello": "world"
}));
}).then(function (answer) {
deepEqual(answer, {
"error": "conflict",
"id": "one",
"message": "Unable to post document",
"method": "post",
"reason": "document exists",
"result": "error",
"status": 409,
"statusText": "Conflict"
}, "Post document with same id -> 409 Conflict");
}).fail(unexpectedError).always(start);
util.closeAndcleanUpJio(o.jio);
}); });
test("PutAttachment", function () { test("PutAttachment", function () {
var o = generateTools(); var shared = {}, jio, jio_local_list = [];
o.jio = jIO.newJio({
shared.workspace = {};
shared.local_storage_description1 = {
"type": "local",
"username": "splitstorage",
"application_name": "putAttachment1",
"mode": "memory"
};
shared.local_storage_description2 = {
"type": "local",
"username": "splitstorage",
"application_name": "putAttachment2",
"mode": "memory"
};
jio = jIO.createJIO({
"type": "split", "type": "split",
"storage_list": [{ "storage_list": [
"type": "local", shared.local_storage_description1,
"username": "splitstorage", shared.local_storage_description2
"application_name": "putAttachment1" ]
}, { }, {"workspace": shared.workspace});
"type": "local", jio_local_list[0] = jIO.createJIO(shared.local_storage_description1, {
"username": "splitstorage", "workspace": shared.workspace
"application_name": "putAttachment2" });
}] jio_local_list[1] = jIO.createJIO(shared.local_storage_description2, {
"workspace": shared.workspace
}); });
jio_local_list.run = function (method, argument) {
var i, promises = [];
for (i = 0; i < this.length; i += 1) {
promises[i] = this[i][method].apply(this[i], argument);
}
return RSVP.all(promises);
};
jio_local_list.get = function () {
return this.run("get", arguments);
};
jio_local_list.getAttachmentAsBinaryString = function () {
return this.run("getAttachment", arguments).then(function (answers) {
var i, promises = [];
for (i = 0; i < answers.length; i += 1) {
promises[i] = tool.readBlobAsBinaryString(answers[i].data);
}
return RSVP.all(promises);
});
};
o.spy(o, "status", 404, "Put attachment on a inexistent document"); stop();
o.jio.putAttachment({
"_id": "one", return reverse(jio.putAttachment({
"_attachment": "my_attachment",
"_data": "My Data",
"_mimetype": "text/plain"
}, o.f);
o.tick(o);
o.jio.post({"_id": "one", "_underscored_meta": "uvalue", "meta": "data"});
o.clock.tick(1000);
o.spy(o, "value", {
"ok": true,
"id": "one",
"attachment": "my_attachment"
}, "Put attachment");
o.jio.putAttachment({
"_id": "one", "_id": "one",
"_attachment": "my_attachment", "_attachment": "my_attachment",
"_data": "My Data", "_data": "My Data",
"_mimetype": "text/plain" "_content_type": "text/plain"
}, o.f); })).then(function (answer) {
o.tick(o);
deepEqual(answer, {
// check uploaded documents "attachment": "my_attachment",
deepEqual(util.jsonlocalstorage.getItem( "error": "not_found",
'jio/localstorage/splitstorage/putAttachment1/one' "id": "one",
), { "message": "Unable to put attachment",
"_id": "one", "method": "putAttachment",
"_underscored_meta": "uvalue", "reason": "missing",
"data": "{\"meta\"", "result": "error",
"_attachments": { "status": 404,
"my_attachment": { "statusText": "Not Found"
"length": 3, }, "Put attachment on a inexistent document -> 404 Not Found");
"digest": "md5-1b4686bc8ca15befdccb1da1dcb8c271", // md5("My ")
"content_type": "text/plain" return jio.post({
} "_id": "one",
} "_underscored_meta": "uvalue",
}, "Check uploaded document in sub storage 1"); "meta": "data"
});
deepEqual(util.jsonlocalstorage.getItem( }).then(function () {
'jio/localstorage/splitstorage/putAttachment2/one'
), { return jio.putAttachment({
"_id": "one", "_id": "one",
"_underscored_meta": "uvalue", "_attachment": "my_attachment",
"data": ":\"data\"}", "_data": "My Data",
"_attachments": { "_mimetype": "text/plain"
"my_attachment": { });
"length": 4,
"digest": "md5-f6068daa29dbb05a7ead1e3b5a48bbee", // md5("Data")
"content_type": "text/plain"
}
}
}, "Check uploaded document in sub storage 2");
deepEqual(util.jsonlocalstorage.getItem( }).then(function (answer) {
'jio/localstorage/splitstorage/putAttachment1/one/my_attachment'
), "My ", "Check uploaded document in sub storage 1"); deepEqual(answer, {
"attachment": "my_attachment",
"id": "one",
"method": "putAttachment",
"result": "success",
"status": 204,
"statusText": "No Content"
}, "Put attachment on a document");
// check uploaded documents
return jio_local_list.get({"_id": "one"});
}).then(function (answers) {
deepEqual(answers[0].data, {
"_attachments": {
"my_attachment": {
"content_type": "text/plain",
"digest": "sha256-ebf2d770a6a2dfa135f6c81431f22fc3cbcde9ae" +
"e52759ca9e520d4d964c1322", // sha256("My ")
"length": 3
}
},
"_id": "one",
"_underscored_meta": "uvalue",
"data": "{\"meta\""
}, "Check uploaded document in sub storage 1");
deepEqual(answers[1].data, {
"_attachments": {
"my_attachment": {
"content_type": "text/plain",
"digest": "sha256-cec3a9b89b2e391393d0f68e4bc12a9fa6cf358b" +
"3cdf79496dc442d52b8dd528", // sha256("Data")
"length": 4
}
},
"_id": "one",
"_underscored_meta": "uvalue",
"data": ":\"data\"}"
}, "Check uploaded document in sub storage 2");
return jio_local_list.getAttachmentAsBinaryString({
"_id": "one",
"_attachment": "my_attachment"
});
deepEqual(util.jsonlocalstorage.getItem( }).then(function (events) {
'jio/localstorage/splitstorage/putAttachment2/one/my_attachment'
), "Data", "Check uploaded document in sub storage 2"); deepEqual(events[0].target.result, "My ",
"Check uploaded document in sub storage 1");
deepEqual(events[1].target.result, "Data",
"Check uploaded document in sub storage 1");
}).fail(unexpectedError).always(start);
util.closeAndcleanUpJio(o.jio);
}); });
test("Get", function () { test("Get", function () {
var o = generateTools(); var shared = {}, jio;
o.jio = jIO.newJio({
shared.workspace = {};
shared.local_storage_description1 = {
"type": "local",
"username": "splitstorage",
"application_name": "get1",
"mode": "memory"
};
shared.local_storage_description2 = {
"type": "local",
"username": "splitstorage",
"application_name": "get2",
"mode": "memory"
};
jio = jIO.createJIO({
"type": "split", "type": "split",
"storage_list": [{ "storage_list": [
"type": "local", shared.local_storage_description1,
"username": "splitstorage", shared.local_storage_description2
"application_name": "get1" ]
}, { }, {"workspace": shared.workspace});
"type": "local",
"username": "splitstorage", stop();
"application_name": "get2"
}] reverse(jio.get({"_id": "one"})).then(function (answer) {
});
deepEqual(answer, {
"error": "not_found",
"id": "one",
"message": "Unable to get document",
"method": "get",
"reason": "missing",
"result": "error",
"status": 404,
"statusText": "Not Found"
}, "Get missing document");
return jio.post({
"_id": "one",
"_underscored_meta": "uvalue",
"meta": "data"
});
o.spy(o, "status", 404, "Get missing document"); }).then(function () {
o.jio.get({"_id": "one"}, o.f);
o.tick(o);
o.jio.post({"_id": "one", "_underscored_meta": "uvalue", "meta": "data"}); return jio.get({"_id": "one"});
o.clock.tick(1000);
o.spy(o, "value", { }).then(function (answer) {
"_id": "one",
"_underscored_meta": "uvalue",
"meta": "data"
}, "Get posted document");
o.jio.get({"_id": "one"}, o.f);
o.tick(o);
o.jio.putAttachment({ deepEqual(answer.data, {
"_id": "one", "_id": "one",
"_attachment": "my_attachment", "_underscored_meta": "uvalue",
"_data": "My Data", "meta": "data"
"_mimetype": "text/plain" }, "Get posted document");
});
o.clock.tick(1000);
o.spy(o, "value", { return jio.putAttachment({
"_id": "one", "_id": "one",
"_underscored_meta": "uvalue", "_attachment": "my_attachment",
"meta": "data", "_data": "My Data",
"_attachments": { "_content_type": "text/plain"
"my_attachment": { });
"length": 7,
"content_type": "text/plain" }).then(function () {
return jio.get({"_id": "one"});
}).then(function (answer) {
deepEqual(answer.data, {
"_id": "one",
"_underscored_meta": "uvalue",
"meta": "data",
"_attachments": {
"my_attachment": {
"length": 7,
"content_type": "text/plain"
}
} }
} }, "Get document with attachment informations");
}, "Get document with attachment informations");
o.jio.get({"_id": "one"}, o.f); }).fail(unexpectedError).always(start);
o.tick(o);
util.closeAndcleanUpJio(o.jio);
}); });
test("GetAttachment", function () { test("GetAttachment", function () {
var o = generateTools(); var shared = {}, jio;
o.jio = jIO.newJio({
shared.workspace = {};
shared.local_storage_description1 = {
"type": "local",
"username": "splitstorage",
"application_name": "getAttachment1",
"mode": "memory"
};
shared.local_storage_description2 = {
"type": "local",
"username": "splitstorage",
"application_name": "getAttachment2",
"mode": "memory"
};
jio = jIO.createJIO({
"type": "split", "type": "split",
"storage_list": [{ "storage_list": [
"type": "local", shared.local_storage_description1,
"username": "splitstorage", shared.local_storage_description2
"application_name": "getAttachment1" ]
}, { }, {"workspace": shared.workspace});
"type": "local",
"username": "splitstorage", stop();
"application_name": "getAttachment2"
}]
});
o.spy(o, "status", 404, "Get attachment from missing document"); reverse(jio.getAttachment({
o.jio.getAttachment({"_id": "one", "_attachment": "my_attachment"}, o.f); "_id": "one",
o.tick(o); "_attachment": "my_attachment"
})).then(function (answer) {
deepEqual(answer, {
"attachment": "my_attachment",
"error": "not_found",
"id": "one",
"message": "Unable to get attachment",
"method": "getAttachment",
"reason": "missing document",
"result": "error",
"status": 404,
"statusText": "Not Found"
}, "Get attachment from missing document -> 404 Not Found");
return jio.post({
"_id": "one",
"_underscored_meta": "uvalue",
"meta": "data"
});
o.jio.post({"_id": "one", "_underscored_meta": "uvalue", "meta": "data"}); }).then(function () {
o.clock.tick(1000);
return reverse(jio.getAttachment({
"_id": "one",
"_attachment": "my_attachment"
}));
}).then(function (answer) {
deepEqual(answer, {
"attachment": "my_attachment",
"error": "not_found",
"id": "one",
"message": "Unable to get attachment",
"method": "getAttachment",
"reason": "missing attachment",
"result": "error",
"status": 404,
"statusText": "Not Found"
}, "Get missing attachment from document");
return jio.putAttachment({
"_id": "one",
"_attachment": "my_attachment",
"_data": "My Data",
"_mimetype": "text/plain"
});
o.spy(o, "status", 404, "Get missing attachment from document"); }).then(function () {
o.jio.getAttachment({"_id": "one", "_attachment": "my_attachment"}, o.f);
o.tick(o);
o.jio.putAttachment({ return jio.getAttachment({"_id": "one", "_attachment": "my_attachment"});
"_id": "one",
"_attachment": "my_attachment", }).then(function (answer) {
"_data": "My Data", return tool.readBlobAsBinaryString(answer.data);
"_mimetype": "text/plain" }).then(function (event) {
});
o.clock.tick(1000);
o.spy(o, "value", "My Data", "Get attachment"); deepEqual(event.target.result, "My Data", "Get attachment");
o.jio.getAttachment({"_id": "one", "_attachment": "my_attachment"}, o.f);
o.tick(o); }).fail(unexpectedError).always(start);
util.closeAndcleanUpJio(o.jio);
}); });
test("removeAttachment", function () { test("RemoveAttachment", function () {
var o = generateTools(); var shared = {}, jio;
o.jio = jIO.newJio({ shared.workspace = {};
shared.local_storage_description1 = {
"type": "local",
"username": "splitstorage",
"application_name": "removeAttachment1",
"mode": "memory"
};
shared.local_storage_description2 = {
"type": "local",
"username": "splitstorage",
"application_name": "removeAttachment2",
"mode": "memory"
};
jio = jIO.createJIO({
"type": "split", "type": "split",
"storage_list": [{ "storage_list": [
"type": "local", shared.local_storage_description1,
"username": "splitstorage", shared.local_storage_description2
"application_name": "removeAttachment1" ]
}, { }, {"workspace": shared.workspace});
"type": "local",
"username": "splitstorage",
"application_name": "removeAttachment2"
}]
});
o.spy(o, "status", 404, "Remove attachment from inexistent document"); stop();
o.jio.removeAttachment({"_id": "one", "_attachment": "my_attachment"}, o.f);
o.tick(o);
o.jio.post({"_id": "one", "_underscored_meta": "uvalue", "meta": "data"}); reverse(jio.removeAttachment({
o.clock.tick(1000); "_id": "one",
"_attachment": "my_attachment"
})).then(function (answer) {
deepEqual(answer, {
"attachment": "my_attachment",
"error": "not_found",
"id": "one",
"message": "Unable to remove attachment",
"method": "removeAttachment",
"reason": "missing document",
"result": "error",
"status": 404,
"statusText": "Not Found"
}, "Remove attachment from inexistent document -> 404 Not Found");
return jio.post({
"_id": "one",
"_underscored_meta": "uvalue",
"meta": "data"
});
o.spy(o, "status", 404, "Remove inexistent attachment"); }).then(function () {
o.jio.removeAttachment({"_id": "one", "_attachment": "my_attachment"}, o.f);
o.tick(o); return reverse(jio.removeAttachment({
"_id": "one",
"_attachment": "my_attachment"
}));
}).then(function (answer) {
deepEqual(answer, {
"attachment": "my_attachment",
"error": "not_found",
"id": "one",
"message": "Unable to remove attachment",
"method": "removeAttachment",
"reason": "missing attachment",
"result": "error",
"status": 404,
"statusText": "Not Found"
}, "Remove inexistent attachment -> 404 Not Found");
return jio.putAttachment({
"_id": "one",
"_attachment": "my_attachment",
"_data": "My Data",
"_mimetype": "text/plain"
});
o.jio.putAttachment({ }).then(function () {
"_id": "one",
"_attachment": "my_attachment", return jio.removeAttachment({
"_data": "My Data", "_id": "one",
"_mimetype": "text/plain" "_attachment": "my_attachment"
}); });
o.clock.tick(1000);
o.spy(o, "value", { }).then(function (answer) {
"ok": true,
"id": "one",
"attachment": "my_attachment"
}, "Remove attachment");
o.jio.removeAttachment({"_id": "one", "_attachment": "my_attachment"}, o.f);
o.tick(o);
o.spy(o, "value", { deepEqual(answer, {
"_id": "one", "attachment": "my_attachment",
"_underscored_meta": "uvalue", "id": "one",
"meta": "data" "method": "removeAttachment",
}, "Get document for check"); "result": "success",
o.jio.get({"_id": "one"}, o.f); "status": 204,
o.tick(o); "statusText": "No Content"
}, "Remove attachment");
return jio.get({"_id": "one"});
}).then(function (answer) {
o.spy(o, "status", 404, "Get attachment for check"); deepEqual(answer.data, {
o.jio.getAttachment({"_id": "one", "_attachment": "my_attachment"}, o.f); "_id": "one",
o.tick(o); "_underscored_meta": "uvalue",
"meta": "data"
}, "Check document");
return reverse(jio.getAttachment({
"_id": "one",
"_attachment": "my_attachment"
}));
}).then(function (answer) {
deepEqual(answer, {
"attachment": "my_attachment",
"error": "not_found",
"id": "one",
"message": "Unable to get attachment",
"method": "getAttachment",
"reason": "missing attachment",
"result": "error",
"status": 404,
"statusText": "Not Found"
}, "Check attachment -> 404 Not Found");
}).fail(unexpectedError).always(start);
util.closeAndcleanUpJio(o.jio);
}); });
test("remove", function () { test("Remove", function () {
var o = generateTools(); var shared = {}, jio;
o.jio = jIO.newJio({
shared.workspace = {};
shared.local_storage_description1 = {
"type": "local",
"username": "splitstorage",
"application_name": "remove1",
"mode": "memory"
};
shared.local_storage_description2 = {
"type": "local",
"username": "splitstorage",
"application_name": "remove2",
"mode": "memory"
};
jio = jIO.createJIO({
"type": "split", "type": "split",
"storage_list": [{ "storage_list": [
"type": "local", shared.local_storage_description1,
"username": "splitstorage", shared.local_storage_description2
"application_name": "remove1" ]
}, { }, {"workspace": shared.workspace});
"type": "local",
"username": "splitstorage", stop();
"application_name": "remove2"
}] reverse(jio.remove({"_id": "one"})).then(function (answer) {
});
deepEqual(answer, {
"error": "not_found",
"id": "one",
"message": "Unable to remove document",
"method": "remove",
"reason": "missing",
"result": "error",
"status": 404,
"statusText": "Not Found"
}, "Remove missing document -> 404 Not Found");
return jio.post({
"_id": "one",
"_underscored_meta": "uvalue",
"meta": "data"
});
o.spy(o, "status", 404, "Remove missing document"); }).then(function () {
o.jio.remove({"_id": "one"}, o.f);
o.tick(o);
o.jio.post({"_id": "one", "_underscored_meta": "uvalue", "meta": "data"}); return jio.putAttachment({
o.clock.tick(1000); "_id": "one",
"_attachment": "my_attachment",
"_data": "My Data",
"_mimetype": "text/plain"
});
o.jio.putAttachment({ }).then(function () {
"_id": "one",
"_attachment": "my_attachment", return jio.remove({"_id": "one"});
"_data": "My Data",
"_mimetype": "text/plain"
});
o.clock.tick(1000);
o.spy(o, "value", {"ok": true, "id": "one"}, "Remove document"); }).then(function (answer) {
o.jio.remove({"_id": "one"}, o.f);
o.tick(o);
o.spy(o, "status", 404, "Get attachment for check"); deepEqual(answer, {
o.jio.getAttachment({"_id": "one", "_attachment": "my_attachment"}, o.f); "id": "one",
o.tick(o); "method": "remove",
"result": "success",
"status": 204,
"statusText": "No Content"
}, "Remove document");
o.spy(o, "status", 404, "Get document for check"); return reverse(jio.getAttachment({
o.jio.get({"_id": "one"}, o.f); "_id": "one",
o.tick(o); "_attachment": "my_attachment"
}));
}).then(function (answer) {
deepEqual(answer, {
"attachment": "my_attachment",
"error": "not_found",
"id": "one",
"message": "Unable to get attachment",
"method": "getAttachment",
"reason": "missing document",
"result": "error",
"status": 404,
"statusText": "Not Found"
}, "Check attachment -> 404 Not Found");
return reverse(jio.get({"_id": "one"}));
}).then(function (answer) {
deepEqual(answer, {
"error": "not_found",
"id": "one",
"message": "Unable to get document",
"method": "get",
"reason": "missing",
"result": "error",
"status": 404,
"statusText": "Not Found"
}, "Check document -> 404 Not Found");
}).fail(unexpectedError).always(start);
util.closeAndcleanUpJio(o.jio);
}); });
test("Put", function () { test("Put", function () {
var o = generateTools(); var shared = {}, jio;
o.jio = jIO.newJio({
shared.workspace = {};
shared.local_storage_description1 = {
"type": "local",
"username": "splitstorage",
"application_name": "put1",
"mode": "memory"
};
shared.local_storage_description2 = {
"type": "local",
"username": "splitstorage",
"application_name": "put2",
"mode": "memory"
};
jio = jIO.createJIO({
"type": "split", "type": "split",
"storage_list": [{ "storage_list": [
"type": "local", shared.local_storage_description1,
"username": "splitstorage", shared.local_storage_description2
"application_name": "put1" ]
}, { }, {"workspace": shared.workspace});
"type": "local",
"username": "splitstorage",
"application_name": "put2"
}]
});
o.spy(o, "value", {"ok": true, "id": "one"}, "Put document"); stop();
o.jio.put({
"_id": "one",
"_underscored_meta": "uvalue",
"meta": "data"
}, o.f);
o.tick(o);
o.spy(o, "value", { jio.put({
"_id": "one", "_id": "one",
"_underscored_meta": "uvalue", "_underscored_meta": "uvalue",
"meta": "data" "meta": "data"
}, "Get document for check"); }).then(function (answer) {
o.jio.get({"_id": "one"}, o.f);
o.tick(o); deepEqual(answer, {
"id": "one",
"method": "put",
"result": "success",
"status": 204,
"statusText": "No Content"
}, "Put new document");
return jio.get({"_id": "one"});
}).then(function (answer) {
deepEqual(answer.data, {
"_id": "one",
"_underscored_meta": "uvalue",
"meta": "data"
}, "Check document");
return jio.put({
"_id": "one",
"_underscored_meta": "uvalue",
"meow": "dog"
});
o.spy(o, "value", {"ok": true, "id": "one"}, "Put document again"); }).then(function (answer) {
o.jio.put({
"_id": "one",
"_underscored_meta": "uvalue",
"meow": "dog"
}, o.f);
o.tick(o);
o.spy(o, "value", { deepEqual(answer, {
"_id": "one", "id": "one",
"_underscored_meta": "uvalue", "method": "put",
"meow": "dog" "result": "success",
}, "Get document for check"); "status": 204,
o.jio.get({"_id": "one"}, o.f); "statusText": "No Content"
o.tick(o); }, "Put same document again");
return jio.get({"_id": "one"});
}).then(function (answer) {
deepEqual(answer.data, {
"_id": "one",
"_underscored_meta": "uvalue",
"meow": "dog"
}, "Get document for check");
}).fail(unexpectedError).always(start);
util.closeAndcleanUpJio(o.jio);
}); });
test("AllDocs", function () { test("AllDocs", function () {
var o = generateTools(); var shared = {}, jio;
o.jio = jIO.newJio({
shared.workspace = {};
shared.local_storage_description1 = {
"type": "local",
"username": "splitstorage",
"application_name": "alldocs1",
"mode": "memory"
};
shared.local_storage_description2 = {
"type": "local",
"username": "splitstorage",
"application_name": "alldocs2",
"mode": "memory"
};
jio = jIO.createJIO({
"type": "split", "type": "split",
"storage_list": [{ "storage_list": [
"type": "local", shared.local_storage_description1,
"username": "splitstorage", shared.local_storage_description2
"application_name": "alldocs1" ]
}, { }, {"workspace": shared.workspace});
"type": "local",
"username": "splitstorage", stop();
"application_name": "alldocs2"
}] function prepareDatabase() {
}); var i, do_list = [];
function post(i) {
for (o.i = 0; o.i < 5; o.i += 1) { return function () {
o.jio.post({ return jio.post({
"_id": "doc" + o.i, "_id": "doc" + i,
"_underscored_meta": "uvalue" + o.i, "_underscored_meta": "uvalue" + i,
"meta": "data" + o.i "meta": "data" + i
}); });
o.clock.tick(1000); };
}
function putAttachment(i) {
return function () {
return jio.putAttachment({
"_id": "doc" + i,
"_attachment": "my_attachment" + i,
"_data": "My Data" + i,
"_content_type": "text/plain"
});
};
}
for (i = 0; i < 5; i += 1) {
do_list.push(post(i));
}
for (i = 0; i < 2; i += 1) {
do_list.push(putAttachment(i));
}
return sequence(do_list);
} }
for (o.i = 0; o.i < 2; o.i += 1) { prepareDatabase().then(function () {
o.jio.putAttachment({
"_id": "doc" + o.i,
"_attachment": "my_attachment" + o.i,
"_data": "My Data" + o.i,
"_mimetype": "text/plain"
});
o.clock.tick(1000);
}
o.spy(o, "value", { return jio.get({"_id": "doc1"});
"_id": "doc1",
"_underscored_meta": "uvalue1", }).then(function (answer) {
"meta": "data1",
"_attachments": { deepEqual(answer.data, {
"my_attachment1": { "_id": "doc1",
"length": 8, "_underscored_meta": "uvalue1",
"content_type": "text/plain" "meta": "data1",
"_attachments": {
"my_attachment1": {
"length": 8,
"content_type": "text/plain"
}
} }
} }, "Check document");
}, "Get document for check");
o.jio.get({"_id": "doc1"}, o.f); return jio.allDocs();
o.tick(o);
}).then(function (answer) {
o.spy(o, "value", {
"total_rows": 5, answer.data.rows.sort(function (a, b) {
"rows": [{ return a.id < b.id ? -1 : a.id > b.id ? 1 : 0;
"id": "doc0", });
"key": "doc0",
"value": {} deepEqual(answer.data, {
}, { "total_rows": 5,
"id": "doc1", "rows": [{
"key": "doc1", "id": "doc0",
"value": {} "key": "doc0",
}, { "value": {}
"id": "doc2", }, {
"key": "doc2", "id": "doc1",
"value": {} "key": "doc1",
}, { "value": {}
"id": "doc3", }, {
"key": "doc3", "id": "doc2",
"value": {} "key": "doc2",
}, { "value": {}
"id": "doc4", }, {
"key": "doc4", "id": "doc3",
"value": {} "key": "doc3",
}] "value": {}
}, "AllDocs with document ids only"); }, {
o.jio.allDocs(function (err, response) { "id": "doc4",
if (response && Array.isArray(response.rows)) { "key": "doc4",
response.rows.sort(function (a, b) { "value": {}
return a.id < b.id ? -1 : a.id > b.id ? 1 : 0; }]
}); }, "AllDocs with document ids only");
}
o.f(err, response); }).fail(unexpectedError).always(start);
});
o.tick(o);
util.closeAndcleanUpJio(o.jio);
}); });
})); }));
test/tests.html
View file @ d42fadc0
...@@ -47,5 +47,8 @@ ...@@ -47,5 +47,8 @@
<script src="../src/jio.storage/replicaterevisionstorage.js"></script> <script src="../src/jio.storage/replicaterevisionstorage.js"></script>
<script src="../test/jio.storage/replicaterevisionstorage.tests.js"></script> <script src="../test/jio.storage/replicaterevisionstorage.tests.js"></script>
<script src="../src/jio.storage/splitstorage.js"></script>
<script src="../test/jio.storage/splitstorage.tests.js"></script>
</body> </body>
</html> </html>
test/tests.require.js
View file @ d42fadc0
...@@ -37,6 +37,9 @@ ...@@ -37,6 +37,9 @@
"replicaterevisionstorage_tests": "replicaterevisionstorage_tests":
"jio.storage/replicaterevisionstorage.tests", "jio.storage/replicaterevisionstorage.tests",
"splitstorage": "../src/jio.storage/splitstorage",
"splitstorage_tests": "jio.storage/splitstorage.tests",
"qunit": "../lib/qunit/qunit", "qunit": "../lib/qunit/qunit",
"sinon": "../lib/sinon/sinon", "sinon": "../lib/sinon/sinon",
"sinon_qunit": "../lib/sinon/sinon-qunit" "sinon_qunit": "../lib/sinon/sinon-qunit"
...@@ -56,6 +59,7 @@ ...@@ -56,6 +59,7 @@
"indexstorage_tests", "indexstorage_tests",
"gidstorage_tests", "gidstorage_tests",
"revisionstorage_tests", "revisionstorage_tests",
"replicaterevisionstorage_tests" "replicaterevisionstorage_tests",
"splitstorage_tests"
]); ]);
}()); }());
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment
GitLab Nexedi Edition | About GitLab | About Nexedi | 沪ICP备2021021310号-2 | 沪ICP备2021021310号-7