/* eslint-disable */
// dom-observer.js - observe DOM for triggers and notify background
(function () {
if (window.__RR_DOM_OBSERVER__) return;
window.__RR_DOM_OBSERVER__ = true;
const active = { triggers: [], hits: new Map() };
function now() {
return Date.now();
}
function applyTriggers(list) {
try {
active.triggers = Array.isArray(list) ? list.slice() : [];
active.hits.clear();
checkAll();
} catch (e) {}
}
function checkAll() {
try {
for (const t of active.triggers) {
maybeFire(t);
}
} catch (e) {}
}
function maybeFire(t) {
try {
const appear = t.appear !== false; // default true
const sel = String(t.selector || '').trim();
if (!sel) return;
const exists = !!document.querySelector(sel);
const key = t.id;
const last = active.hits.get(key) || 0;
const debounce = Math.max(0, Number(t.debounceMs ?? 800));
if (now() - last < debounce) return;
const should = appear ? exists : !exists;
if (should) {
active.hits.set(key, now());
chrome.runtime.sendMessage({
action: 'dom_trigger_fired',
triggerId: t.id,
url: location.href,
});
if (t.once !== false) removeTrigger(t.id);
}
} catch (e) {}
}
function removeTrigger(id) {
try {
active.triggers = active.triggers.filter((x) => x.id !== id);
} catch (e) {}
}
const mo = new MutationObserver(() => {
checkAll();
});
try {
mo.observe(document.documentElement || document, {
childList: true,
subtree: true,
attributes: false,
characterData: false,
});
} catch (e) {}
chrome.runtime.onMessage.addListener((req, _sender, sendResponse) => {
try {
if (req && req.action === 'dom_observer_ping') {
sendResponse({ status: 'pong' });
return false;
}
if (req && req.action === 'set_dom_triggers') {
applyTriggers(req.triggers || []);
sendResponse({ success: true, count: active.triggers.length });
return true;
}
} catch (e) {
sendResponse({ success: false, error: String(e && e.message ? e.message : e) });
return true;
}
return false;
});
})();
