Merge pull request #309 from mkumar-02/17.0-rabbitmq-connector

Added rabbitmq connector module

Author: shibu-narayanan

README.md

@@ -45,6 +45,7 @@ addon | version | maintainers | summary
 [g2p_program_assessment](g2p_program_assessment/) | 17.0.0.0.0 |  | OpenG2P Program: Assessment
 [g2p_program_autoenrol](g2p_program_autoenrol/) | 17.0.0.0.0 |  | OpenG2P Programs: Autoenrol
 [g2p_program_cycleless](g2p_program_cycleless/) | 17.0.0.0.0 |  | OpenG2P Programs: Cycleless
+[g2p_program_datashare_rabbitmq](g2p_program_datashare_rabbitmq/) | 17.0.0.0.0 |  | G2P Program Datashare: RabbitMQ
 [g2p_program_documents](g2p_program_documents/) | 17.0.0.0.0 |  | OpenG2P Program: Documents
 [g2p_program_registrant_info](g2p_program_registrant_info/) | 17.0.0.0.0 |  | G2P Program: Registrant Info
 [g2p_program_reimbursement](g2p_program_reimbursement/) | 17.0.0.0.0 |  | OpenG2P Programs: Reimbursement

g2p_program_datashare_rabbitmq/README.md

@@ -0,0 +1,3 @@
+# OpenG2P Program Datashare: RabbitMQ
+
+Refer to https://docs.openg2p.org.

g2p_program_datashare_rabbitmq/__init__.py

@@ -0,0 +1,3 @@
+# Part of OpenG2P. See LICENSE file for full copyright and licensing details.
+
+from . import models

g2p_program_datashare_rabbitmq/__manifest__.py

@@ -0,0 +1,23 @@
+# Part of OpenG2P. See LICENSE file for full copyright and licensing details.
+{
+    "name": "G2P Program Datashare: RabbitMQ",
+    "category": "G2P",
+    "version": "17.0.0.0.0",
+    "sequence": 1,
+    "author": "OpenG2P",
+    "website": "https://openg2p.org",
+    "license": "LGPL-3",
+    "depends": [
+        "g2p_programs",
+        "g2p_registry_datashare_rabbitmq",
+    ],
+    "data": [
+        "views/datashare_config_rabbitmq.xml",
+    ],
+    "assets": {},
+    "demo": [],
+    "images": [],
+    "application": True,
+    "installable": True,
+    "auto_install": False,
+}

g2p_program_datashare_rabbitmq/models/__init__.py

@@ -0,0 +1,4 @@
+# Part of OpenG2P. See LICENSE file for full copyright and licensing details.
+
+from . import datashare_config_rabbitmq
+from . import program_membership

g2p_program_datashare_rabbitmq/models/datashare_config_rabbitmq.py

@@ -0,0 +1,23 @@
+# Part of OpenG2P. See LICENSE file for full copyright and licensing details.
+
+import logging
+
+from odoo import fields, models
+
+_logger = logging.getLogger(__name__)
+
+
+class G2PDatashareConfigRabbitMQProgram(models.Model):
+    _inherit = "g2p.datashare.config.rabbitmq"
+
+    data_source = fields.Selection(
+        selection_add=[
+            (
+                "beneficiary_registry",
+                "Beneficiary Registry",
+            )
+        ],
+        ondelete={"beneficiary_registry": "cascade"},
+    )
+
+    program_id = fields.Many2one("g2p.program")

g2p_program_datashare_rabbitmq/models/program_membership.py

@@ -0,0 +1,45 @@
+# Part of OpenG2P. See LICENSE file for full copyright and licensing details.
+
+
+from odoo import api, models
+
+
+class G2PProgramMembership(models.Model):
+    _inherit = "g2p.program_membership"
+
+    def _push_to_rabbitmq(self):
+        """Push the record to RabbitMQ after applying JQ transformation."""
+        configs = self.env["g2p.datashare.config.rabbitmq"].search(
+            [("active", "=", True), ("data_source", "=", "beneficiary_registry")]
+        )
+        for rec in self:
+            if rec.is_registrant:
+                rec_data = rec.read()[0]
+                rec_data.update(
+                    {"program_id": self.env["g2p.program"].browse(rec_data["program_id"][0]).read()[0]}
+                )
+                for config in configs:
+                    self.process_reg_id(config.id_type, rec_data)
+                    transformed = config.transform_data(rec_data)
+                    if transformed is not None:
+                        config.publish(transformed)
+
+    def process_reg_id(self, id_type, rec_data):
+        reg_id = self.env["g2p.reg.id"].search(
+            [("id_type", "=", id_type.id), ("partner_id", "=", rec_data["partner_id"][0])], limit=1
+        )
+        if reg_id:
+            return rec_data.update({"reg_id_value": reg_id.value})
+
+    @api.model_create_multi
+    def create(self, vals_list):
+        """Override create to push new records to RabbitMQ."""
+        records = super().create(vals_list)
+        records._push_to_rabbitmq()
+        return records
+
+    def write(self, vals):
+        """Override write to push updated records to RabbitMQ."""
+        res = super().write(vals)
+        self._push_to_rabbitmq()
+        return res

g2p_program_datashare_rabbitmq/pyproject.toml

@@ -0,0 +1,3 @@
+[build-system]
+requires = ["whool"]
+build-backend = "whool.buildapi"

g2p_program_datashare_rabbitmq/static/description/icon.png

@@ -0,0 +1,3 @@
+# Part of OpenG2P. See LICENSE file for full copyright and licensing details.
+
+from . import test_datashare_config_rabbitmq