60 lines
1.2 KiB
JavaScript
60 lines
1.2 KiB
JavaScript
frappe.provide('hub');
|
|
frappe.provide('erpnext.hub');
|
|
|
|
erpnext.hub.cache = {};
|
|
hub.call = function call_hub_method(method, args={}, clear_cache_on_event) {
|
|
return new Promise((resolve, reject) => {
|
|
|
|
// cache
|
|
const key = method + JSON.stringify(args);
|
|
if (erpnext.hub.cache[key]) {
|
|
resolve(erpnext.hub.cache[key]);
|
|
}
|
|
|
|
// cache invalidation
|
|
const clear_cache = () => delete erpnext.hub.cache[key];
|
|
|
|
if (!clear_cache_on_event) {
|
|
invalidate_after_5_mins(clear_cache);
|
|
} else {
|
|
erpnext.hub.on(clear_cache_on_event, () => {
|
|
clear_cache(key)
|
|
});
|
|
}
|
|
|
|
frappe.call({
|
|
method: 'erpnext.hub_node.api.call_hub_method',
|
|
args: {
|
|
method,
|
|
params: args
|
|
}
|
|
})
|
|
.then(r => {
|
|
if (r.message) {
|
|
const response = r.message;
|
|
if (response.error) {
|
|
frappe.throw({
|
|
title: __('Marketplace Error'),
|
|
message: response.error
|
|
});
|
|
}
|
|
|
|
erpnext.hub.cache[key] = response;
|
|
erpnext.hub.trigger(`response:${key}`, { response });
|
|
resolve(response);
|
|
}
|
|
reject(r);
|
|
})
|
|
.fail(reject)
|
|
});
|
|
}
|
|
|
|
function invalidate_after_5_mins(clear_cache) {
|
|
// cache invalidation after 5 minutes
|
|
const timeout = 5 * 60 * 1000;
|
|
|
|
setTimeout(() => {
|
|
clear_cache();
|
|
}, timeout);
|
|
}
|