Giao thức bridge

interface BridgeMessage {
  wsg: 1; // phiên bản giao thức
  kind: 'req' | 'res' | 'evt';
  id?: string; // bắt buộc với req và res
  type: string; // tên yêu cầu hoặc sự kiện
  payload?: unknown;
  error?: { code: string; message: string }; // chỉ có trong res thất bại
}

game → req init                  portal ← tạo hoặc dùng lại phiên chơi, res InitContext
game → req loading.start … loading.progress … loading.finished
game → req gameplay.start        portal: ghi lượt chơi đầu tiên, cộng XP
game → req track {…}
game → req gameplay.stop         (game over)
game → req lb.submit {score}     portal → API → res SubmitResult
game → req ads.interstitial      portal → evt pause, evt audio(false) → quảng cáo → evt audio(true), evt resume → res AdResult
game → req gameplay.start        (lượt mới)

const params = new URLSearchParams(location.search);
const host = params.get('wsg') === '1' ? params.get('host') : null;
const pending = new Map();
const listeners = {};
let seq = 0;

window.addEventListener('message', (event) => {
  if (!host || event.source !== window.parent || event.origin !== host) return;
  const msg = event.data;
  if (!msg || msg.wsg !== 1) return;
  if (msg.kind === 'res') {
    const p = pending.get(msg.id);
    if (!p) return;
    pending.delete(msg.id);
    clearTimeout(p.timer);
    if (msg.error) p.reject(msg.error);
    else p.resolve(msg.payload);
  } else if (msg.kind === 'evt') {
    for (const cb of listeners[msg.type] || []) cb(msg.payload);
  }
});

function request(type, payload) {
  return new Promise((resolve, reject) => {
    const id = `r${++seq}`;
    const ms = type === 'init' ? 3000 : type.startsWith('ads.') ? 120000 : 10000;
    const timer = setTimeout(() => {
      pending.delete(id);
      reject({ code: 'timeout', message: type });
    }, ms);
    pending.set(id, { resolve, reject, timer });
    window.parent.postMessage({ wsg: 1, kind: 'req', id, type, payload }, host);
  });
}

function on(type, cb) {
  (listeners[type] = listeners[type] || []).push(cb);
}

async function connect(gameId) {
  if (!host || window.parent === window) return { environment: 'standalone' };
  try {
    const ctx = await request('init', { gameId });
    return ctx.disabled ? { environment: 'disabled' } : ctx;
  } catch {
    return { environment: 'standalone' }; // portal không trả lời trong 3 giây
  }
}

async function main() {
  const ctx = await connect('my-game');
  if (ctx.environment !== 'portal') return startStandalone(); // tự cài chế độ chạy riêng của bạn
  on('pause', () => game.pause());
  on('resume', () => game.resume());
  await request('loading.finished');
  await request('gameplay.start');
  // ... hết lượt
  await request('gameplay.stop');
  const result = await request('lb.submit', { score: 42 });
  console.log(result.accepted, result.reason);
}

main();