[FIX] queue_job_batch: migrate messaging system

Author: len-foss

queue_job_batch/controllers/webclient.py

@@ -7,15 +7,16 @@
 
 
 class WebClient(WebclientController):
-    def _process_request_for_internal_user(self, store, **kwargs):
-        res = super()._process_request_for_internal_user(store, **kwargs)
-        if kwargs.get("systray_get_queue_job_batches"):
+    @classmethod
+    def _process_request_for_internal_user(self, store, name, params):
+        res = super()._process_request_for_internal_user(store, name, params)
+        if name == "systray_get_queue_job_batches":
             # sudo: bus.bus: reading non-sensitive last id
             bus_last_id = request.env["bus.bus"].sudo()._bus_last_id()
             batches = request.env.user._get_queue_job_batches()
             store.add(batches)
-            store.add(
-                {
+            store.add_global_values(
+                **{
                     "queueJobBatchCounter": len(batches),
                     "queueJobBatchCounterBusId": bus_last_id,
                 }

queue_job_batch/models/queue_job_batch.py

@@ -109,20 +109,16 @@ def _compute_job_count(self):
             rec.completeness = rec.finished_job_count / max(1, rec.job_count)
             rec.failed_percentage = rec.failed_job_count / max(1, rec.job_count)
 
-    @api.model
-    def _to_store_fnames(self):
-        return (
+    def _to_store_defaults(self, target):
+        return [
             "name",
             "state",
             "job_count",
             "finished_job_count",
             "failed_job_count",
             "completeness",
             "failed_percentage",
-        )
+        ]
 
-    def _to_store(self, store: Store):
-        fnames = self._to_store_fnames()
-        for rec in self:
-            data = rec.read(fnames)[0]
-            store.add(rec, data)
+    def _to_store(self, store: Store, fields):
+        store.add_records_fields(self, fields)

queue_job_batch/models/res_users.py

@@ -10,13 +10,8 @@ class Users(models.Model):
 
     def _init_store_data(self, store):
         res = super()._init_store_data(store)
-        store.add(
-            {
-                "hasQueueJobBatchUserGroup": self.env.user.has_group(
-                    "queue_job_batch.group_queue_job_batch_user"
-                ),
-            }
-        )
+        has_it = self.env.user.has_group("queue_job_batch.group_queue_job_batch_user")
+        store.add_global_values(hasQueueJobBatchUserGroup=has_it)
         return res
 
     def _get_queue_job_batches(self):

queue_job_batch/static/src/components/QueueJobBatchMenu.esm.js

@@ -32,7 +32,7 @@ export class QueueJobBatchMenu extends Component {
     }
 
     onBeforeOpen() {
-        this.store.fetchData({systray_get_queue_job_batches: true});
+        this.store.fetchStoreData("systray_get_queue_job_batches");
     }
 
     getGroupInfo(batch) {