JSAN.use('util.error'); this.error = new util.error();
JSAN.use('main.network'); this.network = new main.network();
- var obj = this;
-
- JSAN.use('util.file');
- JSAN.use('util.functional');
- JSAN.use('util.fm_utils');
-
- function gen_fm_retrieval_func(classname,data) {
- var app = data[0]; var method = data[1]; var params = data[2]; var cacheable = data[3];
- return function () {
-
- function convert() {
- try {
- if (obj.list[classname].constructor.name == 'Array') {
- obj.hash[classname] =
- util.functional.convert_object_list_to_hash(
- obj.list[classname]
- );
- }
- } catch(E) {
-
- obj.error.sdump('D_ERROR',E + '\n');
- }
-
- }
-
- try {
- obj.list[classname] = obj.network.request( app, method, params);
- convert();
- // if cacheable, store an offline copy
- if (cacheable) {
- var file = new util.file( classname );
- file.set_object( obj.list[classname] );
- }
-
- } catch(E) {
- // if cacheable, try offline
- if (cacheable) {
- try {
- var file = new util.file( classname );
- obj.list[classname] = file.get_object();
- convert();
- } catch(E) {
- throw(E);
- }
- } else {
- throw(E); // for now
- }
- }
- }
- }
-
- this.chain = [];
-
- this.chain.push(
- function() {
- var f = gen_fm_retrieval_func(
- 'au',
- [
- 'open-ils.search',
- 'open-ils.search.actor.user.session',
- [ obj.session ],
- false
- ]
- );
- try {
- f();
- } catch(E) {
- // Probably the one thing we should not cache, so what do we do?
- obj.list.au = new au();
- obj.list.au.home_lib( '1' );
- }
- }
- );
-
- obj.error.sdump('D_DEBUG','_fm_objects = ' + js2JSON(this._fm_objects) + '\n');
-
- for (var i in this._fm_objects) {
- this.chain.push( gen_fm_retrieval_func(i,this._fm_objects[i]) );
- }
-
- // The previous org_tree call returned a tree, not a list or hash.
- this.chain.push(
- function () {
- obj.org_tree = obj.list.aou;
- obj.list.aou = util.fm_utils.flatten_ou_branch( obj.org_tree );
- obj.hash.aou = util.functional.convert_object_list_to_hash( obj.list.aou );
- }
- );
-
- this.chain.push(
- gen_fm_retrieval_func('my_aou',
- [
- 'open-ils.actor',
- 'open-ils.actor.org_unit.full_path.retrieve',
- [ obj.session ],
- true
- ]
- )
- );
-
- // Do this after we get the user object
- this.chain.push(
-
- function () {
-
- gen_fm_retrieval_func( 'my_actsc',
- [
- 'open-ils.circ',
- 'open-ils.circ.stat_cat.actor.retrieve.all',
- [ obj.session, obj.list.au.home_ou() ],
- true
- ]
- )();
- }
- );
-
return this;
-};
+}
OpenILS.data.prototype = {
'list' : {},
'hash' : {},
- 'init' : function (stash) {
-
- if (stash) {
-
- try {
- const OpenILS=new Components.Constructor("@mozilla.org/openils_data_cache;1", "nsIOpenILS");
- var data_cache=new OpenILS( );
- var dc = data_cache.wrappedJSObject.OpenILS.prototype.data;
- for (var i in dc) {
- this.error.sdump('D_DATA','Retrieving ' + i + ' : ' + dc[i] + '\n');
- this[i] = dc[i];
- }
- } catch(E) {
- this.error.sdump('D_ERROR','Error in OpenILS.data.init(true): ' + js2JSON(E) );
- }
+ 'init' : function (params) {
- if (typeof this.on_complete == 'function') {
-
- this.on_complete();
+ try {
+ if (params && params.via == 'stash') {
+ this.stash_retrieve();
+ } else {
+ this.network_retrieve();
}
+
+ } catch(E) {
+ this.error.sdump('D_ERROR','Error in OpenILS.data.init('
+ +js2JSON(params)+'): ' + js2JSON(E) );
+ }
- } else {
- if (typeof this.on_complete == 'function') {
-
- this.chain.push( this.on_complete );
- }
- JSAN.use('util.exec'); this.exec = new util.exec();
- this.exec.on_error = function(E) { alert('oops: ' + E ); }
- this.exec.chain( this.chain );
- }
},
'stash' : function () {
'ccs' : [ 'open-ils.search', 'open-ils.search.config.copy_status.retrieve.all', [], true ],
'aou' : [ 'open-ils.actor', 'open-ils.actor.org_tree.retrieve', [], true ],
'aout' : [ 'open-ils.actor', 'open-ils.actor.org_types.retrieve', [], true ]
- }
+ },
+
+ 'stash_retrieve' : function() {
+ const OpenILS=new Components.Constructor("@mozilla.org/openils_data_cache;1", "nsIOpenILS");
+ var data_cache=new OpenILS( );
+ var dc = data_cache.wrappedJSObject.OpenILS.prototype.data;
+ for (var i in dc) {
+ this.error.sdump('D_DATA','Retrieving ' + i + ' : ' + dc[i] + '\n');
+ this[i] = dc[i];
+ }
+ if (typeof this.on_complete == 'function') {
+
+ this.on_complete();
+ }
+ },
+
+ 'network_retrieve' : function() {
+ var obj = this;
+
+ JSAN.use('util.file');
+ JSAN.use('util.functional');
+ JSAN.use('util.fm_utils');
+
+ function gen_fm_retrieval_func(classname,data) {
+ var app = data[0]; var method = data[1]; var params = data[2]; var cacheable = data[3];
+ return function () {
+
+ function convert() {
+ try {
+ if (obj.list[classname].constructor.name == 'Array') {
+ obj.hash[classname] =
+ util.functional.convert_object_list_to_hash(
+ obj.list[classname]
+ );
+ }
+ } catch(E) {
+
+ obj.error.sdump('D_ERROR',E + '\n');
+ }
+ }
+
+ try {
+ obj.list[classname] = obj.network.request( app, method, params);
+ convert();
+ // if cacheable, store an offline copy
+ if (cacheable) {
+ var file = new util.file( classname );
+ file.set_object( obj.list[classname] );
+ }
+
+ } catch(E) {
+ // if cacheable, try offline
+ if (cacheable) {
+ try {
+ var file = new util.file( classname );
+ obj.list[classname] = file.get_object();
+ convert();
+ } catch(E) {
+ throw(E);
+ }
+ } else {
+ throw(E); // for now
+ }
+ }
+ }
+ }
+
+ this.chain = [];
+
+ this.chain.push(
+ function() {
+ var f = gen_fm_retrieval_func(
+ 'au',
+ [
+ 'open-ils.search',
+ 'open-ils.search.actor.user.session',
+ [ obj.session ],
+ false
+ ]
+ );
+ try {
+ f();
+ } catch(E) {
+ // Probably the one thing we should not cache, so what do we do?
+ obj.list.au = new au();
+ obj.list.au.home_lib( '1' );
+ }
+ }
+ );
+
+ obj.error.sdump('D_DEBUG','_fm_objects = ' + js2JSON(this._fm_objects) + '\n');
+
+ for (var i in this._fm_objects) {
+ this.chain.push( gen_fm_retrieval_func(i,this._fm_objects[i]) );
+ }
+
+ // The previous org_tree call returned a tree, not a list or hash.
+ this.chain.push(
+ function () {
+ obj.org_tree = obj.list.aou;
+ obj.list.aou = util.fm_utils.flatten_ou_branch( obj.org_tree );
+ obj.hash.aou = util.functional.convert_object_list_to_hash( obj.list.aou );
+ }
+ );
+
+ this.chain.push(
+ gen_fm_retrieval_func('my_aou',
+ [
+ 'open-ils.actor',
+ 'open-ils.actor.org_unit.full_path.retrieve',
+ [ obj.session ],
+ true
+ ]
+ )
+ );
+
+ // Do this after we get the user object
+ this.chain.push(
+
+ function () {
+
+ gen_fm_retrieval_func( 'my_actsc',
+ [
+ 'open-ils.circ',
+ 'open-ils.circ.stat_cat.actor.retrieve.all',
+ [ obj.session, obj.list.au.home_ou() ],
+ true
+ ]
+ )();
+ }
+ );
+
+ if (typeof this.on_complete == 'function') {
+
+ this.chain.push( this.on_complete );
+ }
+ JSAN.use('util.exec'); this.exec = new util.exec();
+ this.exec.on_error = function(E) {
+
+ if (typeof obj.on_error == 'function') {
+ obj.on_error();
+ } else {
+ alert('oops: ' + E );
+ }
+ }
+
+ this.exec.chain( this.chain );
+
+ }
}
dump('exiting OpenILS/data.js\n');
projects / Evergreen.git / commitdiff