|
| 1 | +/** @odoo-module **/ |
| 2 | + |
| 3 | +// Copyright 2025 Quartile (https://www.quartile.co) |
| 4 | +// License AGPL-3.0 or later (https://www.gnu.org/licenses/agpl). |
| 5 | + |
| 6 | +import FormController from "web.FormController"; |
| 7 | +import rpc from "web.rpc"; |
| 8 | + |
| 9 | +const root = (ctrl) => (ctrl && (ctrl.el || (ctrl.$el && ctrl.$el[0]))) || null; |
| 10 | + |
| 11 | +const alive = (ctrl) => { |
| 12 | + const r = root(ctrl); |
| 13 | + return ( |
| 14 | + r && |
| 15 | + r.isConnected && |
| 16 | + !(typeof ctrl.isDestroyed === "function" && ctrl.isDestroyed()) |
| 17 | + ); |
| 18 | +}; |
| 19 | + |
| 20 | +const qsa = (el, sel) => Array.from(el ? el.querySelectorAll(sel) : []); |
| 21 | + |
| 22 | +const first = (...args) => { |
| 23 | + for (let i = 0; i < args.length; i++) { |
| 24 | + const v = args[i]; |
| 25 | + if (v !== null && v !== undefined && v !== "") return v; |
| 26 | + } |
| 27 | + return null; |
| 28 | +}; |
| 29 | + |
| 30 | +const childSpan = (el) => { |
| 31 | + if (!el) return null; |
| 32 | + if (el.querySelector) { |
| 33 | + return el.querySelector(":scope > span") || null; |
| 34 | + } |
| 35 | + const c = el.firstElementChild; |
| 36 | + return c && c.tagName === "SPAN" ? c : null; |
| 37 | +}; |
| 38 | + |
| 39 | +const after = (p, fn) => { |
| 40 | + if (p && typeof p.always === "function") { |
| 41 | + p.always(fn); |
| 42 | + return p; |
| 43 | + } |
| 44 | + return Promise.resolve(p).finally(fn); |
| 45 | +}; |
| 46 | + |
| 47 | +const shrinkDraft = (d) => |
| 48 | + Object.entries(d || {}).reduce((o, [k, v]) => { |
| 49 | + const t = typeof v; |
| 50 | + const isNullish = (x) => x === null || x === undefined; |
| 51 | + if (isNullish(v) || t === "string" || t === "number" || t === "boolean") { |
| 52 | + o[k] = v; |
| 53 | + } else if ( |
| 54 | + (v && v.type === "record" && typeof v.res_id === "number") || |
| 55 | + (v && typeof v.res_id === "number") |
| 56 | + ) { |
| 57 | + // Many2one (data snapshot shape) |
| 58 | + o[k] = v.res_id; |
| 59 | + } else if (v && typeof v === "object" && typeof v.id === "number") { |
| 60 | + // Many2one (pending change as {id, display_name}) |
| 61 | + o[k] = v.id; |
| 62 | + } else if (Array.isArray(v) && v.length === 2 && typeof v[0] === "number") { |
| 63 | + // Many2one (pending change as [id, name]) |
| 64 | + o[k] = v[0]; |
| 65 | + } else if ( |
| 66 | + Array.isArray(v) || |
| 67 | + (v && (Array.isArray(v.data) || Array.isArray(v.res_ids))) |
| 68 | + ) { |
| 69 | + // Many2many (and possibly other x2many) values; let Python decide |
| 70 | + o[k] = v; |
| 71 | + } |
| 72 | + return o; |
| 73 | + }, {}); |
| 74 | + |
| 75 | +const bannersIn = (ctrl) => |
| 76 | + qsa(root(ctrl), '.o_form_view div[role="alert"][data-rule-id]'); |
| 77 | + |
| 78 | +const hasBanners = (ctrl) => bannersIn(ctrl).length > 0; |
| 79 | + |
| 80 | +const triggerSet = (ctrl) => { |
| 81 | + const set = Object.create(null); |
| 82 | + const els = bannersIn(ctrl); |
| 83 | + for (let i = 0; i < els.length; i++) { |
| 84 | + const el = els[i]; |
| 85 | + const raw = first(el.dataset.triggerFields, ""); |
| 86 | + (raw || "").split(",").forEach((n) => { |
| 87 | + if (n) set[n.trim()] = true; |
| 88 | + }); |
| 89 | + } |
| 90 | + return set; |
| 91 | +}; |
| 92 | + |
| 93 | +// Pick only keys in `set` from `src` |
| 94 | +const pickKeys = (src, set) => { |
| 95 | + const out = {}; |
| 96 | + if (!src) return out; |
| 97 | + Object.keys(src).forEach((k) => { |
| 98 | + if (set[k]) out[k] = src[k]; |
| 99 | + }); |
| 100 | + return out; |
| 101 | +}; |
| 102 | + |
| 103 | +async function refreshBanners(ctrl, extraChanges) { |
| 104 | + if (!alive(ctrl)) return; |
| 105 | + const st = ctrl.model && ctrl.handle ? ctrl.model.get(ctrl.handle) : null; |
| 106 | + const resId = st && st.res_id; |
| 107 | + const base = shrinkDraft(st && st.data) || {}; |
| 108 | + const latest = shrinkDraft(extraChanges || {}); |
| 109 | + const snap = Object.assign({}, base, latest); |
| 110 | + const tset = triggerSet(ctrl); |
| 111 | + const hasTriggers = Object.keys(tset).length > 0; |
| 112 | + const formVals = resId ? (hasTriggers ? pickKeys(snap, tset) : {}) : snap; |
| 113 | + |
| 114 | + const hideBanner = (el) => { |
| 115 | + el.style.display = "none"; |
| 116 | + const sp = childSpan(el); |
| 117 | + if (sp) sp.innerHTML = ""; |
| 118 | + else el.innerHTML = ""; |
| 119 | + }; |
| 120 | + |
| 121 | + const showBanner = (el, res) => { |
| 122 | + const sev = first(res.severity, el.dataset.defaultSeverity, "danger"); |
| 123 | + const html = res.html || ""; |
| 124 | + el.className = "o_form_banner alert alert-" + sev; |
| 125 | + const sp = childSpan(el); |
| 126 | + if (sp) sp.innerHTML = html; |
| 127 | + else el.innerHTML = html; |
| 128 | + el.style.display = ""; |
| 129 | + }; |
| 130 | + |
| 131 | + const updateEl = async (el) => { |
| 132 | + const ruleId = parseInt(first(el.dataset.ruleId, el.dataset.wfbRuleId), 10); |
| 133 | + const model = first(el.dataset.model, el.dataset.wfbModel, ctrl.modelName); |
| 134 | + const res = |
| 135 | + (await rpc.query({ |
| 136 | + model: "web.form.banner.rule", |
| 137 | + method: "compute_message", |
| 138 | + args: [ruleId, model, resId, formVals], |
| 139 | + })) || {}; |
| 140 | + if (!alive(ctrl)) return; |
| 141 | + if (!res.visible) return hideBanner(el); |
| 142 | + showBanner(el, res); |
| 143 | + }; |
| 144 | + |
| 145 | + // Fire requests in parallel; resolve when all done |
| 146 | + await Promise.all(bannersIn(ctrl).map(updateEl)); |
| 147 | +} |
| 148 | + |
| 149 | +function withRefresh(ctrl, superFn, args) { |
| 150 | + const p = superFn.apply(ctrl, args); |
| 151 | + return after(p, function () { |
| 152 | + refreshBanners(ctrl); |
| 153 | + }); |
| 154 | +} |
| 155 | + |
| 156 | +FormController.include({ |
| 157 | + start: function () { |
| 158 | + const p = this._super.apply(this, arguments); |
| 159 | + // Keep original Deferred/Promise for Odoo callers |
| 160 | + if (p && typeof p.always === "function") { |
| 161 | + p.always(() => refreshBanners(this)); |
| 162 | + } else { |
| 163 | + Promise.resolve(p).then(() => refreshBanners(this)); |
| 164 | + } |
| 165 | + return p; |
| 166 | + }, |
| 167 | + reload: function () { |
| 168 | + return withRefresh(this, this._super, arguments); |
| 169 | + }, |
| 170 | + saveRecord: function () { |
| 171 | + return withRefresh(this, this._super, arguments); |
| 172 | + }, |
| 173 | + update: function () { |
| 174 | + return withRefresh(this, this._super, arguments); |
| 175 | + }, |
| 176 | + // Onchange: refresh only when a declared trigger actually changed |
| 177 | + _onFieldChanged: function (ev) { |
| 178 | + const res = this._super.apply(this, arguments); |
| 179 | + if (!alive(this) || !hasBanners(this)) return res; |
| 180 | + const tset = triggerSet(this); |
| 181 | + if (!Object.keys(tset).length) return res; |
| 182 | + const changed = (ev && ev.data && ev.data.changes) || {}; |
| 183 | + const names = Object.keys(changed); |
| 184 | + if (!names.some((n) => tset[n])) return res; |
| 185 | + // Defer one tick so x2many widgets commit their in-memory value first |
| 186 | + after(res, () => setTimeout(() => refreshBanners(this, changed), 0)); |
| 187 | + return res; |
| 188 | + }, |
| 189 | + activate: function () { |
| 190 | + const res = this._super.apply(this, arguments); |
| 191 | + if (hasBanners(this)) after(res, () => refreshBanners(this)); |
| 192 | + return res; |
| 193 | + }, |
| 194 | + on_attach_callback: function () { |
| 195 | + this._super.apply(this, arguments); |
| 196 | + setTimeout(() => refreshBanners(this)); |
| 197 | + }, |
| 198 | +}); |
0 commit comments