Skip to content

O
officejs
Commit 0667c061 authored by Tristan Cavelier's avatar Tristan Cavelier
Browse files
Options

saveDocument and loadDocument from conflictmanagerstorage are completed

parent 5e4c414a
Show whitespace changes
Inline Side-by-side
Showing with 528 additions and 149 deletions
OfficeJS/grunt/20_gruntJIOStorage/grunt.js
View file @ 0667c061
...@@ -61,6 +61,7 @@ module.exports = function(grunt) { ...@@ -61,6 +61,7 @@ module.exports = function(grunt) {
LocalOrCookieStorage: true, LocalOrCookieStorage: true,
Base64: true, Base64: true,
MD5: true, MD5: true,
hex_sha256: true,
jio: true, jio: true,
console: true, console: true,
unescape: true, unescape: true,
......
OfficeJS/lib/jio/jio.storage.js
View file @ 0667c061
/*! JIO Storage - v0.1.0 - 2012-06-21 /*! JIO Storage - v0.1.0 - 2012-06-22
* Copyright (c) 2012 Nexedi; Licensed */ * Copyright (c) 2012 Nexedi; Licensed */
(function(LocalOrCookieStorage, $, Base64, sjcl, MD5, Jio) { (function(LocalOrCookieStorage, $, Base64, sjcl, MD5, Jio) {
...@@ -1100,6 +1100,8 @@ Jio.addStorageType('crypt', newCryptedStorage); ...@@ -1100,6 +1100,8 @@ Jio.addStorageType('crypt', newCryptedStorage);
var newConflictManagerStorage = function ( spec, my ) { var newConflictManagerStorage = function ( spec, my ) {
var that = Jio.storage( spec, my, 'handler' ), priv = {}; var that = Jio.storage( spec, my, 'handler' ), priv = {};
spec = spec || {};
my = my || {};
var local_namespace = 'jio/conflictmanager/'; var local_namespace = 'jio/conflictmanager/';
...@@ -1122,23 +1124,14 @@ var newConflictManagerStorage = function ( spec, my ) { ...@@ -1122,23 +1124,14 @@ var newConflictManagerStorage = function ( spec, my ) {
return ''; return '';
}; };
priv.isTheLatestVersion = function (local,distant) { priv.removeValuesFromArrayWhere = function (array,fun) {
var k; var i, newarray = [];
if (!distant.owner) { for (i = 0; i < array.length; i+= 1) {
return true; if (!fun(array[i])) {
} newarray.push(array[i]);
for (k in distant.owner) {
if (k !== priv.username) {
if (local.winner.version <= distant.owner[k].last_version) {
return false;
} }
} }
} return newarray;
return true;
};
priv.conflictResearch = function () {
// TODO : ;
}; };
/** /**
...@@ -1154,7 +1147,7 @@ var newConflictManagerStorage = function ( spec, my ) { ...@@ -1154,7 +1147,7 @@ var newConflictManagerStorage = function ( spec, my ) {
run_index = 0, run_index = 0,
end = false, is_a_new_file = false, end = false, is_a_new_file = false,
previous_revision = 0, previous_revision = 0,
local_file_hash = MD5 (command.getContent()), local_file_hash = hex_sha256 (command.getContent()),
run = function (index) { run = function (index) {
switch (index) { switch (index) {
case 0: case 0:
...@@ -1188,6 +1181,7 @@ var newConflictManagerStorage = function ( spec, my ) { ...@@ -1188,6 +1181,7 @@ var newConflictManagerStorage = function ( spec, my ) {
run_index ++; run (run_index); run_index ++; run (run_index);
break; break;
case 2: // load metadata from distant case 2: // load metadata from distant
(function () {
var cloned_option = command.cloneOption (); var cloned_option = command.cloneOption ();
cloned_option.onResponse = function () {}; cloned_option.onResponse = function () {};
cloned_option.onFail = function (error) { cloned_option.onFail = function (error) {
...@@ -1196,8 +1190,8 @@ var newConflictManagerStorage = function ( spec, my ) { ...@@ -1196,8 +1190,8 @@ var newConflictManagerStorage = function ( spec, my ) {
run_index ++; run (run_index); run_index ++; run (run_index);
} else { } else {
run_index = (-10); run_index = (-10);
that.fail(error);
end = true; end = true;
that.fail(error);
} }
}; };
cloned_option.onDone = function (result) { cloned_option.onDone = function (result) {
...@@ -1209,10 +1203,10 @@ var newConflictManagerStorage = function ( spec, my ) { ...@@ -1209,10 +1203,10 @@ var newConflictManagerStorage = function ( spec, my ) {
option:cloned_option}); option:cloned_option});
that.addJob ( that.newStorage (priv.secondstorage_spec), that.addJob ( that.newStorage (priv.secondstorage_spec),
newcommand ); newcommand );
}());
break; break;
// wait for 1 and 2
case 5: // check conflicts case 5: // check conflicts
var updateCommandMetadata = function () { var updateMetadataCommon = function () {
var original_creation_date; var original_creation_date;
original_creation_date = command_file_metadata.owner[ original_creation_date = command_file_metadata.owner[
...@@ -1225,22 +1219,28 @@ var newConflictManagerStorage = function ( spec, my ) { ...@@ -1225,22 +1219,28 @@ var newConflictManagerStorage = function ( spec, my ) {
} else { } else {
command_file_metadata.owner[priv.username] = {}; command_file_metadata.owner[priv.username] = {};
} }
command_file_metadata.winner.owner = priv.username;
command_file_metadata.winner.revision ++;
command_file_metadata.winner.hash = local_file_hash;
command_file_metadata.owner[priv.username].revision =
command_file_metadata.winner.revision;
command_file_metadata.owner[priv.username]. command_file_metadata.owner[priv.username].
last_modified = now.getTime(); last_modified = now.getTime();
command_file_metadata.owner[priv.username]. command_file_metadata.owner[priv.username].
creation_date = original_creation_date; creation_date = original_creation_date;
command_file_metadata.owner[priv.username].hash = command_file_metadata.owner[priv.username].hash =
local_file_hash; local_file_hash;
};
var updateCommandMetadataNotOnConflict = function () {
updateMetadataCommon ();
command_file_metadata.winner.owner = priv.username;
command_file_metadata.winner.revision ++;
command_file_metadata.winner.hash = local_file_hash;
command_file_metadata.owner[priv.username].revision =
command_file_metadata.winner.revision;
};
var updateCommandMetadataOnConflict = function () {
updateMetadataCommon ();
command_file_metadata.owner[priv.username].revision ++;
}; };
// if this is a new file // if this is a new file
if (is_a_new_file) { if (is_a_new_file) {
updateCommandMetadata(); updateCommandMetadataNotOnConflict();
LocalOrCookieStorage.setItem (local_metadata_file_name, LocalOrCookieStorage.setItem (local_metadata_file_name,
command_file_metadata); command_file_metadata);
run_index = (98); run_index = (98);
...@@ -1248,52 +1248,134 @@ var newConflictManagerStorage = function ( spec, my ) { ...@@ -1248,52 +1248,134 @@ var newConflictManagerStorage = function ( spec, my ) {
run (7); // save document revision run (7); // save document revision
break; break;
} }
// if no conflict
if (local_file_metadata.winner.revision === if (local_file_metadata.winner.revision ===
command_file_metadata.winner.revision && command_file_metadata.winner.revision &&
local_file_metadata.winner.hash === local_file_metadata.winner.hash ===
command_file_metadata.winner.hash) { command_file_metadata.winner.hash) {
// OK! Now, update distant metadata, store them and save // OK! Now, update distant metadata, store them and save
updateCommandMetadata(); updateCommandMetadataNotOnConflict();
LocalOrCookieStorage.setItem (local_metadata_file_name, LocalOrCookieStorage.setItem (local_metadata_file_name,
command_file_metadata); command_file_metadata);
run_index = 98; run_index = 98;
run (6); // save metadata run (6); // save metadata
run (7); // save document revision run (7); // save document revision
} else { } else {
// var conflict_hash = ''; // if conflict
// // gen hash var conflict_object = {
// conflict_hash = MD5 (JSON.stringify ({ label: 'revision',
// path: command.getPath() path: command.getPath(),
// // TODO : ; conflict_owner: {
// })); name: command_file_metadata.winner.owner,
// // TODO : ; revision: command_file_metadata.winner.revision,
// command_file_metadata.conflict_list.push ({ hash: command_file_metadata.winner.hash}
// label:'revision', },
// hash: conflict_hash, // gen hash
// path: command.getPath(), conflict_hash = hex_sha256 (JSON.stringify (
// local_owner: { conflict_object));
// name: priv.username, conflict_object.hash = conflict_hash;
// revision: local_file_metadata.owner[ // browse known conflict list
// priv.username].revision + 1, var i, known_conflict_list =
// hash: local_file_hash command.getOption('known_conflict_list') || [];
// }, var compare_fun = function (v) {
// conflict_owner: { return (v.hash === conflict_hash);
// name: command_file_metadata.winner.owner, };
// revision: command_file_metadata.winner.revision, for (i = 0; i < known_conflict_list.length; i+= 1) {
// hash: command_file_metadata.winner.hash // if known conflict
// } if (known_conflict_list[i].hash ===
// }); conflict_hash) {
command.getOption('onConflict')(); priv.removeValuesFromArrayWhere(
command_file_metadata.conflict_list,
compare_fun); // FIXME : must remove something!
updateCommandMetadataNotOnConflict();
run_index = 98;
run (6);
run (7);
return;
}
}
updateCommandMetadataOnConflict();
// if unknown conflict
command_file_metadata.conflict_list.push (conflict_object);
run_index = (-10); run_index = (-10);
end = true; end = true;
run (6); // save metadata
run (7); // save document revision
that.fail(); // TODO that.fail(); // TODO
command.getOption('onConflict')(conflict_object);
} }
break; break;
case 6: // save metadata case 6: // save metadata
console.log ('save metadata'); (function () {
var cloned_option = command.cloneOption ();
cloned_option.onResponse = function () {};
cloned_option.onFail = function (error) {
run_index = (-10);
end = true;
that.fail(error);
};
cloned_option.onDone = function () {
run_index ++; run (run_index);
};
var newcommand = that.newCommand(
'saveDocument',{path:metadata_file_name,
content:JSON.stringify (
command_file_metadata),
option:cloned_option});
newcommand.setMaxRetry (0); // inf
that.addJob ( that.newStorage (priv.secondstorage_spec),
newcommand );
}());
break; break;
case 7: // save document revision case 7: // save document revision
console.log ('save document revision'); (function () {
var cloned_option = command.cloneOption ();
cloned_option.onResponse = function () {};
cloned_option.onFail = function (error) {
run_index = (-10);
end = true;
that.fail(error);
};
cloned_option.onDone = function () {
run (8);
};
var newcommand = that.newCommand(
'saveDocument',
{path:command.getPath() + '.' +
command_file_metadata.owner[priv.username].revision +
'.' + priv.username,
content:command.getContent(),
option:cloned_option});
newcommand.setMaxRetry (0); // inf
that.addJob ( that.newStorage (priv.secondstorage_spec),
newcommand );
}());
break;
case 8:
(function () {
if ( previous_revision !== 0 ) {
var cloned_option = command.cloneOption ();
cloned_option.onResponse = function () {};
cloned_option.onFail = function (error) {
run_index = (-10);
end = true;
that.fail(error);
};
cloned_option.onDone = function () {
run_index ++; run (run_index);
};
var newcommand = that.newCommand(
'removeDocument',
{path:command.getPath() + '.' +
previous_revision + '.' + priv.username,
option:cloned_option});
newcommand.setMaxRetry (0); // inf
that.addJob ( that.newStorage (priv.secondstorage_spec),
newcommand );
} else {
run_index ++; run (run_index);
}
}());
break; break;
case 100: case 100:
if (!end) { if (!end) {
...@@ -1316,7 +1398,114 @@ var newConflictManagerStorage = function ( spec, my ) { ...@@ -1316,7 +1398,114 @@ var newConflictManagerStorage = function ( spec, my ) {
* @method loadDocument * @method loadDocument
*/ */
that.loadDocument = function (command) { that.loadDocument = function (command) {
that.fail({message:'NIY'}); var metadata_file_name = command.getPath() + '.metadata',
local_metadata_file_name = local_namespace + metadata_file_name,
command_file_metadata = {}, // distant file.metadata
run_index = 0,
end = false, owner = '', loaded_file,
run = function (index) {
switch (index) {
case 0: // load metadata file from distant
(function () {
var cloned_option = command.cloneOption ();
cloned_option.onResponse = function () {};
cloned_option.onFail = function (error) {
run_index = (-10);
end = true;
that.fail(error);
};
cloned_option.onDone = function (result) {
command_file_metadata = JSON.parse (result.content);
owner = command.getOption('owner');
run_index = 98;
// if owner
if (owner) {
run (3);
} else {
// if no owner
run (2);
}
run (1);
};
var newcommand = that.newCommand(
'loadDocument',
{path:metadata_file_name,
option:cloned_option});
newcommand.setMaxRetry (0); // inf
that.addJob ( that.newStorage (priv.secondstorage_spec),
newcommand );
}());
break;
case 1: // update local metadata
LocalOrCookieStorage.setItem (local_metadata_file_name,
command_file_metadata);
run_index ++; run (run_index);
break;
case 2: // load winner
(function () {
var cloned_option = command.cloneOption ();
cloned_option.onResponse = function () {};
cloned_option.onFail = function (error) {
run_index = (-10);
end = true;
that.fail(error);
};
cloned_option.onDone = function (result) {
loaded_file = result;
run_index ++; run (run_index);
};
var newcommand = that.newCommand(
'loadDocument',
{path:command.getPath() + '.' +
command_file_metadata.winner.revision +
'.' + command_file_metadata.winner.owner,
option:cloned_option});
newcommand.setMaxRetry (0); // inf
that.addJob ( that.newStorage (priv.secondstorage_spec),
newcommand );
}());
break;
case 3: // load owner
(function () {
var cloned_option = command.cloneOption ();
cloned_option.onResponse = function () {};
cloned_option.onFail = function (error) {
run_index = (-10);
end = true;
that.fail(error);
};
cloned_option.onDone = function (result) {
loaded_file = result;
run_index ++; run (run_index);
};
if (!command_file_metadata.owner[owner]) {
cloned_option.onFail ({status:404,
statusText:'Not Found',
message:'Document not found.'});
return;
}
var newcommand = that.newCommand(
'loadDocument',
{path:command.getPath() + '.' +
command_file_metadata.owner[owner].revision +
'.' + owner,
option:cloned_option});
newcommand.setMaxRetry (0); // inf
that.addJob ( that.newStorage (priv.secondstorage_spec),
newcommand );
}());
break;
case 100:
if (!end) {
end = true;
that.done(loaded_file);
return;
}
break;
default: break;
}
};
run (0);
}; };
/** /**
......
OfficeJS/lib/jio/jio.storage.min.js
View file @ 0667c061
/*! JIO Storage - v0.1.0 - 2012-06-21 /*! JIO Storage - v0.1.0 - 2012-06-22
* Copyright (c) 2012 Nexedi; Licensed */ * Copyright (c) 2012 Nexedi; Licensed */
(function(a,b,c,d,e,f){var g=function(b,c){var d=f.storage(b,c,"base"),e={};e.username=b.username||"",e.applicationname=b.applicationname||"untitled";var g="jio/local_user_array",h="jio/local_file_name_array/"+e.username+"/"+e.applicationname,i=d.serialized;return d.serialized=function(){var a=i();return a.applicationname=e.applicationname,a.username=e.username,a},d.validateState=function(){return e.username?"":'Need at least one parameter: "username".'},e.getUserArray=function(){return a.getItem(g)||[]},e.addUser=function(b){var c=e.getUserArray();c.push(b),a.setItem(g,c)},e.userExists=function(a){var b=e.getUserArray(),c,d;for(c=0,d=b.length;c<d;c+=1)if(b[c]===a)return!0;return!1},e.getFileNameArray=function(){return a.getItem(h)||[]},e.addFileName=function(b){var c=e.getFileNameArray();c.push(b),a.setItem(h,c)},e.removeFileName=function(b){var c,d,f=e.getFileNameArray(),g=[];for(c=0,d=f.length;c<d;c+=1)f[c]!==b&&g.push(f[c]);a.setItem(h,g)},d.saveDocument=function(b){setTimeout(function(){var c=null,f="jio/local/"+e.username+"/"+e.applicationname+"/"+b.getPath();c=a.getItem(f),c?(c.last_modified=Date.now(),c.content=b.getContent()):(c={name:b.getPath(),content:b.getContent(),creation_date:Date.now(),last_modified:Date.now()},e.userExists(e.username)||e.addUser(e.username),e.addFileName(b.getPath())),a.setItem(f,c),d.done()},100)},d.loadDocument=function(b){setTimeout(function(){var c=null;c=a.getItem("jio/local/"+e.username+"/"+e.applicationname+"/"+b.getPath()),c?(b.getOption("metadata_only")&&delete c.content,d.done(c)):d.fail(b,{status:404,statusText:"Not Found.",message:'Document "'+b.getPath()+'" not found in localStorage.'})},100)},d.getDocumentList=function(b){setTimeout(function(){var c=[],f=[],g,h,i="key",j="jio/local/"+e.username+"/"+e.applicationname,k={};f=e.getFileNameArray();for(g=0,h=f.length;g<h;g+=1)k=a.getItem(j+"/"+f[g]),k&&(b.getOption("metadata_only")?c.push({name:k.name,creation_date:k.creation_date,last_modified:k.last_modified}):c.push({name:k.name,content:k.content,creation_date:k.creation_date,last_modified:k.last_modified}));d.done(c)},100)},d.removeDocument=function(b){setTimeout(function(){var c="jio/local/"+e.username+"/"+e.applicationname+"/"+b.getPath();a.deleteItem(c),e.removeFileName(b.getPath()),d.done()},100)},d};f.addStorageType("local",g);var h=function(a,d){var e=f.storage(a,d,"base"),g={};g.username=a.username||"",g.applicationname=a.applicationname||"untitled",g.url=a.url||"",g.password=a.password||"";var h=e.serialized;return e.serialized=function(){var a=h();return a.username=g.username,a.applicationname=g.applicationname,a.url=g.url,a.password=g.password,a},e.validateState=function(){return g.username&&g.url?"":'Need at least 2 parameters: "username" and "url".'},e.saveDocument=function(a){b.ajax({url:g.url+"/dav/"+g.username+"/"+g.applicationname+"/"+a.getPath(),type:"PUT",data:a.getContent(),async:!0,dataType:"text",headers:{Authorization:"Basic "+c.encode(g.username+":"+g.password)},success:function(){e.done()},error:function(b){b.message='Cannot save "'+a.getPath()+'" into DAVStorage.',e.fail(b)}})},e.loadDocument=function(a){var d={},f=function(){b.ajax({url:g.url+"/dav/"+g.username+"/"+g.applicationname+"/"+a.getPath(),type:"GET",async:!0,dataType:"text",headers:{Authorization:"Basic "+c.encode(g.username+":"+g.password)},success:function(a){d.content=a,e.done(d)},error:function(b){b.status===404?b.message='Document "'+a.getPath()+'" not found in localStorage.':b.message='Cannot load "'+a.getPath()+'" from DAVStorage.',e.fail(b)}})};d.name=a.getPath(),b.ajax({url:g.url+"/dav/"+g.username+"/"+g.applicationname+"/"+a.getPath(),type:"PROPFIND",async:!0,dataType:"xml",headers:{Authorization:"Basic "+c.encode(g.username+":"+g.password)},success:function(c){b(c).find("lp1\\:getlastmodified, getlastmodified").each(function(){d.last_modified=b(this).text()}),b(c).find("lp1\\:creationdate, creationdate").each(function(){d.creation_date=b(this).text()}),a.getOption("metadata_only")?e.done(d):f()},error:function(b){b.message='Cannot load "'+a.getPath()+'" informations from DAVStorage.',e.fail(b)}})},e.getDocumentList=function(a){var d=[],f={},h=[];b.ajax({url:g.url+"/dav/"+g.username+"/"+g.applicationname+"/",async:!0,type:"PROPFIND",dataType:"xml",headers:{Authorization:"Basic "+c.encode(g.username+":"+g.password),Depth:"1"},success:function(a){b(a).find("D\\:response, response").each(function(a,c){if(a>0){f={},b(c).find("D\\:href, href").each(function(){h=b(this).text().split("/"),f.name=h[h.length-1]?h[h.length-1]:h[h.length-2]+"/"});if(f.name===".htaccess"||f.name===".htpasswd")return;b(c).find("lp1\\:getlastmodified, getlastmodified").each(function(){f.last_modified=b(this).text()}),b(c).find("lp1\\:creationdate, creationdate").each(function(){f.creation_date=b(this).text()}),d.push(f)}}),e.done(d)},error:function(a){a.message="Cannot get a document list from DAVStorage.",e.fail(a)}})},e.removeDocument=function(a){b.ajax({url:g.url+"/dav/"+g.username+"/"+g.applicationname+"/"+a.getPath(),type:"DELETE",async:!0,headers:{Authorization:"Basic "+c.encode(g.username+":"+g.password)},success:function(){e.done()},error:function(a){a.status===404?e.done():(a.message='Cannot remove "'+e.getFileName()+'" from DAVStorage.',e.fail(a))}})},e};f.addStorageType("dav",h);var i=function(a,b){var c=f.storage(a,b,"handler"),d={};d.return_value_array=[],d.storagelist=a.storagelist||[],d.nb_storage=d.storagelist.length;var e=c.serialized;return c.serialized=function(){var a=e();return a.storagelist=d.storagelist,a},c.validateState=function(){return d.storagelist.length===0?'Need at least one parameter: "storagelist" containing at least one storage.':""},d.isTheLast=function(){return d.return_value_array.length===d.nb_storage},d.doJob=function(a,b){var e=!1,f=[],g,h=function(a){d.return_value_array.push(a)},i=function(a){e||(f.push(a),d.isTheLast()&&c.fail({status:207,statusText:"Multi-Status",message:b,array:f}))},j=function(a){e||(e=!0,c.done(a))};for(g=0;g<d.nb_storage;g+=1){var k=a.clone(),l=c.newStorage(d.storagelist[g]);k.onResponseDo(h),k.onFailDo(i),k.onDoneDo(j),c.addJob(l,k)}a.setMaxRetry(1)},c.saveDocument=function(a){d.doJob(a,'All save "'+a.getPath()+'" requests have failed.'),c.end()},c.loadDocument=function(a){d.doJob(a,'All load "'+a.getPath()+'" requests have failed.'),c.end()},c.getDocumentList=function(a){d.doJob(a,"All get document list requests have failed."),c.end()},c.removeDocument=function(a){d.doJob(a,'All remove "'+a.getPath()+'" requests have failed.'),c.end()},c};f.addStorageType("replicate",i);var j=function(b,c){var d=f.storage(b,c,"handler"),e={},g=b.storage||!1;e.secondstorage_spec=b.storage||{type:"base"},e.secondstorage_string=JSON.stringify(e.secondstorage_spec);var h="jio/indexed_storage_array",i="jio/indexed_file_array/"+e.secondstorage_string,j=d.serialized;return d.serialized=function(){var a=j();return a.storage=e.secondstorage_spec,a},d.validateState=function(){return g?"":'Need at least one parameter: "storage" containing storage specifications.'},e.isStorageArrayIndexed=function(){return a.getItem(h)?!0:!1},e.getIndexedStorageArray=function(){return a.getItem(h)||[]},e.indexStorage=function(b){var c=e.getIndexedStorageArray();c.push(typeof b=="string"?b:JSON.stringify(b)),a.setItem(h,c)},e.isAnIndexedStorage=function(a){var b=typeof a=="string"?a:JSON.stringify(a),c,d,f=e.getIndexedStorageArray();for(c=0,d=f.length;c<d;c+=1)if(JSON.stringify(f[c])===b)return!0;return!1},e.fileArrayExists=function(){return a.getItem(i)?!0:!1},e.getFileArray=function(){return a.getItem(i)||[]},e.setFileArray=function(b){return a.setItem(i,b)},e.isFileIndexed=function(a){var b,c,d=e.getFileArray();for(b=0,c=d.length;b<c;b+=1)if(d[b].name===a)return!0;return!1},e.addFile=function(b){var c=e.getFileArray();c.push(b),a.setItem(i,c)},e.removeFile=function(b){var c,d,f=e.getFileArray(),g=[];for(c=0,d=f.length;c<d;c+=1)f[c].name!==b&&g.push(f[c]);a.setItem(i,g)},e.update=function(){var a=function(a){e.isAnIndexedStorage(e.secondstorage_string)||e.indexStorage(e.secondstorage_string),e.setFileArray(a)};d.addJob(d.newStorage(e.secondstorage_spec),d.newCommand("getDocumentList",{path:".",option:{onDone:a,max_retry:3}}))},d.saveDocument=function(a){var b=a.clone();b.onResponseDo(function(){}),b.onDoneDo(function(b){e.isFileIndexed(a.getPath())||e.addFile({name:a.getPath(),last_modified:0,creation_date:0}),e.update(),d.done()}),b.onFailDo(function(a){d.fail(a)}),d.addJob(d.newStorage(e.secondstorage_spec),b)},d.loadDocument=function(a){var b,c,f,g,h=function(a){d.done(a)},i=function(a){d.fail(a)},j=function(){var b=a.clone();b.onResponseDo(function(){}),b.onFailDo(i),b.onDoneDo(h),d.addJob(d.newStorage(e.secondstorage_spec),b)};e.update(),a.getOption("metadata_only")?setTimeout(function(){if(e.fileArrayExists()){b=e.getFileArray();for(c=0,f=b.length;c<f;c+=1)if(b[c].name===a.getPath())return d.done(b[c])}else j()},100):j()},d.getDocumentList=function(a){var b,c,f=!1;e.update(),a.getOption("metadata_only")?(b=setInterval(function(){f&&(d.fail({status:0,statusText:"Timeout",message:"The request has timed out."}),clearInterval(b)),e.fileArrayExists()&&(d.done(e.getFileArray()),clearInterval(b))},100),setTimeout(function(){f=!0},1e4)):(c=a.clone(),c.onDoneDo(function(a){d.done(a)}),c.onFailDo(function(a){d.fail(a)}),d.addJob(d.newStorage(e.secondstorage_spec),c))},d.removeDocument=function(a){var b=a.clone();b.onResponseDo(function(){}),b.onDoneDo(function(b){e.removeFile(a.getPath()),e.update(),d.done()}),b.onFailDo(function(a){d.fail(a)}),d.addJob(d.newStorage(e.secondstorage_spec),b)},d};f.addStorageType("indexed",j);var k=function(a,c){var e=f.storage(a,c,"handler"),g={};g.username=a.username||"",g.password=a.password||"",g.secondstorage_spec=a.storage||{type:"base"};var h=e.serialized;return e.serialized=function(){var a=h();return a.username=g.username,a.password=g.password,a},e.validateState=function(){return g.username&&JSON.stringify(g.secondstorage_spec)===JSON.stringify({type:"base"})?"":'Need at least two parameters: "username" and "storage".'},g.encrypt_param_object={iv:"kaprWwY/Ucr7pumXoTHbpA",v:1,iter:1e3,ks:256,ts:128,mode:"ccm",adata:"",cipher:"aes",salt:"K4bmZG9d704"},g.decrypt_param_object={iv:"kaprWwY/Ucr7pumXoTHbpA",ks:256,ts:128,salt:"K4bmZG9d704"},g.encrypt=function(a,b,c){var f=d.encrypt(e.getStorageUserName()+":"+e.getStoragePassword(),a,g.encrypt_param_object);b(JSON.parse(f).ct,c)},g.decrypt=function(a,c,f,h){var i,j=b.extend(!0,{},g.decrypt_param_object);j.ct=a||"",j=JSON.stringify(j);try{i=d.decrypt(e.getStorageUserName()+":"+e.getStoragePassword(),j)}catch(k){c({status:0,statusText:"Decrypt Fail",message:"Unable to decrypt."},f,h);return}c(i,f,h)},e.saveDocument=function(a){var b,c,d=function(){g.encrypt(a.getPath(),function(a){b=a,f()})},f=function(){g.encrypt(a.getContent(),function(a){c=a,h()})},h=function(){var a=e.cloneOption(),d,f;a.onResponse=function(){},a.onDone=function(){e.done()},a.onFail=function(a){e.fail(a)},d=e.newCommand({path:b,content:c,option:a}),f=e.newStorage(g.secondstorage_spec),e.addJob(f,d)};d()},e.loadDocument=function(a){var b,c,d=function(){g.encrypt(a.getPath(),function(a){b=a,f()})},f=function(){var c=a.cloneOption(),d,f;c.onResponse=function(){},c.onFail=i,c.onDone=h,d=e.newCommand({path:b,option:c}),f=e.newStorage(g.secondstorage_spec),e.addJob(f,d)},h=function(b){b.name=a.getPath(),a.getOption("metadata_only")?e.done(b):g.decrypt(b.content,function(a){typeof a=="object"?e.fail({status:0,statusText:"Decrypt Fail",message:"Unable to decrypt"}):(b.content=a,e.done(b))})},i=function(a){e.fail(a)};d()},e.getDocumentList=function(a){var b,c,d,f=0,h,i=!0,j=function(){var c=a.clone(),d=e.newStorage(g.secondstorage_spec);c.onResponseDo(k),c.onDoneDo(function(){}),c.onFailDo(function(){}),e.addJob(b)},k=function(a){if(a.status.isDone()){h=a.return_value;for(c=0,d=h.length;c<d;c+=1)g.decrypt(h[c].name,l,c,"name")}else e.fail(a.error)},l=function(a,b,c){var g;f++;if(typeof a=="object"){i&&e.fail({status:0,statusText:"Decrypt Fail",message:"Unable to decrypt."}),i=!1;return}h[b][c]=a,f===d&&i&&e.done(h)};j()},e.removeDocument=function(){var a,b,c=function(){g.encrypt(e.getFileName(),function(a){b=a,d()})},d=function(){a=e.cloneJob(),a.name=b,a.storage=e.getSecondStorage(),a.onResponse=f,e.addJob(a)},f=function(a){a.status==="done"?e.done():e.fail(a.error)};c()},e};f.addStorageType("crypt",k);var l=function(b,c){var d=f.storage(b,c,"handler"),g={},h="jio/conflictmanager/";g.username=b.username||"";var i=b.storage?!0:!1;g.secondstorage_spec=b.storage||{type:"base"};var j=d.serialized;return d.serialized=function(){var a=j();return a.storage=g.secondstorage_spec,a},d.validateState=function(){return!g.username||i?'Need at least two parameter: "owner" and "storage" .':""},g.isTheLatestVersion=function(a,b){var c;if(!b.owner)return!0;for(c in b.owner)if(c!==g.username&&a.winner.version<=b.owner[c].last_version)return!1;return!0},g.conflictResearch=function(){},d.saveDocument=function(b){var c=b.getPath()+".metadata",f=new Date,i=h+c,j={},k={},l=0,m=!1,n=!1,o=0,p=e(b.getContent()),q=function(e){switch(e){case 0:l=3,q(2),q(1);break;case 1:var h={revision:0,hash:"",last_modified:0,creation_date:f.getTime()};j=a.getItem(i),j?j.owner[g.username]||(j.owner[g.username]=h):(j={winner:{},owner:{},conflict_list:[]},j.winner={revision:0,owner:g.username,hash:""},j.owner[g.username]=h),l++,q(l);break;case 2:var r=b.cloneOption();r.onResponse=function(){},r.onFail=function(a){a.status===404?(k=j,l++,q(l)):(l=-10,d.fail(a),m=!0)},r.onDone=function(a){k=JSON.parse(a.content),l++,q(l)};var s=d.newCommand("loadDocument",{path:c,option:r});d.addJob(d.newStorage(g.secondstorage_spec),s);break;case 5:var t=function(){var a;a=k.owner[k.winner.owner].creation_date||f.getTime(),k.owner[g.username]?o=k.owner[g.username].revision:k.owner[g.username]={},k.winner.owner=g.username,k.winner.revision++,k.winner.hash=p,k.owner[g.username].revision=k.winner.revision,k.owner[g.username].last_modified=f.getTime(),k.owner[g.username].creation_date=a,k.owner[g.username].hash=p};if(n){t(),a.setItem(i,k),l=98,q(6),q(7);break}j.winner.revision===k.winner.revision&&j.winner.hash===k.winner.hash?(t(),a.setItem(i,k),l=98,q(6),q(7)):(b.getOption("onConflict")(),l=-10,m=!0,d.fail());break;case 6:console.log("save metadata");break;case 7:console.log("save document revision");break;case 100:if(!m){m=!0,d.done();return}break;default:}};q(0),b.setMaxRetry(1)},d.loadDocument=function(a){d.fail({message:"NIY"})},d.getDocumentList=function(a){d.fail({message:"NIY"})},d.removeDocument=function(a){d.fail({message:"NIY"})},d};f.addStorageType("replicate",i)})(LocalOrCookieStorage,jQuery,Base64,sjcl,MD5,jio); (function(a,b,c,d,e,f){var g=function(b,c){var d=f.storage(b,c,"base"),e={};e.username=b.username||"",e.applicationname=b.applicationname||"untitled";var g="jio/local_user_array",h="jio/local_file_name_array/"+e.username+"/"+e.applicationname,i=d.serialized;return d.serialized=function(){var a=i();return a.applicationname=e.applicationname,a.username=e.username,a},d.validateState=function(){return e.username?"":'Need at least one parameter: "username".'},e.getUserArray=function(){return a.getItem(g)||[]},e.addUser=function(b){var c=e.getUserArray();c.push(b),a.setItem(g,c)},e.userExists=function(a){var b=e.getUserArray(),c,d;for(c=0,d=b.length;c<d;c+=1)if(b[c]===a)return!0;return!1},e.getFileNameArray=function(){return a.getItem(h)||[]},e.addFileName=function(b){var c=e.getFileNameArray();c.push(b),a.setItem(h,c)},e.removeFileName=function(b){var c,d,f=e.getFileNameArray(),g=[];for(c=0,d=f.length;c<d;c+=1)f[c]!==b&&g.push(f[c]);a.setItem(h,g)},d.saveDocument=function(b){setTimeout(function(){var c=null,f="jio/local/"+e.username+"/"+e.applicationname+"/"+b.getPath();c=a.getItem(f),c?(c.last_modified=Date.now(),c.content=b.getContent()):(c={name:b.getPath(),content:b.getContent(),creation_date:Date.now(),last_modified:Date.now()},e.userExists(e.username)||e.addUser(e.username),e.addFileName(b.getPath())),a.setItem(f,c),d.done()},100)},d.loadDocument=function(b){setTimeout(function(){var c=null;c=a.getItem("jio/local/"+e.username+"/"+e.applicationname+"/"+b.getPath()),c?(b.getOption("metadata_only")&&delete c.content,d.done(c)):d.fail(b,{status:404,statusText:"Not Found.",message:'Document "'+b.getPath()+'" not found in localStorage.'})},100)},d.getDocumentList=function(b){setTimeout(function(){var c=[],f=[],g,h,i="key",j="jio/local/"+e.username+"/"+e.applicationname,k={};f=e.getFileNameArray();for(g=0,h=f.length;g<h;g+=1)k=a.getItem(j+"/"+f[g]),k&&(b.getOption("metadata_only")?c.push({name:k.name,creation_date:k.creation_date,last_modified:k.last_modified}):c.push({name:k.name,content:k.content,creation_date:k.creation_date,last_modified:k.last_modified}));d.done(c)},100)},d.removeDocument=function(b){setTimeout(function(){var c="jio/local/"+e.username+"/"+e.applicationname+"/"+b.getPath();a.deleteItem(c),e.removeFileName(b.getPath()),d.done()},100)},d};f.addStorageType("local",g);var h=function(a,d){var e=f.storage(a,d,"base"),g={};g.username=a.username||"",g.applicationname=a.applicationname||"untitled",g.url=a.url||"",g.password=a.password||"";var h=e.serialized;return e.serialized=function(){var a=h();return a.username=g.username,a.applicationname=g.applicationname,a.url=g.url,a.password=g.password,a},e.validateState=function(){return g.username&&g.url?"":'Need at least 2 parameters: "username" and "url".'},e.saveDocument=function(a){b.ajax({url:g.url+"/dav/"+g.username+"/"+g.applicationname+"/"+a.getPath(),type:"PUT",data:a.getContent(),async:!0,dataType:"text",headers:{Authorization:"Basic "+c.encode(g.username+":"+g.password)},success:function(){e.done()},error:function(b){b.message='Cannot save "'+a.getPath()+'" into DAVStorage.',e.fail(b)}})},e.loadDocument=function(a){var d={},f=function(){b.ajax({url:g.url+"/dav/"+g.username+"/"+g.applicationname+"/"+a.getPath(),type:"GET",async:!0,dataType:"text",headers:{Authorization:"Basic "+c.encode(g.username+":"+g.password)},success:function(a){d.content=a,e.done(d)},error:function(b){b.status===404?b.message='Document "'+a.getPath()+'" not found in localStorage.':b.message='Cannot load "'+a.getPath()+'" from DAVStorage.',e.fail(b)}})};d.name=a.getPath(),b.ajax({url:g.url+"/dav/"+g.username+"/"+g.applicationname+"/"+a.getPath(),type:"PROPFIND",async:!0,dataType:"xml",headers:{Authorization:"Basic "+c.encode(g.username+":"+g.password)},success:function(c){b(c).find("lp1\\:getlastmodified, getlastmodified").each(function(){d.last_modified=b(this).text()}),b(c).find("lp1\\:creationdate, creationdate").each(function(){d.creation_date=b(this).text()}),a.getOption("metadata_only")?e.done(d):f()},error:function(b){b.message='Cannot load "'+a.getPath()+'" informations from DAVStorage.',e.fail(b)}})},e.getDocumentList=function(a){var d=[],f={},h=[];b.ajax({url:g.url+"/dav/"+g.username+"/"+g.applicationname+"/",async:!0,type:"PROPFIND",dataType:"xml",headers:{Authorization:"Basic "+c.encode(g.username+":"+g.password),Depth:"1"},success:function(a){b(a).find("D\\:response, response").each(function(a,c){if(a>0){f={},b(c).find("D\\:href, href").each(function(){h=b(this).text().split("/"),f.name=h[h.length-1]?h[h.length-1]:h[h.length-2]+"/"});if(f.name===".htaccess"||f.name===".htpasswd")return;b(c).find("lp1\\:getlastmodified, getlastmodified").each(function(){f.last_modified=b(this).text()}),b(c).find("lp1\\:creationdate, creationdate").each(function(){f.creation_date=b(this).text()}),d.push(f)}}),e.done(d)},error:function(a){a.message="Cannot get a document list from DAVStorage.",e.fail(a)}})},e.removeDocument=function(a){b.ajax({url:g.url+"/dav/"+g.username+"/"+g.applicationname+"/"+a.getPath(),type:"DELETE",async:!0,headers:{Authorization:"Basic "+c.encode(g.username+":"+g.password)},success:function(){e.done()},error:function(a){a.status===404?e.done():(a.message='Cannot remove "'+e.getFileName()+'" from DAVStorage.',e.fail(a))}})},e};f.addStorageType("dav",h);var i=function(a,b){var c=f.storage(a,b,"handler"),d={};d.return_value_array=[],d.storagelist=a.storagelist||[],d.nb_storage=d.storagelist.length;var e=c.serialized;return c.serialized=function(){var a=e();return a.storagelist=d.storagelist,a},c.validateState=function(){return d.storagelist.length===0?'Need at least one parameter: "storagelist" containing at least one storage.':""},d.isTheLast=function(){return d.return_value_array.length===d.nb_storage},d.doJob=function(a,b){var e=!1,f=[],g,h=function(a){d.return_value_array.push(a)},i=function(a){e||(f.push(a),d.isTheLast()&&c.fail({status:207,statusText:"Multi-Status",message:b,array:f}))},j=function(a){e||(e=!0,c.done(a))};for(g=0;g<d.nb_storage;g+=1){var k=a.clone(),l=c.newStorage(d.storagelist[g]);k.onResponseDo(h),k.onFailDo(i),k.onDoneDo(j),c.addJob(l,k)}a.setMaxRetry(1)},c.saveDocument=function(a){d.doJob(a,'All save "'+a.getPath()+'" requests have failed.'),c.end()},c.loadDocument=function(a){d.doJob(a,'All load "'+a.getPath()+'" requests have failed.'),c.end()},c.getDocumentList=function(a){d.doJob(a,"All get document list requests have failed."),c.end()},c.removeDocument=function(a){d.doJob(a,'All remove "'+a.getPath()+'" requests have failed.'),c.end()},c};f.addStorageType("replicate",i);var j=function(b,c){var d=f.storage(b,c,"handler"),e={},g=b.storage||!1;e.secondstorage_spec=b.storage||{type:"base"},e.secondstorage_string=JSON.stringify(e.secondstorage_spec);var h="jio/indexed_storage_array",i="jio/indexed_file_array/"+e.secondstorage_string,j=d.serialized;return d.serialized=function(){var a=j();return a.storage=e.secondstorage_spec,a},d.validateState=function(){return g?"":'Need at least one parameter: "storage" containing storage specifications.'},e.isStorageArrayIndexed=function(){return a.getItem(h)?!0:!1},e.getIndexedStorageArray=function(){return a.getItem(h)||[]},e.indexStorage=function(b){var c=e.getIndexedStorageArray();c.push(typeof b=="string"?b:JSON.stringify(b)),a.setItem(h,c)},e.isAnIndexedStorage=function(a){var b=typeof a=="string"?a:JSON.stringify(a),c,d,f=e.getIndexedStorageArray();for(c=0,d=f.length;c<d;c+=1)if(JSON.stringify(f[c])===b)return!0;return!1},e.fileArrayExists=function(){return a.getItem(i)?!0:!1},e.getFileArray=function(){return a.getItem(i)||[]},e.setFileArray=function(b){return a.setItem(i,b)},e.isFileIndexed=function(a){var b,c,d=e.getFileArray();for(b=0,c=d.length;b<c;b+=1)if(d[b].name===a)return!0;return!1},e.addFile=function(b){var c=e.getFileArray();c.push(b),a.setItem(i,c)},e.removeFile=function(b){var c,d,f=e.getFileArray(),g=[];for(c=0,d=f.length;c<d;c+=1)f[c].name!==b&&g.push(f[c]);a.setItem(i,g)},e.update=function(){var a=function(a){e.isAnIndexedStorage(e.secondstorage_string)||e.indexStorage(e.secondstorage_string),e.setFileArray(a)};d.addJob(d.newStorage(e.secondstorage_spec),d.newCommand("getDocumentList",{path:".",option:{onDone:a,max_retry:3}}))},d.saveDocument=function(a){var b=a.clone();b.onResponseDo(function(){}),b.onDoneDo(function(b){e.isFileIndexed(a.getPath())||e.addFile({name:a.getPath(),last_modified:0,creation_date:0}),e.update(),d.done()}),b.onFailDo(function(a){d.fail(a)}),d.addJob(d.newStorage(e.secondstorage_spec),b)},d.loadDocument=function(a){var b,c,f,g,h=function(a){d.done(a)},i=function(a){d.fail(a)},j=function(){var b=a.clone();b.onResponseDo(function(){}),b.onFailDo(i),b.onDoneDo(h),d.addJob(d.newStorage(e.secondstorage_spec),b)};e.update(),a.getOption("metadata_only")?setTimeout(function(){if(e.fileArrayExists()){b=e.getFileArray();for(c=0,f=b.length;c<f;c+=1)if(b[c].name===a.getPath())return d.done(b[c])}else j()},100):j()},d.getDocumentList=function(a){var b,c,f=!1;e.update(),a.getOption("metadata_only")?(b=setInterval(function(){f&&(d.fail({status:0,statusText:"Timeout",message:"The request has timed out."}),clearInterval(b)),e.fileArrayExists()&&(d.done(e.getFileArray()),clearInterval(b))},100),setTimeout(function(){f=!0},1e4)):(c=a.clone(),c.onDoneDo(function(a){d.done(a)}),c.onFailDo(function(a){d.fail(a)}),d.addJob(d.newStorage(e.secondstorage_spec),c))},d.removeDocument=function(a){var b=a.clone();b.onResponseDo(function(){}),b.onDoneDo(function(b){e.removeFile(a.getPath()),e.update(),d.done()}),b.onFailDo(function(a){d.fail(a)}),d.addJob(d.newStorage(e.secondstorage_spec),b)},d};f.addStorageType("indexed",j);var k=function(a,c){var e=f.storage(a,c,"handler"),g={};g.username=a.username||"",g.password=a.password||"",g.secondstorage_spec=a.storage||{type:"base"};var h=e.serialized;return e.serialized=function(){var a=h();return a.username=g.username,a.password=g.password,a},e.validateState=function(){return g.username&&JSON.stringify(g.secondstorage_spec)===JSON.stringify({type:"base"})?"":'Need at least two parameters: "username" and "storage".'},g.encrypt_param_object={iv:"kaprWwY/Ucr7pumXoTHbpA",v:1,iter:1e3,ks:256,ts:128,mode:"ccm",adata:"",cipher:"aes",salt:"K4bmZG9d704"},g.decrypt_param_object={iv:"kaprWwY/Ucr7pumXoTHbpA",ks:256,ts:128,salt:"K4bmZG9d704"},g.encrypt=function(a,b,c){var f=d.encrypt(e.getStorageUserName()+":"+e.getStoragePassword(),a,g.encrypt_param_object);b(JSON.parse(f).ct,c)},g.decrypt=function(a,c,f,h){var i,j=b.extend(!0,{},g.decrypt_param_object);j.ct=a||"",j=JSON.stringify(j);try{i=d.decrypt(e.getStorageUserName()+":"+e.getStoragePassword(),j)}catch(k){c({status:0,statusText:"Decrypt Fail",message:"Unable to decrypt."},f,h);return}c(i,f,h)},e.saveDocument=function(a){var b,c,d=function(){g.encrypt(a.getPath(),function(a){b=a,f()})},f=function(){g.encrypt(a.getContent(),function(a){c=a,h()})},h=function(){var a=e.cloneOption(),d,f;a.onResponse=function(){},a.onDone=function(){e.done()},a.onFail=function(a){e.fail(a)},d=e.newCommand({path:b,content:c,option:a}),f=e.newStorage(g.secondstorage_spec),e.addJob(f,d)};d()},e.loadDocument=function(a){var b,c,d=function(){g.encrypt(a.getPath(),function(a){b=a,f()})},f=function(){var c=a.cloneOption(),d,f;c.onResponse=function(){},c.onFail=i,c.onDone=h,d=e.newCommand({path:b,option:c}),f=e.newStorage(g.secondstorage_spec),e.addJob(f,d)},h=function(b){b.name=a.getPath(),a.getOption("metadata_only")?e.done(b):g.decrypt(b.content,function(a){typeof a=="object"?e.fail({status:0,statusText:"Decrypt Fail",message:"Unable to decrypt"}):(b.content=a,e.done(b))})},i=function(a){e.fail(a)};d()},e.getDocumentList=function(a){var b,c,d,f=0,h,i=!0,j=function(){var c=a.clone(),d=e.newStorage(g.secondstorage_spec);c.onResponseDo(k),c.onDoneDo(function(){}),c.onFailDo(function(){}),e.addJob(b)},k=function(a){if(a.status.isDone()){h=a.return_value;for(c=0,d=h.length;c<d;c+=1)g.decrypt(h[c].name,l,c,"name")}else e.fail(a.error)},l=function(a,b,c){var g;f++;if(typeof a=="object"){i&&e.fail({status:0,statusText:"Decrypt Fail",message:"Unable to decrypt."}),i=!1;return}h[b][c]=a,f===d&&i&&e.done(h)};j()},e.removeDocument=function(){var a,b,c=function(){g.encrypt(e.getFileName(),function(a){b=a,d()})},d=function(){a=e.cloneJob(),a.name=b,a.storage=e.getSecondStorage(),a.onResponse=f,e.addJob(a)},f=function(a){a.status==="done"?e.done():e.fail(a.error)};c()},e};f.addStorageType("crypt",k);var l=function(b,c){var d=f.storage(b,c,"handler"),e={};b=b||{},c=c||{};var g="jio/conflictmanager/";e.username=b.username||"";var h=b.storage?!0:!1;e.secondstorage_spec=b.storage||{type:"base"};var i=d.serialized;return d.serialized=function(){var a=i();return a.storage=e.secondstorage_spec,a},d.validateState=function(){return!e.username||h?'Need at least two parameter: "owner" and "storage" .':""},e.removeValuesFromArrayWhere=function(a,b){var c,d=[];for(c=0;c<a.length;c+=1)b(a[c])||d.push(a[c]);return d},d.saveDocument=function(b){var c=b.getPath()+".metadata",f=new Date,h=g+c,i={},j={},k=0,l=!1,m=!1,n=0,o=hex_sha256(b.getContent()),p=function(g){switch(g){case 0:k=3,p(2),p(1);break;case 1:var q={revision:0,hash:"",last_modified:0,creation_date:f.getTime()};i=a.getItem(h),i?i.owner[e.username]||(i.owner[e.username]=q):(i={winner:{},owner:{},conflict_list:[]},i.winner={revision:0,owner:e.username,hash:""},i.owner[e.username]=q),k++,p(k);break;case 2:(function(){var a=b.cloneOption();a.onResponse=function(){},a.onFail=function(a){a.status===404?(j=i,k++,p(k)):(k=-10,l=!0,d.fail(a))},a.onDone=function(a){j=JSON.parse(a.content),k++,p(k)};var f=d.newCommand("loadDocument",{path:c,option:a});d.addJob(d.newStorage(e.secondstorage_spec),f)})();break;case 5:var r=function(){var a;a=j.owner[j.winner.owner].creation_date||f.getTime(),j.owner[e.username]?n=j.owner[e.username].revision:j.owner[e.username]={},j.owner[e.username].last_modified=f.getTime(),j.owner[e.username].creation_date=a,j.owner[e.username].hash=o},s=function(){r(),j.winner.owner=e.username,j.winner.revision++,j.winner.hash=o,j.owner[e.username].revision=j.winner.revision},t=function(){r(),j.owner[e.username].revision++};if(m){s(),a.setItem(h,j),k=98,p(6),p(7);break}if(i.winner.revision===j.winner.revision&&i.winner.hash===j.winner.hash)s(),a.setItem(h,j),k=98,p(6),p(7);else{var u={label:"revision",path:b.getPath(),conflict_owner:{name:j.winner.owner,revision:j.winner.revision,hash:j.winner.hash}},v=hex_sha256(JSON.stringify(u));u.hash=v;var w,x=b.getOption("known_conflict_list")||[],y=function(a){return a.hash===v};for(w=0;w<x.length;w+=1)if(x[w].hash===v){e.removeValuesFromArrayWhere(j.conflict_list,y),s(),k=98,p(6),p(7);return}t(),j.conflict_list.push(u),k=-10,l=!0,p(6),p(7),d.fail(),b.getOption("onConflict")(u)}break;case 6:(function(){var a=b.cloneOption();a.onResponse=function(){},a.onFail=function(a){k=-10,l=!0,d.fail(a)},a.onDone=function(){k++,p(k)};var f=d.newCommand("saveDocument",{path:c,content:JSON.stringify(j),option:a});f.setMaxRetry(0),d.addJob(d.newStorage(e.secondstorage_spec),f)})();break;case 7:(function(){var a=b.cloneOption();a.onResponse=function(){},a.onFail=function(a){k=-10,l=!0,d.fail(a)},a.onDone=function(){p(8)};var c=d.newCommand("saveDocument",{path:b.getPath()+"."+j.owner[e.username].revision+"."+e.username,content:b.getContent(),option:a});c.setMaxRetry(0),d.addJob(d.newStorage(e.secondstorage_spec),c)})();break;case 8:(function(){if(n!==0){var a=b.cloneOption();a.onResponse=function(){},a.onFail=function(a){k=-10,l=!0,d.fail(a)},a.onDone=function(){k++,p(k)};var c=d.newCommand("removeDocument",{path:b.getPath()+"."+n+"."+e.username,option:a});c.setMaxRetry(0),d.addJob(d.newStorage(e.secondstorage_spec),c)}else k++,p(k)})();break;case 100:if(!l){l=!0,d.done();return}break;default:}};p(0),b.setMaxRetry(1)},d.loadDocument=function(b){var c=b.getPath()+".metadata",f=g+c,h={},i=0,j=!1,k="",l,m=function(g){switch(g){case 0:(function(){var a=b.cloneOption();a.onResponse=function(){},a.onFail=function(a){i=-10,j=!0,d.fail(a)},a.onDone=function(a){h=JSON.parse(a.content),k=b.getOption("owner"),i=98,k?m(3):m(2),m(1)};var f=d.newCommand("loadDocument",{path:c,option:a});f.setMaxRetry(0),d.addJob(d.newStorage(e.secondstorage_spec),f)})();break;case 1:a.setItem(f,h),i++,m(i);break;case 2:(function(){var a=b.cloneOption();a.onResponse=function(){},a.onFail=function(a){i=-10,j=!0,d.fail(a)},a.onDone=function(a){l=a,i++,m(i)};var c=d.newCommand("loadDocument",{path:b.getPath()+"."+h.winner.revision+"."+h.winner.owner,option:a});c.setMaxRetry(0),d.addJob(d.newStorage(e.secondstorage_spec),c)})();break;case 3:(function(){var a=b.cloneOption();a.onResponse=function(){},a.onFail=function(a){i=-10,j=!0,d.fail(a)},a.onDone=function(a){l=a,i++,m(i)};if(!h.owner[k]){a.onFail({status:404,statusText:"Not Found",message:"Document not found."});return}var c=d.newCommand("loadDocument",{path:b.getPath()+"."+h.owner[k].revision+"."+k,option:a});c.setMaxRetry(0),d.addJob(d.newStorage(e.secondstorage_spec),c)})();break;case 100:if(!j){j=!0,d.done(l);return}break;default:}};m(0)},d.getDocumentList=function(a){d.fail({message:"NIY"})},d.removeDocument=function(a){d.fail({message:"NIY"})},d};f.addStorageType("replicate",i)})(LocalOrCookieStorage,jQuery,Base64,sjcl,MD5,jio);
\ No newline at end of file \ No newline at end of file
OfficeJS/src/jio.storage/conflictmanagerstorage.js
View file @ 0667c061
var newConflictManagerStorage = function ( spec, my ) { var newConflictManagerStorage = function ( spec, my ) {
var that = Jio.storage( spec, my, 'handler' ), priv = {}; var that = Jio.storage( spec, my, 'handler' ), priv = {};
spec = spec || {};
my = my || {};
var local_namespace = 'jio/conflictmanager/'; var local_namespace = 'jio/conflictmanager/';
...@@ -22,23 +24,14 @@ var newConflictManagerStorage = function ( spec, my ) { ...@@ -22,23 +24,14 @@ var newConflictManagerStorage = function ( spec, my ) {
return ''; return '';
}; };
priv.isTheLatestVersion = function (local,distant) { priv.removeValuesFromArrayWhere = function (array,fun) {
var k; var i, newarray = [];
if (!distant.owner) { for (i = 0; i < array.length; i+= 1) {
return true; if (!fun(array[i])) {
newarray.push(array[i]);
} }
for (k in distant.owner) {
if (k !== priv.username) {
if (local.winner.version <= distant.owner[k].last_version) {
return false;
} }
} return newarray;
}
return true;
};
priv.conflictResearch = function () {
// TODO : ;
}; };
/** /**
...@@ -54,7 +47,7 @@ var newConflictManagerStorage = function ( spec, my ) { ...@@ -54,7 +47,7 @@ var newConflictManagerStorage = function ( spec, my ) {
run_index = 0, run_index = 0,
end = false, is_a_new_file = false, end = false, is_a_new_file = false,
previous_revision = 0, previous_revision = 0,
local_file_hash = MD5 (command.getContent()), local_file_hash = hex_sha256 (command.getContent()),
run = function (index) { run = function (index) {
switch (index) { switch (index) {
case 0: case 0:
...@@ -88,6 +81,7 @@ var newConflictManagerStorage = function ( spec, my ) { ...@@ -88,6 +81,7 @@ var newConflictManagerStorage = function ( spec, my ) {
run_index ++; run (run_index); run_index ++; run (run_index);
break; break;
case 2: // load metadata from distant case 2: // load metadata from distant
(function () {
var cloned_option = command.cloneOption (); var cloned_option = command.cloneOption ();
cloned_option.onResponse = function () {}; cloned_option.onResponse = function () {};
cloned_option.onFail = function (error) { cloned_option.onFail = function (error) {
...@@ -96,8 +90,8 @@ var newConflictManagerStorage = function ( spec, my ) { ...@@ -96,8 +90,8 @@ var newConflictManagerStorage = function ( spec, my ) {
run_index ++; run (run_index); run_index ++; run (run_index);
} else { } else {
run_index = (-10); run_index = (-10);
that.fail(error);
end = true; end = true;
that.fail(error);
} }
}; };
cloned_option.onDone = function (result) { cloned_option.onDone = function (result) {
...@@ -109,10 +103,10 @@ var newConflictManagerStorage = function ( spec, my ) { ...@@ -109,10 +103,10 @@ var newConflictManagerStorage = function ( spec, my ) {
option:cloned_option}); option:cloned_option});
that.addJob ( that.newStorage (priv.secondstorage_spec), that.addJob ( that.newStorage (priv.secondstorage_spec),
newcommand ); newcommand );
}());
break; break;
// wait for 1 and 2
case 5: // check conflicts case 5: // check conflicts
var updateCommandMetadata = function () { var updateMetadataCommon = function () {
var original_creation_date; var original_creation_date;
original_creation_date = command_file_metadata.owner[ original_creation_date = command_file_metadata.owner[
...@@ -125,22 +119,28 @@ var newConflictManagerStorage = function ( spec, my ) { ...@@ -125,22 +119,28 @@ var newConflictManagerStorage = function ( spec, my ) {
} else { } else {
command_file_metadata.owner[priv.username] = {}; command_file_metadata.owner[priv.username] = {};
} }
command_file_metadata.winner.owner = priv.username;
command_file_metadata.winner.revision ++;
command_file_metadata.winner.hash = local_file_hash;
command_file_metadata.owner[priv.username].revision =
command_file_metadata.winner.revision;
command_file_metadata.owner[priv.username]. command_file_metadata.owner[priv.username].
last_modified = now.getTime(); last_modified = now.getTime();
command_file_metadata.owner[priv.username]. command_file_metadata.owner[priv.username].
creation_date = original_creation_date; creation_date = original_creation_date;
command_file_metadata.owner[priv.username].hash = command_file_metadata.owner[priv.username].hash =
local_file_hash; local_file_hash;
};
var updateCommandMetadataNotOnConflict = function () {
updateMetadataCommon ();
command_file_metadata.winner.owner = priv.username;
command_file_metadata.winner.revision ++;
command_file_metadata.winner.hash = local_file_hash;
command_file_metadata.owner[priv.username].revision =
command_file_metadata.winner.revision;
};
var updateCommandMetadataOnConflict = function () {
updateMetadataCommon ();
command_file_metadata.owner[priv.username].revision ++;
}; };
// if this is a new file // if this is a new file
if (is_a_new_file) { if (is_a_new_file) {
updateCommandMetadata(); updateCommandMetadataNotOnConflict();
LocalOrCookieStorage.setItem (local_metadata_file_name, LocalOrCookieStorage.setItem (local_metadata_file_name,
command_file_metadata); command_file_metadata);
run_index = (98); run_index = (98);
...@@ -148,52 +148,134 @@ var newConflictManagerStorage = function ( spec, my ) { ...@@ -148,52 +148,134 @@ var newConflictManagerStorage = function ( spec, my ) {
run (7); // save document revision run (7); // save document revision
break; break;
} }
// if no conflict
if (local_file_metadata.winner.revision === if (local_file_metadata.winner.revision ===
command_file_metadata.winner.revision && command_file_metadata.winner.revision &&
local_file_metadata.winner.hash === local_file_metadata.winner.hash ===
command_file_metadata.winner.hash) { command_file_metadata.winner.hash) {
// OK! Now, update distant metadata, store them and save // OK! Now, update distant metadata, store them and save
updateCommandMetadata(); updateCommandMetadataNotOnConflict();
LocalOrCookieStorage.setItem (local_metadata_file_name, LocalOrCookieStorage.setItem (local_metadata_file_name,
command_file_metadata); command_file_metadata);
run_index = 98; run_index = 98;
run (6); // save metadata run (6); // save metadata
run (7); // save document revision run (7); // save document revision
} else { } else {
// var conflict_hash = ''; // if conflict
// // gen hash var conflict_object = {
// conflict_hash = MD5 (JSON.stringify ({ label: 'revision',
// path: command.getPath() path: command.getPath(),
// // TODO : ; conflict_owner: {
// })); name: command_file_metadata.winner.owner,
// // TODO : ; revision: command_file_metadata.winner.revision,
// command_file_metadata.conflict_list.push ({ hash: command_file_metadata.winner.hash}
// label:'revision', },
// hash: conflict_hash, // gen hash
// path: command.getPath(), conflict_hash = hex_sha256 (JSON.stringify (
// local_owner: { conflict_object));
// name: priv.username, conflict_object.hash = conflict_hash;
// revision: local_file_metadata.owner[ // browse known conflict list
// priv.username].revision + 1, var i, known_conflict_list =
// hash: local_file_hash command.getOption('known_conflict_list') || [];
// }, var compare_fun = function (v) {
// conflict_owner: { return (v.hash === conflict_hash);
// name: command_file_metadata.winner.owner, };
// revision: command_file_metadata.winner.revision, for (i = 0; i < known_conflict_list.length; i+= 1) {
// hash: command_file_metadata.winner.hash // if known conflict
// } if (known_conflict_list[i].hash ===
// }); conflict_hash) {
command.getOption('onConflict')(); priv.removeValuesFromArrayWhere(
command_file_metadata.conflict_list,
compare_fun); // FIXME : must remove something!
updateCommandMetadataNotOnConflict();
run_index = 98;
run (6);
run (7);
return;
}
}
updateCommandMetadataOnConflict();
// if unknown conflict
command_file_metadata.conflict_list.push (conflict_object);
run_index = (-10); run_index = (-10);
end = true; end = true;
run (6); // save metadata
run (7); // save document revision
that.fail(); // TODO that.fail(); // TODO
command.getOption('onConflict')(conflict_object);
} }
break; break;
case 6: // save metadata case 6: // save metadata
console.log ('save metadata'); (function () {
var cloned_option = command.cloneOption ();
cloned_option.onResponse = function () {};
cloned_option.onFail = function (error) {
run_index = (-10);
end = true;
that.fail(error);
};
cloned_option.onDone = function () {
run_index ++; run (run_index);
};
var newcommand = that.newCommand(
'saveDocument',{path:metadata_file_name,
content:JSON.stringify (
command_file_metadata),
option:cloned_option});
newcommand.setMaxRetry (0); // inf
that.addJob ( that.newStorage (priv.secondstorage_spec),
newcommand );
}());
break; break;
case 7: // save document revision case 7: // save document revision
console.log ('save document revision'); (function () {
var cloned_option = command.cloneOption ();
cloned_option.onResponse = function () {};
cloned_option.onFail = function (error) {
run_index = (-10);
end = true;
that.fail(error);
};
cloned_option.onDone = function () {
run (8);
};
var newcommand = that.newCommand(
'saveDocument',
{path:command.getPath() + '.' +
command_file_metadata.owner[priv.username].revision +
'.' + priv.username,
content:command.getContent(),
option:cloned_option});
newcommand.setMaxRetry (0); // inf
that.addJob ( that.newStorage (priv.secondstorage_spec),
newcommand );
}());
break;
case 8:
(function () {
if ( previous_revision !== 0 ) {
var cloned_option = command.cloneOption ();
cloned_option.onResponse = function () {};
cloned_option.onFail = function (error) {
run_index = (-10);
end = true;
that.fail(error);
};
cloned_option.onDone = function () {
run_index ++; run (run_index);
};
var newcommand = that.newCommand(
'removeDocument',
{path:command.getPath() + '.' +
previous_revision + '.' + priv.username,
option:cloned_option});
newcommand.setMaxRetry (0); // inf
that.addJob ( that.newStorage (priv.secondstorage_spec),
newcommand );
} else {
run_index ++; run (run_index);
}
}());
break; break;
case 100: case 100:
if (!end) { if (!end) {
...@@ -216,7 +298,114 @@ var newConflictManagerStorage = function ( spec, my ) { ...@@ -216,7 +298,114 @@ var newConflictManagerStorage = function ( spec, my ) {
* @method loadDocument * @method loadDocument
*/ */
that.loadDocument = function (command) { that.loadDocument = function (command) {
that.fail({message:'NIY'}); var metadata_file_name = command.getPath() + '.metadata',
local_metadata_file_name = local_namespace + metadata_file_name,
command_file_metadata = {}, // distant file.metadata
run_index = 0,
end = false, owner = '', loaded_file,
run = function (index) {
switch (index) {
case 0: // load metadata file from distant
(function () {
var cloned_option = command.cloneOption ();
cloned_option.onResponse = function () {};
cloned_option.onFail = function (error) {
run_index = (-10);
end = true;
that.fail(error);
};
cloned_option.onDone = function (result) {
command_file_metadata = JSON.parse (result.content);
owner = command.getOption('owner');
run_index = 98;
// if owner
if (owner) {
run (3);
} else {
// if no owner
run (2);
}
run (1);
};
var newcommand = that.newCommand(
'loadDocument',
{path:metadata_file_name,
option:cloned_option});
newcommand.setMaxRetry (0); // inf
that.addJob ( that.newStorage (priv.secondstorage_spec),
newcommand );
}());
break;
case 1: // update local metadata
LocalOrCookieStorage.setItem (local_metadata_file_name,
command_file_metadata);
run_index ++; run (run_index);
break;
case 2: // load winner
(function () {
var cloned_option = command.cloneOption ();
cloned_option.onResponse = function () {};
cloned_option.onFail = function (error) {
run_index = (-10);
end = true;
that.fail(error);
};
cloned_option.onDone = function (result) {
loaded_file = result;
run_index ++; run (run_index);
};
var newcommand = that.newCommand(
'loadDocument',
{path:command.getPath() + '.' +
command_file_metadata.winner.revision +
'.' + command_file_metadata.winner.owner,
option:cloned_option});
newcommand.setMaxRetry (0); // inf
that.addJob ( that.newStorage (priv.secondstorage_spec),
newcommand );
}());
break;
case 3: // load owner
(function () {
var cloned_option = command.cloneOption ();
cloned_option.onResponse = function () {};
cloned_option.onFail = function (error) {
run_index = (-10);
end = true;
that.fail(error);
};
cloned_option.onDone = function (result) {
loaded_file = result;
run_index ++; run (run_index);
};
if (!command_file_metadata.owner[owner]) {
cloned_option.onFail ({status:404,
statusText:'Not Found',
message:'Document not found.'});
return;
}
var newcommand = that.newCommand(
'loadDocument',
{path:command.getPath() + '.' +
command_file_metadata.owner[owner].revision +
'.' + owner,
option:cloned_option});
newcommand.setMaxRetry (0); // inf
that.addJob ( that.newStorage (priv.secondstorage_spec),
newcommand );
}());
break;
case 100:
if (!end) {
end = true;
that.done(loaded_file);
return;
}
break;
default: break;
}
};
run (0);
}; };
/** /**
......
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