queue_job: add mixin to link jobs

You can easily link jobs to their related records.

queue_job/models/__init__.py

@@ -3,3 +3,4 @@
 from . import queue_job
 from . import queue_job_channel
 from . import queue_job_function
+from . import queue_job_consumer_mixin

queue_job/models/queue_job.py

@@ -1,4 +1,4 @@
-# Copyright 2013-2020 Camptocamp SA
+# Copyright 2013 Camptocamp SA
 # License LGPL-3.0 or later (http://www.gnu.org/licenses/lgpl.html)
 
 import logging
@@ -234,10 +234,20 @@ def create(self, vals_list):
             raise exceptions.AccessError(
                 _("Queue jobs must be created by calling 'with_delay()'.")
             )
-        return super(
+        records = super(
             QueueJob,
             self.with_context(mail_create_nolog=True, mail_create_nosubscribe=True),
         ).create(vals_list)
+        records._handle_origin_link()
+        return records
+
+    def _handle_origin_link(self):
+        """Update job relation on origin records."""
+        for qjob in self:
+            model = self.env.get(qjob.model_name)
+            if not model or model and not hasattr(model, "_collect_queue_job"):
+                continue
+            qjob.records._collect_queue_job(qjob)
 
     def write(self, vals):
         if self.env.context.get("_job_edit_sentinel") is not self.EDIT_SENTINEL:

queue_job/models/queue_job_consumer_mixin.py

@@ -0,0 +1,40 @@
+# Copyright 2023 Camptocamp SA
+# License LGPL-3.0 or later (http://www.gnu.org/licenses/lgpl.html)
+
+from odoo import fields, models
+from odoo.tools import safe_eval
+
+
+class QueueJobConsumerMixin(models.AbstractModel):
+    """Provide common features to models using jobs."""
+
+    _name = "queue.job.consumer.mixin"
+    _description = _name
+
+    job_ids = fields.Many2many(
+        string="Related jobs",
+        comodel_name="queue.job",
+        column1="rec_id",
+        column2="job_id",
+    )
+
+    def _collect_queue_job(self, qjob):
+        """Update job relation w/ queue jobs."""
+        for rec in self:
+            rec.job_ids |= qjob
+
+    def action_view_related_jobs(self):
+        self.ensure_one()
+        xmlid = "queue_job.action_queue_job"
+        action = self.env["ir.actions.act_window"]._for_xml_id(xmlid)
+        action["domain"] = [("id", "in", self.job_ids.ids)]
+        # Purge default search filters from ctx to avoid hiding records
+        ctx = action.get("context", {})
+        if isinstance(ctx, str):
+            ctx = safe_eval.safe_eval(ctx, self.env.context)
+        action["context"] = {
+            k: v for k, v in ctx.items() if not k.startswith("search_default_")
+        }
+        # Drop ID otherwise the context will be loaded from the action's record
+        action.pop("id")
+        return action