import { createBus } from 'omnitab';

// Create a scoped message bus
const bus = createBus('my-app');

// Subscribe to an event
const unsubscribe = bus.subscribe('user:update', (payload) => {
  console.log('Received update:', payload);
});

// Publish to all other tabs
bus.publish('user:update', { name: 'Alice' });

// Cleanup when done
unsubscribe();
bus.disconnect();

import { createBus } from 'omnitab';

const bus = createBus('my-app', {
  enableHealthChecks: true,
  enableMessageQueue: true,
  retryDelay: 1500,
});

bus.publish('cart:update', { items: [...], total: 99.99 });
bus.publish('session:expired'); // payload is optional

const unsubscribe = bus.subscribe('cart:update', (payload) => {
  console.log('Cart changed:', payload);
});

// Later — remove the listener
unsubscribe();

bus.disconnect();

const bus = createBus('my-app', {
  // Top-level bus options
  enableHealthChecks: true,
  enableMessageQueue: true,

  // SharedWorker-specific options
  worker: {
    connectTimeout: 3000,
    heartbeatInterval: 5000,
  },

  // StorageEvent (localStorage fallback) options
  storage: {
    ttl: 8000,
    evictionPolicy: 'oldest',
    onStorageFull: (err) => console.warn('Storage full:', err),
  },
});

const bus = createBus('shop');

// Any tab that receives an update re-renders the cart
bus.subscribe('cart:update', (cart) => {
  renderCart(cart);
});

// Any tab that mutates the cart broadcasts the change
function updateCart(newCart) {
  saveCart(newCart);
  bus.publish('cart:update', newCart);
}

const bus = createBus('ui');

bus.subscribe('theme:change', (theme) => {
  document.documentElement.dataset.theme = theme;
});

function setTheme(theme: 'light' | 'dark') {
  document.documentElement.dataset.theme = theme;
  bus.publish('theme:change', theme);
}

const bus = createBus('notifications');

// The tab with the WebSocket connection broadcasts
websocket.onmessage = (event) => {
  const notification = JSON.parse(event.data);
  bus.publish('notification:new', notification);
};

// All tabs receive and display the notification
bus.subscribe('notification:new', (notification) => {
  showToast(notification.message);
});

const bus = createBus('auth');

bus.subscribe('auth:logout', () => {
  clearLocalSession();
  window.location.href = '/login';
});

function logout() {
  clearLocalSession();
  bus.publish('auth:logout');
  window.location.href = '/login';
}

const bus = createBus('my-app', {
  // Health checks + retry
  enableHealthChecks: true,
  healthCheckInterval: 15000,   // Check every 15s
  enableMessageQueue: true,
  maxRetries: 5,
  retryDelay: 500,
  retryBackoff: 2,              // 500ms -> 1s -> 2s -> 4s -> 8s

  // Tune the SharedWorker connection
  worker: {
    connectTimeout: 3000,       // Fall back if worker doesn't connect in 3s
    heartbeatInterval: 5000,    // Ping worker every 5s to detect silent crashes
  },

  // Tune the localStorage fallback (for Safari / IE11)
  storage: {
    ttl: 8000,
    evictionPolicy: 'oldest',
    onStorageFull: (err) => {
      console.warn('Omnitab: localStorage full', err);
    },
  },
});