1 files changed, 89 insertions, 0 deletions
diff --git a/addons/pos_cache/static/src/js/pos_cache.js b/addons/pos_cache/static/src/js/pos_cache.js
new file mode 100644
index 00000000..48dfbd4a
--- /dev/null
+++ b/addons/pos_cache/static/src/js/pos_cache.js
@@ -0,0 +1,89 @@
+odoo.define('pos_cache.pos_cache', function (require) {
+"use strict";
+
+var models = require('point_of_sale.models');
+var core = require('web.core');
+var rpc = require('web.rpc');
+var _t = core._t;
+
+var posmodel_super = models.PosModel.prototype;
+models.PosModel = models.PosModel.extend({
+    load_server_data: function () {
+        var self = this;
+
+        var product_index = _.findIndex(this.models, function (model) {
+            return model.model === "product.product";
+        });
+
+        var product_model = self.models[product_index];
+
+        // We don't want to load product.product the normal
+        // uncached way, so get rid of it.
+        if (product_index !== -1) {
+            this.models.splice(product_index, 1);
+            this.product_model = product_model;
+        }
+        return posmodel_super.load_server_data.apply(this, arguments).then(function () {
+          // Give both the fields and domain to pos_cache in the
+          // backend. This way we don't have to hardcode these
+          // values in the backend and they automatically stay in
+          // sync with whatever is defined (and maybe extended by
+          // other modules) in js.
+          var product_fields =  typeof self.product_model.fields === 'function'  ? self.product_model.fields(self)  : self.product_model.fields;
+          var product_domain =  typeof self.product_model.domain === 'function'  ? self.product_model.domain(self)  : self.product_model.domain;
+            var limit_products_per_request = self.config.limit_products_per_request;
+            var cur_request = 0;
+            function next(resolve, reject){
+                var domain = product_domain;
+                if (limit_products_per_request){
+                    domain = domain.slice();
+                    // implement offset-limit via id, because "pos.cache"
+                    // doesn't have such fields and we can add them in master
+                    // branch only
+                    domain.unshift(['id', '>', cur_request * limit_products_per_request],
+                                   ['id', '<=', (cur_request + 1) * limit_products_per_request]);
+                }
+                return rpc.query({
+                    model: 'pos.config',
+                    method: 'get_products_from_cache',
+                    args: [self.pos_session.config_id[0], product_fields, domain],
+                }).then(function (products) {
+                    self.db.add_products(_.map(products, function (product) {
+                        product.categ = _.findWhere(self.product_categories, {'id': product.categ_id[0]});
+                        product.pos = self;
+                        return new models.Product({}, product);
+                    }));
+                    if (limit_products_per_request) {
+                        cur_request++;
+                        // check that we have more products
+                        domain = product_domain.slice();
+                        domain.unshift(['id', '>', cur_request * limit_products_per_request]);
+                        rpc.query({
+                            model: 'product.product',
+                            method: 'search_read',
+                            args: [domain, ['id']],
+                            kwargs: {
+                                limit: 1,
+                            }
+                        }).then(function (products) {
+                            if (products.length){
+                                next(resolve, reject);
+                            } else {
+                                resolve();
+                            }
+                        });
+                    } else {
+                        resolve();
+                    }
+                });
+            }
+            self.setLoadingMessage(_t('Loading') + ' product.product', 1);
+
+            return new Promise((resolve, reject) => {
+                next(resolve, reject);
+            });
+        });
+    },
+});
+
+});