|
| 1 | +# Copyright 2024 Akretion (http://www.akretion.com). |
| 2 | +# @author Florian Mounier <florian.mounier@akretion.com> |
| 3 | +# License AGPL-3.0 or later (http://www.gnu.org/licenses/agpl). |
| 4 | + |
| 5 | +import requests |
| 6 | + |
| 7 | +from odoo import _, api, fields, models |
| 8 | +from odoo.exceptions import UserError |
| 9 | + |
| 10 | + |
| 11 | +class CrossConnectServer(models.Model): |
| 12 | + _name = "cross.connect.server" |
| 13 | + _description = "Cross Connect Server" |
| 14 | + _inherit = "server.env.mixin" |
| 15 | + |
| 16 | + name = fields.Char( |
| 17 | + required=True, |
| 18 | + help="This name will be used for the new created app", |
| 19 | + ) |
| 20 | + server_url = fields.Char(required=True) |
| 21 | + api_key = fields.Char( |
| 22 | + required=True, |
| 23 | + ) |
| 24 | + group_ids = fields.One2many( |
| 25 | + "res.groups", |
| 26 | + inverse_name="cross_connect_server_id", |
| 27 | + string="Cross Connect Server Groups", |
| 28 | + readonly=True, |
| 29 | + ) |
| 30 | + menu_id = fields.Many2one( |
| 31 | + "ir.ui.menu", |
| 32 | + string="Menu", |
| 33 | + help="Menu to display the Cross Connect Server in the menu", |
| 34 | + compute="_compute_menu_id", |
| 35 | + store=True, |
| 36 | + ) |
| 37 | + web_icon_data = fields.Binary( |
| 38 | + compute="_compute_web_icon_data", inverse="_inverse_web_icon_data" |
| 39 | + ) |
| 40 | + |
| 41 | + @api.depends("name", "group_ids") |
| 42 | + def _compute_menu_id(self): |
| 43 | + for record in self: |
| 44 | + if not record.group_ids: |
| 45 | + if record.menu_id: |
| 46 | + if record.menu_id.action: |
| 47 | + record.menu_id.action.unlink() |
| 48 | + record.menu_id.unlink() |
| 49 | + record.menu_id = False |
| 50 | + continue |
| 51 | + |
| 52 | + menu_groups = record.group_ids |
| 53 | + |
| 54 | + if not record.menu_id: |
| 55 | + action = self.env["ir.actions.act_url"].create( |
| 56 | + { |
| 57 | + "name": record.name, |
| 58 | + "url": f"/cross_connect_server/{record.id}", |
| 59 | + "target": "new", |
| 60 | + } |
| 61 | + ) |
| 62 | + |
| 63 | + record.menu_id = self.env["ir.ui.menu"].create( |
| 64 | + { |
| 65 | + "name": record.name, |
| 66 | + "action": f"ir.actions.act_url,{action.id}", # noqa |
| 67 | + "web_icon": "cross_connect_client,static/description/web_icon_data.png", |
| 68 | + "groups_id": [(6, 0, menu_groups.ids)], |
| 69 | + "sequence": 100, |
| 70 | + } |
| 71 | + ) |
| 72 | + else: |
| 73 | + record.menu_id.name = record.name |
| 74 | + record.menu_id.groups_id = [(6, 0, menu_groups.ids)] |
| 75 | + |
| 76 | + @api.depends("menu_id") |
| 77 | + def _compute_web_icon_data(self): |
| 78 | + for record in self: |
| 79 | + record.web_icon_data = record.menu_id.web_icon_data |
| 80 | + |
| 81 | + def _inverse_web_icon_data(self): |
| 82 | + for record in self: |
| 83 | + record.menu_id.web_icon_data = record.web_icon_data |
| 84 | + |
| 85 | + def _absolute_url_for(self, path): |
| 86 | + return f"{self.server_url.rstrip('/')}/cross_connect/{path.lstrip('/')}" |
| 87 | + |
| 88 | + def _request(self, method, url, headers=None, data=None): |
| 89 | + headers = headers or {} |
| 90 | + headers["api-key"] = self.api_key |
| 91 | + response = requests.request( |
| 92 | + method, |
| 93 | + self._absolute_url_for(url), |
| 94 | + headers=headers, |
| 95 | + json=data, |
| 96 | + timeout=10, |
| 97 | + ) |
| 98 | + response.raise_for_status() |
| 99 | + return response.json() |
| 100 | + |
| 101 | + def _get_cross_connect_url(self, redirect_url=None): |
| 102 | + self.ensure_one() |
| 103 | + groups = self.env.user.groups_id & self.group_ids |
| 104 | + if not groups: |
| 105 | + raise UserError(_("You are not allowed to access this server")) |
| 106 | + |
| 107 | + if not self.env.user.email: |
| 108 | + raise UserError(_("User email is required")) |
| 109 | + |
| 110 | + data = { |
| 111 | + "id": self.env.user.id, |
| 112 | + "name": self.env.user.name, |
| 113 | + "login": self.env.user.login, |
| 114 | + "email": self.env.user.email, |
| 115 | + "lang": self.env.user.lang, |
| 116 | + "groups": [group.cross_connect_server_group_id for group in groups], |
| 117 | + } |
| 118 | + if redirect_url: |
| 119 | + data["redirect_url"] = redirect_url |
| 120 | + |
| 121 | + response = self._request("POST", "/access", data=data) |
| 122 | + client_id = response.get("client_id") |
| 123 | + token = response.get("token") |
| 124 | + if not token: |
| 125 | + raise UserError(_("Missing token")) |
| 126 | + |
| 127 | + return self._absolute_url_for(f"login/{client_id}/{token}") |
| 128 | + |
| 129 | + def _sync_groups(self): |
| 130 | + self.ensure_one() |
| 131 | + response = self._request("GET", "/sync") |
| 132 | + remote_groups = response.get("groups", []) |
| 133 | + # Removing groups that are not on the remote server |
| 134 | + remote_groups_ids = {remote_group["id"] for remote_group in remote_groups} |
| 135 | + self.group_ids.filtered( |
| 136 | + lambda group: group.cross_connect_server_group_id not in remote_groups_ids |
| 137 | + ).write({"cross_connect_server_id": False}) |
| 138 | + |
| 139 | + # Create or Update existing groups |
| 140 | + for remote_group in remote_groups: |
| 141 | + existing_group = self.env["res.groups"].search( |
| 142 | + [("cross_connect_server_group_id", "=", remote_group["id"])] |
| 143 | + ) |
| 144 | + if existing_group and not existing_group.cross_connect_server_id: |
| 145 | + existing_group.write({"cross_connect_server_id": self.id}) |
| 146 | + if existing_group: |
| 147 | + existing_group.sudo().write( |
| 148 | + { |
| 149 | + "name": f"{self.name}: {remote_group['name']}", |
| 150 | + "comment": remote_group["comment"], |
| 151 | + } |
| 152 | + ) |
| 153 | + else: |
| 154 | + self.env["res.groups"].sudo().create( |
| 155 | + { |
| 156 | + "cross_connect_server_id": self.id, |
| 157 | + "cross_connect_server_group_id": remote_group["id"], |
| 158 | + "name": f"{self.name}: {remote_group['name']}", |
| 159 | + "comment": remote_group["comment"], |
| 160 | + } |
| 161 | + ) |
| 162 | + |
| 163 | + def action_sync(self): |
| 164 | + for record in self: |
| 165 | + record._sync_groups() |
| 166 | + |
| 167 | + def action_disable(self): |
| 168 | + for record in self: |
| 169 | + record.group_ids.write({"cross_connect_server_id": False}) |
| 170 | + |
| 171 | + @property |
| 172 | + def _server_env_fields(self): |
| 173 | + return {"api_key": {}} |
| 174 | + |
| 175 | + def unlink(self): |
| 176 | + for rec in self: |
| 177 | + # deleting the groups will delete the menu and related action. |
| 178 | + rec.group_ids.unlink() |
| 179 | + return super().unlink() |
0 commit comments