|
| 1 | +from odoo.exceptions import UserError |
| 2 | +from odoo.tests import TransactionCase |
| 3 | + |
| 4 | + |
| 5 | +class TestSQLBasedEligibilityManager(TransactionCase): |
| 6 | + @classmethod |
| 7 | + def setUpClass(cls): |
| 8 | + super().setUpClass() |
| 9 | + cls.partner = cls.env["res.partner"].create({"name": "Test Partner", "is_group": False}) |
| 10 | + cls.program_id = cls.env["g2p.program"].create( |
| 11 | + { |
| 12 | + "name": "Test Program", |
| 13 | + "target_type": "individual", |
| 14 | + } |
| 15 | + ) |
| 16 | + cls.membership = cls.env["g2p.program_membership"].create( |
| 17 | + { |
| 18 | + "partner_id": cls.partner.id, |
| 19 | + "program_id": cls.program_id.id, |
| 20 | + "state": "enrolled", |
| 21 | + } |
| 22 | + ) |
| 23 | + cls.sql_manager = cls.env["g2p.program_membership.manager.sql"].create( |
| 24 | + { |
| 25 | + "name": "SQL Manager", |
| 26 | + "program_id": cls.program_id.id, |
| 27 | + } |
| 28 | + ) |
| 29 | + |
| 30 | + def test_sql_query_onchange(self): |
| 31 | + self.sql_manager._sql_query_onchange() |
| 32 | + |
| 33 | + self.assertEqual( |
| 34 | + self.sql_manager.sql_query_valid, |
| 35 | + "recheck", |
| 36 | + ) |
| 37 | + self.assertFalse(self.sql_manager.sql_query_valid_message) |
| 38 | + self.assertEqual(self.sql_manager.sql_record_count, 0) |
| 39 | + |
| 40 | + def test_prepare_eligible_domain(self): |
| 41 | + domain = self.sql_manager._prepare_eligible_domain(membership=self.program_id.program_membership_ids) |
| 42 | + |
| 43 | + self.assertEqual(domain, [("id", "in", [self.partner.id]), ("disabled", "=", False), ("is_group", "=", False)]) |
| 44 | + |
| 45 | + self.program_id.target_type = "group" |
| 46 | + domain = self.sql_manager._prepare_eligible_domain(beneficiaries=self.partner.ids) |
| 47 | + self.assertEqual(domain, [("id", "in", [self.partner.id]), ("disabled", "=", False), ("is_group", "=", True)]) |
| 48 | + |
| 49 | + def test_generate_sql_query(self): |
| 50 | + self.sql_manager.sql_query = "select id from res_partner where name = 'Test Partner'" |
| 51 | + sql_query = self.sql_manager._generate_sql_query() |
| 52 | + |
| 53 | + self.assertIn(self.sql_manager.sql_query, sql_query) |
| 54 | + self.assertIn("active AND disabled IS NULL AND NOT is_group", sql_query) |
| 55 | + |
| 56 | + self.program_id.target_type = "group" |
| 57 | + self.sql_manager.sql_query = "insert into res_partner (name) values ('Test Partner')" |
| 58 | + sql_query = self.sql_manager._generate_sql_query() |
| 59 | + |
| 60 | + self.assertIn("DML ERROR", sql_query) |
| 61 | + self.assertIn("active AND disabled IS NULL AND is_group", sql_query) |
| 62 | + |
| 63 | + def test_get_beneficiaries_sql_query(self): |
| 64 | + with self.assertRaisesRegex( |
| 65 | + UserError, "The SQL Query is not valid. Be sure to validate this in the Eligibility Manager." |
| 66 | + ): |
| 67 | + self.sql_manager._get_beneficiaries_sql_query() |
| 68 | + |
| 69 | + self.sql_manager.sql_query = "select id from res_partner" |
| 70 | + self.sql_manager.sql_query_valid = "valid" |
| 71 | + |
| 72 | + sql_query_result = self.sql_manager._get_beneficiaries_sql_query() |
| 73 | + |
| 74 | + self.assertIn(self.partner.id, sql_query_result) |
| 75 | + |
| 76 | + def test_sql_query(self): |
| 77 | + self.sql_manager.sql_query = "select id from res_partner" |
| 78 | + self.sql_manager.test_sql_query() |
| 79 | + |
| 80 | + self.assertEqual(self.sql_manager.sql_query_valid, "valid") |
| 81 | + self.assertFalse(self.sql_manager.sql_query_valid_message) |
| 82 | + self.assertEqual(self.sql_manager.sql_record_count, 1) |
| 83 | + |
| 84 | + self.sql_manager.sql_query = "select id from res_partner where name = 'Wrong Name'" |
| 85 | + self.sql_manager.test_sql_query() |
| 86 | + |
| 87 | + self.assertEqual(self.sql_manager.sql_query_valid, "valid") |
| 88 | + self.assertEqual( |
| 89 | + self.sql_manager.sql_query_valid_message, "The SQL Query is valid but it did not return any record." |
| 90 | + ) |
| 91 | + self.assertEqual(self.sql_manager.sql_record_count, 0) |
| 92 | + |
| 93 | + def test_enroll_eligible_registrants(self): |
| 94 | + res = self.sql_manager.enroll_eligible_registrants(self.program_id.program_membership_ids) |
| 95 | + |
| 96 | + self.assertTrue(res) |
| 97 | + self.assertEqual(res.partner_id, self.partner) |
| 98 | + self.assertEqual(res.program_id, self.program_id) |
| 99 | + |
| 100 | + def test_verify_eligibility(self): |
| 101 | + beneficiaries = self.sql_manager._verify_eligibility(self.program_id.program_membership_ids) |
| 102 | + |
| 103 | + self.assertIn(self.partner.id, beneficiaries) |
| 104 | + |
| 105 | + def test_import_eligible_registrants(self): |
| 106 | + self.env["res.partner"].create({"name": "New Test Partner", "is_group": False}) |
| 107 | + |
| 108 | + self.sql_manager.sql_query = "select id from res_partner" |
| 109 | + self.sql_manager.sql_query_valid = "valid" |
| 110 | + ben_count = self.sql_manager.import_eligible_registrants() |
| 111 | + |
| 112 | + self.assertEqual(ben_count, 1) |
| 113 | + |
| 114 | + def test_import_registrants_async(self): |
| 115 | + new_partner = self.env["res.partner"].create({"name": "New Test Partner", "is_group": False}) |
| 116 | + current_count = len(self.env["queue.job"].search([])) |
| 117 | + |
| 118 | + self.sql_manager._import_registrants_async(new_partner.ids) |
| 119 | + |
| 120 | + # 2 jobs are created for the import and the verification |
| 121 | + # - the actual job |
| 122 | + # - the function after running the actual job |
| 123 | + self.assertEqual(current_count + 2, len(self.env["queue.job"].search([]))) |
| 124 | + |
| 125 | + def test_mark_import_as_done(self): |
| 126 | + self.sql_manager.mark_import_as_done() |
| 127 | + |
| 128 | + self.assertFalse(self.program_id.locked) |
| 129 | + self.assertFalse(self.program_id.locked_reason) |
| 130 | + |
| 131 | + def test_import_registrants(self): |
| 132 | + self.sql_manager.sql_query = "select id from res_partner" |
| 133 | + self.sql_manager.sql_query_valid = "valid" |
| 134 | + new_partner = self.env["res.partner"].create({"name": "New Test Partner", "is_group": False}) |
| 135 | + |
| 136 | + self.sql_manager._import_registrants(new_partner.ids, do_count=True) |
| 137 | + |
| 138 | + self.assertEqual(len(self.program_id.program_membership_ids), 2) |
| 139 | + self.assertIn(self.partner.id, self.program_id.program_membership_ids.mapped("partner_id").ids) |
| 140 | + self.assertIn(self.program_id.id, self.program_id.program_membership_ids.mapped("program_id").ids) |
0 commit comments