preluare job queue din 14

Author: dhongu

deltatech_queue_job/README.rst

@@ -0,0 +1,62 @@
+===================
+Deltatech Queue Job
+===================
+
+.. !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
+   !! This file is generated by oca-gen-addon-readme !!
+   !! changes will be overwritten.                   !!
+   !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
+
+.. |badge1| image:: https://img.shields.io/badge/maturity-Beta-yellow.png
+    :target: https://odoo-community.org/page/development-status
+    :alt: Beta
+.. |badge2| image:: https://img.shields.io/badge/licence-LGPL--3-blue.png
+    :target: http://www.gnu.org/licenses/lgpl-3.0-standalone.html
+    :alt: License: LGPL-3
+.. |badge3| image:: https://img.shields.io/badge/github-dhongu%2Fdeltatech-lightgray.png?logo=github
+    :target: https://github.com/dhongu/deltatech/tree/14.0/deltatech_queue_job
+    :alt: dhongu/deltatech
+
+|badge1| |badge2| |badge3| 
+
+
+**Table of contents**
+
+.. contents::
+   :local:
+
+Bug Tracker
+===========
+
+Bugs are tracked on `GitHub Issues <https://github.com/dhongu/deltatech/issues>`_.
+In case of trouble, please check there if your issue has already been reported.
+If you spotted it first, help us smashing it by providing a detailed and welcomed
+`feedback <https://github.com/dhongu/deltatech/issues/new?body=module:%20deltatech_queue_job%0Aversion:%2014.0%0A%0A**Steps%20to%20reproduce**%0A-%20...%0A%0A**Current%20behavior**%0A%0A**Expected%20behavior**>`_.
+
+Do not contact contributors directly about support or help with technical issues.
+
+Credits
+=======
+
+Authors
+~~~~~~~
+
+* Terrabit
+* Dorin Hongu
+* Camptocamp
+* ACSONE SA/NV
+
+Maintainers
+~~~~~~~~~~~
+
+.. |maintainer-dhongu| image:: https://github.com/dhongu.png?size=40px
+    :target: https://github.com/dhongu
+    :alt: dhongu
+
+Current maintainer:
+
+|maintainer-dhongu| 
+
+This module is part of the `dhongu/deltatech <https://github.com/dhongu/deltatech/tree/14.0/deltatech_queue_job>`_ project on GitHub.
+
+You are welcome to contribute.

deltatech_queue_job/__init__.py

@@ -0,0 +1,5 @@
+# ©  2021 Deltatech
+# See README.rst file on addons root folder for license details
+
+from . import models
+from . import wizards

deltatech_queue_job/__manifest__.py

@@ -0,0 +1,25 @@
+# ©  2015-2019 Deltatech
+# See README.rst file on addons root folder for license details
+{
+    "name": "Deltatech Queue Job",
+    "summary": "Queue Job using Crone",
+    "version": "15.0.1.0.1",
+    "author": "Terrabit, Dorin Hongu, Camptocamp,ACSONE SA/NV,Odoo Community Association (OCA)",
+    "website": "https://www.terrabit.ro",
+    "support": "[email protected]",
+    "category": "Warehouse",
+    "depends": ["base", "mail"],
+    "data": [
+        "security/security.xml",
+        "security/ir.model.access.csv",
+        "views/queue_job_views.xml",
+        "views/queue_job_menus.xml",
+        "data/ir_cron_data.xml",
+        "wizards/queue_jobs_to_done_views.xml",
+        "wizards/queue_requeue_job_views.xml",
+    ],
+    "license": "LGPL-3",
+    "images": ["static/description/main_screenshot.png"],
+    "development_status": "Beta",
+    "maintainers": ["dhongu"],
+}

deltatech_queue_job/data/ir_cron_data.xml

@@ -0,0 +1,36 @@
+<?xml version='1.0' encoding='utf-8' ?>
+<odoo>
+    <data noupdate="1">
+        <record id="ir_cron_queue_job" model="ir.cron">
+            <field name="name">Queue: Run</field>
+            <field name="model_id" ref="model_queue_job" />
+            <field name="state">code</field>
+            <field name="numbercall">-1</field>
+            <field name="code">model._cron_runjob()</field>
+            <field name="interval_number">1</field>
+            <field name="interval_type">minutes</field>
+            <field name="user_id" ref="base.user_root" />
+            <field name="active" eval="True" />
+            <field name="doall" eval="False" />
+        </record>
+        <record id="ir_cron_autovacuum_queue_jobs" model="ir.cron">
+            <field name="name">AutoVacuum Job Queue</field>
+            <field name="model_id" ref="model_queue_job" />
+            <field eval="True" name="active" />
+            <field name="user_id" ref="base.user_root" />
+            <field name="interval_number">1</field>
+            <field name="interval_type">days</field>
+            <field name="numbercall">-1</field>
+            <field eval="False" name="doall" />
+            <field name="state">code</field>
+            <field name="code">model.autovacuum()</field>
+        </record>
+    </data>
+
+    <!-- Queue-job-related subtypes for messaging / Chatter -->
+    <record id="mt_job_failed" model="mail.message.subtype">
+        <field name="name">Job failed</field>
+        <field name="res_model">queue.job</field>
+        <field name="default" eval="True" />
+    </record>
+</odoo>

deltatech_queue_job/exception.py

@@ -0,0 +1,43 @@
+# Copyright 2012-2016 Camptocamp
+# License LGPL-3.0 or later (http://www.gnu.org/licenses/lgpl.html)
+
+
+class BaseQueueJobError(Exception):
+    """Base queue job error"""
+
+
+class JobError(BaseQueueJobError):
+    """A job had an error"""
+
+
+class NoSuchJobError(JobError):
+    """The job does not exist."""
+
+
+class FailedJobError(JobError):
+    """A job had an error having to be resolved."""
+
+
+class RetryableJobError(JobError):
+    """A job had an error but can be retried.
+
+    The job will be retried after the given number of seconds.  If seconds is
+    empty, it will be retried according to the ``retry_pattern`` of the job or
+    by :const:`odoo.addons.queue_job.job.RETRY_INTERVAL` if nothing is defined.
+
+    If ``ignore_retry`` is True, the retry counter will not be increased.
+    """
+
+    def __init__(self, msg, seconds=None, ignore_retry=False):
+        super().__init__(msg)
+        self.seconds = seconds
+        self.ignore_retry = ignore_retry
+
+
+# TODO: remove support of NothingToDo: too dangerous
+class NothingToDoJob(JobError):
+    """The Job has nothing to do."""
+
+
+class ChannelNotFound(BaseQueueJobError):
+    """A channel could not be found"""

deltatech_queue_job/fields.py

@@ -0,0 +1,118 @@
+# copyright 2016 Camptocamp
+# license lgpl-3.0 or later (http://www.gnu.org/licenses/lgpl.html)
+
+import json
+from datetime import date, datetime
+
+import dateutil
+import lxml
+
+from odoo import fields, models
+from odoo.tools.func import lazy
+
+
+class JobSerialized(fields.Field):
+    """Provide the storage for job fields stored as json
+
+    A base_type must be set, it must be dict, list or tuple.
+    When the field is not set, the json will be the corresponding
+    json string ("{}" or "[]").
+
+    Support for some custom types has been added to the json decoder/encoder
+    (see JobEncoder and JobDecoder).
+    """
+
+    type = "job_serialized"
+    column_type = ("text", "text")
+
+    _base_type = None
+
+    # these are the default values when we convert an empty value
+    _default_json_mapping = {
+        dict: "{}",
+        list: "[]",
+        tuple: "[]",
+        models.BaseModel: lambda env: json.dumps(
+            {"_type": "odoo_recordset", "model": "base", "ids": [], "uid": env.uid}
+        ),
+    }
+
+    def __init__(self, string=fields.Default, base_type=fields.Default, **kwargs):
+        super().__init__(string=string, _base_type=base_type, **kwargs)
+
+    def _setup_attrs(self, model, name):
+        super()._setup_attrs(model, name)
+        if self._base_type not in self._default_json_mapping:
+            raise ValueError("%s is not a supported base type" % (self._base_type))
+
+    def _base_type_default_json(self, env):
+        default_json = self._default_json_mapping.get(self._base_type)
+        if not isinstance(default_json, str):
+            default_json = default_json(env)
+        return default_json
+
+    def convert_to_column(self, value, record, values=None, validate=True):
+        return self.convert_to_cache(value, record, validate=validate)
+
+    def convert_to_cache(self, value, record, validate=True):
+        # cache format: json.dumps(value) or None
+        if isinstance(value, self._base_type):
+            return json.dumps(value, cls=JobEncoder)
+        else:
+            return value or None
+
+    def convert_to_record(self, value, record):
+        default = self._base_type_default_json(record.env)
+        return json.loads(value or default, cls=JobDecoder, env=record.env)
+
+
+class JobEncoder(json.JSONEncoder):
+    """Encode Odoo recordsets so that we can later recompose them"""
+
+    def default(self, obj):
+        if isinstance(obj, models.BaseModel):
+            return {
+                "_type": "odoo_recordset",
+                "model": obj._name,
+                "ids": obj.ids,
+                "uid": obj.env.uid,
+                "su": obj.env.su,
+            }
+        elif isinstance(obj, datetime):
+            return {"_type": "datetime_isoformat", "value": obj.isoformat()}
+        elif isinstance(obj, date):
+            return {"_type": "date_isoformat", "value": obj.isoformat()}
+        elif isinstance(obj, lxml.etree._Element):
+            return {
+                "_type": "etree_element",
+                "value": lxml.etree.tostring(obj, encoding=str),
+            }
+        elif isinstance(obj, lazy):
+            return obj._value
+        return json.JSONEncoder.default(self, obj)
+
+
+class JobDecoder(json.JSONDecoder):
+    """Decode json, recomposing recordsets"""
+
+    def __init__(self, *args, **kwargs):
+        env = kwargs.pop("env")
+        super().__init__(object_hook=self.object_hook, *args, **kwargs)
+        assert env
+        self.env = env
+
+    def object_hook(self, obj):
+        if "_type" not in obj:
+            return obj
+        type_ = obj["_type"]
+        if type_ == "odoo_recordset":
+            model = self.env(user=obj.get("uid"), su=obj.get("su"))[obj["model"]]
+
+            return model.browse(obj["ids"])
+        elif type_ == "datetime_isoformat":
+            return dateutil.parser.parse(obj["value"])
+        elif type_ == "date_isoformat":
+            return dateutil.parser.parse(obj["value"]).date()
+        elif type_ == "etree_element":
+            return lxml.etree.fromstring(obj["value"])
+        return obj