Skip to content

J
jio
Commit 23189f9c authored by Tristan Cavelier's avatar Tristan Cavelier
Browse files
Options

jiotests.js jio tests + local storage tests detached

parent 77b9d102
Show whitespace changes
Inline Side-by-side
Showing with 1307 additions and 683 deletions
test/jio.storage/localstorage.tests.js 0 → 100644
View file @ 23189f9c
/*jslint indent: 2, maxlen: 80, nomen: true */
/*global define, jIO, jio_tests, window, test, ok, deepEqual, sinon, expect */
// define([module_name], [dependencies], module);
(function (dependencies, module) {
"use strict";
if (typeof define === 'function' && define.amd) {
return define(dependencies, module);
}
module(jIO, jio_tests);
}(['jio', 'jio_tests', 'localstorage'], function (jIO, util) {
"use strict";
function generateTools() {
return {
clock: sinon.useFakeTimers(),
spy: util.ospy,
tick: util.otick
};
}
module("LocalStorage");
test("Post", function () {
expect(5);
var clock = sinon.useFakeTimers(), jio = jIO.newJio({
"type": "local",
"username": "upost",
"application_name": "apost"
});
// post without id
jio.post({}, function (err, response) {
var uuid;
util.
spyJioCallback('jobstatus', 'done', "Post without id")(err, response);
uuid = (err || response).id;
ok(util.isUuid(uuid), "Uuid should look like " +
"xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx : " + uuid);
});
clock.tick(1000);
// post non empty document
jio.post(
{"_id": "post1", "title": "myPost1"},
util.spyJioCallback("value", {"ok": true, "id": "post1"}, "Post")
);
clock.tick(1000);
deepEqual(
util.jsonlocalstorage.getItem("jio/localstorage/upost/apost/post1"),
{
"_id": "post1",
"title": "myPost1"
},
"Check document"
);
// post but document already exists
jio.post({"_id": "post1", "title": "myPost2"}, util.spyJioCallback(
"status",
409,
"Post but document already exists"
));
clock.tick(1000);
util.closeAndcleanUpJio(jio);
});
test("Put", function () {
expect(5);
var clock = sinon.useFakeTimers(), jio = jIO.newJio({
"type": "local",
"username": "uput",
"application_name": "aput"
});
// put without id
// error 20 -> document id required
jio.put({}, util.spyJioCallback("status", 20, "Put without id"));
clock.tick(1000);
// put non empty document
jio.put({"_id": "put1", "title": "myPut1"}, util.spyJioCallback("value", {
"ok": true,
"id": "put1"
}, "Creates a document"));
clock.tick(1000);
// check document
deepEqual(
util.jsonlocalstorage.getItem("jio/localstorage/uput/aput/put1"),
{
"_id": "put1",
"title": "myPut1"
},
"Check document"
);
// put but document already exists
jio.put({"_id": "put1", "title": "myPut2"}, util.spyJioCallback("value", {
"ok": true,
"id": "put1"
}, "Update the document"));
clock.tick(1000);
// check document
deepEqual(
util.jsonlocalstorage.getItem("jio/localstorage/uput/aput/put1"),
{
"_id": "put1",
"title": "myPut2"
},
"Check document"
);
util.closeAndcleanUpJio(jio);
});
test("PutAttachment", function () {
var o = generateTools(this);
o.jio = jIO.newJio({
"type": "local",
"username": "uputattmt",
"application_name": "aputattmt"
});
// putAttachment without doc id
// error 20 -> document id required
o.spy(o, "status", 20, "PutAttachment without doc id");
o.jio.putAttachment({}, o.f);
o.tick(o);
// putAttachment without attachment id
// error 22 -> attachment id required
o.spy(o, "status", 22, "PutAttachment without attachment id");
o.jio.putAttachment({"_id": "putattmt1"}, o.f);
o.tick(o);
// putAttachment without document
// error 404 -> not found
o.spy(o, "status", 404, "PutAttachment without document");
o.jio.putAttachment({"_id": "putattmt1", "_attachment": "putattmt2"}, o.f);
o.tick(o);
// adding a document
util.jsonlocalstorage.setItem(
"jio/localstorage/uputattmt/aputattmt/putattmt1",
{
"_id": "putattmt1",
"title": "myPutAttmt1"
}
);
// putAttachment with document
o.spy(o, "value",
{"ok": true, "id": "putattmt1", "attachment": "putattmt2"},
"PutAttachment with document, without data");
o.jio.putAttachment({"_id": "putattmt1", "_attachment": "putattmt2"}, o.f);
o.tick(o);
// check document
deepEqual(
util.jsonlocalstorage.getItem(
"jio/localstorage/uputattmt/aputattmt/putattmt1"
),
{
"_id": "putattmt1",
"title": "myPutAttmt1",
"_attachments": {
"putattmt2": {
"length": 0,
// md5("")
"digest": "md5-d41d8cd98f00b204e9800998ecf8427e"
}
}
},
"Check document"
);
// check attachment
deepEqual(util.jsonlocalstorage.getItem(
"jio/localstorage/uputattmt/aputattmt/putattmt1/putattmt2"
), "", "Check attachment");
// update attachment
o.spy(o, "value",
{"ok": true, "id": "putattmt1", "attachment": "putattmt2"},
"Update Attachment, with data");
o.jio.putAttachment({
"_id": "putattmt1",
"_attachment": "putattmt2",
"_data": "abc"
}, o.f);
o.tick(o);
// check document
deepEqual(
util.jsonlocalstorage.getItem(
"jio/localstorage/uputattmt/aputattmt/putattmt1"
),
{
"_id": "putattmt1",
"title": "myPutAttmt1",
"_attachments": {
"putattmt2": {
"length": 3,
// md5("abc")
"digest": "md5-900150983cd24fb0d6963f7d28e17f72"
}
}
},
"Check document"
);
// check attachment
deepEqual(util.jsonlocalstorage.getItem(
"jio/localstorage/uputattmt/aputattmt/putattmt1/putattmt2"
), "abc", "Check attachment");
util.closeAndcleanUpJio(o.jio);
});
test("Get", function () {
var o = generateTools(this);
o.jio = jIO.newJio({
"type": "local",
"username": "uget",
"application_name": "aget"
});
// get inexistent document
o.spy(o, "status", 404, "Get inexistent document");
o.jio.get({"_id": "get1"}, o.f);
o.tick(o);
// get inexistent attachment
o.spy(o, "status", 404, "Get inexistent attachment");
o.jio.getAttachment({"_id": "get1", "_attachment": "get2"}, o.f);
o.tick(o);
// adding a document
o.doc_get1 = {
"_id": "get1",
"title": "myGet1"
};
util.jsonlocalstorage.setItem(
"jio/localstorage/uget/aget/get1",
o.doc_get1
);
// get document
o.spy(o, "value", o.doc_get1, "Get document");
o.jio.get({"_id": "get1"}, o.f);
o.tick(o);
// get inexistent attachment (document exists)
o.spy(o, "status", 404, "Get inexistent attachment (document exists)");
o.jio.getAttachment({"_id": "get1", "_attachment": "get2"}, o.f);
o.tick(o);
// adding an attachment
o.doc_get1._attachments = {
"get2": {
"length": 2,
// md5("de")
"digest": "md5-5f02f0889301fd7be1ac972c11bf3e7d"
}
};
util.jsonlocalstorage.setItem(
"jio/localstorage/uget/aget/get1",
o.doc_get1
);
util.jsonlocalstorage.setItem("jio/localstorage/uget/aget/get1/get2", "de");
// get attachment
o.spy(o, "value", "de", "Get attachment");
o.jio.getAttachment({"_id": "get1", "_attachment": "get2"}, o.f);
o.tick(o);
util.closeAndcleanUpJio(o.jio);
});
test("Remove", function () {
var o = generateTools(this);
o.jio = jIO.newJio({
"type": "local",
"username": "uremove",
"application_name": "aremove"
});
// remove inexistent document
o.spy(o, "status", 404, "Remove inexistent document");
o.jio.remove({"_id": "remove1"}, o.f);
o.tick(o);
// remove inexistent attachment
o.spy(o, "status", 404, "Remove inexistent attachment");
o.jio.removeAttachment({"_id": "remove1", "_attachment": "remove2"}, o.f);
o.tick(o);
// adding a document + attmt
util.jsonlocalstorage.setItem("jio/localstorage/uremove/aremove/remove1", {
"_id": "remove1",
"title": "myRemove1",
"_attachments": {
"remove2": {
"length": 4,
"digest": "md5-blahblah"
}
}
});
util.jsonlocalstorage.setItem(
"jio/localstorage/uremove/aremove/remove1/remove2",
"fghi"
);
// remove attachment
o.spy(o, "value", {"ok": true, "id": "remove1", "attachment": "remove2"},
"Remove document");
o.jio.removeAttachment({"_id": "remove1", "_attachment": "remove2"}, o.f);
o.tick(o);
// remove document
o.spy(o, "value", {"ok": true, "id": "remove1"}, "Remove document");
o.jio.remove({"_id": "remove1"}, o.f);
o.tick(o);
// check document
ok(util.jsonlocalstorage.getItem(
"jio/localstorage/uremove/aremove/remove1"
) === null, "Check document is removed");
// adding a document + attmt
util.jsonlocalstorage.setItem("jio/localstorage/uremove/aremove/remove1", {
"_id": "remove1",
"title": "myRemove1",
"_attachments": {
"remove2": {
"length": 4,
"digest": "md5-blahblah"
}
}
});
util.jsonlocalstorage.setItem(
"jio/localstorage/uremove/aremove/remove1/remove2", "fghi");
// remove attachment
o.spy(o, "value", {"ok": true, "id": "remove1"},
"Remove document and attachment");
o.jio.remove({"_id": "remove1"}, o.f);
o.tick(o);
ok(util.jsonlocalstorage.getItem(
"jio/localstorage/uremove/aremove/remove1"
) === null, "Check document is removed");
ok(util.jsonlocalstorage.getItem(
"jio/localstorage/uremove/aremove/remove1/remove2"
) === null, "Check attachment is removed");
util.closeAndcleanUpJio(o.jio);
});
test("AllDocs", function () {
var o = generateTools(this), i, m = 15;
o.jio = jIO.newJio({
"type": "local",
"username": "ualldocs",
"application_name": "aalldocs"
});
o.localpath = "jio/localstorage/ualldocs/aalldocs";
// sample data
o.titles = [
"Shawshank Redemption",
"Godfather",
"Godfather 2",
"Pulp Fiction",
"The Good, The Bad and The Ugly",
"12 Angry Men",
"The Dark Knight",
"Schindlers List",
"Lord of the Rings - Return of the King",
"Fight Club",
"Star Wars Episode V",
"Lord Of the Rings - Fellowship of the Ring",
"One flew over the Cuckoo's Nest",
"Inception",
"Godfellas"
];
o.years = [
1994,
1972,
1974,
1994,
1966,
1957,
2008,
1993,
2003,
1999,
1980,
2001,
1975,
2010,
1990
];
o.director = [
"Frank Darabont",
"Francis Ford Coppola",
"Francis Ford Coppola",
"Quentin Tarantino",
"Sergio Leone",
"Sidney Lumet",
"Christopher Nolan",
"Steven Spielberg",
"Peter Jackson",
"David Fincher",
"Irvin Kershner",
"Peter Jackson",
"Milos Forman",
"Christopher Nolan",
"Martin Scorsese"
];
for (i = 0; i < m; i += 1) {
o.fakeDoc = {};
o.fakeDoc._id = "doc_"+(i < 10 ? "0"+i : i);
o.fakeDoc.title = o.titles[i];
o.fakeDoc.year = o.years[i];
o.fakeDoc.author = o.director[i];
if (i === 5) {
o.fakeDoc._attachments = {
"att": {
"digest": "md5-dontcare",
"content_type": "text/plain",
"length": 3
}
};
util.jsonlocalstorage.setItem(o.localpath + "/doc_05/att", "abc");
}
util.jsonlocalstorage.setItem(
o.localpath+"/doc_"+(i < 10 ? "0"+i : i),
o.fakeDoc
);
}
// response
o.allDocsResponse = {};
o.allDocsResponse.rows = [];
o.allDocsResponse.total_rows = 15;
for (i = 0; i < m; i += 1) {
o.allDocsResponse.rows.push({
"id": "doc_"+(i < 10 ? "0"+i : i),
"key": "doc_"+(i < 10 ? "0"+i : i),
"value": {}
});
}
// alldocs
o.spy(o, "value", o.allDocsResponse, "All docs");
o.jio.allDocs(function (err, response) {
if (response && response.rows) {
response.rows.sort(function (a, b) {
return a.id > b.id ? 1 : a.id < b.id ? -1 : 0;
});
}
o.f(err, response);
});
o.tick(o);
// include docs
o.allDocsResponse = {};
o.allDocsResponse.rows = [];
o.allDocsResponse.total_rows = m;
for (i = 0; i < m; i += 1) {
o.allDocsResponse.rows.push({
"id": "doc_"+(i < 10 ? "0"+i : i),
"key": "doc_"+(i < 10 ? "0"+i : i),
"value": {},
"doc": util.jsonlocalstorage.getItem(
o.localpath+"/doc_"+(i < 10 ? "0"+i : i)
)
});
}
// alldocs
o.spy(o, "value", o.allDocsResponse, "All docs (include docs)");
o.jio.allDocs({"include_docs": true}, function (err, response) {
if (response && response.rows) {
response.rows.sort(function (a, b) {
return a.id > b.id ? 1 : a.id < b.id ? -1 : 0;
});
}
o.f(err, response);
});
o.tick(o);
// complex queries
o.thisShouldBeTheAnswer4 = {"total_rows": 0, "rows": []};
o.allDocsResponse.rows.forEach(function (row) {
var new_row;
if (row.doc.year >= 1980) {
new_row = JSON.parse(JSON.stringify(row));
new_row.value.title = row.doc.title;
new_row.value.year = row.doc.year;
delete new_row.doc;
o.thisShouldBeTheAnswer4.rows.push(new_row);
o.thisShouldBeTheAnswer4.total_rows += 1;
}
});
o.thisShouldBeTheAnswer4.rows.sort(function (a, b) {
return a.value.year > b.value.year ? -1 :
a.value.year < b.value.year ? 1 : 0;
});
o.thisShouldBeTheAnswer4.total_rows = 5;
o.thisShouldBeTheAnswer4.rows.length = 5;
o.spy(o, "value", o.thisShouldBeTheAnswer4,
"allDocs (complex queries year >= 1980, all query options)");
o.jio.allDocs({
"query": '(year: >= "1980")',
"limit": [0,5],
"sort_on": [["year", "descending"]],
"select_list": ["title", "year"]
}, o.f);
o.tick(o);
// empty query returns all
o.thisShouldBeTheAnswer5 = {"total_rows": 0, "rows": []};
o.allDocsResponse.rows.forEach(function (row) {
var new_row = JSON.parse(JSON.stringify(row));
new_row.value.title = row.doc.title;
o.thisShouldBeTheAnswer5.rows.push(new_row);
o.thisShouldBeTheAnswer5.total_rows += 1;
});
o.thisShouldBeTheAnswer5.rows.sort(function (a, b) {
return a.value.title > b.value.title ? -1 :
a.value.title < b.value.title ? 1 : 0;
});
o.spy(o, "value", o.thisShouldBeTheAnswer5,
"allDocs (empty query in complex query)");
o.jio.allDocs({
"sort_on": [["title", "descending"]],
"select_list": ["title"],
"include_docs": true
}, o.f);
o.tick(o);
util.closeAndcleanUpJio(o.jio);
});
}));
test/jio/tests.js 0 → 100644
View file @ 23189f9c
/*jslint indent: 2, maxlen: 80, nomen: true */
/*global define, jIO, localStorage, window, test, ok, deepEqual, sinon,
expect */
// define([module_name], [dependencies], module);
(function (dependencies, module) {
"use strict";
if (typeof define === 'function' && define.amd) {
return define(dependencies, module);
}
window.jio_tests = module(jIO);
}(['jio'], function (jIO) {
"use strict";
var to_export = {}, tmp;
// localStorage cleanup
for (tmp in localStorage) {
if (localStorage.hasOwnProperty(tmp)) {
if (/^jio\//.test(tmp)) {
localStorage.removeItem(tmp);
}
}
}
//////////////////////////////////////////////////////////////////////////////
// Tools
function spyJioCallback(result_type, value, message) {
return function (err, response) {
var val;
switch (result_type) {
case 'value':
val = err || response;
break;
case 'status':
val = (err || {}).status;
break;
case 'jobstatus':
val = (err ? 'fail' : 'done');
break;
default:
ok(false, "Unknown case " + result_type);
break;
}
deepEqual(val, value, message);
};
}
to_export.spyJioCallback = spyJioCallback;
/**
* Clones all native object in deep. Managed types: Object, Array, String,
* Number, Boolean, Function, null.
*
* @param {A} object The object to clone
* @return {A} The cloned object
*/
function deepClone(object) {
var i, cloned;
if (Array.isArray(object)) {
cloned = [];
for (i = 0; i < object.length; i += 1) {
cloned[i] = deepClone(object[i]);
}
return cloned;
}
if (typeof object === "object") {
cloned = {};
for (i in object) {
if (object.hasOwnProperty(i)) {
cloned[i] = deepClone(object[i]);
}
}
return cloned;
}
return object;
}
// XXX docstring
function isUuid(uuid) {
var x = "[0-9a-fA-F]";
if (typeof uuid !== "string") {
return false;
}
return (uuid.match(
"^" + x + "{8}-" + x + "{4}-" +
x + "{4}-" + x + "{4}-" + x + "{12}$"
) === null ? false : true);
}
to_export.isUuid = isUuid;
// XXX docstring
to_export.jsonlocalstorage = {
clear: function () {
return localStorage.clear();
},
getItem: function (item) {
var value = localStorage.getItem(item);
return value === null ? null : JSON.parse(value);
},
setItem: function (item, value) {
return localStorage.setItem(item, JSON.stringify(value));
},
removeItem: function (item) {
return localStorage.removeItem(item);
}
};
function objectifyDocumentArray(array) {
var obj = {}, k;
for (k = 0; k < array.length; k += 1) {
obj[array[k]._id] = array[k];
}
return obj;
}
function closeAndcleanUpJio(jio) {
jio.close();
to_export.jsonlocalstorage.removeItem("jio/id/" + jio.getId());
to_export.jsonlocalstorage.removeItem("jio/job_array/" + jio.getId());
}
to_export.closeAndcleanUpJio = closeAndcleanUpJio;
function getJioLastJob(jio) {
return (to_export.jsonlocalstorage.getItem(
"jio/job_array/" + jio.getId()
) || [undefined]).pop();
}
//////////////////////////////////////////////////////////////////////////////
// Compatibility
function ospy(o, result_type, value, message, function_name) {
function_name = function_name || 'f';
o[function_name] = function (err, response) {
var val;
switch (result_type) {
case 'value':
val = err || response;
break;
case 'status':
val = (err || {}).status;
break;
case 'jobstatus':
val = (err ? 'fail' : 'done');
break;
default:
ok(false, "Unknown case " + result_type);
break;
}
deepEqual(val, value, message);
};
sinon.spy(o, function_name);
}
to_export.ospy = ospy;
function otick(o, a, b) {
var tick = 10000, function_name = 'f';
if (typeof a === 'number' && !isNaN(a)) {
tick = a;
a = b;
}
if (typeof a === 'string') {
function_name = a;
}
o.clock.tick(tick);
if (!o[function_name].calledOnce) {
if (o[function_name].called) {
ok(false, 'too much results');
} else {
ok(false, 'no response');
}
}
}
to_export.otick = otick;
//////////////////////////////////////////////////////////////////////////////
// Dummy Storage
// XX docstring
function dummyStorage(spec, my) {
var that = my.basicStorage(spec, my);
that._mode = spec.mode || 'normal';
that._key = spec.key;
that._value = spec.value;
if (that._mode === 'spec error') {
throw new TypeError(
"Initialization error set by the storage description."
);
}
that.specToStore = function () {
return {
"mode": that._mode,
"key": that._key,
"value": that._value
};
};
that.post = function (command) {
setTimeout(function () {
var metadata = command.cloneDoc(), options = command.cloneOption();
if (that._mode === 'no response') {
return;
}
// if (that._mode === 'no response + timeout reset') {
// return setTimeout(function () {
// command.resetTimeout();
// }, that._value);
// }
if (that._mode === 'invalid error response') {
return that.error();
}
if (that._mode === 'always fail') {
return that.error({
"error": "conflict",
"message": "",
"reason": "unknown",
"status": 409,
"statusText": "Conflict"
});
}
if (that._mode === 'post response no id') {
return that.success();
}
that.success({"id": "document id a", "ok": true});
});
};
that.put = function (command) {
setTimeout(function () {
var metadata = command.cloneDoc(), options = command.cloneOption();
if (that._mode === 'retry') {
if (!dummyStorage[that._key]) {
dummyStorage[that._key] = 0;
}
dummyStorage[that._key] += 1;
if (dummyStorage[that._key] === that._value) {
return that.success({"id": metadata._id, "ok": true});
}
return that.retry();
}
that.success({"id": metadata._id, "ok": true});
});
};
that.remove = function (command) {
setTimeout(function () {
var metadata = command.cloneDoc(), options = command.cloneOption();
that.success({"id": metadata._id, "ok": true});
});
};
return that;
}
jIO.addStorageType('dummy', dummyStorage);
to_export.dummyStorage = dummyStorage;
//////////////////////////////////////////////////////////////////////////////
// Tests
module("JIO");
/**
* Tests the instance initialization
*/
test('Instanciation', function () {
expect(1);
var jio = jIO.newJio(undefined);
// tests if jio is an object
ok(typeof jio === 'object', 'Init ok!');
// checks the workspace
// XXX nothing to check for the moment, need to be implemented first
closeAndcleanUpJio(jio);
});
module("JIO Dummy Storage");
// XXX This will be uncommented when given parameters checking will be implem
// /**
// * Tests wrong commands
// */
// test('Wrong parameters', function () {
// var result, jio = jIO.newJio({
// "type": "dummy",
// "mode": "normal"
// }, {
// "workspace": {}
// });
// try {
// jio.post(); // post(kwargs, [options], [callbacks]);
// result = "No error thrown";
// } catch (e1) {
// result = e1.name + ": " + e1.message;
// }
// deepEqual(
// result,
// "TypeError: JIO().post(): Argument 1 is not of type 'object'",
// "Wrong parameter"
// );
// try {
// jio.allDocs(); // allDocs([options], [callbacks]);
// result = "No error thrown";
// } catch (e2) {
// result = e2.name + ": " + e2.message;
// }
// deepEqual(result, "No error thrown", "Good parameter");
// });
// XXX this will be uncommented when validateState will be replaced by a
// simple `throw` in the storage init
// /**
// * Tests a storage initialization error
// */
// test('Description Error', function () {
// var clock, jio;
// clock = sinon.useFakeTimers();
// jio = jIO.newJio({
// "type": "blue"
// }, {
// "workspace": {}
// });
// // Tests wrong storage type
// jio.post({}).always(function (answer) {
// deepEqual(answer, {
// "error": "internal_storage_error",
// "message": "Check if the storage description respects the " +
// "constraints provided by the storage designer. (TypeError: " +
// "Unknown storage 'blue')",
// "reason": "invalid description",
// "status": 551,
// "statusText": "Internal Storage Error"
// }, "Unknown storage");
// });
// clock.tick(1);
// // Tests wrong storage description
// jio = jIO.newJio({
// "type": "dummy",
// "mode": "spec error"
// }, {
// "workspace": {}
// });
// jio.post({}).always(function (answer) {
// deepEqual(answer, {
// "error": "internal_storage_error",
// "message": "Check if the storage description respects the " +
// "constraints provided by the storage designer. (TypeError: " +
// "Initialization error set by the storage description.)",
// "reason": "invalid description",
// "status": 551,
// "statusText": "Internal Storage Error"
// }, "Initialization error");
// });
// clock.tick(1);
// });
// XXX timeout is not implemented yet
// /**
// * Tests a command which does not respond
// */
// test('No Response or Response Timeout', function () {
// var clock, jio, state;
// expect(5);
// clock = sinon.useFakeTimers();
// jio = jIO.newJio({
// "type": "dummy",
// "mode": "no response"
// }, {
// "workspace": {}
// });
// // tests with default timeout
// jio.post({}).always(function (answer) {
// deepEqual(answer, {
// "error": "request_timeout",
// "message": "Operation canceled after around 10000 milliseconds.",
// "reason": "timeout",
// "status": 408,
// "statusText": "Request Timeout"
// }, "Timeout error (default timeout)");
// });
// clock.tick(10000); // wait 10 seconds
// jio = jIO.newJio({
// "type": "dummy",
// "mode": "no response + timeout reset",
// "value": 5000 // reset after 5 seconds
// }, {
// "workspace": {}
// });
// // tests with storage timeout extension
// state = "Not called yet";
// jio.post({}).always(function (answer) {
// state = "Called";
// deepEqual(answer, {
// "error": "request_timeout",
// "message": "Operation canceled after around 15000 milliseconds.",
// "reason": "timeout",
// "status": 408,
// "statusText": "Request Timeout"
// }, "Timeout error (storage timeout reset)");
// });
// clock.tick(10000); // wait 10 seconds
// deepEqual(state, "Not called yet", "Check callback state.");
// clock.tick(5000); // wait 5 seconds
// jio = jIO.newJio({
// "type": "dummy",
// "mode": "no response"
// }, {
// "workspace": {},
// "default_timeout": 2
// });
// // tests with jio option timeout
// jio.post({}).always(function (answer) {
// deepEqual(answer, {
// "error": "request_timeout",
// "message": "Operation canceled after around 2 milliseconds.",
// "reason": "timeout",
// "status": 408,
// "statusText": "Request Timeout"
// }, "Timeout error (specific default timeout)");
// });
// clock.tick(2);
// // tests with command option timeout
// jio.post({}, {"timeout": 50}).always(function (answer) {
// deepEqual(answer, {
// "error": "request_timeout",
// "message": "Operation canceled after around 50 milliseconds.",
// "reason": "timeout",
// "status": 408,
// "statusText": "Request Timeout"
// }, "Timeout error (command timeout)");
// });
// clock.tick(50);
// });
// /**
// * Tests wrong responses
// */
// test('Invalid Response', function () {
// var clock, jio;
// clock = sinon.useFakeTimers();
// jio = jIO.newJio({
// "type": "dummy",
// "mode": "post response no id"
// });
// jio.post({}, function (err, response) {
// deepEqual(err || response, {
// "error": "internal_storage_error",
// "message": "New document id have to be specified",
// "reason": "invalid response",
// "status": 551,
// "statusText": "Internal Storage Error"
// }, "Invalid Post Response");
// });
// clock.tick(1000);
// closeAndcleanUpJio(jio);
// jio = jIO.newJio({
// "type": "dummy",
// "mode": "invalid error response"
// });
// jio.post({}, function (err, response) {
// deepEqual(err || response, {
// "error": "internal_storage_error",
// "message": "Unknown status \"undefined\"",
// "reason": "invalid response",
// "status": 551,
// "statusText": "Internal Storage Error"
// }, "Invalid Post Error Response");
// });
// clock.tick(1000);
// closeAndcleanUpJio(jio);
// });
/**
* Tests a valid responses
*/
test('Valid Responses & Callbacks', function () {
expect(4);
var clock, jio, message;
clock = sinon.useFakeTimers();
jio = jIO.newJio({
"type": "dummy",
"mode": "normal"
});
// Tests post command callbacks post(metadata).always(onResponse) +
// valid response.
message = "Post Command: post(metadata).always(function (answer) {..}) + " +
"valid response.";
jio.post({}, function (err, response) {
deepEqual(err || response, {
"ok": true,
"id": "document id a"
}, message);
});
clock.tick(1000);
// Tests post command callbacks post(metadata).done(onSuccess).fail(onError)
message = "Post Command: post(metadata).done(function (answer) {..})." +
"fail(function (answer) {..})";
jio.post({}, function (answer) {
deepEqual(answer, {
"ok": true,
"id": "document id a"
}, message);
}, function (answer) {
deepEqual(answer, "Should not fail", message);
});
clock.tick(1000);
// Tests post command callbacks post(metadata, onResponse)
message = "Post Command: post(metadata, function (err, response) {..})";
jio.post({}, function (err, response) {
if (err) {
return deepEqual(err, "Should not fail", message);
}
deepEqual(response, {
"ok": true,
"id": "document id a"
}, message);
});
clock.tick(1000);
closeAndcleanUpJio(jio);
// Tests post command callbacks post(metadata, onSuccess, onError) + error
// response.
message = "Post Command: post(metadata, function (response) {..}, " +
"function (err) {..}) + valid error response.";
jio = jIO.newJio({
"type": "dummy",
"mode": "always fail"
});
jio.post({}, function (response) {
deepEqual(response, "Should fail", message);
}, function (err) {
deepEqual(err, {
"status": 409,
"statusText": "Conflict",
"error": "conflict",
"reason": "unknown",
"message": ""
}, message);
});
clock.tick(1000);
closeAndcleanUpJio(jio);
});
module("JIO Job Management");
test("Several Jobs at the same time", function () {
expect(3);
var clock = sinon.useFakeTimers(), jio = jIO.newJio({"type": "dummy"});
jio.put({"_id": "file1", "title": "t1"}, spyJioCallback('value', {
"ok": true,
"id": "file1"
}, "job1"));
jio.put({"_id": "file2", "title": "t2"}, spyJioCallback('value', {
"ok": true,
"id": "file2"
}, "job2"));
jio.put({"_id": "file3", "title": "t3"}, spyJioCallback('value', {
"ok": true,
"id": "file3"
}, "job3"));
clock.tick(1000);
closeAndcleanUpJio(jio);
});
test("Similar Jobs at the same time (Update)", function () {
expect(8);
var clock = sinon.useFakeTimers(), jio = jIO.newJio({"type": "dummy"});
function compareResults(err, response) {
deepEqual(err || response, {"id": "file", "ok": true}, "job ok");
}
jio.put({"_id": "file", "title": "t"}, compareResults);
jio.put({"_id": "file", "title": "t"}, compareResults);
jio.put({"_id": "file", "title": "t"}, compareResults);
deepEqual(getJioLastJob(jio).id, 1, "Check job queue");
clock.tick(1000);
jio.put({"_id": "file", "content": "content"}, compareResults);
jio.remove({"_id": "file", "content": "content"}, compareResults);
jio.put({"_id": "file", "content": "content"}, compareResults);
deepEqual(getJioLastJob(jio).id, 5, "Check job queue");
clock.tick(10000);
closeAndcleanUpJio(jio);
});
test("Same document jobs at the same time (Wait for job(s))", function () {
expect(6);
var clock = sinon.useFakeTimers(), jio = jIO.newJio({"type": "dummy"});
function compareResults(err, response) {
deepEqual(err || response, {"id": "file", "ok": true}, "job ok");
}
jio.put({"_id": "file", "content": "content"}, compareResults);
deepEqual(
getJioLastJob(jio).status.waitforjob,
undefined,
"Job 1 is not waiting for someone"
);
jio.remove({"_id": "file", "content": "content"}, compareResults);
deepEqual(
getJioLastJob(jio).status.waitforjob,
[1],
"Job 2 is wainting for 1"
);
jio.put({"_id": "file"}, compareResults);
deepEqual(
getJioLastJob(jio).status.waitforjob,
[1, 2],
"Job 3 is waiting for 1 and 2"
);
clock.tick(1000);
closeAndcleanUpJio(jio);
});
test("Server will be available soon (Wait for time)", function () {
expect(2);
var clock = sinon.useFakeTimers(), jio;
jio = jIO.newJio({
"type": "dummy",
"mode": "retry",
"key": "035139054",
"value": 3
});
jio.put(
{"_id": "file", "content": "content"},
{"max_retry": 3},
function (err, response) {
deepEqual(err || response, {"id": "file", "ok": true}, "Job ok");
}
);
clock.tick(2000);
deepEqual(dummyStorage['035139054'], 3, "tried 3 times");
delete dummyStorage['035139054'];
closeAndcleanUpJio(jio);
});
test("Restore old Jio", function () {
var o = {
clock: sinon.useFakeTimers(),
spy: ospy,
tick: otick
};
function waitUntilLastJobIs(state) {
while (true) {
if (getJioLastJob(o.jio) === undefined) {
ok(false, "No job have state: " + state);
break;
}
if (getJioLastJob(o.jio).status.label === state) {
break;
}
o.clock.tick(25);
}
}
function waitUntilAJobExists(timeout) {
var cpt = 0, job = false;
while (true) {
if (getJioLastJob(o.jio) !== undefined) {
job = true;
break;
}
if (cpt >= timeout) {
break;
}
o.clock.tick(25);
cpt += 25;
}
ok(job, "Wait until a job is created");
}
o.jio = jIO.newJio({
"type": "dummy",
"mode": "retry",
"key": "12314",
"value": 3
});
o.jio_id = o.jio.getId();
o.jio.put({"_id": "file", "title": "myFile"}, {"max_retry":3}, o.f);
waitUntilLastJobIs("initial"); // "on going" or "wait" should work
// xxx also test with waitUntilLastJobIs("on going") ?
o.jio.close();
o.jio = jIO.newJio({
"type": "dummy",
"mode": "retry",
"key": "12314",
"value": 3
});
waitUntilAJobExists(30000); // timeout 30 sec
deepEqual(getJioLastJob(o.jio).command.label, 'put', 'Job restored');
o.clock.tick(2000);
ok(getJioLastJob(o.jio) === undefined, "Job executed");
o.clock.tick(1000);
to_export.jsonlocalstorage.removeItem("jio/id/" + o.jio_id);
to_export.jsonlocalstorage.removeItem("jio/job_array/" + o.jio_id);
closeAndcleanUpJio(o.jio);
});
return to_export;
}));
test/jiotests.js
View file @ 23189f9c
...@@ -401,59 +401,6 @@ test("Additional Filters", function () { ...@@ -401,59 +401,6 @@ test("Additional Filters", function () {
], 'The first document should be kept'); ], 'The first document should be kept');
}); });
module ('Jio Global tests');
test ( "Jio simple methods", function () {
// Test Jio simple methods
// It checks if we can create several instance of jio at the same
// time. Checks if they don't overlap informations, if they are
// started and stopped correctly and if they are ready when they
// have to be ready.
var o = generateTools(this);
o.jio = JIO.newJio();
ok ( o.jio, 'a new jio -> 1');
o.jio2 = JIO.newJio();
ok ( o.jio2, 'another new jio -> 2');
JIO.addStorageType('qunit', empty_fun);
ok ( o.jio2.getId() !== o.jio.getId(), '1 and 2 must be different');
o.jio.stop();
o.jio2.stop();
});
// test ( 'Jio Publish/Sububscribe/Unsubscribe methods', function () {
// // Test the Publisher, Subscriber of a single jio.
// // It is just testing if these function are working correctly.
// // The test publishes an event, waits a little, and check if the
// // event has been received by the callback of the previous
// // subscribe. Then, the test unsubscribe the callback function from
// // the event, and publish the same event. If it receives the event,
// // the unsubscribe method is not working correctly.
// var o = {};
// o.jio = JIO.newJio();
// var spy1 = this.spy();
// // Subscribe the pubsub_test event.
// o.callback = o.jio.subscribe('pubsub_test',spy1);
// // And publish the event.
// o.jio.publish('pubsub_test');
// ok (spy1.calledOnce, 'subscribing & publishing, event called once');
// o.jio.unsubscribe('pubsub_test',spy1);
// o.jio.publish('pubsub_test');
// ok (spy1.calledOnce, 'unsubscribing, same event not called twice');
// o.jio.stop();
// });
module ( "Jio Dummy Storages" ); module ( "Jio Dummy Storages" );
test ("All requests ok", function () { test ("All requests ok", function () {
...@@ -752,636 +699,6 @@ test ("All document found", function () { ...@@ -752,636 +699,6 @@ test ("All document found", function () {
o.jio.stop(); o.jio.stop();
}); });
module ( "Jio Job Managing" );
test ("Several Jobs at the same time", function () {
var o = generateTools(this);
o.jio = JIO.newJio({"type":"dummyallok"});
o.spy(o, "value", {"ok": true, "id": "file"}, "job1", "f");
o.spy(o, "value", {"ok": true, "id": "file2"}, "job2", "f2");
o.spy(o, "value", {"ok": true, "id": "file3"}, "job3", "f3");
o.jio.put({"_id": "file", "content": "content"}, o.f);
o.jio.put({"_id": "file2", "content": "content2"}, o.f2);
o.jio.put({"_id": "file3", "content": "content3"}, o.f3);
o.tick(o, 1000, "f");
o.tick(o, "f2");
o.tick(o, "f3");
o.jio.stop();
});
test ("Similar Jobs at the same time (Update)", function () {
var o = generateTools(this);
o.jio = JIO.newJio({"type":"dummyallok"});
o.spy(o, "value", {"ok": true, "id": "file"}, "job1 ok", "f");
o.spy(o, "value", {"ok": true, "id": "file"}, "job2 ok", "f2");
o.spy(o, "value", {"ok": true, "id": "file"}, "job3 ok", "f3");
o.jio.put({"_id": "file", "content": "content"}, o.f); // 1
o.jio.put({"_id": "file", "content": "content"}, o.f2); // 2
o.jio.put({"_id": "file", "content": "content"}, o.f3); // 3
deepEqual(getLastJob(o.jio.getId()).id, 1, "Check job queue");
o.tick(o, 1000, "f");
o.tick(o, "f2");
o.tick(o, "f3");
o.spy(o, "value", {"ok": true, "id": "file"}, "job4 ok", "f");
o.spy(o, "value", {"ok": true, "id": "file"}, "job5 ok", "f2");
o.spy(o, "value", {"ok": true, "id": "file"}, "job6 ok", "f3");
o.jio.put({"_id": "file", "content": "content"}, o.f); // 4
o.jio.remove({"_id": "file", "content": "content"}, o.f2); // 5
o.jio.put({"_id": "file", "content": "content"}, o.f3); // 6
deepEqual(getLastJob(o.jio.getId()).id, 5, "Check job queue");
o.tick(o, 1000, "f");
o.tick(o, "f2");
o.tick(o, "f3");
o.jio.stop();
});
test ("One document aim jobs at the same time (Wait for job(s))" , function () {
var o = generateTools(this);
o.jio = JIO.newJio({"type":"dummyallok"});
o.spy(o, "value", {"ok": true, "id": "file"}, "job1", "f");
o.spy(o, "value", {"ok": true, "id": "file"}, "job2", "f2");
o.spy(o, "value", {"ok": true, "id": "file"}, "job3", "f3");
o.jio.put({"_id": "file", "content": "content"}, o.f);
o.testLastJobWaitForJob(undefined, "job1 is not waiting for someone");
o.jio.remove({"_id": "file", "content": "content"}, o.f2);
o.testLastJobWaitForJob([1], "job2 is waiting");
o.jio.put({"_id": "file"}, o.f3);
o.testLastJobWaitForJob([1, 2], "job3 is waiting");
o.tick(o, 1000, "f");
o.tick(o, "f2");
o.tick(o, "f3");
o.spy(o, "value", {"ok": true, "id": "lol"}, "Chaining callbacks");
o.jio.removeAttachment({
"_id": "lol",
"_attachment": "hu"
}, function (err, response) {
if (err) {
return;
}
o.jio.remove({"_id": "lol"}, o.f);
});
o.tick(o, 10000);
o.jio.stop();
});
test ("Server will be available soon (Wait for time)" , function () {
var o = generateTools(this);
o.max_retry = 3;
o.jio = JIO.newJio({"type":"dummyall3tries"});
o.spy(o, "value", {"ok": true, "id": "file"}, "job1", "f");
o.jio.put({"_id": "file", "content": "content"},
{"max_retry": o.max_retry}, o.f);
for (o.i = 0; o.i < o.max_retry - 1; o.i += 1) {
o.waitUntilLastJobIs("on going");
o.waitUntilLastJobIs("wait");
o.testLastJobWaitForTime("job1 is waiting for time");
}
o.tick(o, 1000, "f");
o.jio.stop();
});
module ( "Jio Restore");
test ("Restore old Jio", function() {
var o = generateTools(this);
o.jio = JIO.newJio({
"type": "dummyall3tries",
"application_name": "jiotests"
});
o.jio_id = o.jio.getId();
o.jio.put({"_id": "file", "title": "myFile"}, {"max_retry":3}, o.f);
o.waitUntilLastJobIs("initial"); // "on going" or "wait" should work
// xxx also test with o.waitUntilLastJobIs("on going") ?
o.jio.close();
o.jio = JIO.newJio({
"type": "dummyallok",
"application_name": "jiotests"
});
o.waitUntilAJobExists(30000); // timeout 30 sec
o.testLastJobLabel("put", "Job restored");
o.clock.tick(2000);
ok(getLastJob(o.jio.getId()) === undefined, "Job executed");
o.clock.tick(1000);
o.jio.stop();
});
module ( "Jio LocalStorage" );
test ("Post", function(){
var o = generateTools(this);
o.jio = JIO.newJio({
"type": "local",
"username": "upost",
"application_name": "apost"
});
// post without id
o.spy (o, "jobstatus", "done", "Post without id");
o.jio.post({}, function (err, response) {
var uuid;
o.f(err, response);
uuid = (err || response).id;
ok(isUuid(uuid), "Uuid should look like " +
"xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx : " + uuid);
});
o.tick(o);
// post non empty document
o.spy (o, "value", {"ok": true, "id": "post1"}, "Post");
o.jio.post({"_id": "post1", "title": "myPost1"}, o.f);
o.tick(o);
deepEqual(
localstorage.getItem("jio/localstorage/upost/apost/post1"),
{
"_id": "post1",
"title": "myPost1"
},
"Check document"
);
// post but document already exists
o.spy (o, "status", 409, "Post but document already exists");
o.jio.post({"_id": "post1", "title": "myPost2"}, o.f);
o.tick(o);
o.jio.stop();
});
test ("Put", function(){
var o = generateTools(this);
o.jio = JIO.newJio({
"type": "local",
"username": "uput",
"application_name": "aput"
});
// put without id
// error 20 -> document id required
o.spy (o, "status", 20, "Put without id");
o.jio.put({}, o.f);
o.tick(o);
// put non empty document
o.spy (o, "value", {"ok": true, "id": "put1"}, "Creates a document");
o.jio.put({"_id": "put1", "title": "myPut1"}, o.f);
o.tick(o);
// check document
deepEqual(
localstorage.getItem("jio/localstorage/uput/aput/put1"),
{
"_id": "put1",
"title": "myPut1"
},
"Check document"
);
// put but document already exists
o.spy (o, "value", {"ok": true, "id": "put1"}, "Update the document");
o.jio.put({"_id": "put1", "title": "myPut2"}, o.f);
o.tick(o);
// check document
deepEqual(
localstorage.getItem("jio/localstorage/uput/aput/put1"),
{
"_id": "put1",
"title": "myPut2"
},
"Check document"
);
o.jio.stop();
});
test ("PutAttachment", function(){
var o = generateTools(this);
o.jio = JIO.newJio({
"type": "local",
"username": "uputattmt",
"application_name": "aputattmt"
});
// putAttachment without doc id
// error 20 -> document id required
o.spy(o, "status", 20, "PutAttachment without doc id");
o.jio.putAttachment({}, o.f);
o.tick(o);
// putAttachment without attachment id
// error 22 -> attachment id required
o.spy(o, "status", 22, "PutAttachment without attachment id");
o.jio.putAttachment({"_id": "putattmt1"}, o.f);
o.tick(o);
// putAttachment without document
// error 404 -> not found
o.spy(o, "status", 404, "PutAttachment without document");
o.jio.putAttachment({"_id": "putattmt1", "_attachment": "putattmt2"}, o.f);
o.tick(o);
// adding a document
localstorage.setItem("jio/localstorage/uputattmt/aputattmt/putattmt1", {
"_id": "putattmt1",
"title": "myPutAttmt1"
});
// putAttachment with document
o.spy(o, "value",
{"ok": true, "id": "putattmt1", "attachment": "putattmt2"},
"PutAttachment with document, without data");
o.jio.putAttachment({"_id": "putattmt1", "_attachment": "putattmt2"}, o.f);
o.tick(o);
// check document
deepEqual(
localstorage.getItem("jio/localstorage/uputattmt/aputattmt/putattmt1"),
{
"_id": "putattmt1",
"title": "myPutAttmt1",
"_attachments": {
"putattmt2": {
"length": 0,
// md5("")
"digest": "md5-d41d8cd98f00b204e9800998ecf8427e"
}
}
},
"Check document"
);
// check attachment
deepEqual(
localstorage.getItem(
"jio/localstorage/uputattmt/aputattmt/putattmt1/putattmt2"),
"", "Check attachment"
);
// update attachment
o.spy(o, "value",
{"ok": true, "id": "putattmt1", "attachment": "putattmt2"},
"Update Attachment, with data");
o.jio.putAttachment({
"_id": "putattmt1",
"_attachment": "putattmt2",
"_data": "abc"
}, o.f);
o.tick(o);
// check document
deepEqual(
localstorage.getItem("jio/localstorage/uputattmt/aputattmt/putattmt1"),
{
"_id": "putattmt1",
"title": "myPutAttmt1",
"_attachments": {
"putattmt2": {
"length": 3,
// md5("abc")
"digest": "md5-900150983cd24fb0d6963f7d28e17f72"
}
}
},
"Check document"
);
// check attachment
deepEqual(
localstorage.getItem(
"jio/localstorage/uputattmt/aputattmt/putattmt1/putattmt2"),
"abc", "Check attachment"
);
o.jio.stop();
});
test ("Get", function(){
var o = generateTools(this);
o.jio = JIO.newJio({
"type": "local",
"username": "uget",
"application_name": "aget"
});
// get inexistent document
o.spy(o, "status", 404, "Get inexistent document");
o.jio.get({"_id": "get1"}, o.f);
o.tick(o);
// get inexistent attachment
o.spy(o, "status", 404, "Get inexistent attachment");
o.jio.getAttachment({"_id": "get1", "_attachment": "get2"}, o.f);
o.tick(o);
// adding a document
o.doc_get1 = {
"_id": "get1",
"title": "myGet1"
};
localstorage.setItem("jio/localstorage/uget/aget/get1", o.doc_get1);
// get document
o.spy(o, "value", o.doc_get1, "Get document");
o.jio.get({"_id": "get1"}, o.f);
o.tick(o);
// get inexistent attachment (document exists)
o.spy(o, "status", 404, "Get inexistent attachment (document exists)");
o.jio.getAttachment({"_id": "get1", "_attachment": "get2"}, o.f);
o.tick(o);
// adding an attachment
o.doc_get1["_attachments"] = {
"get2": {
"length": 2,
// md5("de")
"digest": "md5-5f02f0889301fd7be1ac972c11bf3e7d"
}
};
localstorage.setItem("jio/localstorage/uget/aget/get1", o.doc_get1);
localstorage.setItem("jio/localstorage/uget/aget/get1/get2", "de");
// get attachment
o.spy(o, "value", "de", "Get attachment");
o.jio.getAttachment({"_id": "get1", "_attachment": "get2"}, o.f);
o.tick(o);
o.jio.stop();
});
test ("Remove", function(){
var o = generateTools(this);
o.jio = JIO.newJio({
"type": "local",
"username": "uremove",
"application_name": "aremove"
});
// remove inexistent document
o.spy(o, "status", 404, "Remove inexistent document");
o.jio.remove({"_id": "remove1"}, o.f);
o.tick(o);
// remove inexistent attachment
o.spy(o, "status", 404, "Remove inexistent attachment");
o.jio.removeAttachment({"_id": "remove1", "_attachment": "remove2"}, o.f);
o.tick(o);
// adding a document + attmt
localstorage.setItem("jio/localstorage/uremove/aremove/remove1", {
"_id": "remove1",
"title": "myRemove1",
"_attachments": {
"remove2": {
"length": 4,
"digest": "md5-blahblah"
}
}
});
localstorage.setItem(
"jio/localstorage/uremove/aremove/remove1/remove2", "fghi");
// remove attachment
o.spy(o, "value", {"ok": true, "id": "remove1", "attachment": "remove2"},
"Remove document");
o.jio.removeAttachment({"_id": "remove1", "_attachment": "remove2"}, o.f);
o.tick(o);
// remove document
o.spy(o, "value", {"ok": true, "id": "remove1"}, "Remove document");
o.jio.remove({"_id": "remove1"}, o.f);
o.tick(o);
// check document
ok(localstorage.getItem("jio/localstorage/uremove/aremove/remove1")===null,
"Check document is removed");
// adding a document + attmt
localstorage.setItem("jio/localstorage/uremove/aremove/remove1", {
"_id": "remove1",
"title": "myRemove1",
"_attachments": {
"remove2": {
"length": 4,
"digest": "md5-blahblah"
}
}
});
localstorage.setItem(
"jio/localstorage/uremove/aremove/remove1/remove2", "fghi");
// remove attachment
o.spy(o, "value", {"ok": true, "id": "remove1"},
"Remove document and attachment");
o.jio.remove({"_id": "remove1"}, o.f);
o.tick(o);
ok(localstorage.getItem("jio/localstorage/uremove/aremove/remove1"
)===null, "Check document is removed");
ok(localstorage.getItem("jio/localstorage/uremove/aremove/remove1/remove2"
)===null, "Check attachment is removed");
o.jio.stop();
});
test ("AllDocs", function(){
var o = generateTools(this), i, m = 15;
o.jio = JIO.newJio({
"type": "local",
"username": "ualldocs",
"application_name": "aalldocs"
});
o.localpath = "jio/localstorage/ualldocs/aalldocs";
// sample data
o.titles = ["Shawshank Redemption", "Godfather", "Godfather 2",
"Pulp Fiction", "The Good, The Bad and The Ugly", "12 Angry Men",
"The Dark Knight", "Schindlers List",
"Lord of the Rings - Return of the King", "Fight Club",
"Star Wars Episode V", "Lord Of the Rings - Fellowship of the Ring",
"One flew over the Cuckoo's Nest", "Inception", "Godfellas"
];
o.years = [1994,1972,1974,1994,1966,1957,2008,1993,2003,1999,1980,2001,
1975,2010,1990
];
o.director = ["Frank Darabont", "Francis Ford Coppola",
"Francis Ford Coppola", "Quentin Tarantino", "Sergio Leone",
"Sidney Lumet", "Christopher Nolan", "Steven Spielberg",
"Peter Jackson", "David Fincher", "Irvin Kershner", "Peter Jackson",
"Milos Forman", "Christopher Nolan", " Martin Scorsese"
]
for (i = 0; i < m; i += 1) {
o.fakeDoc = {};
o.fakeDoc._id = "doc_"+(i < 10 ? "0"+i : i);
o.fakeDoc.title = o.titles[i];
o.fakeDoc.year = o.years[i];
o.fakeDoc.author = o.director[i];
if (i === 5) {
o.fakeDoc._attachments = {
"att": {
"digest": "md5-dontcare",
"content_type": "text/plain",
"length": 3
}
};
localstorage.setItem(o.localpath + "/doc_05/att", "abc");
}
localstorage.setItem(o.localpath+"/doc_"+(i < 10 ? "0"+i : i), o.fakeDoc);
}
// response
o.allDocsResponse = {};
o.allDocsResponse.rows = [];
o.allDocsResponse.total_rows = 15;
for (i = 0; i < m; i += 1) {
o.allDocsResponse.rows.push({
"id": "doc_"+(i < 10 ? "0"+i : i),
"key": "doc_"+(i < 10 ? "0"+i : i),
"value": {}
});
};
// alldocs
o.spy(o, "value", o.allDocsResponse, "All docs");
o.jio.allDocs(function (err, response) {
if (response && response.rows) {
response.rows.sort(function (a, b) {
return a.id > b.id ? 1 : a.id < b.id ? -1 : 0;
});
}
o.f(err, response);
});
o.tick(o);
// include docs
o.allDocsResponse = {};
o.allDocsResponse.rows = [];
o.allDocsResponse.total_rows = m;
for (i = 0; i < m; i += 1) {
o.allDocsResponse.rows.push({
"id": "doc_"+(i < 10 ? "0"+i : i),
"key": "doc_"+(i < 10 ? "0"+i : i),
"value": {},
"doc": localstorage.getItem(o.localpath+"/doc_"+(i < 10 ? "0"+i : i))
});
};
// alldocs
o.spy(o, "value", o.allDocsResponse, "All docs (include docs)");
o.jio.allDocs({"include_docs": true}, function (err, response) {
if (response && response.rows) {
response.rows.sort(function (a, b) {
return a.id > b.id ? 1 : a.id < b.id ? -1 : 0;
});
}
o.f(err, response);
});
o.tick(o);
// complex queries
o.thisShouldBeTheAnswer4 = {"total_rows": 0, "rows": []};
o.allDocsResponse.rows.forEach(function (row) {
var new_row;
if (row.doc.year >= 1980) {
new_row = JSON.parse(JSON.stringify(row));
new_row.value.title = row.doc.title;
new_row.value.year = row.doc.year;
delete new_row.doc;
o.thisShouldBeTheAnswer4.rows.push(new_row);
o.thisShouldBeTheAnswer4.total_rows += 1;
}
});
o.thisShouldBeTheAnswer4.rows.sort(function (a, b) {
return a.value.year > b.value.year ? -1 :
a.value.year < b.value.year ? 1 : 0;
});
o.thisShouldBeTheAnswer4.total_rows = 5;
o.thisShouldBeTheAnswer4.rows.length = 5;
o.spy(o, "value", o.thisShouldBeTheAnswer4,
"allDocs (complex queries year >= 1980, all query options)");
o.jio.allDocs({
"query": '(year: >= "1980")',
"limit": [0,5],
"sort_on": [["year", "descending"]],
"select_list": ["title", "year"]
}, o.f);
o.tick(o);
// empty query returns all
o.thisShouldBeTheAnswer5 = {"total_rows": 0, "rows": []};
o.allDocsResponse.rows.forEach(function (row) {
var new_row = JSON.parse(JSON.stringify(row));
new_row.value.title = row.doc.title;
o.thisShouldBeTheAnswer5.rows.push(new_row);
o.thisShouldBeTheAnswer5.total_rows += 1;
});
o.thisShouldBeTheAnswer5.rows.sort(function (a, b) {
return a.value.title > b.value.title ? -1 :
a.value.title < b.value.title ? 1 : 0;
});
o.spy(o, "value", o.thisShouldBeTheAnswer5,
"allDocs (empty query in complex query)");
o.jio.allDocs({
"sort_on": [["title", "descending"]],
"select_list": ["title"],
"include_docs": true
}, o.f);
o.tick(o);
o.jio.stop();
});
module ( "Jio Revision Storage + Local Storage" ); module ( "Jio Revision Storage + Local Storage" );
test ("Post", function(){ test ("Post", function(){
......
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