Events & Stream — Observe everything

<script>
const EXT_ORIGIN='extension';
const SUB = {
  onOk(fn){ this._ok = fn; return this; },
  onErr(fn){ this._err = fn; return this; },
  any(fn){ this._any = fn; return this; }
};
addEventListener('message', e => {
  const d=e.data; if(!d||d.origin!==EXT_ORIGIN||d.type!=='RTO_RESPONSE') return;
  if (SUB._any) SUB._any(d);
  if (d.ok) SUB._ok?.(d); else SUB._err?.(d);
});
// Example:
SUB.any(ev => console.log('[RTO]', ev.ok?'ok':'err', ev.requestId, ev));
SUB.onErr(ev => {/* centralized error handling */});
</script>

<script>
const ADMIN_ORIGIN='admin';
function askLog(action, args={}, timeoutMs=12000){
  const requestId='r'+Math.random().toString(36).slice(2);
  const t0=performance.now();
  postMessage({ origin:ADMIN_ORIGIN, type:'RTO_REQUEST', requestId, action, args }, '*');
  return new Promise((resolve,reject)=>{
    function onMsg(e){
      const d=e.data; if(!d||d.type!=='RTO_RESPONSE'||d.requestId!==requestId) return;
      removeEventListener('message', onMsg);
      const dt=Math.round(performance.now()-t0);
      (window.__rtoHist||(window.__rtoHist=[])).push({t:Date.now(), requestId, action, ok:d.ok, dt, error:d.error||null});
      if(!d.ok) reject(Object.assign(new Error(d.error?.message||'error'), d.error||{})); else resolve({ ...d, dt });
    }
    addEventListener('message', onMsg);
    setTimeout(()=>{ removeEventListener('message', onMsg); reject(Object.assign(new Error('timeout'),{code:'TIMEOUT'})); }, timeoutMs);
  });
}
</script>