cyb/src/services/backend/channels/BroadcastChannelSender.ts

import { updateSenseList } from 'src/features/sense/redux/sense.redux';
import { setDefaultAccount } from 'src/redux/features/pocket';
import { Account } from 'src/types/defaultAccount';
import { SenseListItem } from '../types/sense';
import type {
  BroadcastChannelMessage,
  ServiceName,
  ServiceStatus,
  SyncEntryName,
  SyncProgress,
} from '../types/services';
import { CYB_BROADCAST_CHANNEL } from './consts';

class BroadcastChannelSender {
  private channel: BroadcastChannel;

  constructor() {
    this.channel = new BroadcastChannel(CYB_BROADCAST_CHANNEL);
  }

  public postServiceStatus(name: ServiceName, status: ServiceStatus, message?: string) {
    this.channel.postMessage({
      type: 'service_status',
      value: { name, status, message },
    });
  }

  public postSyncEntryProgress(entry: SyncEntryName, state: SyncProgress) {
    // console.log('postSyncEntryProgress', entry, state);
    this.channel.postMessage({ type: 'sync_entry', value: { entry, state } });
  }

  public postMlSyncEntryProgress(entry: string, state: SyncProgress) {
    // console.log('postMlSyncEntryProgress', entry, state);
    this.channel.postMessage({
      type: 'sync_ml_entry',
      value: { entry, state },
    });
  }

  public postSenseUpdate(senseList: SenseListItem[]) {
    // console.log('postSenseUpdate', senseList);
    if (senseList.length > 0) {
      this.channel.postMessage(updateSenseList(senseList));
    }
  }

  public postSetDefaultAccount(name: string, account?: Account) {
    this.channel.postMessage(
      setDefaultAccount({
        name,
        account,
      })
    );
  }

  post(msg: BroadcastChannelMessage) {
    this.channel.postMessage(msg);
  }
}

export default BroadcastChannelSender;